|
|
|
|
@ -606,6 +606,7 @@ typedef struct FlowManagerThreadData_ {
|
|
|
|
|
FlowCounters cnt;
|
|
|
|
|
|
|
|
|
|
FlowManagerTimeoutThread timeout;
|
|
|
|
|
uint16_t counter_defrag_timeout;
|
|
|
|
|
} FlowManagerThreadData;
|
|
|
|
|
|
|
|
|
|
static void FlowCountersInit(ThreadVars *t, FlowCounters *fc)
|
|
|
|
|
@ -678,6 +679,7 @@ static TmEcode FlowManagerThreadInit(ThreadVars *t, const void *initdata, void *
|
|
|
|
|
*data = ftd;
|
|
|
|
|
|
|
|
|
|
FlowCountersInit(t, &ftd->cnt);
|
|
|
|
|
ftd->counter_defrag_timeout = StatsRegisterCounter("defrag.mgr.tracker_timeout", t);
|
|
|
|
|
|
|
|
|
|
PacketPoolInit();
|
|
|
|
|
return TM_ECODE_OK;
|
|
|
|
|
@ -875,7 +877,10 @@ static TmEcode FlowManager(ThreadVars *th_v, void *thread_data)
|
|
|
|
|
}
|
|
|
|
|
if (other_last_sec == 0 || other_last_sec < (uint32_t)SCTIME_SECS(ts)) {
|
|
|
|
|
if (ftd->instance == 0) {
|
|
|
|
|
DefragTimeoutHash(ts);
|
|
|
|
|
uint32_t defrag_cnt = DefragTimeoutHash(ts);
|
|
|
|
|
if (defrag_cnt) {
|
|
|
|
|
StatsAddUI64(th_v, ftd->counter_defrag_timeout, defrag_cnt);
|
|
|
|
|
}
|
|
|
|
|
HostTimeoutHash(ts);
|
|
|
|
|
IPPairTimeoutHash(ts);
|
|
|
|
|
HttpRangeContainersTimeoutHash(ts);
|
|
|
|
|
|