MCPcopy Create free account
hub / github.com/catboost/catboost / SendResponse

Method SendResponse

library/cpp/par/par_network.cpp:263–273  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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();

Callers 3

SendResponseMethod · 0.45
SendReplyMethod · 0.45
MetaThreadFunctionMethod · 0.45

Calls 4

GetHostAndPortFunction · 0.85
GetGuidAsStringFunction · 0.85
ExtractValueIfPresentMethod · 0.80
sizeMethod · 0.45

Tested by

no test coverage detected