MCPcopy Create free account
hub / github.com/catboost/catboost / WaitForRecv

Function WaitForRecv

library/cpp/netliba/v12/ib_test.cpp:84–93  ·  view source on GitHub ↗

can hang if opposite side exits, but it's only basic test

Source from the content-addressed store, hash-verified

82
83 // can hang if opposite side exits, but it's only basic test
84 static void WaitForRecv(TIBBufferPool* bp, TPtrArg<TComplectionQueue> cq, ibv_wc* wc) {
85 for (;;) {
86 if (cq->Poll(wc, 1) == 1) {
87 if (wc->opcode & IBV_WC_RECV) {
88 break;
89 }
90 bp->FreeBuf(wc->wr_id);
91 }
92 }
93 }
94
95 void RunIBTest(bool isClient, const char* serverName) {
96 TIntrusivePtr<TIBPort> port = GetIBDevice();

Callers 1

RunIBTestFunction · 0.70

Calls 2

PollMethod · 0.45
FreeBufMethod · 0.45

Tested by

no test coverage detected