diff --git a/core/runner/sink/http/HttpSink.cpp b/core/runner/sink/http/HttpSink.cpp index 49724c42c8..a48bc285b4 100644 --- a/core/runner/sink/http/HttpSink.cpp +++ b/core/runner/sink/http/HttpSink.cpp @@ -147,6 +147,7 @@ bool HttpSink::AddRequestToClient(unique_ptr&& 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(request)); ++runningHandlers; + mSendingItemsTotal->Add(1); requestReused = true; } else { auto errMsg = curl_easy_strerror(msg->data.result);