void (*shutdown)(struct ast_threadpool_listener *listener);
};
-/*!
- * \brief listener for a threadpool
- *
- * The listener is notified of changes in a threadpool. It can
- * react by doing things like increasing the number of threads
- * in the pool
- */
-struct ast_threadpool_listener {
- /*! Callbacks called by the threadpool */
- const struct ast_threadpool_listener_callbacks *callbacks;
- /*! User data for the listener */
- void *user_data;
-};
-
struct ast_threadpool_options {
#define AST_THREADPOOL_OPTIONS_VERSION 1
/*! Version of thradpool options in use */
struct ast_threadpool_listener *ast_threadpool_listener_alloc(
const struct ast_threadpool_listener_callbacks *callbacks, void *user_data);
+void *ast_threadpool_listener_get_user_data(const struct ast_threadpool_listener *listener);
+
/*!
* \brief Create a new threadpool
*
};
/*!
+ * \brief listener for a threadpool
+ *
+ * The listener is notified of changes in a threadpool. It can
+ * react by doing things like increasing the number of threads
+ * in the pool
+ */
+struct ast_threadpool_listener {
+ /*! Callbacks called by the threadpool */
+ const struct ast_threadpool_listener_callbacks *callbacks;
+ /*! User data for the listener */
+ void *user_data;
+};
+
+/*!
* \brief states for worker threads
*/
enum worker_state {
return listener;
}
+void *ast_threadpool_listener_get_user_data(const struct ast_threadpool_listener *listener)
+{
+ return listener->user_data;
+}
+
struct pool_options_pair {
struct ast_threadpool *pool;
struct ast_threadpool_options options;
int active_threads,
int idle_threads)
{
- struct test_listener_data *tld = listener->user_data;
+ struct test_listener_data *tld = ast_threadpool_listener_get_user_data(listener);
SCOPED_MUTEX(lock, &tld->lock);
tld->num_active = active_threads;
tld->num_idle = idle_threads;
struct ast_threadpool_listener *listener,
int was_empty)
{
- struct test_listener_data *tld = listener->user_data;
+ struct test_listener_data *tld = ast_threadpool_listener_get_user_data(listener);
SCOPED_MUTEX(lock, &tld->lock);
tld->task_pushed = 1;
++tld->num_tasks;
static void test_emptied(struct ast_threadpool *pool,
struct ast_threadpool_listener *listener)
{
- struct test_listener_data *tld = listener->user_data;
+ struct test_listener_data *tld = ast_threadpool_listener_get_user_data(listener);
SCOPED_MUTEX(lock, &tld->lock);
tld->empty_notice = 1;
ast_cond_signal(&tld->cond);
static void test_shutdown(struct ast_threadpool_listener *listener)
{
- struct test_listener_data *tld = listener->user_data;
+ struct test_listener_data *tld = ast_threadpool_listener_get_user_data(listener);
ast_cond_destroy(&tld->cond);
ast_mutex_destroy(&tld->lock);
}
static void wait_for_task_pushed(struct ast_threadpool_listener *listener)
{
- struct test_listener_data *tld = listener->user_data;
+ struct test_listener_data *tld = ast_threadpool_listener_get_user_data(listener);
struct timeval start = ast_tvnow();
struct timespec end = {
.tv_sec = start.tv_sec + 5,
int num_idle,
int empty_notice)
{
- struct test_listener_data *tld = listener->user_data;
+ struct test_listener_data *tld = ast_threadpool_listener_get_user_data(listener);
enum ast_test_result_state res = AST_TEST_PASS;
if (tld->task_pushed != task_pushed) {