Method LoadTablet

src/tabletnode/remote_tabletnode.cc:236–261

RemoteTabletNode::~RemoteTabletNode() {}

void RemoteTabletNode::LoadTablet(google::protobuf::RpcController* controller,
                                  const LoadTabletRequest* request, LoadTabletResponse* response,
                                  google::protobuf::Closure* done) {
  uint64_t id = request->sequence_id();
  response->set_sequence_id(id);
  LOG(INFO) << "accept RPC (LoadTablet) id: " << id
            << ", src: " << tera::utils::GetRemoteAddress(controller);
  const std::string& tablet_path = request->path();
  std::lock_guard<std::mutex> lock(tablets_ctrl_mutex_);
  if (tablets_ctrl_status_.find(tablet_path) != tablets_ctrl_status_.end()) {
    ThreadPool::Task query_task = std::bind(&RemoteTabletNode::DoQueryTabletLoadStatus, this,
                                            controller, request, response, done);
    lightweight_ctrl_thread_pool_->AddTask(query_task);
    return;
  }
  if (ctrl_thread_pool_->PendingNum() > FLAGS_tera_tabletnode_ctrl_thread_num) {
    response->set_status(kTabletNodeIsBusy);
    done->Run();
    return;
  }

  tablets_ctrl_status_[tablet_path] = TabletCtrlStatus::kCtrlWaitLoad;
  ThreadPool::Task callback =
      std::bind(&RemoteTabletNode::DoLoadTablet, this, controller, request, response, done);
  ctrl_thread_pool_->AddTask(callback);
}

void RemoteTabletNode::UnloadTablet(google::protobuf::RpcController* controller,
                                    const UnloadTabletRequest* request,