| 966 | } |
| 967 | |
| 968 | void SendResponseImpl(const TGUID& reqId, EPacketPriority prior, TVector<char>* data, const TColors& colors) // non-virtual, for direct call from TRequestOps |
| 969 | { |
| 970 | if (data && data->size() > MAX_PACKET_SIZE) { |
| 971 | Y_ABORT_UNLESS(0, "data size is too large"); |
| 972 | } |
| 973 | SendRespList.Enqueue(new TSendResponse(reqId, prior, data, colors)); |
| 974 | Host->CancelWait(); |
| 975 | } |
| 976 | void SendResponse(const TGUID& reqId, TVector<char>* data, const TColors& colors) override { |
| 977 | SendResponseImpl(reqId, colors.GetPriority(), data, colors); |
| 978 | } |
no test coverage detected