diff options
| author | robot-piglet <robot-piglet@yandex-team.com> | 2023-11-16 00:46:14 +0300 |
|---|---|---|
| committer | robot-piglet <robot-piglet@yandex-team.com> | 2023-11-16 01:04:38 +0300 |
| commit | f619a79974c2b2bd91fcf96ed31058362f0230f6 (patch) | |
| tree | ae94747312a8b2fc1a0ccc37454c40d68cbc32b6 | |
| parent | 401253f291059c8eb079c95e469cc73af2dc2af5 (diff) | |
| download | ydb-f619a79974c2b2bd91fcf96ed31058362f0230f6.tar.gz | |
Intermediate changes
| -rw-r--r-- | yt/yt/core/rpc/grpc/helpers.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/yt/yt/core/rpc/grpc/helpers.cpp b/yt/yt/core/rpc/grpc/helpers.cpp index e5b2b3db777..20b163e30ac 100644 --- a/yt/yt/core/rpc/grpc/helpers.cpp +++ b/yt/yt/core/rpc/grpc/helpers.cpp @@ -559,7 +559,7 @@ void TGuardedGrpcCompletionQueue::Shutdown() return; } State_ = EState::Shutdown; - if (LocksCount_ != 0) { + if (LocksCount_.load() != 0) { guard.Release(); ReleaseDone_.Wait(); } @@ -582,7 +582,7 @@ grpc_completion_queue* TGuardedGrpcCompletionQueue::UnwrapUnsafe() void TGuardedGrpcCompletionQueue::Release() { auto guard = ReaderGuard(SpinLock_); - if (LocksCount_.fetch_sub(1, std::memory_order::release) == 0 && State_ == EState::Shutdown) { + if (LocksCount_.fetch_sub(1, std::memory_order::release) == 1 && State_ == EState::Shutdown) { guard.Release(); ReleaseDone_.NotifyOne(); } |