Method ExecuteForCheckpoint

phxqueue/lock/locksm.cpp:199–241

}

bool LockSM::ExecuteForCheckpoint(const int paxos_group_id, const uint64_t instance_id,
                                  const string &paxos_value) {
    comm::LockSMBP::GetThreadInstance()->
            OnExecuteForCheckpoint(impl_->lock->GetTopicID(), paxos_group_id,
                                   instance_id, paxos_value);

    if (impl_->lock->GetLockOption()->no_leveldb)
        return true;

    const uint64_t checkpoint{impl_->lock->GetLockMgr()->checkpoint(paxos_group_id)};
    bool sync{instance_id - checkpoint >= impl_->lock->GetLockOption()->checkpoint_interval};
    if (!sync) {
        const uint64_t now{comm::utils::Time::GetSteadyClockMS()};
        if (now > last_sync_ms_ + 60000) {
            sync = true;
        }
    }
    if (sync) {
        last_sync_ms_ = comm::utils::Time::GetSteadyClockMS();

        comm::LockSMBP::GetThreadInstance()->
                OnExecuteForCheckpointSync(impl_->lock->GetTopicID(), paxos_group_id,
                                           instance_id, paxos_value);
    } else {
        comm::LockSMBP::GetThreadInstance()->
                OnExecuteForCheckpointNoSync(impl_->lock->GetTopicID(), paxos_group_id,
                                             instance_id, paxos_value);
    }
    QLVerb("topic_id %d paxos_group_id %d instance_id %llu cp %llu sync %d",
           impl_->lock->GetTopicID(), paxos_group_id, instance_id, checkpoint, sync);

    proto::LockPaxosArgs args;
    bool succ{args.ParseFromString(paxos_value)};
    if (!succ) {
        QLErr("topic_id %d paxos_group_id %d instance_id %llu ParseFromString err",
              impl_->lock->GetTopicID(), paxos_group_id, instance_id);

        return false;
    }

    return DoExecute(impl_->lock, LockDb::Type::LEVELDB,
                     paxos_group_id, instance_id, args, sync);
}

const uint64_t LockSM::GetCheckpointInstanceID(const int paxos_group_id) const {
    comm::LockSMBP::GetThreadInstance()->