| 110 | } |
| 111 | |
| 112 | void TRemoteQueryProcessor::CancelQuery(const TGUID& reqId) { |
| 113 | CHROMIUM_TRACE_FUNCTION(); |
| 114 | PAR_DEBUG_LOG << "At " << Requester->GetHostAndPort() << " cancel query: " << GetGuidAsString(reqId) << Endl; |
| 115 | Requester->CancelRequest(reqId); |
| 116 | } |
| 117 | |
| 118 | void TRemoteQueryProcessor::RegisterCmdType(const char* sz, ICmdProcessor* p) { |
| 119 | Y_ASSERT(Requester.Get() == nullptr && "function is not thread safe, should be called before RunThread()"); |
no test coverage detected