| 261 | return SRQ; |
| 262 | } |
| 263 | void PostReceive(TPtrArg<TMemoryRegion> mem, ui64 id, const void* buf, size_t len) { |
| 264 | Y_ASSERT(mem->IsCovered(buf, len)); |
| 265 | ibv_recv_wr wr, *bad; |
| 266 | ibv_sge sg; |
| 267 | sg.addr = reinterpret_cast<ui64>(buf) / sizeof(char); |
| 268 | sg.length = len; |
| 269 | sg.lkey = mem->GetLKey(); |
| 270 | Zero(wr); |
| 271 | wr.wr_id = id; |
| 272 | wr.sg_list = &sg; |
| 273 | wr.num_sge = 1; |
| 274 | CHECK_Z(ibv_post_srq_recv(SRQ, &wr, &bad)); |
| 275 | } |
| 276 | }; |
| 277 | |
| 278 | inline void MakeAH(ibv_ah_attr* res, TPtrArg<TIBPort> port, int lid, int serviceLevel) { |