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

Function WaitForRecv

library/cpp/netliba/v6/ib_test.cpp:80–89  ·  view source on GitHub ↗

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

Source from the content-addressed store, hash-verified

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

Callers 1

RunIBTestFunction · 0.70

Calls 2

PollMethod · 0.45
FreeBufMethod · 0.45

Tested by

no test coverage detected