#include "suricata-common.h"#include "conf.h"#include "threadvars.h"#include "tm-threads.h"#include "runmodes.h"#include "util-time.h"#include "flow.h"#include "flow-queue.h"#include "flow-hash.h"#include "flow-util.h"#include "flow-private.h"#include "flow-timeout.h"#include "flow-manager.h"#include "flow-storage.h"#include "flow-spare-pool.h"#include "flow-callbacks.h"#include "stream-tcp.h"#include "stream-tcp-cache.h"#include "util-device-private.h"#include "util-debug.h"#include "threads.h"#include "detect-engine-threshold.h"#include "host-timeout.h"#include "defrag-hash.h"#include "defrag-timeout.h"#include "ippair-timeout.h"#include "rust.h"#include "app-layer-htp-range.h"#include "output-flow.h"#include "runmode-unix-socket.h"
Go to the source code of this file.
Data Structures | |
| struct | FlowTimeoutCounters_ |
| struct | FlowManagerTimeoutThread |
| struct | FlowCounters_ |
| struct | FlowManagerThreadData_ |
| struct | FlowRecyclerThreadData_ |
Macros | |
| #define | BITS 32 |
| #define | TYPE uint32_t |
| #define | RECYCLE_MAX_QUEUE_ITEMS 25 |
Typedefs | |
| typedef struct FlowTimeoutCounters_ | FlowTimeoutCounters |
| typedef struct FlowManagerTimeoutThread | FlowManagerTimeoutThread |
| typedef struct FlowCounters_ | FlowCounters |
| typedef struct FlowManagerThreadData_ | FlowManagerThreadData |
| typedef struct FlowRecyclerThreadData_ | FlowRecyclerThreadData |
Functions | |
| SC_ATOMIC_DECLARE (uint32_t, flowmgr_cnt) | |
| SC_ATOMIC_DECLARE (uint32_t, flowrec_cnt) | |
| SC_ATOMIC_DECLARE (uint32_t, flowrec_busy) | |
| SC_ATOMIC_EXTERN (unsigned int, flow_flags) | |
| void | FlowWakeupFlowManagerThread (void) |
| void | FlowWakeupFlowRecyclerThread (void) |
| void | FlowTimeoutsInit (void) |
| void | FlowTimeoutsEmergency (void) |
| void | FlowDisableFlowManagerThread (void) |
| Used to disable flow manager thread(s). More... | |
| void | FlowManagerThreadSpawn (void) |
| spawn the flow manager thread More... | |
| void | FlowRecyclerThreadSpawn (void) |
| spawn the flow recycler thread More... | |
| void | FlowDisableFlowRecyclerThread (void) |
| Used to disable flow recycler thread(s). More... | |
| void | TmModuleFlowManagerRegister (void) |
| void | TmModuleFlowRecyclerRegister (void) |
Variables | |
| FlowQueue | flow_recycle_q |
Detailed Description
Definition in file flow-manager.c.
Macro Definition Documentation
◆ BITS
| #define BITS 32 |
◆ RECYCLE_MAX_QUEUE_ITEMS
| #define RECYCLE_MAX_QUEUE_ITEMS 25 |
Definition at line 607 of file flow-manager.c.
◆ TYPE
| #define TYPE uint32_t |
Typedef Documentation
◆ FlowCounters
| typedef struct FlowCounters_ FlowCounters |
◆ FlowManagerThreadData
| typedef struct FlowManagerThreadData_ FlowManagerThreadData |
◆ FlowManagerTimeoutThread
| typedef struct FlowManagerTimeoutThread FlowManagerTimeoutThread |
◆ FlowRecyclerThreadData
| typedef struct FlowRecyclerThreadData_ FlowRecyclerThreadData |
◆ FlowTimeoutCounters
| typedef struct FlowTimeoutCounters_ FlowTimeoutCounters |
Function Documentation
◆ FlowDisableFlowManagerThread()
| void FlowDisableFlowManagerThread | ( | void | ) |
Used to disable flow manager thread(s).
- Todo:
- Kinda hackish since it uses the tv name to identify flow manager thread. We need an all weather identification scheme.
Definition at line 133 of file flow-manager.c.
References FatalError, ThreadVars_::name, ThreadVars_::next, SC_ATOMIC_SET, SCMutexLock, SCMutexUnlock, SleepMsec, thread_name_flow_mgr, THV_KILL, THV_RUNNING_DONE, TmThreadsCheckFlag(), TmThreadsSetFlag(), tv, tv_root, tv_root_lock, and TVT_MGMT.
Referenced by PostRunDeinit().
◆ FlowDisableFlowRecyclerThread()
| void FlowDisableFlowRecyclerThread | ( | void | ) |
Used to disable flow recycler thread(s).
- Note
- this should only be called when the flow manager is already gone
- Todo:
- Kinda hackish since it uses the tv name to identify flow recycler thread. We need an all weather identification scheme.
Definition at line 1232 of file flow-manager.c.
◆ FlowManagerThreadSpawn()
| void FlowManagerThreadSpawn | ( | void | ) |
spawn the flow manager thread
Definition at line 1001 of file flow-manager.c.
References FatalError, and SCConfGetInt().
◆ FlowRecyclerThreadSpawn()
| void FlowRecyclerThreadSpawn | ( | void | ) |
spawn the flow recycler thread
Definition at line 1196 of file flow-manager.c.
References FatalError, and SCConfGetInt().
◆ FlowTimeoutsEmergency()
| void FlowTimeoutsEmergency | ( | void | ) |
Definition at line 104 of file flow-manager.c.
References flow_timeouts_emerg, and SC_ATOMIC_SET.
◆ FlowTimeoutsInit()
| void FlowTimeoutsInit | ( | void | ) |
Definition at line 99 of file flow-manager.c.
References flow_timeouts_normal, and SC_ATOMIC_SET.
Referenced by FlowInitFlowProto().
◆ FlowWakeupFlowManagerThread()
| void FlowWakeupFlowManagerThread | ( | void | ) |
Definition at line 85 of file flow-manager.c.
References SCCtrlMutexLock.
◆ FlowWakeupFlowRecyclerThread()
| void FlowWakeupFlowRecyclerThread | ( | void | ) |
Definition at line 92 of file flow-manager.c.
References SCCtrlMutexLock.
◆ SC_ATOMIC_DECLARE() [1/3]
| SC_ATOMIC_DECLARE | ( | uint32_t | , |
| flowmgr_cnt | |||
| ) |
◆ SC_ATOMIC_DECLARE() [2/3]
| SC_ATOMIC_DECLARE | ( | uint32_t | , |
| flowrec_busy | |||
| ) |
◆ SC_ATOMIC_DECLARE() [3/3]
| SC_ATOMIC_DECLARE | ( | uint32_t | , |
| flowrec_cnt | |||
| ) |
◆ SC_ATOMIC_EXTERN()
| SC_ATOMIC_EXTERN | ( | unsigned int | , |
| flow_flags | |||
| ) |
◆ TmModuleFlowManagerRegister()
| void TmModuleFlowManagerRegister | ( | void | ) |
Definition at line 1290 of file flow-manager.c.
References TmModule_::name, TmModule_::ThreadInit, TMM_FLOWMANAGER, and tmm_modules.
Referenced by RegisterAllModules().
◆ TmModuleFlowRecyclerRegister()
| void TmModuleFlowRecyclerRegister | ( | void | ) |
Definition at line 1304 of file flow-manager.c.
References TmModule_::name, TmModule_::ThreadInit, TMM_FLOWRECYCLER, and tmm_modules.
Referenced by RegisterAllModules().
Variable Documentation
◆ flow_recycle_q
| FlowQueue flow_recycle_q |
queue to pass flows to cleanup/log thread(s)
Definition at line 66 of file flow-manager.c.
Referenced by FlowInitConfig(), and FlowShutdown().
