Method SendFile

src/algorithm/checkpoint_sender.cpp:235–295

}

int CheckpointSender :: SendFile(const StateMachine * poSM, const std::string & sDirPath, const std::string & sFilePath)
{
    PLGHead("START smid %d dirpath %s filepath %s", poSM->SMID(), sDirPath.c_str(), sFilePath.c_str());

    string sPath = sDirPath + sFilePath;

    if (m_mapAlreadySendedFile.find(sPath) != end(m_mapAlreadySendedFile))
    {
        PLGErr("file already send, filepath %s", sPath.c_str());
        return 0;
    }

    int iFD = open(sPath.c_str(), O_RDWR, S_IREAD);

    if (iFD == -1)
    {
        PLGErr("Open file fail, filepath %s", sPath.c_str());
        return -1;
    }

    ssize_t iReadLen = 0;
    size_t llOffset = 0;
    while (true)
    {
        iReadLen = read(iFD, m_sTmpBuffer, sizeof(m_sTmpBuffer));
        if (iReadLen == 0)
        {
            break;
        }

        if (iReadLen < 0)
        {
            close(iFD);
            return -1;
        }

        int ret = SendBuffer(poSM->SMID(), poSM->GetCheckpointInstanceID(m_poConfig->GetMyGroupIdx()), 
                sFilePath, llOffset, string(m_sTmpBuffer, iReadLen));
        if (ret != 0)
        {
            close(iFD);
            return ret;
        }

        PLGDebug("Send ok, offset %zu readlen %d", llOffset, iReadLen);

        if (iReadLen < (ssize_t)sizeof(m_sTmpBuffer))
        {
            break;
        }

        llOffset += iReadLen;
    }

    m_mapAlreadySendedFile[sPath] = true;

    close(iFD);
    PLGImp("END");