| 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(); |
no test coverage detected