| 1022 | } |
| 1023 | } |
| 1024 | void ExecStatsRequest(TIntrusivePtr<TStatsRequest> req) { |
| 1025 | StatsReqList.Enqueue(req); |
| 1026 | Host->CancelWait(); |
| 1027 | req->Complete.Wait(); |
| 1028 | } |
| 1029 | TUdpAddress GetPeerAddress(const TGUID& reqId) override { |
| 1030 | TIntrusivePtr<TStatsRequest> req = new TStatsRequest(TStatsRequest::GET_PEER_ADDRESS); |
| 1031 | req->RequestId = reqId; |
nothing calls this directly
no test coverage detected