Method UpdatePaxosArgs

phxqueue/lock/keepmasterthread.cpp:435–472

}

comm::RetCode KeepMasterThread::UpdatePaxosArgs() {
    const int topic_id{impl_->lock->GetTopicID()};

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

        return ret;
    }

    if (impl_->last_update_paxos_args_time == topic_config->GetLastModTime()) {
        return comm::RetCode::RET_OK;
    }

    auto opt(impl_->lock->GetLockOption());
    auto nr_group(opt->nr_group);

    auto node(impl_->lock->GetNode());

    node->SetTimeoutMs(topic_config->GetProto().topic().lock_paxos_propose_timeout_ms());
    node->SetHoldPaxosLogCount(topic_config->GetProto().topic().lock_paxos_nr_hold_log());
    for (int paxos_group_id{0}; paxos_group_id < nr_group; ++paxos_group_id) {
        node->SetMaxHoldThreads(paxos_group_id, topic_config->GetProto().topic().lock_paxos_max_hold_threads());
        node->SetMasterLease(paxos_group_id, topic_config->GetProto().topic().lock_paxos_master_lease());
        node->SetProposeWaitTimeThresholdMS(paxos_group_id, topic_config->GetProto().topic().lock_paxos_propose_wait_time_threshold_ms());
        node->SetLogSync(paxos_group_id, topic_config->GetProto().topic().lock_paxos_log_sync());
        //node->SetBatchCount(paxos_group_id, topic_config->GetProto().topic().lock_paxos_batch_count());
        node->SetBatchDelayTimeMs(paxos_group_id, topic_config->GetProto().topic().lock_paxos_batch_delay_time_ms());
    }

    impl_->last_update_paxos_args_time = topic_config->GetLastModTime();

    QLInfo("paxos args updated");

    return comm::RetCode::RET_OK;
}


}  // namespace lock