issue-1791: added logs (#1797)

* issue-1791: added logs
ydb-platform · Aug 14, 2024 · d6de877 · d6de877
1 parent 7712258
commit d6de877
Show file tree

Hide file tree

Showing 2 changed files with 32 additions and 0 deletions.
diff --git a/cloud/blockstore/libs/storage/partition_nonrepl/part_nonrepl_rdma_actor.cpp b/cloud/blockstore/libs/storage/partition_nonrepl/part_nonrepl_rdma_actor.cpp
@@ -466,6 +466,12 @@ void TNonreplicatedPartitionRdmaActor::HandleWakeup(
 
 void TNonreplicatedPartitionRdmaActor::ReplyAndDie(const NActors::TActorContext& ctx)
 {
+    LOG_INFO(
+        ctx,
+        TBlockStoreComponents::PARTITION,
+        "[%s] Reply and die",
+        SelfId().ToString().c_str());
+
     for (auto& [_, endpoint]: AgentId2EndpointFuture) {
         endpoint.Subscribe([](auto& future) {
             if (future.HasValue()) {
@@ -489,6 +495,12 @@ void TNonreplicatedPartitionRdmaActor::HandlePoisonPill(
         MakeIntrusive<TCallContext>());
 
     if (!RequestsInProgress.Empty()) {
+        LOG_INFO(
+            ctx,
+            TBlockStoreComponents::PARTITION,
+            "[%s] Postpone PoisonPill response. Wait for requests in progress",
+            SelfId().ToString().c_str());
+
         return;
     }
 

diff --git a/cloud/blockstore/libs/storage/volume/volume_actor.cpp b/cloud/blockstore/libs/storage/volume/volume_actor.cpp
@@ -26,6 +26,7 @@
 #include <library/cpp/lwtrace/signature.h>
 
 #include <util/string/builder.h>
+#include <util/stream/str.h>
 
 namespace NCloud::NBlockStore::NStorage {
 
@@ -597,11 +598,30 @@ void TVolumeActor::HandlePoisonTaken(
         }
     }
 
+    const auto removed = std::distance(WaitForPartitions.begin(), it);
+
     WaitForPartitions.erase(WaitForPartitions.begin(), it);
 
     if (WaitForPartitions.empty()) {
         StoppedPartitions.clear();
     }
+
+    TStringStream waitList;
+    for (const auto& [p, _]: WaitForPartitions) {
+        waitList << p.ToString() << " ";
+    }
+
+    TStringStream stoppedList;
+    for (const auto& p: StoppedPartitions) {
+        stoppedList << p.ToString() << " ";
+    }
+
+    LOG_INFO(ctx, TBlockStoreComponents::VOLUME,
+        "[%lu] Partitions removed from the wait list: %lu. W: [ %s], S: [ %s]",
+        TabletID(),
+        removed,
+        waitList.Str().c_str(),
+        stoppedList.Str().c_str());
 }
 
 void TVolumeActor::HandleUpdateThrottlerState(