add debug output for worker actions

3 files changed, 3 insertions, 1 deletions

diff --git a/action.c b/action.c
index f9297a55..619d37b6 100644
--- a/action.c
+++ b/action.c
@@ -916,6 +916,7 @@ actionCallDoAction(action_t *pThis, msg_t *pMsg, void *actParams, wti_t *pWti)
 		  getActStateName(pThis), pThis->iActionNbr);
 
 	if(pWti->actWrkrData[pThis->iActionNbr] == NULL) {
+dbgprintf("DDDD: wti %p create new worker instance for action %d\n", pWti, pThis->iActionNbr);
 		DBGPRINTF("we need to create a new action worker instance for "
 			  "action %d\n", pThis->iActionNbr);
 		CHKiRet(pThis->pMod->mod.om.createWrkrInstance(&(pWti->actWrkrData[pThis->iActionNbr]), pThis->pModData));
diff --git a/runtime/wti.c b/runtime/wti.c
index e9d3599d..545d5179 100644
--- a/runtime/wti.c
+++ b/runtime/wti.c
@@ -292,6 +292,7 @@ wtiWorker(wti_t *pThis)
 	dbgSetThrdName(pThis->pszDbgHdr);
 	pthread_cleanup_push(wtiWorkerCancelCleanup, pThis);
 	pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &iCancelStateSave);
+dbgprintf("DDDD: wti %p: worker starting\n", pThis);
 
 	/* now we have our identity, on to real processing */
 	while(1) { /* loop will be broken below - need to do mutex locks */
@@ -341,6 +342,7 @@ wtiWorker(wti_t *pThis)
 	/* indicate termination */
 	pthread_cleanup_pop(0); /* remove cleanup handler */
 	pthread_setcancelstate(iCancelStateSave, NULL);
+dbgprintf("DDDD: wti %p: worker exiting\n", pThis);
 
 	RETiRet;
 }
diff --git a/tools/omfile.c b/tools/omfile.c
index 4300bb4d..cecca07b 100644
--- a/tools/omfile.c
+++ b/tools/omfile.c
@@ -962,7 +962,6 @@ bufferLine(wrkrInstanceData_t *pWrkrData, uchar *filename, uchar *line)
 	linebuf_t *lb;
 	DEFiRet;
 
-	dbgprintf("DDDD: buffering root %p, line %s\n", pWrkrData->pRoot, line);
 	CHKmalloc(lb = (linebuf_t*) malloc(sizeof(linebuf_t)));
 	CHKmalloc(lb->filename = ustrdup(filename));
 	CHKmalloc(lb->ln = ustrdup(line));