diff options
| -rw-r--r-- | action.c | 2 | ||||
| -rw-r--r-- | tools/omfwd.c | 3 |
2 files changed, 4 insertions, 1 deletions
@@ -644,7 +644,7 @@ actionDoRetry(action_t *pThis, wti_t *pWti, int *pbShutdownImmediate) iRetries = 0; while((*pbShutdownImmediate == 0) && getActionState(pWti, pThis) == ACT_STATE_RTRY) { DBGPRINTF("actionDoRetry: enter loop, iRetries=%d\n", iRetries); - iRet = pThis->pMod->tryResume(pThis->pModData); + iRet = pThis->pMod->tryResume(pWti->actWrkrInfo[pThis->iActionNbr].actWrkrData); DBGPRINTF("actionDoRetry: action->tryResume returned %d\n", iRet); if((getActionResumeInRow(pWti, pThis) > 9) && (getActionResumeInRow(pWti, pThis) % 10 == 0)) { bTreatOKasSusp = 1; diff --git a/tools/omfwd.c b/tools/omfwd.c index 01702043..ed0898c9 100644 --- a/tools/omfwd.c +++ b/tools/omfwd.c @@ -341,6 +341,7 @@ ENDcreateInstance BEGINcreateWrkrInstance CODESTARTcreateWrkrInstance + dbgprintf("DDDD: createWrkrInstance: pWrkrData %p\n", pWrkrData); ENDcreateWrkrInstance @@ -734,6 +735,7 @@ finalize_it: BEGINtryResume CODESTARTtryResume + dbgprintf("DDDD: tryResume: pWrkrData %p\n", pWrkrData); iRet = doTryResume(pWrkrData->pData); ENDtryResume @@ -753,6 +755,7 @@ BEGINdoAction # endif instanceData *pData; CODESTARTdoAction + dbgprintf("DDDD: doAction: pWrkrData %p\n", pWrkrData); pData = pWrkrData->pData; CHKiRet(doTryResume(pData)); |