disk-assisted queue mode finally begins to look good ;)

1 files changed, 2 insertions, 0 deletions

diff --git a/wti.h b/wti.h
index db782d2b..8bd47d1d 100644
--- a/wti.h
+++ b/wti.h
@@ -35,7 +35,9 @@ typedef struct wti_s {
 	obj_t *pUsrp;		/* pointer to an object meaningful for current user pointer (e.g. queue pUsr data elemt) */
 	wtp_t *pWtp; /* my worker thread pool (important if only the work thread instance is passed! */
 	pthread_cond_t condInitDone; /* signaled when the thread startup is done (once per thread existance) */
+	pthread_cond_t condExitDone; /* signaled when the thread exit is done (once per thread existance) */
 	pthread_mutex_t mut;
+	int bShutdownRqtd;	/* shutdown for this thread requested? 0 - no , 1 - yes */
 	uchar *pszDbgHdr;	/* header string for debug messages */
 } wti_t;