| 213 | return SendQueue.begin(); |
| 214 | } |
| 215 | TDeque<TQueuedRecv>::iterator GetRecv(const TGUID& packetGuid) { |
| 216 | for (TDeque<TQueuedRecv>::iterator z = RecvQueue.begin(); z != RecvQueue.end(); ++z) { |
| 217 | if (z->PacketGuid == packetGuid) { |
| 218 | return z; |
| 219 | } |
| 220 | } |
| 221 | Y_ABORT_UNLESS(0, "no recv by guid"); |
| 222 | return RecvQueue.begin(); |
| 223 | } |
| 224 | void PostRDMA(TQueuedSend& qs) { |
| 225 | Y_ASSERT(qs.RemoteAddr != 0 && qs.MemBlock.Get() != nullptr); |
| 226 | QP->PostRDMAWrite(qs.RemoteAddr, qs.RemoteKey, |
no test coverage detected