Skip to content

Commit

Permalink
refine log
Browse files Browse the repository at this point in the history
  • Loading branch information
linrunqi08 committed Sep 13, 2024
1 parent d080b60 commit a1aca6a
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions core/plugin/flusher/sls/FlusherSLS.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -616,14 +616,13 @@ void FlusherSLS::OnSendDone(const HttpResponse& response, SenderQueueItem* item)
cpt->Commit();
cpt->IncreaseSequenceID();
}

GetRegionConcurrencyLimiter(mRegion)->OnSuccess();
DealSenderQueueItemAfterSend(item, false);
LOG_DEBUG(sLogger,
("send data to sls succeeded, item address", item)("request id", slsResponse.mRequestId)(
"config", configName)("region", mRegion)("project", mProject)("logstore", data->mLogstore)(
"response time", curTime - data->mLastSendTime)("total send time", curTime - data->mEnqueTime)(
"try cnt", data->mTryCnt)("endpoint", data->mCurrentEndpoint)("is profile data", isProfileData));
GetRegionConcurrencyLimiter(mRegion)->OnSuccess();
DealSenderQueueItemAfterSend(item, false);
} else {
OperationOnFail operation;
SendResult sendResult = ConvertErrorCode(slsResponse.mErrorCode);
Expand Down

0 comments on commit a1aca6a

Please sign in to comment.