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/netliba/v6/ib_cs.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/netliba/v6/ib_cs.cpp')
| -rw-r--r-- | library/cpp/netliba/v6/ib_cs.cpp | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/library/cpp/netliba/v6/ib_cs.cpp b/library/cpp/netliba/v6/ib_cs.cpp index 1b904e3358..93fc4ef67e 100644 --- a/library/cpp/netliba/v6/ib_cs.cpp +++ b/library/cpp/netliba/v6/ib_cs.cpp @@ -200,7 +200,7 @@ namespace NNetliba { return z; } } - Y_VERIFY(0, "no send by guid"); + Y_ABORT_UNLESS(0, "no send by guid"); return SendQueue.begin(); } TDeque<TQueuedSend>::iterator GetSend(TIBMsgHandle msgHandle) { @@ -209,7 +209,7 @@ namespace NNetliba { return z; } } - Y_VERIFY(0, "no send by handle"); + Y_ABORT_UNLESS(0, "no send by handle"); return SendQueue.begin(); } TDeque<TQueuedRecv>::iterator GetRecv(const TGUID& packetGuid) { @@ -218,7 +218,7 @@ namespace NNetliba { return z; } } - Y_VERIFY(0, "no recv by guid"); + Y_ABORT_UNLESS(0, "no recv by guid"); return RecvQueue.begin(); } void PostRDMA(TQueuedSend& qs) { @@ -354,7 +354,7 @@ namespace NNetliba { //printf("Remove peer %p from hash (QPN %d)\n", peer.Get(), peer->QP->GetQPN()); TPeerChannelHash::iterator z = Channels.find(peer->QP->GetQPN()); if (z == Channels.end()) { - Y_VERIFY(0, "peer failed for unregistered peer"); + Y_ABORT_UNLESS(0, "peer failed for unregistered peer"); } Channels.erase(z); } @@ -447,7 +447,7 @@ namespace NNetliba { TDeque<TQueuedRecv>::iterator z = peer->GetRecv(cmd.PacketGuid); TQueuedRecv& qr = *z; #ifdef _DEBUG - Y_VERIFY(MurmurHash<ui64>(qr.Data->GetData(), qr.Data->GetSize()) == cmd.DataHash || cmd.DataHash == 0, "RDMA data hash mismatch"); + Y_ABORT_UNLESS(MurmurHash<ui64>(qr.Data->GetData(), qr.Data->GetSize()) == cmd.DataHash || cmd.DataHash == 0, "RDMA data hash mismatch"); #endif TRequest* req = new TRequest; req->Address = peer->PeerAddress; @@ -525,12 +525,12 @@ namespace NNetliba { BP.FreeBuf(wc->wr_id); } } else { - Y_VERIFY(0, "got completion without outstanding messages"); + Y_ABORT_UNLESS(0, "got completion without outstanding messages"); } } else { //printf("Got completion for non existing qpn %d, bufId %d (status %d)\n", wc->qp_num, (int)wc->wr_id, (int)wc->status); if (wc->status == IBV_WC_SUCCESS) { - Y_VERIFY(0, "only errors should go unmatched"); + Y_ABORT_UNLESS(0, "only errors should go unmatched"); } // no need to free buf since it has to be freed in PeerFailed() } @@ -617,7 +617,7 @@ namespace NNetliba { // received msg if ((int)wc.qp_num == WelcomeQPN) { if (wc.status != IBV_WC_SUCCESS) { - Y_VERIFY(0, "ud recv op completed with error %d\n", (int)wc.status); + Y_ABORT_UNLESS(0, "ud recv op completed with error %d\n", (int)wc.status); } Y_ASSERT(wc.opcode == IBV_WC_RECV | IBV_WC_SEND); ParseWelcomePacket(&wc); @@ -645,7 +645,7 @@ namespace NNetliba { } TDeque<TQueuedSend>::iterator z = peer->GetSend(msgHandle); if (z == peer->SendQueue.end()) { - Y_VERIFY(0, "peer %p, copy completed, msg %d not found?\n", peer.Get(), (int)msgHandle); + Y_ABORT_UNLESS(0, "peer %p, copy completed, msg %d not found?\n", peer.Get(), (int)msgHandle); continue; } TQueuedSend& qs = *z; |