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 | |
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
-rw-r--r-- | action.c | 5 | ||||
-rw-r--r-- | action.h | 1 |
2 files changed, 6 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; @@ -92,6 +92,7 @@ struct action_s { /* for statistics subsystem */ statsobj_t *statsobj; STATSCOUNTER_DEF(ctrProcessed, mutCtrProcessed); + STATSCOUNTER_DEF(ctrFail, mutCtrFail); }; |