Method MakeCheckPoint

phxqueue/store/keepsyncthread.cpp:124–254

void KeepSyncThread::MakeCheckPoint() {
    QLVerb("KeepSyncThread::MakeCheckPoint");

    comm::RetCode ret;

    phxpaxos::Node *node = impl_->store->GetNode();
    SyncCtrl *sync = impl_->store->GetSyncCtrl();

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

    const int topic_id = impl_->store->GetTopicID();
    const int ngroup = opt->ngroup;
    const int nqueue = opt->nqueue;
    const int nsub = opt->nsub;

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

    int store_make_cp_interval_s = topic_config->GetProto().topic().store_make_cp_interval_s();
    if (!store_make_cp_interval_s) store_make_cp_interval_s = 1;


    comm::proto::Addr addr;
    addr.set_ip(opt->ip);
    addr.set_port(opt->port);
    addr.set_paxos_port(opt->paxos_port);

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

    int store_id;
    if (comm::RetCode::RET_OK != (ret = store_config->GetStoreIDByAddr(addr, store_id))) {
        QLErr("GetStoreIDByAddr ret %d", as_integer(ret));
        return;
    }

    set<int> pub_ids;
    if (comm::RetCode::RET_OK !=
        (ret = config::utils::GetPubIDsByStoreID(topic_id, store_id, pub_ids))) {
        QLErr("GetPubIDsByStoreID ret %d topic_id %d store_id %d", as_integer(ret), topic_id, store_id);
        return;
    }

    for (int paxos_group_id{0}; paxos_group_id < ngroup; ++paxos_group_id) {
        time_t now = time(nullptr);
        QLVerb("KeepSyncThread::MakeCheckPoint now %" PRIu64 " next %" PRIu64,
               now, impl_->next_make_cp_times[paxos_group_id]);