seperated mutex for queue size management from those for queue thread

    management

1 files changed, 2 insertions, 1 deletions

diff --git a/queue.h b/queue.h
index 481c5aa1..3b53eda3 100644
--- a/queue.h
+++ b/queue.h
@@ -115,7 +115,8 @@ typedef struct queue_s {
 	rsRetVal (*qDel)(struct queue_s *pThis, void **ppUsr);
 	/* end type-specific handler */
 	/* synchronization variables */
-	pthread_mutex_t *mut;
+	pthread_mutex_t mutThrdMgmt; /* mutex for the queue's thread management */
+	pthread_mutex_t *mut; /* mutex for enqueing and dequeueing messages */
 	pthread_cond_t *notFull, *notEmpty;
 	pthread_cond_t condThrdTrm;/* signalled when threads terminate */
 	pthread_cond_t *condSignalOnEmpty;/* caller-provided condition to be signalled when queue is empty (DA mode!) */