From 30aece94a64eb2564e6bb3067a98ec9405daebfb Mon Sep 17 00:00:00 2001 From: Rainer Gerhards Date: Mon, 4 Nov 2013 14:34:20 +0100 Subject: cosmetic: keep related code together --- action.c | 31 +++++++++++++++---------------- 1 file changed, 15 insertions(+), 16 deletions(-) (limited to 'action.c') diff --git a/action.c b/action.c index f57a7399..344ff03e 100644 --- a/action.c +++ b/action.c @@ -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 -- cgit v1.2.3