Method UnloadTablet

src/tabletnode/remote_tabletnode.cc:263–294

}

void RemoteTabletNode::UnloadTablet(google::protobuf::RpcController* controller,
                                    const UnloadTabletRequest* request,
                                    UnloadTabletResponse* response,
                                    google::protobuf::Closure* done) {
  uint64_t id = request->sequence_id();
  response->set_sequence_id(id);
  LOG(INFO) << "accept RPC (UnloadTablet) id: " << id
            << ", src: " << tera::utils::GetRemoteAddress(controller);
  if (request->has_path()) {
    std::lock_guard<std::mutex> lock(tablets_ctrl_mutex_);
    const std::string& tablet_path = request->path();
    if (tablets_ctrl_status_.find(tablet_path) != tablets_ctrl_status_.end()) {
      ThreadPool::Task query_task = std::bind(&RemoteTabletNode::DoQueryTabletUnloadStatus, 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;
  }
  if (request->has_path()) {
    tablets_ctrl_status_[request->path()] = TabletCtrlStatus::kCtrlWaitUnload;
  }

  ThreadPool::Task callback =
      std::bind(&RemoteTabletNode::DoUnloadTablet, this, controller, request, response, done);
  ctrl_thread_pool_->AddTask(callback);
}

void RemoteTabletNode::ReadTablet(google::protobuf::RpcController* controller,
                                  const ReadTabletRequest* request, ReadTabletResponse* response,