From 855bb334c8ad6cace55d875bc4aeddc1a81b005f Mon Sep 17 00:00:00 2001 From: Richard Mudgett Date: Thu, 28 Feb 2013 21:31:14 +0000 Subject: [PATCH] threadpool: Make ast_threadpool_push() return -1 if shutting_down git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@382295 65c4cc65-6c06-0410-ace0-fbb531ad65f3 --- main/threadpool.c | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/main/threadpool.c b/main/threadpool.c index 68d84aff83..58647d59f6 100644 --- a/main/threadpool.c +++ b/main/threadpool.c @@ -898,7 +898,7 @@ int ast_threadpool_push(struct ast_threadpool *pool, int (*task)(void *data), vo if (!pool->shutting_down) { return ast_taskprocessor_push(pool->tps, task, data); } - return 0; + return -1; } void ast_threadpool_shutdown(struct ast_threadpool *pool) @@ -1143,7 +1143,9 @@ static void serializer_task_pushed(struct ast_taskprocessor_listener *listener, 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); + if (ast_threadpool_push(ser->pool, execute_tasks, tps)) { + ast_taskprocessor_unreference(tps); + } } } -- 2.47.2