Count all results in a batch when responding to a Log write,

Count all results in a batch

2 files changed, 6 insertions, 1 deletions

diff --git a/ydb/core/blobstorage/pdisk/blobstorage_pdisk_completion_impl.cpp b/ydb/core/blobstorage/pdisk/blobstorage_pdisk_completion_impl.cpp
index 3843ca650c..8dcb56dee4 100644
--- a/ydb/core/blobstorage/pdisk/blobstorage_pdisk_completion_impl.cpp
+++ b/ydb/core/blobstorage/pdisk/blobstorage_pdisk_completion_impl.cpp
@@ -30,8 +30,9 @@ void TCompletionLogWrite::Exec(TActorSystem *actorSystem) {
 
     auto sendResponse = [&] (TLogWrite *evLog) {
         Y_VERIFY_DEBUG(evLog->Result);
+        ui32 results = evLog->Result->Results.size();
         actorSystem->Send(evLog->Sender, evLog->Result.Release());
-        PDisk->Mon.WriteLog.CountResponse();
+        PDisk->Mon.WriteLog.CountMultipleResponses(results);
     };
 
     THashMap<ui64, TLogWrite *> batchMap;
diff --git a/ydb/core/blobstorage/pdisk/blobstorage_pdisk_mon.h b/ydb/core/blobstorage/pdisk/blobstorage_pdisk_mon.h
index b4ffd62c21..82efac7bad 100644
--- a/ydb/core/blobstorage/pdisk/blobstorage_pdisk_mon.h
+++ b/ydb/core/blobstorage/pdisk/blobstorage_pdisk_mon.h
@@ -679,6 +679,10 @@ struct TPDiskMon {
             Results->Inc();
             *Bytes += size;
         }
+
+        void CountMultipleResponses(ui32 num) {
+            Results->Add(num);
+        }
     };
 
     struct TReqCounters {