Method CreateAddIndexToTabletTask

src/nameserver/name_server_impl.cc:9565–9595

}

std::shared_ptr<Task> NameServerImpl::CreateAddIndexToTabletTask(uint64_t op_index, ::fedb::api::OPType op_type,
                                                                 uint32_t tid, uint32_t pid,
                                                                 const std::vector<std::string>& endpoints,
                                                                 const ::fedb::common::ColumnKey& column_key) {
    std::shared_ptr<Task> task = std::make_shared<Task>("", std::make_shared<::fedb::api::TaskInfo>());
    for (const auto& endpoint : endpoints) {
        std::shared_ptr<TabletInfo> tablet = GetHealthTabletInfoNoLock(endpoint);
        if (!tablet) {
            return std::shared_ptr<Task>();
        }
        std::shared_ptr<Task> sub_task = std::make_shared<Task>(endpoint, std::make_shared<::fedb::api::TaskInfo>());
        sub_task->task_info_->set_op_id(op_index);
        sub_task->task_info_->set_op_type(op_type);
        sub_task->task_info_->set_task_type(::fedb::api::TaskType::kAddIndexToTablet);
        sub_task->task_info_->set_status(::fedb::api::TaskStatus::kInited);
        boost::function<bool()> fun =
            boost::bind(&TabletClient::AddIndex, tablet->client_, tid, pid, column_key, sub_task->task_info_);
        sub_task->fun_ = boost::bind(&NameServerImpl::WrapTaskFun, this, fun, sub_task->task_info_);
        task->sub_task_.push_back(sub_task);
        PDLOG(INFO,
              "add subtask AddIndexToTablet. op_id[%lu] tid[%u] pid[%u] "
              "endpoint[%s]",
              op_index, tid, pid, endpoint.c_str());
    }
    task->task_info_->set_op_id(op_index);
    task->task_info_->set_op_type(op_type);
    task->task_info_->set_task_type(::fedb::api::TaskType::kAddIndexToTablet);
    task->task_info_->set_status(::fedb::api::TaskStatus::kInited);
    task->fun_ = boost::bind(&NameServerImpl::RunSubTask, this, task);
    return task;
}

void NameServerImpl::CreateDatabase(RpcController* controller, const CreateDatabaseRequest* request,
                                    GeneralResponse* response, Closure* done) {