Method DoRun

phxqueue/store/keepmasterthread.cpp:77–103

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

    const int topic_id = impl_->store->GetTopicID();

    InitMasterRate();

    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);
        exit(-1);
    }

    while (true) {
        if (impl_->stop) return;

        sleep(topic_config->GetProto().topic().store_adjust_master_rate_time_interval_s());

        UpdatePaxosArgs();

        AdjustMasterRate();

        KeepMaster();
    }
}

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