Skip to content

Commit 93c21b6

Browse files
authored
Fix multiput's multiple counting buffer size (#10522)
1 parent 509064d commit 93c21b6

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

ydb/core/blobstorage/dsproxy/dsproxy.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -341,6 +341,7 @@ class TBlobStorageGroupRequestActor : public TActor<TBlobStorageGroupRequestActo
341341
TActorId ProxyActorId;
342342
std::shared_ptr<TEvBlobStorage::TExecutionRelay> ExecutionRelay;
343343
bool ExecutionRelayUsed = false;
344+
bool FirstResponse = true;
344345
};
345346

346347
void Encrypt(char *destination, const char *source, size_t shift, size_t sizeBytes, const TLogoBlobID &id,

ydb/core/blobstorage/dsproxy/dsproxy_request.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -826,7 +826,7 @@ namespace NKikimr {
826826

827827
// ensure that we are dying for the first time
828828
Y_ABORT_UNLESS(!Dead);
829-
if (RequestHandleClass && PoolCounters) {
829+
if (RequestHandleClass && PoolCounters && FirstResponse) {
830830
PoolCounters->GetItem(*RequestHandleClass, RequestBytes).Register(
831831
RequestBytes, GeneratedSubrequests, GeneratedSubrequestBytes, Timer.Passed());
832832
}
@@ -857,6 +857,7 @@ namespace NKikimr {
857857

858858
// send the reply to original request sender
859859
Send(source, ev.release(), 0, cookie);
860+
FirstResponse = false;
860861
};
861862

862863
void TBlobStorageGroupRequestActor::SendResponse(std::unique_ptr<IEventBase>&& ev, TBlobStorageGroupProxyTimeStats *timeStats) {

0 commit comments

Comments
 (0)