fixed some memory leaks in new code -- thanks to varmojfekoj for the patch

1 files changed, 1 insertions, 0 deletions

diff --git a/queue.c b/queue.c
index bd7aace1..29b5e43e 100644
--- a/queue.c
+++ b/queue.c
@@ -741,6 +741,7 @@ rsRetVal queueDestruct(queue_t *pThis)
 		for(i = 0 ; i < pThis->iNumWorkerThreads ; ++i) {
 			pthread_join(pThis->pWorkerThreads[i], NULL);
 		}
+		free(pThis->pWorkerThreads);
 		dbgprintf("Worker threads for queue 0x%lx terminated.\n", (unsigned long) pThis);
 	}