diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2012-04-18 16:22:46 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2012-04-18 16:22:46 +0200 |
| commit | be5d462673e70afbe509e10c59b81ca7b86135ac (patch) | |
| tree | f3b4571274ff5bf96061a7a0009425913d0ffbd4 /runtime/msg.c | |
| parent | 80d62d6bb7fe19c50f10732f98c8de90094845b0 (diff) | |
| parent | adad82ffae842934ac1a409a14f5c22951f6cc37 (diff) | |
| download | rsyslog-be5d462673e70afbe509e10c59b81ca7b86135ac.tar.gz rsyslog-be5d462673e70afbe509e10c59b81ca7b86135ac.tar.xz rsyslog-be5d462673e70afbe509e10c59b81ca7b86135ac.zip | |
Merge branch 'v5-stable-newstats' into v5-beta
Diffstat (limited to 'runtime/msg.c')
| -rw-r--r-- | runtime/msg.c | 21 |
1 files changed, 21 insertions, 0 deletions
diff --git a/runtime/msg.c b/runtime/msg.c index 810a396e..f5c6184c 100644 --- a/runtime/msg.c +++ b/runtime/msg.c @@ -1057,6 +1057,12 @@ static rsRetVal MsgSerialize(msg_t *pThis, strm_t *pStrm) objSerializePTR(pStrm, pCSAPPNAME, CSTR); objSerializePTR(pStrm, pCSPROCID, CSTR); objSerializePTR(pStrm, pCSMSGID, CSTR); + + if(pThis->pRuleset != NULL) { + rulesetGetName(pThis->pRuleset); + CHKiRet(obj.SerializeProp(pStrm, UCHAR_CONSTANT("pszRuleset"), PROPTYPE_PSZ, + rulesetGetName(pThis->pRuleset))); + } /* offset must be serialized after pszRawMsg, because we need that to obtain the correct * MSG size. @@ -1663,6 +1669,16 @@ void MsgSetRuleset(msg_t *pMsg, ruleset_t *pRuleset) } +/* rgerhards 2012-04-18: set associated ruleset (by ruleset name) + * If ruleset cannot be found, no update is done. + */ +static void +MsgSetRulesetByName(msg_t *pMsg, cstr_t *rulesetName) +{ + rulesetGetRuleset(&(pMsg->pRuleset), rsCStrGetSzStrNoNULL(rulesetName)); +} + + /* set TAG in msg object * (rewritten 2009-06-18 rgerhards) */ @@ -3196,8 +3212,13 @@ rsRetVal MsgSetProperty(msg_t *pThis, var_t *pProp) memcpy(&pThis->tRcvdAt, &pProp->val.vSyslogTime, sizeof(struct syslogTime)); } else if(isProp("tTIMESTAMP")) { memcpy(&pThis->tTIMESTAMP, &pProp->val.vSyslogTime, sizeof(struct syslogTime)); + } else if(isProp("pszRuleset")) { + MsgSetRulesetByName(pThis, pProp->val.pStr); } else if(isProp("pszMSG")) { dbgprintf("no longer supported property pszMSG silently ignored\n"); + } else { + dbgprintf("unknown supported property '%s' silently ignored\n", + rsCStrGetSzStrNoNULL(pProp->pcsName)); } finalize_it: |