diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-04 09:12:56 +0100 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-04 09:12:56 +0100 |
commit | b278457d495379dd0eca1d9da8b51fcf7fad4559 (patch) | |
tree | 3261827916c421a5312edfeadf1812d3cc7feb9f /action.h | |
parent | 32b37ecd82b508e707cf1aa0b27acb4ac96a295c (diff) | |
download | rsyslog-b278457d495379dd0eca1d9da8b51fcf7fad4559.tar.gz rsyslog-b278457d495379dd0eca1d9da8b51fcf7fad4559.tar.bz2 rsyslog-b278457d495379dd0eca1d9da8b51fcf7fad4559.zip |
refactor: move batch "unrolling" up one layer
Diffstat (limited to 'action.h')
-rw-r--r-- | action.h | 3 |
1 files changed, 2 insertions, 1 deletions
@@ -57,7 +57,7 @@ struct action_s { struct modInfo_s *pMod;/* pointer to output module handling this selector */ void *pModData; /* pointer to module data - content is module-specific */ sbool bRepMsgHasMsg; /* "message repeated..." has msg fragment in it (0-no, 1-yes) */ - rsRetVal (*submitToActQ)(action_t *, batch_t *, wti_t*);/* function submit message to action queue */ + rsRetVal (*submitToActQ)(action_t *, wti_t*, msg_t*);/* function submit message to action queue */ rsRetVal (*qConstruct)(struct queue_s *pThis); enum { ACT_STRING_PASSING = 0, ACT_ARRAY_PASSING = 1, ACT_MSG_PASSING = 2, ACT_JSON_PASSING = 3} @@ -91,6 +91,7 @@ rsRetVal addAction(action_t **ppAction, modInfo_t *pMod, void *pModData, omodStr rsRetVal activateActions(void); rsRetVal actionNewInst(struct nvlst *lst, action_t **ppAction); rsRetVal actionProcessCnf(struct cnfobj *o); +rsRetVal actionCommitAll(wti_t *pWti); /* external data */ extern int iActionNbr; |