Update HttpSink.cpp

alibaba · Jan 13, 2025 · 95bb07a · 95bb07a
1 parent 3e83e53
commit 95bb07a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/core/runner/sink/http/HttpSink.cpp b/core/runner/sink/http/HttpSink.cpp
@@ -147,6 +147,7 @@ bool HttpSink::AddRequestToClient(unique_ptr<HttpSinkRequest>&& request) {
 
     request->mPrivateData = headers;
     curl_easy_setopt(curl, CURLOPT_PRIVATE, request.get());
+    request->mLastSendTime = chrono::system_clock::now();
 
     auto res = curl_multi_add_handle(mClient, curl);
     if (res != CURLM_OK) {
@@ -291,6 +292,7 @@ void HttpSink::HandleCompletedRequests(int& runningHandlers) {
                         ++request->mTryCnt;
                         AddRequestToClient(unique_ptr<HttpSinkRequest>(request));
                         ++runningHandlers;
+                        mSendingItemsTotal->Add(1);
                         requestReused = true;
                     } else {
                         auto errMsg = curl_easy_strerror(msg->data.result);