refine code

alibaba · Sep 26, 2024 · 1a3adbc · 1a3adbc
1 parent dd6fea3
commit 1a3adbc
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/core/plugin/flusher/sls/FlusherSLS.cpp b/core/plugin/flusher/sls/FlusherSLS.cpp
@@ -183,6 +183,13 @@ void FlusherSLS::ClearInvalidConcurrencyLimiters() {
  ++iter;
  }
  }
+ for (auto iter = sLogstoreConcurrencyLimiterMap.begin(); iter != sLogstoreConcurrencyLimiterMap.end();) {
+ if (iter->second.expired()) {
+ iter = sLogstoreConcurrencyLimiterMap.erase(iter);
+ } else {
+ ++iter;
+ }
+ }
 }
 
 mutex FlusherSLS::sDefaultRegionLock;