output streaming: cleanup at runmode destruction

diff --git a/src/output-streaming.c b/src/output-streaming.c
index 41bbae266ad7c1a50bcc504859ef2596f228832a..35e40d0c62442012b0ea4adfef1d8ccb7a3fb620 100644 (file)
--- a/src/output-streaming.c
+++ b/src/output-streaming.c
@@ -452,3 +452,14 @@ void TmModuleStreamingLoggerRegister (void) {
     tmm_modules[TMM_STREAMINGLOGGER].ThreadDeinit = OutputStreamingLogThreadDeinit;
     tmm_modules[TMM_STREAMINGLOGGER].cap_flags = 0;
 }
+
+void OutputStreamingShutdown(void)
+{
+    OutputStreamingLogger *logger = list;
+    while (logger) {
+        OutputStreamingLogger *next_logger = logger->next;
+        SCFree(logger);
+        logger = next_logger;
+    }
+    list = NULL;
+}

diff --git a/src/output-streaming.h b/src/output-streaming.h
index ff924dc0022a738f93c80a7f9127be7ad21e2b70..8b303742287522e0c279d4664166c26f199a8565 100644 (file)
--- a/src/output-streaming.h
+++ b/src/output-streaming.h
@@ -50,4 +50,6 @@ int OutputRegisterStreamingLogger(const char *name, StreamingLogger LogFunc, Out
 
 void TmModuleStreamingLoggerRegister (void);
 
+void OutputStreamingShutdown(void);
+
 #endif /* __OUTPUT_STREAMING_H__ */

diff --git a/src/runmodes.c b/src/runmodes.c
index 76f9022f86f1a208ac6f58b033a6130430f64d2b..166e627addc322b796dab5f389c697bcef525f21 100644 (file)
--- a/src/runmodes.c
+++ b/src/runmodes.c
@@ -447,6 +447,7 @@ void RunModeShutDown(void)
     OutputTxShutdown();
     OutputFileShutdown();
     OutputFiledataShutdown();
+    OutputStreamingShutdown();
     OutputStatsShutdown();
 
     /* Close any log files. */
@@ -462,6 +463,7 @@ void RunModeShutDown(void)
     tx_logger_module = NULL;
     file_logger_module = NULL;
     filedata_logger_module = NULL;
+    streaming_logger_module = NULL;
 }
 
 /** \internal