diff options
author | ilnurkh <ilnurkh@yandex-team.com> | 2023-10-09 23:39:40 +0300 |
---|---|---|
committer | ilnurkh <ilnurkh@yandex-team.com> | 2023-10-09 23:57:14 +0300 |
commit | e601ca03f859335d57ecff2e5aa6af234b6052ed (patch) | |
tree | de519a847e58a1b3993fcbfe05ff44cc946a3e24 /library/cpp/unified_agent_client/grpc_io.cpp | |
parent | bbf2b6878af3854815a2c0ecb07a687071787639 (diff) | |
download | ydb-e601ca03f859335d57ecff2e5aa6af234b6052ed.tar.gz |
Y_VERIFY->Y_ABORT_UNLESS at ^l
https://clubs.at.yandex-team.ru/arcadia/29404
Diffstat (limited to 'library/cpp/unified_agent_client/grpc_io.cpp')
-rw-r--r-- | library/cpp/unified_agent_client/grpc_io.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/library/cpp/unified_agent_client/grpc_io.cpp b/library/cpp/unified_agent_client/grpc_io.cpp index b59cfb674a..569e04dde8 100644 --- a/library/cpp/unified_agent_client/grpc_io.cpp +++ b/library/cpp/unified_agent_client/grpc_io.cpp @@ -36,10 +36,10 @@ namespace NUnifiedAgent { grpc_core::ApplicationCallbackExecCtx callbackExecCtx; grpc_core::ExecCtx execCtx; IOCallback->Ref(); - Y_VERIFY(grpc_cq_begin_op(CompletionQueue.cq(), this)); + Y_ABORT_UNLESS(grpc_cq_begin_op(CompletionQueue.cq(), this)); grpc_cq_end_op(CompletionQueue.cq(), this, y_absl::OkStatus(), [](void* self, grpc_cq_completion*) { - Y_VERIFY(static_cast<TGrpcNotification*>(self)->InQueue.exchange(false)); + Y_ABORT_UNLESS(static_cast<TGrpcNotification*>(self)->InQueue.exchange(false)); }, this, Completion.Get()); } @@ -81,7 +81,7 @@ namespace NUnifiedAgent { } void TGrpcTimer::OnIOCompleted(EIOStatus status) { - Y_VERIFY(AlarmIsSet); + Y_ABORT_UNLESS(AlarmIsSet); if (NextTriggerTime) { Alarm.Set(&CompletionQueue, InstantToTimespec(*NextTriggerTime), this); NextTriggerTime.Clear(); |