bugfix: during queue shutdown, an assert invalidly triggered when the

    primary queue's DA worker was terminated while the DA queue's regular
    worker was still executing. This could result in a segfault during
    shutdown. tracker: http://bugzilla.adiscon.com/show_bug.cgi?id=41

1 files changed, 2 insertions, 0 deletions

diff --git a/wtp.c b/wtp.c
index 599e63c3..7e920631 100644
--- a/wtp.c
+++ b/wtp.c
@@ -128,6 +128,8 @@ finalize_it:
 BEGINobjDestruct(wtp) /* be sure to specify the object type also in END and CODESTART macros! */
 	int i;
 CODESTARTobjDestruct(wtp)
+	wtpProcessThrdChanges(pThis); /* process thread changes one last time */
+
 	/* destruct workers */
 	for(i = 0 ; i < pThis->iNumWorkerThreads ; ++i)
 		wtiDestruct(&pThis->pWrkr[i]);