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

Method SendReply

library/cpp/par/par_remote.cpp:123–131  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

121 }
122
123 void TRemoteQueryProcessor::SendReply(const TGUID& reqId, TVector<char>* response) {
124 CHROMIUM_TRACE_FUNCTION();
125 static TTiming& queryExecutionTiming = TParHostStats::GetTiming(ETimingTag::QueryExecutionTime);
126 TIntrusivePtr<TQueryResultDst> queryResultDst;
127 if (IncomingRequestsData.ExtractValueIfPresent(reqId, queryResultDst)) {
128 queryExecutionTiming += (TInstant::Now() - queryResultDst->QueryCreationTime).SecondsFloat();
129 Requester->SendResponse(reqId, response);
130 }
131 }
132
133 void TRemoteQueryProcessor::RegisterCallback(const TGUID& reqId, IRemoteQueryCancelNotify* notify) {
134 CHROMIUM_TRACE_FUNCTION();

Callers 7

NewRequestMethod · 0.45
NewRequestMethod · 0.45
LocalExecMethod · 0.45
GotResponseMethod · 0.45
NewRequestMethod · 0.45
MRCommandCompleteMethod · 0.45

Calls 4

ExtractValueIfPresentMethod · 0.80
SecondsFloatMethod · 0.80
NowFunction · 0.50
SendResponseMethod · 0.45

Tested by

no test coverage detected