From fabcb72a0994cd832cc1a5019123cfec35ef0b82 Mon Sep 17 00:00:00 2001 From: Rainer Gerhards Date: Fri, 18 Jan 2008 23:24:51 +0000 Subject: saving state --- queue.h | 2 ++ 1 file changed, 2 insertions(+) (limited to 'queue.h') diff --git a/queue.h b/queue.h index 20e08147..481c5aa1 100644 --- a/queue.h +++ b/queue.h @@ -79,6 +79,7 @@ typedef struct qWrkThrd_s { struct queue_s *pQueue; /* my queue (important if only the work thread instance is passed! */ int iThrd; /* my worker thread array index */ pthread_cond_t condInitDone; /* signaled when the thread startup is done (once per thread existance) */ + pthread_mutex_t mut; } qWrkThrd_t; /* type for queue worker threads */ /* the queue object */ @@ -144,6 +145,7 @@ typedef struct queue_s { pthread_mutex_t mutDA; /* mutex for low water mark algo */ pthread_cond_t condDA; /* and its matching condition */ struct queue_s *pqDA; /* queue for disk-assisted modes */ + struct queue_s *pqParent;/* pointer to the parent (if this is a child queue) */ int bDAEnqOnly; /* EnqOnly setting for DA queue */ /* now follow queueing mode specific data elements */ union { /* different data elements based on queue type (qType) */ -- cgit v1.2.3