diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2012-09-26 12:25:10 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2012-09-26 12:25:10 +0200 |
| commit | 7c2183ee323dc062b0dde6bac4cd9c5afa4ab369 (patch) | |
| tree | 5ff20593e1526ee27859d7aa3ac1e95e4eca4652 /runtime/modules.c | |
| parent | b715e86769b9b6d77e9c57e4d0cc70725962cf1f (diff) | |
| download | rsyslog-7c2183ee323dc062b0dde6bac4cd9c5afa4ab369.tar.gz rsyslog-7c2183ee323dc062b0dde6bac4cd9c5afa4ab369.tar.bz2 rsyslog-7c2183ee323dc062b0dde6bac4cd9c5afa4ab369.zip | |
input stmt: add core engine plumbing
Diffstat (limited to 'runtime/modules.c')
| -rw-r--r-- | runtime/modules.c | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/runtime/modules.c b/runtime/modules.c index d3c51e90..c0dd0ffb 100644 --- a/runtime/modules.c +++ b/runtime/modules.c @@ -607,6 +607,12 @@ doModInit(rsRetVal (*modInit)(int, int*, rsRetVal(**)(), rsRetVal(*)(), modInfo_ CHKiRet((*pNew->modQueryEtryPt)((uchar*)"willRun", &pNew->mod.im.willRun)); CHKiRet((*pNew->modQueryEtryPt)((uchar*)"afterRun", &pNew->mod.im.afterRun)); pNew->mod.im.bCanRun = 0; + localRet = (*pNew->modQueryEtryPt)((uchar*)"newInpInst", &pNew->mod.im.newInpInst); + if(localRet == RS_RET_MODULE_ENTRY_POINT_NOT_FOUND) { + pNew->mod.om.newActInst = NULL; + } else if(localRet != RS_RET_OK) { + ABORT_FINALIZE(localRet); + } break; case eMOD_OUT: CHKiRet((*pNew->modQueryEtryPt)((uchar*)"freeInstance", &pNew->freeInstance)); @@ -625,7 +631,8 @@ doModInit(rsRetVal (*modInit)(int, int*, rsRetVal(**)(), rsRetVal(*)(), modInfo_ else if(localRet != RS_RET_OK) ABORT_FINALIZE(localRet); - localRet = (*pNew->modQueryEtryPt)((uchar*)"endTransaction", &pNew->mod.om.endTransaction); + localRet = (*pNew->modQueryEtryPt)((uchar*)"endTransaction", + &pNew->mod.om.endTransaction); if(localRet == RS_RET_MODULE_ENTRY_POINT_NOT_FOUND) { pNew->mod.om.endTransaction = dummyEndTransaction; } else if(localRet != RS_RET_OK) { |