diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2011-12-19 12:34:19 +0100 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2011-12-19 12:34:19 +0100 |
| commit | 7837c523b8da7ac90c6efbb3de12855978ecaecf (patch) | |
| tree | 6962dda38a5e201aa512c08e70e0201a24416ca4 /action.c | |
| parent | 5fe837bf7dbdcc245ee233feb1fbcc6d052a4898 (diff) | |
| download | rsyslog-7837c523b8da7ac90c6efbb3de12855978ecaecf.tar.gz rsyslog-7837c523b8da7ac90c6efbb3de12855978ecaecf.tar.xz rsyslog-7837c523b8da7ac90c6efbb3de12855978ecaecf.zip | |
additional counter for lost messages due to failed actions added
Diffstat (limited to 'action.c')
| -rw-r--r-- | action.c | 5 |
1 files changed, 5 insertions, 0 deletions
@@ -341,6 +341,10 @@ actionConstructFinalize(action_t *pThis) CHKiRet(statsobj.AddCounter(pThis->statsobj, UCHAR_CONSTANT("processed"), ctrType_IntCtr, &pThis->ctrProcessed)); + STATSCOUNTER_INIT(pThis->ctrFail, pThis->mutCtrFail); + CHKiRet(statsobj.AddCounter(pThis->statsobj, UCHAR_CONSTANT("failed"), + ctrType_IntCtr, &pThis->ctrFail)); + CHKiRet(statsobj.ConstructFinalize(pThis->statsobj)); /* create our queue */ @@ -1099,6 +1103,7 @@ submitBatch(action_t *pAction, batch_t *pBatch, int nElem) && pBatch->pElem[i].state != BATCH_STATE_COMM ) { pBatch->pElem[i].state = BATCH_STATE_BAD; pBatch->pElem[i].bPrevWasSuspended = 1; + STATSCOUNTER_INC(pAction->ctrFail, pAction->mutCtrFail); } } bDone = 1; |