diff options
author | ilnurkh <ilnurkh@yandex-team.com> | 2023-10-17 08:15:44 +0300 |
---|---|---|
committer | ilnurkh <ilnurkh@yandex-team.com> | 2023-10-17 09:00:07 +0300 |
commit | 784925324fd115c37bc98c5bbfe64c15f9966d74 (patch) | |
tree | f763f6eaacfcd4757d249977aaddfa4e9b2a355b /library/cpp/actors/interconnect/poller_actor_linux.h | |
parent | d6c75d9ec33559b29eb61a8f2e17cbca30fd5ae2 (diff) | |
download | ydb-784925324fd115c37bc98c5bbfe64c15f9966d74.tar.gz |
Y_FAIL->Y_ABORT at '^li'
https://clubs.at.yandex-team.ru/arcadia/29404
Diffstat (limited to 'library/cpp/actors/interconnect/poller_actor_linux.h')
-rw-r--r-- | library/cpp/actors/interconnect/poller_actor_linux.h | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/library/cpp/actors/interconnect/poller_actor_linux.h b/library/cpp/actors/interconnect/poller_actor_linux.h index f19f53f730..8831d2062b 100644 --- a/library/cpp/actors/interconnect/poller_actor_linux.h +++ b/library/cpp/actors/interconnect/poller_actor_linux.h @@ -19,7 +19,7 @@ namespace NActors { event.data.ptr = nullptr; event.events = EPOLLIN; if (epoll_ctl(EpollDescriptor, EPOLL_CTL_ADD, ReadEnd, &event) == -1) { - Y_FAIL("epoll_ctl(EPOLL_CTL_ADD) failed with %s", strerror(errno)); + Y_ABORT("epoll_ctl(EPOLL_CTL_ADD) failed with %s", strerror(errno)); } ISimpleThread::Start(); // start poller thread @@ -44,7 +44,7 @@ namespace NActors { if (errno == EINTR) { return false; // restart the call a bit later } else { - Y_FAIL("epoll_wait() failed with %s", strerror(errno)); + Y_ABORT("epoll_wait() failed with %s", strerror(errno)); } } @@ -69,7 +69,7 @@ namespace NActors { event.events = EPOLLONESHOT | EPOLLRDHUP | flags; event.data.ptr = record; if (epoll_ctl(EpollDescriptor, EPOLL_CTL_MOD, record->Socket->GetDescriptor(), &event) == -1) { - Y_FAIL("epoll_ctl(EPOLL_CTL_MOD) failed with %s", strerror(errno)); + Y_ABORT("epoll_ctl(EPOLL_CTL_MOD) failed with %s", strerror(errno)); } } @@ -85,7 +85,7 @@ namespace NActors { void UnregisterSocketInLoop(const TIntrusivePtr<TSharedDescriptor>& socket) { if (epoll_ctl(EpollDescriptor, EPOLL_CTL_DEL, socket->GetDescriptor(), nullptr) == -1) { - Y_FAIL("epoll_ctl(EPOLL_CTL_DEL) failed with %s", strerror(errno)); + Y_ABORT("epoll_ctl(EPOLL_CTL_DEL) failed with %s", strerror(errno)); } } @@ -94,7 +94,7 @@ namespace NActors { event.events = EPOLLONESHOT | EPOLLRDHUP; event.data.ptr = record.Get(); if (epoll_ctl(EpollDescriptor, EPOLL_CTL_ADD, record->Socket->GetDescriptor(), &event) == -1) { - Y_FAIL("epoll_ctl(EPOLL_CTL_ADD) failed with %s", strerror(errno)); + Y_ABORT("epoll_ctl(EPOLL_CTL_ADD) failed with %s", strerror(errno)); } } @@ -109,7 +109,7 @@ namespace NActors { event.events = EPOLLONESHOT | EPOLLRDHUP | flags; event.data.ptr = record.Get(); if (epoll_ctl(EpollDescriptor, EPOLL_CTL_MOD, record->Socket->GetDescriptor(), &event) == -1) { - Y_FAIL("epoll_ctl(EPOLL_CTL_MOD) failed with %s", strerror(errno)); + Y_ABORT("epoll_ctl(EPOLL_CTL_MOD) failed with %s", strerror(errno)); } } } |