| 869 | } |
| 870 | |
| 871 | void SendResponseImpl(const TGUID& reqId, EPacketPriority prior, TVector<char>* data) // non-virtual, for direct call from TRequestOps |
| 872 | { |
| 873 | if (data && data->size() > MAX_PACKET_SIZE) { |
| 874 | Y_ABORT_UNLESS(0, "data size is too large"); |
| 875 | } |
| 876 | SendRespList.Enqueue(new TSendResponse(reqId, prior, data)); |
| 877 | Host->CancelWait(); |
| 878 | } |
| 879 | void SendResponse(const TGUID& reqId, TVector<char>* data) override { |
| 880 | SendResponseImpl(reqId, PP_NORMAL, data); |
| 881 | } |
no test coverage detected