Method Pump

src/twcrypto/cryptoarchive.cpp:363–412

}

unsigned int cCryptoSource::Pump(unsigned int size)
{
    if (mpBuffer == 0)
    {
        // first time this has been called
        mBufferLen  = mpCipher->GetBlockSizePlain();
        mpBuffer    = new int8[mBufferLen];
        mBufferUsed = mBufferLen;
    }

    // RAD: Cast to int (Why are these locals signed if the interface is unsigned?)
    ASSERT(size <= std::numeric_limits<unsigned int>::max());
    int nSize = static_cast<int>(size);

    int i = 0;
    while (i < nSize)
    {
        if (mBufferUsed >= mBufferLen)
        {
            ASSERT(mBufferUsed == mBufferLen); // should be if our math is right

            int8* pTmp = new int8[mpCipher->GetBlockSizeCipher()];

            int l = mpSrcArchive->ReadBlob(pTmp, mpCipher->GetBlockSizeCipher());
            if (l != mpCipher->GetBlockSizeCipher())
            {
                delete [] pTmp;
                return 0;
            }

            mpCipher->ProcessBlock(pTmp, mpBuffer);

            delete [] pTmp;
            mBufferUsed = 0;
        }

        int bytesToCopy = mBufferLen - mBufferUsed;
        if (bytesToCopy > nSize - i)
            bytesToCopy = nSize - i;

        outQueue->Put((byte*)(mpBuffer + mBufferUsed), bytesToCopy);

        mBufferUsed += bytesToCopy;
        i += bytesToCopy;
    }

    ASSERT(i == nSize); // should be if our math is right

    return i;
}

unsigned long cCryptoSource::PumpAll()
{