Method CreateAddReplicaRemoteTask

src/nameserver/name_server_impl.cc:7023–7049

}

std::shared_ptr<Task> NameServerImpl::CreateAddReplicaRemoteTask(const std::string& endpoint, uint64_t op_index,
                                                                 ::fedb::api::OPType op_type, uint32_t tid,
                                                                 uint32_t remote_tid, uint32_t pid,
                                                                 const std::string& des_endpoint, uint64_t task_id) {
    std::shared_ptr<Task> task = std::make_shared<Task>(endpoint, std::make_shared<::fedb::api::TaskInfo>());
    auto it = tablets_.find(endpoint);
    if (it == tablets_.end()) {
        PDLOG(WARNING, "provide endpoint [%s] not found", endpoint.c_str());
        return std::shared_ptr<Task>();
    }
    if (it->second->state_ != ::fedb::api::TabletState::kTabletHealthy) {
        PDLOG(WARNING, "provide endpoint [%s] is not healthy", endpoint.c_str());
        return std::shared_ptr<Task>();
    }
    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::kAddReplica);
    task->task_info_->set_status(::fedb::api::TaskStatus::kInited);
    task->task_info_->set_endpoint(endpoint);
    if (task_id != INVALID_PARENT_ID) {
        task->task_info_->set_task_id(task_id);
    }
    boost::function<bool()> fun = boost::bind(&TabletClient::AddReplica, it->second->client_, tid, pid, des_endpoint,
                                              remote_tid, task->task_info_);
    task->fun_ = boost::bind(&NameServerImpl::WrapTaskFun, this, fun, task->task_info_);
    return task;
}

std::shared_ptr<Task> NameServerImpl::CreateAddReplicaNSRemoteTask(const std::string& alias, const std::string& name,
                                                                   const std::vector<std::string>& endpoint_vec,