Method CheckMaster

phxqueue/lock/lock.cpp:401–438

}

comm::RetCode Lock::CheckMaster(const int paxos_group_id, comm::proto::Addr &redirect_addr) {
    comm::RetCode ret;

    if (impl_->node->IsIMMaster(paxos_group_id))
        return comm::RetCode::RET_OK;

    auto &&node_info = impl_->node->GetMaster(paxos_group_id);
    if (node_info.GetIP().empty() || 0 == node_info.GetPort() || "0.0.0.0" == node_info.GetIP())
        return comm::RetCode::RET_ERR_NO_MASTER;

    const auto &topic_id(impl_->topic_id);

    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}; lock->addrs_size() > i; ++i) {
        auto &&tmp_addr(lock->addrs(i));
        if (tmp_addr.ip() == node_info.GetIP() && tmp_addr.paxos_port() == node_info.GetPort()) {
            redirect_addr = tmp_addr;

            return comm::RetCode::RET_ERR_NOT_MASTER;
        }
    }

    return comm::RetCode::RET_ERR_RANGE_ADDR;
}

// ret: RET_OK if acquired, others if not acquired
comm::RetCode Lock::PaxosAcquireLock(const comm::proto::AcquireLockRequest &req,