diff options
Diffstat (limited to 'main/threadpool.c')
| -rw-r--r-- | main/threadpool.c | 40 |
1 files changed, 21 insertions, 19 deletions
diff --git a/main/threadpool.c b/main/threadpool.c index ab390e9d8..68d84aff8 100644 --- a/main/threadpool.c +++ b/main/threadpool.c @@ -94,7 +94,7 @@ struct ast_threadpool { * that the threadpool had its state change. */ struct ast_taskprocessor *control_tps; - /*! True if the threadpool is in the processof shutting down */ + /*! True if the threadpool is in the process of shutting down */ int shutting_down; /*! Threadpool-specific options */ struct ast_threadpool_options options; @@ -1127,28 +1127,30 @@ static struct serializer *serializer_create(struct ast_threadpool *pool) static int execute_tasks(void *data) { - struct ast_taskprocessor *tps = data; + struct ast_taskprocessor *tps = data; - while (ast_taskprocessor_execute(tps)) { - /* No-op */ - } + while (ast_taskprocessor_execute(tps)) { + /* No-op */ + } - ast_taskprocessor_unreference(tps); - return 0; + ast_taskprocessor_unreference(tps); + return 0; } -static void serializer_task_pushed(struct ast_taskprocessor_listener *listener, int was_empty) { - if (was_empty) { - struct serializer *ser = ast_taskprocessor_listener_get_user_data(listener); - struct ast_taskprocessor *tps = ast_taskprocessor_listener_get_tps(listener); - ast_threadpool_push(ser->pool, execute_tasks, tps); - } -}; +static void serializer_task_pushed(struct ast_taskprocessor_listener *listener, int was_empty) +{ + if (was_empty) { + struct serializer *ser = ast_taskprocessor_listener_get_user_data(listener); + struct ast_taskprocessor *tps = ast_taskprocessor_listener_get_tps(listener); + + ast_threadpool_push(ser->pool, execute_tasks, tps); + } +} static int serializer_start(struct ast_taskprocessor_listener *listener) { - /* No-op */ - return 0; + /* No-op */ + return 0; } static void serializer_shutdown(struct ast_taskprocessor_listener *listener) @@ -1158,9 +1160,9 @@ static void serializer_shutdown(struct ast_taskprocessor_listener *listener) } static struct ast_taskprocessor_listener_callbacks serializer_tps_listener_callbacks = { - .task_pushed = serializer_task_pushed, - .start = serializer_start, - .shutdown = serializer_shutdown, + .task_pushed = serializer_task_pushed, + .start = serializer_start, + .shutdown = serializer_shutdown, }; struct ast_taskprocessor *ast_threadpool_serializer(const char *name, struct ast_threadpool *pool) |