aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/interconnect/poller_actor_linux.h
diff options
context:
space:
mode:
authorilnurkh <ilnurkh@yandex-team.com>2023-10-17 08:15:44 +0300
committerilnurkh <ilnurkh@yandex-team.com>2023-10-17 09:00:07 +0300
commit784925324fd115c37bc98c5bbfe64c15f9966d74 (patch)
treef763f6eaacfcd4757d249977aaddfa4e9b2a355b /library/cpp/actors/interconnect/poller_actor_linux.h
parentd6c75d9ec33559b29eb61a8f2e17cbca30fd5ae2 (diff)
downloadydb-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.h12
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));
}
}
}