aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/unified_agent_client/grpc_io.cpp
diff options
context:
space:
mode:
authorilnurkh <ilnurkh@yandex-team.com>2023-10-09 23:39:40 +0300
committerilnurkh <ilnurkh@yandex-team.com>2023-10-09 23:57:14 +0300
commite601ca03f859335d57ecff2e5aa6af234b6052ed (patch)
treede519a847e58a1b3993fcbfe05ff44cc946a3e24 /library/cpp/unified_agent_client/grpc_io.cpp
parentbbf2b6878af3854815a2c0ecb07a687071787639 (diff)
downloadydb-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.cpp6
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();