diff --git a/include/asterisk/taskprocessor.h b/include/asterisk/taskprocessor.h index 4f61939f87..dc110e2e53 100644 --- a/include/asterisk/taskprocessor.h +++ b/include/asterisk/taskprocessor.h @@ -77,6 +77,7 @@ struct ast_taskprocessor_listener_callbacks { /*! * \brief Allocate the listener's private data * + * This is called during taskprocesor creation. * It is not necessary to assign the private data to the listener. * * \param listener The listener to which the private data belongs @@ -150,9 +151,7 @@ struct ast_taskprocessor_listener { * Allocate a taskprocessor listener * * This will result in the listener being allocated with the specified - * callbacks. The listener's alloc() callback will be called to allocate - * private data for the listener. The private data will be assigned to the - * listener when the listener's alloc() function returns. + * callbacks. * * \param callbacks The callbacks to assign to the listener * \retval NULL Failure @@ -177,6 +176,8 @@ struct ast_taskprocessor *ast_taskprocessor_get(const char *name, enum ast_tps_o /*! * \brief Create a taskprocessor with a custom listener * + * The listener's alloc() and start() callbacks will be called during this function. + * * \param name The name of the taskprocessor to create * \param listener The listener for operations on this taskprocessor * \retval NULL Failure diff --git a/main/threadpool.c b/main/threadpool.c index ee60dc7e30..57520cf112 100644 --- a/main/threadpool.c +++ b/main/threadpool.c @@ -436,7 +436,7 @@ static int activate_threads(void *obj, void *arg, int flags) } /*! - * \brief Queue task called when tasks are pushed into the threadpool + * \brief Queued task called when tasks are pushed into the threadpool * * This function first calls into the threadpool's listener to let it know * that a task has been pushed. It then wakes up all idle threads and moves @@ -444,7 +444,7 @@ static int activate_threads(void *obj, void *arg, int flags) * \param data A task_pushed_data * \return 0 */ -static int handle_task_pushed(void *data) +static int queued_task_pushed(void *data) { struct task_pushed_data *tpd = data; struct ast_threadpool *pool = tpd->pool; @@ -481,7 +481,7 @@ static void threadpool_tps_task_pushed(struct ast_taskprocessor_listener *listen return; } - ast_taskprocessor_push(pool->control_tps, handle_task_pushed, tpd); + ast_taskprocessor_push(pool->control_tps, queued_task_pushed, tpd); } /*! @@ -491,7 +491,7 @@ static void threadpool_tps_task_pushed(struct ast_taskprocessor_listener *listen * \param data The pool that has become empty * \return 0 */ -static int handle_emptied(void *data) +static int queued_emptied(void *data) { struct ast_threadpool *pool = data; @@ -515,7 +515,7 @@ static void threadpool_tps_emptied(struct ast_taskprocessor_listener *listener) return; } - ast_taskprocessor_push(pool->control_tps, handle_emptied, pool); + ast_taskprocessor_push(pool->control_tps, queued_emptied, pool); } /*!