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