| 320 | } |
| 321 | |
| 322 | void SendResponse(const TGUID& reqId, TVector<char>* data) override { |
| 323 | if (data && data->size() > MAX_PACKET_SIZE) { |
| 324 | Y_ABORT( |
| 325 | "data size is too large; data->size()=%" PRISZT ", MAX_PACKET_SIZE=%" PRISZT, |
| 326 | data->size(), MAX_PACKET_SIZE); |
| 327 | } |
| 328 | SendRespList_.Enqueue(new TSendResponse(reqId, PP_NORMAL, data)); |
| 329 | Host_->CancelWait(); |
| 330 | } |
| 331 | |
| 332 | void StopNoWait() override { |
| 333 | AbortTransactions_ = true; |
nothing calls this directly
no test coverage detected