diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2012-04-01 18:58:58 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2012-04-01 18:58:58 +0200 |
| commit | 5351538b0aaa3db199b1116c33b38542e81edb41 (patch) | |
| tree | 111538f384e798b5b2f6b8838c3fa5624b1a5778 /runtime/statsobj.c | |
| parent | 74df1b744f9482a315d88dbc7465557afa96897d (diff) | |
| download | rsyslog-5351538b0aaa3db199b1116c33b38542e81edb41.tar.gz rsyslog-5351538b0aaa3db199b1116c33b38542e81edb41.tar.bz2 rsyslog-5351538b0aaa3db199b1116c33b38542e81edb41.zip | |
impstats: added $PStatsJSON directive
Diffstat (limited to 'runtime/statsobj.c')
| -rw-r--r-- | runtime/statsobj.c | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/runtime/statsobj.c b/runtime/statsobj.c index 9169d7db..a21614f6 100644 --- a/runtime/statsobj.c +++ b/runtime/statsobj.c @@ -262,14 +262,21 @@ finalize_it: * line. If the callback reports an error, processing is stopped. */ static rsRetVal -getAllStatsLines(rsRetVal(*cb)(void*, cstr_t*), void *usrptr) +getAllStatsLines(rsRetVal(*cb)(void*, cstr_t*), void *usrptr, statsFmtType_t fmt) { statsobj_t *o; cstr_t *cstr; DEFiRet; for(o = objRoot ; o != NULL ; o = o->next) { - CHKiRet(getStatsLine(o, &cstr)); + switch(fmt) { + case statsFmt_Legacy: + CHKiRet(getStatsLine(o, &cstr)); + break; + case statsFmt_JSON: + CHKiRet(getStatsLineCEE(o, &cstr)); + break; + } CHKiRet(cb(usrptr, cstr)); rsCStrDestruct(&cstr); } |