aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/network.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/messagebus/network.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/messagebus/network.cpp')
-rw-r--r--library/cpp/messagebus/network.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/library/cpp/messagebus/network.cpp b/library/cpp/messagebus/network.cpp
index 304bedae5ac..a4afafa94ee 100644
--- a/library/cpp/messagebus/network.cpp
+++ b/library/cpp/messagebus/network.cpp
@@ -11,7 +11,7 @@ using namespace NBus::NPrivate;
namespace {
TBindResult BindOnPortProto(int port, int af, bool reusePort) {
- Y_VERIFY(af == AF_INET || af == AF_INET6, "wrong af");
+ Y_ABORT_UNLESS(af == AF_INET || af == AF_INET6, "wrong af");
SOCKET fd = ::socket(af, SOCK_STREAM, 0);
if (fd == INVALID_SOCKET) {
@@ -82,7 +82,7 @@ namespace {
}
std::pair<unsigned, TVector<TBindResult>> AggregateBindResults(TBindResult&& r1, TBindResult&& r2) {
- Y_VERIFY(r1.Addr.GetPort() == r2.Addr.GetPort(), "internal");
+ Y_ABORT_UNLESS(r1.Addr.GetPort() == r2.Addr.GetPort(), "internal");
std::pair<unsigned, TVector<TBindResult>> r;
r.second.reserve(2);
@@ -138,7 +138,7 @@ ssize_t NBus::NPrivate::SocketSend(SOCKET s, TArrayRef<const char> data) {
#endif
ssize_t r = ::send(s, data.data(), data.size(), flags);
if (r < 0) {
- Y_VERIFY(LastSystemError() != EBADF, "bad fd");
+ Y_ABORT_UNLESS(LastSystemError() != EBADF, "bad fd");
}
return r;
}
@@ -150,7 +150,7 @@ ssize_t NBus::NPrivate::SocketRecv(SOCKET s, TArrayRef<char> buffer) {
#endif
ssize_t r = ::recv(s, buffer.data(), buffer.size(), flags);
if (r < 0) {
- Y_VERIFY(LastSystemError() != EBADF, "bad fd");
+ Y_ABORT_UNLESS(LastSystemError() != EBADF, "bad fd");
}
return r;
}