| 261 | } |
| 262 | |
| 263 | void SendResponse(const TGUID& reqId, TVector<char>* data) override { |
| 264 | CHROMIUM_TRACE_FUNCTION(); |
| 265 | TNetworkAddress addr; |
| 266 | if (!IncomingRequestsInfo.ExtractValueIfPresent(reqId, addr)) { |
| 267 | PAR_DEBUG_LOG << "At " << GetHostAndPort() << " reply to " << addr.GetNehAddr() << " already sent or cancelled" << Endl; |
| 268 | return; |
| 269 | } |
| 270 | |
| 271 | PAR_DEBUG_LOG << "From " << GetHostAndPort() << " sending reply for " << GetGuidAsString(reqId) << " data len: " << (data ? data->size() : 0) << Endl; |
| 272 | InternalSendQuery(addr, reqId, "_reply_", data); |
| 273 | } |
| 274 | |
| 275 | TAutoPtr<TNetworkResponse> Request(const TNetworkAddress& address, const TString& url, TVector<char>* data) override { |
| 276 | CHROMIUM_TRACE_FUNCTION(); |
no test coverage detected