Method CheckMaster

phxqueue/store/store.cpp:397–438

comm::RetCode Store::CheckMaster(const int paxos_group_id, comm::proto::Addr &redirect_addr) {
    QLVerb("CheckMaster");

    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;

    auto &&topic_id(impl_->topic_id);

    shared_ptr<const config::StoreConfig> store_config;
    if (comm::RetCode::RET_OK !=
        (ret = config::GlobalConfig::GetThreadInstance()->
         GetStoreConfig(topic_id, store_config))) {
        QLErr("GetStoreConfigByPubID ret %d topic_id %d", as_integer(ret), topic_id);
        return ret;
    }

    shared_ptr<const config::proto::Store> store;
    if (comm::RetCode::RET_OK != (ret = store_config->GetStoreByAddr(impl_->addr, store))) {
        QLErr("GetStoreByAddr ret %d", as_integer(ret));
        return ret;
    }

    QLVerb("find master");
    for (size_t i{0}; i < store->addrs_size(); ++i) {
        auto &&tmp_addr = store->addrs(i);
        if (tmp_addr.ip() == node_info.GetIP() &&
            tmp_addr.paxos_port() == node_info.GetPort()) {
            redirect_addr.CopyFrom(tmp_addr);
            QLVerb("master found. redirect_addr(%s:%d)",
                   redirect_addr.ip().c_str(), redirect_addr.port());

            return comm::RetCode::RET_ERR_NOT_MASTER;
        }
    }
    return comm::RetCode::RET_ERR_RANGE_ADDR;
}


comm::RetCode Store::Add(const comm::proto::AddRequest &req, comm::proto::AddResponse &resp) {