diff options
| author | babenko <babenko@yandex-team.com> | 2023-11-26 10:07:44 +0300 |
|---|---|---|
| committer | babenko <babenko@yandex-team.com> | 2023-11-26 10:35:45 +0300 |
| commit | b14839a0aced193eb62df77d69ff6e8d3f51e75d (patch) | |
| tree | 5e277e7b262a171501f601976998353cacd13fff | |
| parent | ef0f7daa4fdd7a8866514cdd37dafdb5ceaa9724 (diff) | |
| download | ydb-b14839a0aced193eb62df77d69ff6e8d3f51e75d.tar.gz | |
YT-20562: Fix trace context leak in TDynamicChannelPool
| -rw-r--r-- | yt/yt/core/rpc/dynamic_channel_pool.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/yt/yt/core/rpc/dynamic_channel_pool.cpp b/yt/yt/core/rpc/dynamic_channel_pool.cpp index 9c41efd1632..ee69f72da07 100644 --- a/yt/yt/core/rpc/dynamic_channel_pool.cpp +++ b/yt/yt/core/rpc/dynamic_channel_pool.cpp @@ -239,7 +239,7 @@ private: void Run() { YT_LOG_DEBUG("Starting peer discovery"); - TDispatcher::Get()->GetLightInvoker()->Invoke(BIND(&TDiscoverySession::DoRun, MakeStrong(this))); + TDispatcher::Get()->GetLightInvoker()->Invoke(BIND_NO_PROPAGATE(&TDiscoverySession::DoRun, MakeStrong(this))); } void OnPeerDiscovered(const TString& address) @@ -474,7 +474,7 @@ private: void Run() { YT_LOG_DEBUG("Starting peer poller"); - TDispatcher::Get()->GetLightInvoker()->Invoke(BIND(&TPeerPoller::DoRun, MakeStrong(this))); + TDispatcher::Get()->GetLightInvoker()->Invoke(BIND_NO_PROPAGATE(&TPeerPoller::DoRun, MakeStrong(this))); } void Stop() |