Method SendBuffer

src/algorithm/checkpoint_sender.cpp:297–334

}

int CheckpointSender :: SendBuffer(const int iSMID, const uint64_t llCheckpointInstanceID, 
        const std::string & sFilePath, const uint64_t llOffset, const std::string & sBuffer)
{
    uint32_t iChecksum = crc32(0, (const uint8_t *)sBuffer.data(), sBuffer.size(), CRC32SKIP);

    int ret = 0;
    while (true)
    {
        if (m_bIsEnd)
        {
            return -1;
        }
        
        if (!CheckAck(m_llSequence))
        {
            return -1;
        }
        
        ret = m_poLearner->SendCheckpoint(
                m_iSendNodeID, m_llUUID, m_llSequence, llCheckpointInstanceID,
                iChecksum, sFilePath, iSMID, llOffset, sBuffer);

        BP->GetCheckpointBP()->SendCheckpointOneBlock();

        if (ret == 0)
        {
            m_llSequence++;
            break;
        }
        else
        {
            PLGErr("SendCheckpoint fail, ret %d need sleep 30s", ret);
            Time::MsSleep(30000);
        }
    }

    return ret;
}

void CheckpointSender :: Ack(const nodeid_t iSendNodeID, const uint64_t llUUID, const uint64_t llSequence)
{