Merge "test_threadpool: Wait for each task to complete and fix memory leak." into 13

1 files changed, 8 insertions, 0 deletions

diff --git a/tests/test_threadpool.c b/tests/test_threadpool.c
index 42181a25c..afb981be6 100644
--- a/tests/test_threadpool.c
+++ b/tests/test_threadpool.c
@@ -636,6 +636,14 @@ AST_TEST_DEFINE(threadpool_thread_timeout_thrash)
 		ast_mutex_unlock(&tld->lock);
 
 		ast_threadpool_push(pool, simple_task, std);
+
+		res = wait_for_completion(test, std);
+
+		ast_free(std);
+
+		if (res == AST_TEST_FAIL) {
+			goto end;
+		}
 	}
 
 	res = wait_until_thread_state(test, tld, 0, 0);