logging: convert json netflow output to non-thread module

pull/2245/head
Jason Ish 9 years ago committed by Victor Julien
parent 983a619ff0
commit 01cc508257

@ -432,34 +432,22 @@ static TmEcode JsonNetFlowLogThreadDeinit(ThreadVars *t, void *data)
void TmModuleJsonNetFlowLogRegister (void) void TmModuleJsonNetFlowLogRegister (void)
{ {
tmm_modules[TMM_JSONNETFLOWLOG].name = "JsonNetFlowLog";
tmm_modules[TMM_JSONNETFLOWLOG].ThreadInit = JsonNetFlowLogThreadInit;
tmm_modules[TMM_JSONNETFLOWLOG].ThreadDeinit = JsonNetFlowLogThreadDeinit;
tmm_modules[TMM_JSONNETFLOWLOG].RegisterTests = NULL;
tmm_modules[TMM_JSONNETFLOWLOG].cap_flags = 0;
tmm_modules[TMM_JSONNETFLOWLOG].flags = TM_FLAG_LOGAPI_TM;
/* register as separate module */ /* register as separate module */
OutputRegisterFlowModule("JsonNetFlowLog", "netflow-json-log", OutputRegisterFlowModule("JsonNetFlowLog", "netflow-json-log",
OutputNetFlowLogInit, JsonNetFlowLogger, NULL, NULL, NULL); OutputNetFlowLogInit, JsonNetFlowLogger, JsonNetFlowLogThreadInit,
JsonNetFlowLogThreadDeinit, NULL);
/* also register as child of eve-log */ /* also register as child of eve-log */
OutputRegisterFlowSubModule("eve-log", "JsonNetFlowLog", "eve-log.netflow", OutputRegisterFlowSubModule("eve-log", "JsonNetFlowLog", "eve-log.netflow",
OutputNetFlowLogInitSub, JsonNetFlowLogger, NULL, NULL, NULL); OutputNetFlowLogInitSub, JsonNetFlowLogger, JsonNetFlowLogThreadInit,
JsonNetFlowLogThreadDeinit, NULL);
} }
#else #else
static TmEcode OutputJsonThreadInit(ThreadVars *t, void *initdata, void **data)
{
SCLogInfo("Can't init JSON output - JSON support was disabled during build.");
return TM_ECODE_FAILED;
}
void TmModuleJsonNetFlowLogRegister (void) void TmModuleJsonNetFlowLogRegister (void)
{ {
tmm_modules[TMM_JSONNETFLOWLOG].name = "JsonNetFlowLog"; SCLogInfo("Can't register JSON output - JSON support was disabled during build.");
tmm_modules[TMM_JSONNETFLOWLOG].ThreadInit = OutputJsonThreadInit;
} }
#endif #endif

@ -244,7 +244,6 @@ const char * TmModuleTmmIdToString(TmmId id)
CASE_CODE (TMM_STREAMINGLOGGER); CASE_CODE (TMM_STREAMINGLOGGER);
CASE_CODE (TMM_JSONDROPLOG); CASE_CODE (TMM_JSONDROPLOG);
CASE_CODE (TMM_JSONFILELOG); CASE_CODE (TMM_JSONFILELOG);
CASE_CODE (TMM_JSONNETFLOWLOG);
CASE_CODE (TMM_JSONSMTPLOG); CASE_CODE (TMM_JSONSMTPLOG);
CASE_CODE (TMM_JSONSSHLOG); CASE_CODE (TMM_JSONSSHLOG);
CASE_CODE (TMM_JSONSTATSLOG); CASE_CODE (TMM_JSONSTATSLOG);

@ -82,7 +82,6 @@ typedef enum {
TMM_JSONFILELOG, TMM_JSONFILELOG,
TMM_RECEIVENFLOG, TMM_RECEIVENFLOG,
TMM_DECODENFLOG, TMM_DECODENFLOG,
TMM_JSONNETFLOWLOG,
TMM_LOGSTATSLOG, TMM_LOGSTATSLOG,
TMM_JSONTEMPLATELOG, TMM_JSONTEMPLATELOG,

Loading…
Cancel
Save