Method CreateTableRemoteTask

src/nameserver/name_server_impl.cc:6549–6611

}

int NameServerImpl::CreateTableRemoteTask(std::shared_ptr<OPData> op_data) {
    CreateTableData create_table_data;
    if (!create_table_data.ParseFromString(op_data->op_info_.data())) {
        PDLOG(WARNING, "parse create_table_data failed. data[%s]", op_data->op_info_.data().c_str());
        return -1;
    }
    std::string alias = create_table_data.alias();
    ::fedb::nameserver::TableInfo remote_table_info = create_table_data.remote_table_info();
    uint64_t op_index = op_data->op_info_.op_id();
    std::shared_ptr<Task> task =
        CreateTableRemoteTask(remote_table_info, alias, op_index, ::fedb::api::OPType::kCreateTableRemoteOP);
    if (!task) {
        PDLOG(WARNING, "create CreateTableRemote task failed. table[%s] pid[%u]", remote_table_info.name().c_str(),
              op_data->op_info_.pid());
        return -1;
    }
    op_data->task_list_.push_back(task);

    ::fedb::nameserver::TableInfo table_info = create_table_data.table_info();
    uint32_t tid = table_info.tid();
    uint32_t remote_tid = remote_table_info.tid();
    std::string name = table_info.name();
    std::string db = table_info.db();
    for (int idx = 0; idx < remote_table_info.table_partition_size(); idx++) {
        const ::fedb::nameserver::TablePartition& table_partition = remote_table_info.table_partition(idx);
        uint32_t pid = table_partition.pid();
        for (int meta_idx = 0; meta_idx < table_partition.partition_meta_size(); meta_idx++) {
            if (table_partition.partition_meta(meta_idx).is_leader()) {
                const ::fedb::nameserver::PartitionMeta& partition_meta = table_partition.partition_meta(meta_idx);
                const std::string& endpoint = partition_meta.endpoint();
                std::string leader_endpoint;
                std::shared_ptr<::fedb::nameserver::TableInfo> table_info_tmp =
                    std::make_shared<::fedb::nameserver::TableInfo>(table_info);
                if (GetLeader(table_info_tmp, pid, leader_endpoint) < 0 || leader_endpoint.empty()) {
                    PDLOG(WARNING, "get leader failed. table[%s] pid[%u]", name.c_str(), pid);
                    return -1;
                }
                task = CreateAddReplicaRemoteTask(leader_endpoint, op_index, ::fedb::api::OPType::kCreateTableRemoteOP,
                                                  tid, remote_tid, pid, endpoint, idx);
                if (!task) {
                    PDLOG(WARNING,
                          "create addreplica task failed. leader cluster "
                          "tid[%u] replica cluster tid[%u] pid[%u]",
                          tid, remote_tid, pid);
                    return -1;
                }
                op_data->task_list_.push_back(task);
                task = CreateAddTableInfoTask(alias, endpoint, name, db, remote_tid, pid, op_index,
                                              ::fedb::api::OPType::kCreateTableRemoteOP);
                if (!task) {
                    PDLOG(WARNING, "create addtableinfo task failed. tid[%u] pid[%u]", tid, pid);
                    return -1;
                }
                op_data->task_list_.push_back(task);
                break;
            }
        }
    }