YT-22977: Add indirection to OnReplyBusTerminated to avoid recursive spinlock acquisition

commit_hash:4ea49eeeccf565166e2e386bbef7e53c970ec425

1 files changed, 6 insertions, 4 deletions

diff --git a/yt/yt/core/rpc/service_detail.cpp b/yt/yt/core/rpc/service_detail.cpp
index d23ef9ba4c..9fcf0d7d8f 100644
--- a/yt/yt/core/rpc/service_detail.cpp
+++ b/yt/yt/core/rpc/service_detail.cpp
@@ -2183,10 +2183,12 @@ void TServiceBase::RegisterRequest(TServiceContext* context)
         auto& replyBusData = it->second;
         replyBusData.Contexts.insert(context);
         if (inserted) {
-            replyBusData.BusTerminationHandler = BIND_NO_PROPAGATE(
-                &TServiceBase::OnReplyBusTerminated,
-                MakeWeak(this),
-                MakeWeak(replyBus.Get()));
+            replyBusData.BusTerminationHandler =
+                BIND_NO_PROPAGATE(
+                    &TServiceBase::OnReplyBusTerminated,
+                    MakeWeak(this),
+                    MakeWeak(replyBus))
+                .Via(TDispatcher::Get()->GetHeavyInvoker());
             replyBus->SubscribeTerminated(replyBusData.BusTerminationHandler);
         }
     }