Method DumpCheckPoint

phxqueue/store/keepsyncthread.cpp:256–284

}

comm::RetCode KeepSyncThread::DumpCheckPoint(const int paxos_group_id, const uint64_t cp) {
    QLVerb("KeepSyncThread::DumpCheckPoint");

    if (-1 == cp) return comm::RetCode::RET_ERR_NO_NEED_DUMP_CHECKPOINT;

    comm::RetCode ret;

    auto stat = impl_->store->GetCheckPointStatMgr()->GetCheckPointStat(paxos_group_id);
    if (!stat) {
        QLErr("GetCheckPointStat fail paxos_group_id %d", paxos_group_id);
        return comm::RetCode::RET_ERR_LOGIC;
    }

    uint64_t tmp_cp;
    if (comm::RetCode::RET_OK != (ret = stat->GetCheckPoint(tmp_cp))) {
        QLErr("GetCheckPoint ret %d paxos_group_id %d", ret, paxos_group_id);
        return ret;
    }

    if (-1 != tmp_cp && tmp_cp > cp) return comm::RetCode::RET_ERR_NO_NEED_DUMP_CHECKPOINT;

    if (comm::RetCode::RET_OK != (ret = stat->UpdateCheckPointAndFlush(cp))) {
        QLErr("UpdateCheckPointAndFlush ret %d paxos_group_id %d cp %" PRIu64,
              ret, paxos_group_id, cp);
        return ret;
    }

    return comm::RetCode::RET_OK;
}

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