Method DoRun

phxqueue/lock/keepmasterthread.cpp:77–115

}

void KeepMasterThread::DoRun() {
    if (nullptr == impl_->lock || nullptr == impl_->lock->GetNode()) {
        QLErr("lock %p", impl_->lock);

        return;
    }

    comm::RetCode ret{InitMasterRate()};
    if (comm::RetCode::RET_OK != ret) {
        QLErr("InitMasterRate ret %d", ret);

        exit(-1);
    }

    const int topic_id{impl_->lock->GetTopicID()};
    shared_ptr<const config::TopicConfig> topic_config;
    ret = config::GlobalConfig::GetThreadInstance()->GetTopicConfigByTopicID(topic_id, topic_config);
    if (comm::RetCode::RET_OK != ret) {
        QLErr("ERR: GetTopicConfigByTopicID ret %d topic_id %d", ret, topic_id);
        exit(-1);
    }

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

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

        if (comm::RetCode::RET_OK != (ret = UpdatePaxosArgs())) {
            QLErr("UpdatePaxosArgs ret %d", ret);
        }

        if (comm::RetCode::RET_OK != (ret = AdjustMasterRate())) {
            QLErr("AdjustMasterRate ret %d", ret);
        }
        if (comm::RetCode::RET_OK != (ret = KeepMaster())) {
            QLErr("KeepMaster ret %d", ret);
        }
    }
}

comm::RetCode KeepMasterThread::InitMasterRate() {
    impl_->master_rate = 100;