Method PaxosInit

phxqueue/lock/lock.cpp:312–399

}

comm::RetCode Lock::PaxosInit(const string &mirror_dir_path) {
    comm::RetCode ret{comm::RetCode::RET_ERR_UNINIT};

    phxpaxos::Options opts;

    // 1. set members

    const auto &topic_id(impl_->topic_id);

    shared_ptr<const config::TopicConfig> topic_config;
    if (comm::RetCode::RET_OK != (ret = config::GlobalConfig::GetThreadInstance()->
                                  GetTopicConfigByTopicID(topic_id, topic_config))) {
        QLErr("GetTopicConfig ret %d topic_id %d", as_integer(ret), topic_id);

        return ret;
    }

    shared_ptr<const config::LockConfig> lock_config;
    if (comm::RetCode::RET_OK != (ret = config::GlobalConfig::GetThreadInstance()->
                                  GetLockConfig(topic_id, lock_config))) {
        QLErr("GetLockConfig ret %d topic_id %d", as_integer(ret), topic_id);

        return ret;
    }

    shared_ptr<const config::proto::Lock> lock;
    if (comm::RetCode::RET_OK != (ret = lock_config->GetLockByAddr(impl_->addr, lock))) {
        QLErr("GetLockByAddr ret %d", as_integer(ret));

        return ret;
    }

    for (size_t i{0}; i < lock->addrs_size(); ++i) {
        auto &&addr(lock->addrs(i));
        opts.vecNodeInfoList.emplace_back(addr.ip(), addr.paxos_port());
    }


    // 2. set nr_group
    opts.iGroupCount = impl_->opt.nr_group;
    for (int i{0}; i < opts.iGroupCount; ++i) {
        phxpaxos::GroupSMInfo sm_info;
        sm_info.iGroupIdx = i;
        unique_ptr<LockSM> sm(new LockSM(this, mirror_dir_path));
        sm_info.vecSMList.push_back(sm.get());
        sm_info.bIsUseMaster = true;
        opts.vecGroupSMInfoList.push_back(sm_info);

        impl_->sms.push_back(move(sm));
    }


    // 3.0. init data path
    auto nodedb_dir_path(impl_->opt.data_dir_path + "/nodedb/");
    if (!comm::utils::CreateDir(nodedb_dir_path)) {
        QLErr("nodedb_dir_path %s not exist", nodedb_dir_path.c_str());
        return comm::RetCode::RET_DIR_NOT_EXIST;
    }