Method InitMasterRate

phxqueue/store/keepmasterthread.cpp:105–135

}

void KeepMasterThread::InitMasterRate() {
    comm::RetCode ret;

    const int topic_id{impl_->store->GetTopicID()};

    impl_->master_rate = 0;

    auto opt(impl_->store->GetStoreOption());

    phxpaxos::Node *node{impl_->store->GetNode()};

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

    for (int paxos_group_id{0}; paxos_group_id < opt->ngroup; ++paxos_group_id) {
        if (node->IsIMMaster(paxos_group_id)) {
            impl_->master_rate = paxos_group_id * 100 / opt->ngroup + (paxos_group_id * 100 % opt->ngroup ? 1 : 0);
        }
    }

    if (impl_->master_rate < topic_config->GetProto().topic().store_adjust_min_master_rate()) {
        impl_->master_rate = topic_config->GetProto().topic().store_adjust_min_master_rate();
    } else if (impl_->master_rate > topic_config->GetProto().topic().store_adjust_max_master_rate()) {
        impl_->master_rate = topic_config->GetProto().topic().store_adjust_max_master_rate();
    }
}

void KeepMasterThread::AdjustMasterRate() {
    comm::RetCode ret;