Skip to content

Commit

Permalink
output-stats: remove ThreadExitPrintStats callback
Browse files Browse the repository at this point in the history
Not used.

Ticket: OISF#7227
  • Loading branch information
jasonish authored and Corey Thomas committed Sep 3, 2024
1 parent 6754bbe commit 459037c
Show file tree
Hide file tree
Showing 7 changed files with 23 additions and 57 deletions.
5 changes: 2 additions & 3 deletions src/log-stats.c
Original file line number Diff line number Diff line change
Expand Up @@ -284,7 +284,6 @@ static void LogStatsLogDeInitCtx(OutputCtx *output_ctx)

void LogStatsLogRegister (void)
{
OutputRegisterStatsModule(LOGGER_STATS, MODULE_NAME, "stats",
LogStatsLogInitCtx, LogStatsLogger, LogStatsLogThreadInit,
LogStatsLogThreadDeinit, NULL);
OutputRegisterStatsModule(LOGGER_STATS, MODULE_NAME, "stats", LogStatsLogInitCtx,
LogStatsLogger, LogStatsLogThreadInit, LogStatsLogThreadDeinit);
}
6 changes: 3 additions & 3 deletions src/output-json-stats.c
Original file line number Diff line number Diff line change
Expand Up @@ -500,9 +500,9 @@ static OutputInitResult OutputStatsLogInitSub(ConfNode *conf, OutputCtx *parent_

void JsonStatsLogRegister(void) {
/* register as child of eve-log */
OutputRegisterStatsSubModule(LOGGER_JSON_STATS, "eve-log", MODULE_NAME,
"eve-log.stats", OutputStatsLogInitSub, JsonStatsLogger,
JsonStatsLogThreadInit, JsonStatsLogThreadDeinit, NULL);
OutputRegisterStatsSubModule(LOGGER_JSON_STATS, "eve-log", MODULE_NAME, "eve-log.stats",
OutputStatsLogInitSub, JsonStatsLogger, JsonStatsLogThreadInit,
JsonStatsLogThreadDeinit);
}

#ifdef UNITTESTS
Expand Down
25 changes: 2 additions & 23 deletions src/output-stats.c
Original file line number Diff line number Diff line change
Expand Up @@ -44,15 +44,12 @@ typedef struct OutputStatsLogger_ {
const char *name;
ThreadInitFunc ThreadInit;
ThreadDeinitFunc ThreadDeinit;
ThreadExitPrintStatsFunc ThreadExitPrintStats;
} OutputStatsLogger;

static OutputStatsLogger *list = NULL;

int OutputRegisterStatsLogger(const char *name, StatsLogger LogFunc,
OutputCtx *output_ctx, ThreadInitFunc ThreadInit,
ThreadDeinitFunc ThreadDeinit,
ThreadExitPrintStatsFunc ThreadExitPrintStats)
int OutputRegisterStatsLogger(const char *name, StatsLogger LogFunc, OutputCtx *output_ctx,
ThreadInitFunc ThreadInit, ThreadDeinitFunc ThreadDeinit)
{
OutputStatsLogger *op = SCCalloc(1, sizeof(*op));
if (op == NULL)
Expand All @@ -63,7 +60,6 @@ int OutputRegisterStatsLogger(const char *name, StatsLogger LogFunc,
op->name = name;
op->ThreadInit = ThreadInit;
op->ThreadDeinit = ThreadDeinit;
op->ThreadExitPrintStats = ThreadExitPrintStats;

if (list == NULL)
list = op;
Expand Down Expand Up @@ -170,27 +166,10 @@ static TmEcode OutputStatsLogThreadDeinit(ThreadVars *tv, void *thread_data)
return TM_ECODE_OK;
}

static void OutputStatsLogExitPrintStats(ThreadVars *tv, void *thread_data)
{
OutputStatsLoggerThreadData *op_thread_data = (OutputStatsLoggerThreadData *)thread_data;
OutputLoggerThreadStore *store = op_thread_data->store;
OutputStatsLogger *logger = list;

while (logger && store) {
if (logger->ThreadExitPrintStats) {
logger->ThreadExitPrintStats(tv, store->thread_data);
}

logger = logger->next;
store = store->next;
}
}

void TmModuleStatsLoggerRegister (void)
{
tmm_modules[TMM_STATSLOGGER].name = "__stats_logger__";
tmm_modules[TMM_STATSLOGGER].ThreadInit = OutputStatsLogThreadInit;
tmm_modules[TMM_STATSLOGGER].ThreadExitPrintStats = OutputStatsLogExitPrintStats;
tmm_modules[TMM_STATSLOGGER].ThreadDeinit = OutputStatsLogThreadDeinit;
tmm_modules[TMM_STATSLOGGER].cap_flags = 0;
}
Expand Down
5 changes: 2 additions & 3 deletions src/output-stats.h
Original file line number Diff line number Diff line change
Expand Up @@ -49,9 +49,8 @@ TmEcode OutputStatsLog(ThreadVars *tv, void *thread_data, StatsTable *st);

typedef int (*StatsLogger)(ThreadVars *, void *thread_data, const StatsTable *);

int OutputRegisterStatsLogger(const char *name, StatsLogger LogFunc,
OutputCtx *, ThreadInitFunc ThreadInit, ThreadDeinitFunc ThreadDeinit,
ThreadExitPrintStatsFunc ThreadExitPrintStats);
int OutputRegisterStatsLogger(const char *name, StatsLogger LogFunc, OutputCtx *,
ThreadInitFunc ThreadInit, ThreadDeinitFunc ThreadDeinit);

void TmModuleStatsLoggerRegister (void);

Expand Down
17 changes: 6 additions & 11 deletions src/output.c
Original file line number Diff line number Diff line change
Expand Up @@ -539,10 +539,9 @@ void OutputRegisterStreamingModule(LoggerId id, const char *name, const char *co
*
* \retval Returns 0 on success, -1 on failure.
*/
void OutputRegisterStatsModule(LoggerId id, const char *name,
const char *conf_name, OutputInitFunc InitFunc, StatsLogger StatsLogFunc,
ThreadInitFunc ThreadInit, ThreadDeinitFunc ThreadDeinit,
ThreadExitPrintStatsFunc ThreadExitPrintStats)
void OutputRegisterStatsModule(LoggerId id, const char *name, const char *conf_name,
OutputInitFunc InitFunc, StatsLogger StatsLogFunc, ThreadInitFunc ThreadInit,
ThreadDeinitFunc ThreadDeinit)
{
if (unlikely(StatsLogFunc == NULL)) {
goto error;
Expand All @@ -560,7 +559,6 @@ void OutputRegisterStatsModule(LoggerId id, const char *name,
module->StatsLogFunc = StatsLogFunc;
module->ThreadInit = ThreadInit;
module->ThreadDeinit = ThreadDeinit;
module->ThreadExitPrintStats = ThreadExitPrintStats;
TAILQ_INSERT_TAIL(&output_modules, module, entries);

SCLogDebug("Stats logger \"%s\" registered.", name);
Expand All @@ -577,11 +575,9 @@ void OutputRegisterStatsModule(LoggerId id, const char *name,
*
* \retval Returns 0 on success, -1 on failure.
*/
void OutputRegisterStatsSubModule(LoggerId id, const char *parent_name,
const char *name, const char *conf_name, OutputInitSubFunc InitFunc,
StatsLogger StatsLogFunc, ThreadInitFunc ThreadInit,
ThreadDeinitFunc ThreadDeinit,
ThreadExitPrintStatsFunc ThreadExitPrintStats)
void OutputRegisterStatsSubModule(LoggerId id, const char *parent_name, const char *name,
const char *conf_name, OutputInitSubFunc InitFunc, StatsLogger StatsLogFunc,
ThreadInitFunc ThreadInit, ThreadDeinitFunc ThreadDeinit)
{
if (unlikely(StatsLogFunc == NULL)) {
goto error;
Expand All @@ -600,7 +596,6 @@ void OutputRegisterStatsSubModule(LoggerId id, const char *parent_name,
module->StatsLogFunc = StatsLogFunc;
module->ThreadInit = ThreadInit;
module->ThreadDeinit = ThreadDeinit;
module->ThreadExitPrintStats = ThreadExitPrintStats;
TAILQ_INSERT_TAIL(&output_modules, module, entries);

SCLogDebug("Stats logger \"%s\" registered.", name);
Expand Down
17 changes: 6 additions & 11 deletions src/output.h
Original file line number Diff line number Diff line change
Expand Up @@ -133,17 +133,12 @@ void OutputRegisterStreamingModule(LoggerId id, const char *name, const char *co
enum OutputStreamingType stream_type, ThreadInitFunc ThreadInit,
ThreadDeinitFunc ThreadDeinit);

void OutputRegisterStatsModule(LoggerId id, const char *name,
const char *conf_name, OutputInitFunc InitFunc,
StatsLogger StatsLogFunc, ThreadInitFunc ThreadInit,
ThreadDeinitFunc ThreadDeinit,
ThreadExitPrintStatsFunc ThreadExitPrintStats);
void OutputRegisterStatsSubModule(LoggerId id, const char *parent_name,
const char *name, const char *conf_name,
OutputInitSubFunc InitFunc,
StatsLogger StatsLogFunc, ThreadInitFunc ThreadInit,
ThreadDeinitFunc ThreadDeinit,
ThreadExitPrintStatsFunc ThreadExitPrintStats);
void OutputRegisterStatsModule(LoggerId id, const char *name, const char *conf_name,
OutputInitFunc InitFunc, StatsLogger StatsLogFunc, ThreadInitFunc ThreadInit,
ThreadDeinitFunc ThreadDeinit);
void OutputRegisterStatsSubModule(LoggerId id, const char *parent_name, const char *name,
const char *conf_name, OutputInitSubFunc InitFunc, StatsLogger StatsLogFunc,
ThreadInitFunc ThreadInit, ThreadDeinitFunc ThreadDeinit);

OutputModule *OutputGetModuleByConfName(const char *name);
void OutputDeregisterAll(void);
Expand Down
5 changes: 2 additions & 3 deletions src/runmodes.c
Original file line number Diff line number Diff line change
Expand Up @@ -606,9 +606,8 @@ static void SetupOutput(
}
/* stats logger doesn't run in the packet path */
if (module->StatsLogFunc) {
OutputRegisterStatsLogger(module->name, module->StatsLogFunc,
output_ctx,module->ThreadInit, module->ThreadDeinit,
module->ThreadExitPrintStats);
OutputRegisterStatsLogger(module->name, module->StatsLogFunc, output_ctx,
module->ThreadInit, module->ThreadDeinit);
return;
}

Expand Down

0 comments on commit 459037c

Please sign in to comment.