-/* Copyright (C) 2007-2014 Open Information Security Foundation
+/* Copyright (C) 2007-2022 Open Information Security Foundation
*
* You can copy, redistribute or modify this Program under the terms of
* the GNU General Public License version 2 as published by the Free
/** per thread data for this module, contains a list of per thread
* data for the packet loggers. */
-typedef struct OutputLoggerThreadData_ {
+typedef struct OutputStreamingLoggerThreadData_ {
OutputLoggerThreadStore *store;
uint32_t loggers;
-} OutputLoggerThreadData;
+} OutputStreamingLoggerThreadData;
/* logger instance, a module + a output ctx,
* it's perfectly valid that have multiple instances of the same
return TM_ECODE_OK;
}
- OutputLoggerThreadData *op_thread_data = (OutputLoggerThreadData *)thread_data;
+ OutputStreamingLoggerThreadData *op_thread_data =
+ (OutputStreamingLoggerThreadData *)thread_data;
OutputStreamingLogger *logger = list;
OutputLoggerThreadStore *store = op_thread_data->store;
* This will run the thread init functions for the individual registered
* loggers */
static TmEcode OutputStreamingLogThreadInit(ThreadVars *tv, const void *initdata, void **data) {
- OutputLoggerThreadData *td = SCMalloc(sizeof(*td));
+ OutputStreamingLoggerThreadData *td = SCMalloc(sizeof(*td));
if (td == NULL)
return TM_ECODE_FAILED;
memset(td, 0x00, sizeof(*td));
}
static TmEcode OutputStreamingLogThreadDeinit(ThreadVars *tv, void *thread_data) {
- OutputLoggerThreadData *op_thread_data = (OutputLoggerThreadData *)thread_data;
+ OutputStreamingLoggerThreadData *op_thread_data =
+ (OutputStreamingLoggerThreadData *)thread_data;
OutputLoggerThreadStore *store = op_thread_data->store;
OutputStreamingLogger *logger = list;
}
static void OutputStreamingLogExitPrintStats(ThreadVars *tv, void *thread_data) {
- OutputLoggerThreadData *op_thread_data = (OutputLoggerThreadData *)thread_data;
+ OutputStreamingLoggerThreadData *op_thread_data =
+ (OutputStreamingLoggerThreadData *)thread_data;
OutputLoggerThreadStore *store = op_thread_data->store;
OutputStreamingLogger *logger = list;