| 491 | } |
| 492 | |
| 493 | void RemoteTabletNode::Query(google::protobuf::RpcController* controller, |
| 494 | const QueryRequest* request, QueryResponse* response, |
| 495 | google::protobuf::Closure* done) { |
| 496 | uint64_t id = request->sequence_id(); |
| 497 | LOG(INFO) << "accept RPC (Query) id: " << id |
| 498 | << ", src: " << tera::utils::GetRemoteAddress(controller); |
| 499 | ThreadPool::Task callback = |
| 500 | std::bind(&RemoteTabletNode::DoQuery, this, controller, request, response, done); |
| 501 | lightweight_ctrl_thread_pool_->AddPriorityTask(callback); |
| 502 | } |
| 503 | |
| 504 | void RemoteTabletNode::CmdCtrl(google::protobuf::RpcController* controller, |
| 505 | const TsCmdCtrlRequest* request, TsCmdCtrlResponse* response, |
no test coverage detected