diff options
| -rw-r--r-- | action.c | 31 |
1 files changed, 15 insertions, 16 deletions
@@ -1038,6 +1038,21 @@ finalize_it: RETiRet; } +/* Commit all active transactions in *DIRECT mode* */ +void +actionCommitAll(wti_t *pWti) +{ + int i; + action_t *pAction; + + for(i = 0 ; i < iActionNbr ; ++i) { + dbgprintf("DDDD: actionCommitAll: action %d, state %u, root %p\n", + i, getActionStateByNbr(pWti, i), pWti->actWrkrInfo[i].iparamRoot); + pAction = pWti->actWrkrInfo[i].pAction; + if(pAction != NULL && pAction->pQueue->qType == QUEUETYPE_DIRECT) + actionCommit(pWti->actWrkrInfo[i].pAction, pWti); + } +} /* process a single message. This is both called if we run from the * cosumer side of an action queue as well as directly from the main @@ -1065,22 +1080,6 @@ finalize_it: RETiRet; } -/* Commit all active transactions in direct mode */ -void -actionCommitAll(wti_t *pWti) -{ - int i; - action_t *pAction; - - for(i = 0 ; i < iActionNbr ; ++i) { - dbgprintf("DDDD: actionCommitAll: action %d, state %u, root %p\n", - i, getActionStateByNbr(pWti, i), pWti->actWrkrInfo[i].iparamRoot); - pAction = pWti->actWrkrInfo[i].pAction; - if(pAction != NULL && pAction->pQueue->qType == QUEUETYPE_DIRECT) - actionCommit(pWti->actWrkrInfo[i].pAction, pWti); - } -} - /* receive an array of to-process user pointers and submit them * for processing. * rgerhards, 2009-04-22 |