[AGENT] Fix duplicated flow map allocator stats counter

deepflowio · Oct 18, 2023 · 413c4fe · 413c4fe
1 parent c731397
commit 413c4fe
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/agent/src/flow_generator/flow_map.rs b/agent/src/flow_generator/flow_map.rs
@@ -290,7 +290,10 @@ impl FlowMap {
                 stats_collector.register_countable(
                     "allocator",
                     Countable::Ref(allocator.counter()),
-                    vec![StatsOption::Tag("type", "TaggedFlow".to_owned())],
+                    vec![
+                        StatsOption::Tag("type", "TaggedFlow".to_owned()),
+                        StatsOption::Tag("id", format!("{}", id)),
+                    ],
                 );
                 allocator
             },
@@ -300,7 +303,10 @@ impl FlowMap {
                 stats_collector.register_countable(
                     "allocator",
                     Countable::Ref(allocator.counter()),
-                    vec![StatsOption::Tag("type", "L7Stats".to_owned())],
+                    vec![
+                        StatsOption::Tag("type", "L7Stats".to_owned()),
+                        StatsOption::Tag("id", format!("{}", id)),
+                    ],
                 );
                 allocator
             },

diff --git a/agent/src/utils/stats.rs b/agent/src/utils/stats.rs
@@ -236,7 +236,7 @@ impl Collector {
             let equals = s == &source;
             if !closed && equals {
                 warn!(
-                    "Possible memory leak! countable {} is not correctly closed.",
+                    "Found duplicated counter source {}, please check if the old one is correctly closed.",
                     source
                 );
             }