655     FlowManagerThreadData *ftd = SCCalloc(1, sizeof(FlowManagerThreadData));  in FlowManagerThreadInit()  local
656     if (ftd == NULL)  in FlowManagerThreadInit()
659     ftd->instance = SC_ATOMIC_ADD(flowmgr_cnt, 1);  in FlowManagerThreadInit()
660     SCLogDebug("flow manager instance %u", ftd->instance);  in FlowManagerThreadInit()
665     if (ftd->instance == 0)  in FlowManagerThreadInit()
666         ftd->max = range;  in FlowManagerThreadInit()
667     else if ((ftd->instance + 1) == flowmgr_number) {  in FlowManagerThreadInit()
668         ftd->min = (range * ftd->instance) + 1;  in FlowManagerThreadInit()
669         ftd->max = flow_config.hash_size;  in FlowManagerThreadInit()
671         ftd->min = (range * ftd->instance) + 1;  in FlowManagerThreadInit()
672         ftd->max = (range * (ftd->instance + 1));  in FlowManagerThreadInit()
674     BUG_ON(ftd->min > flow_config.hash_size || ftd->max > flow_config.hash_size);  in FlowManagerThreadInit()
676     SCLogDebug("instance %u hash range %u %u", ftd->instance, ftd->min, ftd->max);  in FlowManagerThreadInit()
679     *data = ftd;  in FlowManagerThreadInit()
681     FlowCountersInit(t, &ftd->cnt);  in FlowManagerThreadInit()
722     FlowManagerThreadData *ftd = thread_data;  in FlowManager()  local
753             ftd->instance, min_timeout, pass_in_sec);  in FlowManager()
815             StatsIncr(th_v, ftd->cnt.flow_emerg_mode_enter);  in FlowManager()
818             if (ftd->instance == 0) {  in FlowManager()
833                 FlowTimeoutHash(&ftd->timeout, &ts, ftd->min, ftd->max, &counters);  in FlowManager()
841                 StatsIncr(th_v, ftd->cnt.flow_mgr_full_pass);  in FlowManager()
846                     FlowTimeoutHashInChunks(&ftd->timeout, &ts, ftd->min, ftd->max,  in FlowManager()
852                         StatsIncr(th_v, ftd->cnt.flow_mgr_full_pass);  in FlowManager()
870             StatsAddUI64(th_v, ftd->cnt.flow_mgr_cnt_clo, (uint64_t)counters.clo);  in FlowManager()
871             StatsAddUI64(th_v, ftd->cnt.flow_mgr_cnt_new, (uint64_t)counters.new);  in FlowManager()
872             StatsAddUI64(th_v, ftd->cnt.flow_mgr_cnt_est, (uint64_t)counters.est);  in FlowManager()
873             StatsAddUI64(th_v, ftd->cnt.flow_mgr_cnt_byp, (uint64_t)counters.byp);  in FlowManager()
875             StatsAddUI64(th_v, ftd->cnt.flow_mgr_flows_checked, (uint64_t)counters.flows_checked);  in FlowManager()
876 …         StatsAddUI64(th_v, ftd->cnt.flow_mgr_flows_notimeout, (uint64_t)counters.flows_notimeout);  in FlowManager()
878             StatsAddUI64(th_v, ftd->cnt.flow_mgr_flows_timeout, (uint64_t)counters.flows_timeout);  in FlowManager()
880 … StatsAddUI64(th_v, ftd->cnt.flow_mgr_flows_timeout_inuse, (uint64_t)counters.flows_timeout_inuse);  in FlowManager()
881             StatsAddUI64(th_v, ftd->cnt.flow_mgr_flows_aside, (uint64_t)counters.flows_aside);  in FlowManager()
882 …StatsAddUI64(th_v, ftd->cnt.flow_mgr_flows_aside_needs_work, (uint64_t)counters.flows_aside_needs_…  in FlowManager()
884             StatsAddUI64(th_v, ftd->cnt.flow_bypassed_cnt_clo, (uint64_t)counters.bypassed_count);  in FlowManager()
885             StatsAddUI64(th_v, ftd->cnt.flow_bypassed_pkts, (uint64_t)counters.bypassed_pkts);  in FlowManager()
886             StatsAddUI64(th_v, ftd->cnt.flow_bypassed_bytes, (uint64_t)counters.bypassed_bytes);  in FlowManager()
888             StatsSetUI64(th_v, ftd->cnt.flow_mgr_rows_maxlen, (uint64_t)counters.rows_maxlen);  in FlowManager()
894             StatsSetUI64(th_v, ftd->cnt.flow_mgr_spare, (uint64_t)len);  in FlowManager()
922                 StatsIncr(th_v, ftd->cnt.flow_emerg_mode_over);  in FlowManager()
933         if (ftd->instance == 0 &&  in FlowManager()
1041     FlowRecyclerThreadData *ftd = SCCalloc(1, sizeof(FlowRecyclerThreadData));  in FlowRecyclerThreadInit()  local
1042     if (ftd == NULL)  in FlowRecyclerThreadInit()
1044     if (OutputFlowLogThreadInit(t, NULL, &ftd->output_thread_data) != TM_ECODE_OK) {  in FlowRecyclerThreadInit()
1046         SCFree(ftd);  in FlowRecyclerThreadInit()
1049     SCLogDebug("output_thread_data %p", ftd->output_thread_data);  in FlowRecyclerThreadInit()
1051     *data = ftd;  in FlowRecyclerThreadInit()
1057     FlowRecyclerThreadData *ftd = (FlowRecyclerThreadData *)data;  in FlowRecyclerThreadDeinit()  local
1058     if (ftd->output_thread_data != NULL)  in FlowRecyclerThreadDeinit()
1059         OutputFlowLogThreadDeinit(t, ftd->output_thread_data);  in FlowRecyclerThreadDeinit()
1073     FlowRecyclerThreadData *ftd = (FlowRecyclerThreadData *)thread_data;  in FlowRecycler()  local
1074     BUG_ON(ftd == NULL);  in FlowRecycler()
1134             Recycler(th_v, ftd->output_thread_data, f);  in FlowRecycler()