From e12e53cfbb8b8764dcbd4da3ff143ad9d46a8795 Mon Sep 17 00:00:00 2001 From: Rainer Gerhards Date: Tue, 29 Jan 2008 17:36:19 +0000 Subject: added ability to re-enqueue objects into the queue when a worker thread is cancelled --- queue.h | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'queue.h') diff --git a/queue.h b/queue.h index e48d9796..12e4fcb6 100644 --- a/queue.h +++ b/queue.h @@ -116,6 +116,12 @@ typedef struct queue_s { 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 */ + /* some data elements for the queueUngetObj() functionality. This list should always be short + * and is always kept in memory + */ + qLinkedList_t *pUngetRoot; + qLinkedList_t *pUngetLast; + int iUngottenObjs; /* number of objects currently in the "ungotten" list */ /* now follow queueing mode specific data elements */ union { /* different data elements based on queue type (qType) */ struct { -- cgit v1.2.3