Additional logs

1 files changed, 12 insertions, 6 deletions

diff --git a/ydb/core/client/server/msgbus_server_pq_metacache.cpp b/ydb/core/client/server/msgbus_server_pq_metacache.cpp
index 3229137419..2a0116e1b2 100644
--- a/ydb/core/client/server/msgbus_server_pq_metacache.cpp
+++ b/ydb/core/client/server/msgbus_server_pq_metacache.cpp
@@ -237,6 +237,8 @@ private:
     }
 
     void HandleQueryResponse(NKqp::TEvKqp::TEvQueryResponse::TPtr& ev, const TActorContext& ctx) {
+        LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "HandleQueryResponse TEvQueryResponse");
+
         if (ev->Cookie != (ui64)Generation->Val()) {
             LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "stale response with generation " << ev->Cookie << ", actual is " << Generation->Val());
             return;
@@ -286,6 +288,8 @@ private:
     }
 
     void HandleGetTopicsResult(NKqp::TEvKqp::TEvQueryResponse::TPtr& ev, const TActorContext& ctx) {
+        LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "HandleGetTopicsResult");
+
         const auto& record = ev->Get()->Record.GetRef();
 
         Y_VERIFY(record.GetResponse().GetResults().size() == 1);
@@ -467,6 +471,7 @@ private:
     }
 
     void ProcessDescribeAllTopics(const TActorId& waiter, const TActorContext& ctx) {
+        LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "ProcessDescribeAllTopics");
         if (EverGotTopics && CurrentTopics.empty()) {
             LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "Describe all topics - send empty response");
             SendDescribeAllTopicsResponse(waiter, {}, ctx, true);
@@ -476,6 +481,8 @@ private:
             LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "Respond from cache");
             return SendDescribeAllTopicsResponse(waiter, CurrentTopicsFullConverters, ctx);
         }
+
+        LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "ProcessDescribeAllTopics SendSchemeCacheRequest");
         SendSchemeCacheRequest(
                 std::make_shared<TWaiter>(waiter, DbRoot, false, false, CurrentTopics, EWaiterType::DescribeAllTopics),
                 ctx
@@ -486,9 +493,11 @@ private:
     }
 
     void SendSchemeCacheRequest(std::shared_ptr<TWaiter> waiter, const TActorContext& ctx) {
+        LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "SendSchemeCacheRequest");
         if (waiter->Type == EWaiterType::DescribeAllTopics && !waiter->FirstRequestDone) {
             DescribeAllTopicsWaiters.push(waiter);
             if (HaveDescribeAllTopicsInflight) {
+                LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "SendSchemeCacheRequest returns due to HaveDescribeAllTopicsInflight");
                 return;
             } else {
                 HaveDescribeAllTopicsInflight = true;
@@ -500,10 +509,6 @@ private:
         auto inserted = DescribeTopicsWaiters.insert(std::make_pair(reqId, waiter)).second;
         Y_VERIFY(inserted);
 
-        LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "send request for "
-                            << (waiter->Type == EWaiterType::DescribeAllTopics ? " all " : "") << waiter->GetTopics().size()
-                            << " topics, got " << DescribeTopicsWaiters.size() << " requests infly");
-
         for (const auto& [path, database] : waiter->GetTopics()) {
             auto split = NKikimr::SplitPath(path);
             Y_VERIFY(!split.empty());
@@ -517,13 +522,14 @@ private:
             schemeCacheRequest->ResultSet.emplace_back(std::move(entry));
         }
 
+        LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "send request for " << (waiter->Type == EWaiterType::DescribeAllTopics ? " all " : "") << waiter->GetTopics().size() << " topics, got " << DescribeTopicsWaiters.size() << " requests infly");
+
         ctx.Send(SchemeCacheId, new TEvTxProxySchemeCache::TEvNavigateKeySet(schemeCacheRequest.release()));
     }
 
     void HandleSchemeCacheResponse(TEvTxProxySchemeCache::TEvNavigateKeySetResult::TPtr& ev, const TActorContext& ctx) {
         std::shared_ptr<TSchemeCacheNavigate> result(ev->Get()->Request.Release());
-        LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "Handle SchemeCache response"
-            << ": result# " << result->ToString(*AppData()->TypeRegistry));
+        LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "Handle SchemeCache response" << ": result# " << result->ToString(*AppData()->TypeRegistry));
         auto waiterIter = DescribeTopicsWaiters.find(result->Instant);
         Y_VERIFY(!waiterIter.IsEnd());
         auto waiter = waiterIter->second; //copy shared ptr