mirror of
https://github.com/asterisk/asterisk.git
synced 2025-10-12 15:45:18 +00:00
Merge "threadpool, res_pjsip: Add serializer group shutdown API calls." into 13
This commit is contained in:
@@ -3322,20 +3322,25 @@ int ast_sip_append_body(pjsip_tx_data *tdata, const char *body_text)
|
||||
return 0;
|
||||
}
|
||||
|
||||
struct ast_taskprocessor *ast_sip_create_serializer(void)
|
||||
struct ast_taskprocessor *ast_sip_create_serializer_group(struct ast_serializer_shutdown_group *shutdown_group)
|
||||
{
|
||||
struct ast_taskprocessor *serializer;
|
||||
char name[AST_UUID_STR_LEN];
|
||||
|
||||
ast_uuid_generate_str(name, sizeof(name));
|
||||
|
||||
serializer = ast_threadpool_serializer(name, sip_threadpool);
|
||||
serializer = ast_threadpool_serializer_group(name, sip_threadpool, shutdown_group);
|
||||
if (!serializer) {
|
||||
return NULL;
|
||||
}
|
||||
return serializer;
|
||||
}
|
||||
|
||||
struct ast_taskprocessor *ast_sip_create_serializer(void)
|
||||
{
|
||||
return ast_sip_create_serializer_group(NULL);
|
||||
}
|
||||
|
||||
int ast_sip_push_task(struct ast_taskprocessor *serializer, int (*sip_task)(void *), void *task_data)
|
||||
{
|
||||
if (serializer) {
|
||||
|
Reference in New Issue
Block a user