Initialize the lock and destroy lock and cond in the destructor (thanks, mmichelson)

git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@121365 65c4cc65-6c06-0410-ace0-fbb531ad65f3

diff --git a/main/taskprocessor.c b/main/taskprocessor.c
index ebe708302d384b49d33140c82590e0390de96dbf..8b065e45c5a51ab911b56ae809a63a83fc098ae4 100644 (file)
--- a/main/taskprocessor.c
+++ b/main/taskprocessor.c
@@ -354,6 +354,8 @@ static void tps_taskprocessor_destroy(void *tps)
        ast_mutex_unlock(&t->taskprocessor_lock);
        pthread_join(t->poll_thread, NULL);
        t->poll_thread = AST_PTHREADT_NULL;
+       ast_mutex_destroy(&t->taskprocessor_lock);
+       ast_cond_destroy(&t->poll_cond);
        /* free it */
        if (t->stats) {
                ast_free(t->stats);
@@ -424,6 +426,10 @@ struct ast_taskprocessor *ast_taskprocessor_get(char *name, enum ast_tps_options
                ast_log(LOG_WARNING, "failed to create taskprocessor '%s'\n", name);
                return NULL;
        }
+
+       ast_cond_init(&p->poll_cond, NULL);
+       ast_mutex_init(&p->taskprocessor_lock);
+
        if (!(p->stats = ast_calloc(1, sizeof(*p->stats)))) {
                ao2_unlock(tps_singletons);
                ast_log(LOG_WARNING, "failed to create taskprocessor stats for '%s'\n", name);
@@ -436,7 +442,6 @@ struct ast_taskprocessor *ast_taskprocessor_get(char *name, enum ast_tps_options
                return NULL;
        }
        p->poll_thread_run = 1;
-       ast_cond_init(&p->poll_cond, NULL);
        p->poll_thread = AST_PTHREADT_NULL;
        if (ast_pthread_create(&p->poll_thread, NULL, tps_processing_function, p) < 0) {
                ao2_unlock(tps_singletons);