| 704 | } |
| 705 | |
| 706 | void RemoteTabletNode::DoQuery(google::protobuf::RpcController* controller, |
| 707 | const QueryRequest* request, QueryResponse* response, |
| 708 | google::protobuf::Closure* done) { |
| 709 | uint64_t id = request->sequence_id(); |
| 710 | int64_t start_micros = get_micros(); |
| 711 | LOG(INFO) << "run RPC (Query) id: " << id; |
| 712 | access_entry_->GetAccessUpdater().UpdateTs(request, response); |
| 713 | |
| 714 | // Reset Quota iif version dismatch |
| 715 | quota_entry_->Update(request, response); |
| 716 | |
| 717 | tabletnode_impl_->Query(request, response, done); |
| 718 | |
| 719 | LOG(INFO) << "finish RPC (Query) id: " << id << ", cost " << (get_micros() - start_micros) / 1000 |
| 720 | << "ms."; |
| 721 | } |
| 722 | |
| 723 | void RemoteTabletNode::DoCmdCtrl(google::protobuf::RpcController* controller, |
| 724 | const TsCmdCtrlRequest* request, TsCmdCtrlResponse* response, |
nothing calls this directly
no test coverage detected