From: Victor Julien <vjulien@oisf.net>
Date: Wed, 4 Dec 2024 09:51:06 +0000 (+0100)
Subject: flow/manager: add chunk debug output
X-Git-Tag: suricata-8.0.0-beta1~660
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=7fd707a876868b58c7fbff2451cb176f7111a951;p=thirdparty%2Fsuricata.git

flow/manager: add chunk debug output
---

diff --git a/src/flow-manager.c b/src/flow-manager.c
index 8fb205f5e8..4c6f165888 100644
--- a/src/flow-manager.c
+++ b/src/flow-manager.c
@@ -501,12 +501,13 @@ static uint32_t FlowTimeoutHash(FlowManagerTimeoutThread *td, SCTime_t ts, const
  *  \param counters Flow timeout counters to be passed
  *  \param rows number of rows for this worker unit
  *  \param pos absolute position of the beginning of row slice in the hash table
+ *  \param instance instance id of this FM
  *
  *  \retval number of successfully timed out flows
  */
 static uint32_t FlowTimeoutHashInChunks(FlowManagerTimeoutThread *td, SCTime_t ts,
         const uint32_t hash_min, const uint32_t hash_max, FlowTimeoutCounters *counters,
-        const uint32_t rows, uint32_t *pos)
+        const uint32_t rows, uint32_t *pos, const uint32_t instance)
 {
     uint32_t start = 0;
     uint32_t end = 0;
@@ -525,6 +526,9 @@ again:
     *pos = (end == hash_max) ? hash_min : end;
     rows_left = rows_left - (end - start);
 
+    SCLogDebug("instance %u: %u:%u (hash_min %u, hash_max %u *pos %u)", instance, start, end,
+            hash_min, hash_max, *pos);
+
     cnt += FlowTimeoutHash(td, ts, start, end, counters);
     if (rows_left) {
         goto again;
@@ -859,8 +863,8 @@ static TmEcode FlowManager(ThreadVars *th_v, void *thread_data)
                         rows_per_wu);
 
                 const uint32_t ppos = pos;
-                FlowTimeoutHashInChunks(
-                        &ftd->timeout, ts, ftd->min, ftd->max, &counters, rows_per_wu, &pos);
+                FlowTimeoutHashInChunks(&ftd->timeout, ts, ftd->min, ftd->max, &counters,
+                        rows_per_wu, &pos, ftd->instance);
                 if (ppos > pos) {
                     StatsIncr(th_v, ftd->cnt.flow_mgr_full_pass);
                 }