Method run

src/algorithm/checkpoint_sender.cpp:81–120

}

void CheckpointSender :: run()
{
    m_bIsStarted = true;
    m_llAbsLastAckTime = Time::GetSteadyClockMS();

    //pause checkpoint replayer
    bool bNeedContinue = false;
    while (!m_poCheckpointMgr->GetReplayer()->IsPaused())
    {
        if (m_bIsEnd)
        {
            m_bIsEnded = true;
            return;
        }

        bNeedContinue = true;
        
        m_poCheckpointMgr->GetReplayer()->Pause();
        PLGDebug("wait replayer paused.");
        Time::MsSleep(100);
    }

    int ret = LockCheckpoint();
    if (ret == 0)
    {
        //send
        SendCheckpoint();

        UnLockCheckpoint();
    }

    //continue checkpoint replayer
    if (bNeedContinue)
    {
        m_poCheckpointMgr->GetReplayer()->Continue();
    }

    PLGHead("Checkpoint.Sender [END]");
    m_bIsEnded = true;
}

int CheckpointSender :: LockCheckpoint()
{