diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2013-03-11 12:35:15 +0100 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2013-03-11 12:35:15 +0100 |
| commit | d0289157529dd219c16c0c27f0e6580312ae6470 (patch) | |
| tree | 5d9724e5b48d09326039d2f3855a7ba5396f12de /runtime/lmsig_gt.c | |
| parent | 171482ee70ca74e907ea892f33daf8c07433dcd8 (diff) | |
| download | rsyslog-d0289157529dd219c16c0c27f0e6580312ae6470.tar.gz rsyslog-d0289157529dd219c16c0c27f0e6580312ae6470.tar.bz2 rsyslog-d0289157529dd219c16c0c27f0e6580312ae6470.zip | |
logsig: support dynafiles
Diffstat (limited to 'runtime/lmsig_gt.c')
| -rw-r--r-- | runtime/lmsig_gt.c | 17 |
1 files changed, 8 insertions, 9 deletions
diff --git a/runtime/lmsig_gt.c b/runtime/lmsig_gt.c index 474c573f..021cd9f8 100644 --- a/runtime/lmsig_gt.c +++ b/runtime/lmsig_gt.c @@ -118,35 +118,34 @@ SetCnfParam(void *pT, struct nvlst *lst) static rsRetVal -OnFileOpen(void *pT, uchar *fn) +OnFileOpen(void *pT, uchar *fn, gtfile *pgf) { lmsig_gt_t *pThis = (lmsig_gt_t*) pT; DEFiRet; dbgprintf("DDDD: onFileOpen: %s\n", fn); - rsgtCtxOpenFile(pThis->ctx, fn); - sigblkInit(pThis->ctx); + + *pgf = rsgtCtxOpenFile(pThis->ctx, fn); + sigblkInit(*pgf); RETiRet; } static rsRetVal -OnRecordWrite(void *pT, uchar *rec, rs_size_t lenRec) +OnRecordWrite(void *pF, uchar *rec, rs_size_t lenRec) { - lmsig_gt_t *pThis = (lmsig_gt_t*) pT; DEFiRet; dbgprintf("DDDD: onRecordWrite (%d): %s\n", lenRec, rec); - sigblkAddRecord(pThis->ctx, rec, lenRec); + sigblkAddRecord(pF, rec, lenRec); RETiRet; } static rsRetVal -OnFileClose(void *pT) +OnFileClose(void *pF) { - lmsig_gt_t *pThis = (lmsig_gt_t*) pT; DEFiRet; dbgprintf("DDDD: onFileClose\n"); - rsgtCtxDel(pThis->ctx); + rsgtfileDestruct(pF); RETiRet; } |