fix bug

alibaba · Nov 25, 2024 · d1d43c5 · d1d43c5
1 parent db3994f
commit d1d43c5
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/core/models/MetricValue.cpp b/core/models/MetricValue.cpp
@@ -56,15 +56,15 @@ void UntypedMultiDoubleValues::DelValue(StringView key) {
     mValues.erase(key);
 }
 
-std::map<StringView, double>::const_iterator UntypedMultiDoubleValues::MultiKeyValusBegin() const {
+std::map<StringView, double>::const_iterator UntypedMultiDoubleValues::ValusBegin() const {
     return mValues.begin();
 }
 
-std::map<StringView, double>::const_iterator UntypedMultiDoubleValues::MultiKeyValusEnd() const {
+std::map<StringView, double>::const_iterator UntypedMultiDoubleValues::ValusEnd() const {
     return mValues.end();
 }
 
-size_t UntypedMultiDoubleValues::MultiKeyValusSize() const {
+size_t UntypedMultiDoubleValues::ValusSize() const {
     return mValues.size();
 }
 

diff --git a/core/models/MetricValue.h b/core/models/MetricValue.h
@@ -58,9 +58,9 @@ struct UntypedMultiDoubleValues {
     void SetValueNoCopy(StringView key, double val);
     void DelValue(StringView key);
 
-    std::map<StringView, double>::const_iterator MultiKeyValusBegin() const;
-    std::map<StringView, double>::const_iterator MultiKeyValusEnd() const;
-    size_t MultiKeyValusSize() const;
+    std::map<StringView, double>::const_iterator ValusBegin() const;
+    std::map<StringView, double>::const_iterator ValusEnd() const;
+    size_t ValusSize() const;
 
     size_t DataSize() const;
     void ResetPipelineEvent(PipelineEvent* ptr) { mMetricEventPtr = ptr; }

diff --git a/core/runner/FlusherRunner.cpp b/core/runner/FlusherRunner.cpp
@@ -186,13 +186,13 @@ void FlusherRunner::Dispatch(SenderQueueItem* item) {
             if (!BOOL_FLAG(enable_full_drain_mode) && Application::GetInstance()->IsExiting()
                 && item->mFlusher->Name() == "flusher_sls") {
                 DiskBufferWriter::GetInstance()->PushToDiskBuffer(item, 3);
-                SenderQueueManager::GetInstance()->RemoveItem(item->mFlusher->GetQueueKey(), item);
+                SenderQueueManager::GetInstance()->RemoveItem(item->mQueueKey, item);
             } else {
                 PushToHttpSink(item);
             }
             break;
         default:
-            SenderQueueManager::GetInstance()->RemoveItem(item->mFlusher->GetQueueKey(), item);
+            SenderQueueManager::GetInstance()->RemoveItem(item->mQueueKey, item);
             break;
     }
 }