Method AdjustMasterRate

phxqueue/store/keepmasterthread.cpp:137–151

}

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

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

    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;
    }

    impl_->master_rate = topic_config->GetProto().topic().store_adjust_max_master_rate();
}

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