| 935 | return req->PeerAddress; |
| 936 | } |
| 937 | void GetPendingDataSize(TRequesterPendingDataStats* res) override { |
| 938 | TIntrusivePtr<TStatsRequest> req = new TStatsRequest(TStatsRequest::PENDING_SIZE); |
| 939 | ExecStatsRequest(req); |
| 940 | *res = req->PendingDataSize; |
| 941 | } |
| 942 | bool HasRequest(const TGUID& reqId) override { |
| 943 | TIntrusivePtr<TStatsRequest> req = new TStatsRequest(TStatsRequest::HAS_IN_REQUEST); |
| 944 | req->RequestId = reqId; |