| 764 | } |
| 765 | |
| 766 | void WaitCompletion(ibv_wc* res) { |
| 767 | ibv_wc& wc = *res; |
| 768 | for (;;) { |
| 769 | int rv = CQ->Poll(&wc, 1); |
| 770 | if (rv > 0 && ProcessSendCompletion(wc)) { |
| 771 | break; |
| 772 | } |
| 773 | } |
| 774 | } |
| 775 | |
| 776 | bool TryWaitCompletion() override { |
| 777 | ibv_wc wc; |