| 502 | } |
| 503 | |
| 504 | void RemoteTabletNode::CmdCtrl(google::protobuf::RpcController* controller, |
| 505 | const TsCmdCtrlRequest* request, TsCmdCtrlResponse* response, |
| 506 | google::protobuf::Closure* done) { |
| 507 | uint64_t id = request->sequence_id(); |
| 508 | LOG(INFO) << "accept RPC (CmdCtrl) id: " << id << ", [" << request->command() |
| 509 | << "] src: " << tera::utils::GetRemoteAddress(controller); |
| 510 | ThreadPool::Task callback = |
| 511 | std::bind(&RemoteTabletNode::DoCmdCtrl, this, controller, request, response, done); |
| 512 | lightweight_ctrl_thread_pool_->AddPriorityTask(callback); |
| 513 | } |
| 514 | |
| 515 | void RemoteTabletNode::ComputeSplitKey(google::protobuf::RpcController* controller, |
| 516 | const SplitTabletRequest* request, |
no test coverage detected