diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-05-12 17:57:04 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-05-12 17:57:04 +0200 |
| commit | e2b229868955a6f6a6380273314d0d90ddad1273 (patch) | |
| tree | 5a19ce9b00e9c50c1cddd78ad2d40f3d4dcdf1fb /runtime/batch.h | |
| parent | fbb040b411ee564e4a4bbaf53ec342236929324f (diff) | |
| download | rsyslog-e2b229868955a6f6a6380273314d0d90ddad1273.tar.gz rsyslog-e2b229868955a6f6a6380273314d0d90ddad1273.tar.bz2 rsyslog-e2b229868955a6f6a6380273314d0d90ddad1273.zip | |
action batch processing implemented
... passed initial tests, but of course more are needed
Diffstat (limited to 'runtime/batch.h')
| -rw-r--r-- | runtime/batch.h | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/runtime/batch.h b/runtime/batch.h index cb40cf42..fcbbafce 100644 --- a/runtime/batch.h +++ b/runtime/batch.h @@ -35,7 +35,8 @@ typedef enum { BATCH_STATE_RDY = 0, /* object ready for processing */ BATCH_STATE_BAD = 1, /* unrecoverable failure while processing, do NOT resubmit to same action */ BATCH_STATE_SUB = 2, /* message submitted for processing, outcome yet unkonwn */ - BATCH_STATE_DISC = 3, /* discarded - processed OK, but do not submit to any other action */ + BATCH_STATE_COMM = 3, /* message successfully commited */ + BATCH_STATE_DISC = 4, /* discarded - processed OK, but do not submit to any other action */ } batch_state_t; @@ -57,6 +58,7 @@ struct batch_obj_s { */ struct batch_s { int nElem; /* actual number of element in this entry */ + int iDoneUpTo; /* all messages below this index have state other than RDY */ batch_obj_t *pElem; /* batch elements */ }; |