summaryrefslogtreecommitdiffstats
path: root/action.c
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2009-08-26 15:44:36 +0200
committerRainer Gerhards <rgerhards@adiscon.com>2009-08-26 15:44:36 +0200
commitd1b092da1eeec18ad4aafdad24f9249871d345a5 (patch)
tree3ab2595b9a0713670307209f13a635511503e8d9 /action.c
parenta34cd19763ff2703301060b30e9fa77e275fd2b5 (diff)
downloadrsyslog-d1b092da1eeec18ad4aafdad24f9249871d345a5.tar.gz
rsyslog-d1b092da1eeec18ad4aafdad24f9249871d345a5.tar.xz
rsyslog-d1b092da1eeec18ad4aafdad24f9249871d345a5.zip
reduced number of debug messages a bit again
Diffstat (limited to 'action.c')
-rw-r--r--action.c9
1 files changed, 0 insertions, 9 deletions
diff --git a/action.c b/action.c
index 1e02d23e..d8ccafb6 100644
--- a/action.c
+++ b/action.c
@@ -809,7 +809,6 @@ tryDoAction(action_t *pAction, batch_t *pBatch, int *pnElem)
assert(pBatch != NULL);
assert(pnElem != NULL);
-dbgprintf("XXXX: ENTER tryDoAction elt 0 state %d\n", pBatch->pElem[0].state);
i = pBatch->iDoneUpTo; /* all messages below that index are processed */
iElemProcessed = 0;
@@ -835,7 +834,6 @@ dbgprintf("XXXX: ENTER tryDoAction elt 0 state %d\n", pBatch->pElem[0].state);
pBatch->pElem[i].state = BATCH_STATE_SUB;
} else if(localRet == RS_RET_DISCARDMSG) {
pBatch->pElem[i].state = BATCH_STATE_DISC;
-dbgprintf("XXXX: discardmsg! change state to _DISC: %d\n", pBatch->pElem[i].state);
} else {
iRet = localRet;
FINALIZE;
@@ -852,7 +850,6 @@ finalize_it:
*pnElem += iCommittedUpTo - pBatch->iDoneUpTo;
pBatch->iDoneUpTo = iCommittedUpTo;
}
-dbgprintf("XXXX: done tryDoAction elt 0 state %d, iret %d\n", pBatch->pElem[0].state, iRet);
RETiRet;
}
@@ -875,7 +872,6 @@ submitBatch(action_t *pAction, batch_t *pBatch, int nElem)
bDone = 0;
do {
localRet = tryDoAction(pAction, pBatch, &nElem);
-dbgprintf("XXXX: submitBatch got state %d\n", localRet);
if( localRet == RS_RET_OK
|| localRet == RS_RET_PREVIOUS_COMMITTED
|| localRet == RS_RET_DEFER_COMMIT) {
@@ -885,7 +881,6 @@ dbgprintf("XXXX: submitBatch got state %d\n", localRet);
localRet = finishBatch(pAction);
}
-dbgprintf("XXXX: submitBatch got state %d\n", localRet);
if( localRet == RS_RET_OK
|| localRet == RS_RET_PREVIOUS_COMMITTED
|| localRet == RS_RET_DEFER_COMMIT) {
@@ -893,7 +888,6 @@ dbgprintf("XXXX: submitBatch got state %d\n", localRet);
} else if(localRet == RS_RET_DISCARDMSG) {
iRet = RS_RET_DISCARDMSG; /* TODO: verify this sequence -- rgerhards, 2009-07-30 */
bDone = 1;
-dbgprintf("XXXX: submitBatch DONE state %d\n", localRet);
} else if(localRet == RS_RET_SUSPENDED) {
; /* do nothing, this will retry the full batch */
} else if(localRet == RS_RET_ACTION_FAILED) {
@@ -913,10 +907,8 @@ dbgprintf("XXXX: submitBatch DONE state %d\n", localRet);
bDone = 1;
}
}
-dbgprintf("XXXX: submitBatch pre while state %d\n", localRet);
} while(!bDone); /* do .. while()! */
-dbgprintf("XXXX: END submitBatch elt 0 state %d, iRet %d\n", pBatch->pElem[0].state, iRet);
RETiRet;
}
@@ -1152,7 +1144,6 @@ actionWriteToAction(action_t *pAction)
* So let's enqueue our message for execution. -- rgerhards, 2007-07-24
*/
iRet = qqueueEnqObj(pAction->pQueue, pAction->f_pMsg->flowCtlType, (void*) MsgAddRef(pAction->f_pMsg));
-dbgprintf("XXXX: queueEnqObj returned %d\n", iRet);
if(iRet == RS_RET_OK)
pAction->f_prevcount = 0; /* message processed, so we start a new cycle */