summaryrefslogtreecommitdiffstats
path: root/wtp.c
diff options
context:
space:
mode:
Diffstat (limited to 'wtp.c')
-rw-r--r--wtp.c4
1 files changed, 3 insertions, 1 deletions
diff --git a/wtp.c b/wtp.c
index 1bda60e8..5e4fb3ce 100644
--- a/wtp.c
+++ b/wtp.c
@@ -352,9 +352,11 @@ wtpCancelAll(wtp_t *pThis)
/* process any pending thread requests so that we know who actually is still running */
wtpProcessThrdChanges(pThis);
- /* first tell the workers our request */
+RUNLOG_VAR("%d", pThis->iCurNumWrkThrd);
+ /* go through all workers and cancel those that are active */
for(i = 0 ; i < pThis->iNumWorkerThreads ; ++i) {
// TODO: mutex lock!
+RUNLOG_VAR("%d", pThis->pWrkr[i]->tCurrCmd);
if(pThis->pWrkr[i]->tCurrCmd >= eWRKTHRD_TERMINATING) {
dbgprintf("%s: canceling worker thread %d\n", wtpGetDbgHdr(pThis), i);
pthread_cancel(pThis->pWrkr[i]->thrdID);