Return to InBuffer.cpp CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / elwix / tools / oldlzma / SRC / 7zip / Common

Annotation of elwix/tools/oldlzma/SRC/7zip/Common/InBuffer.cpp, revision 1.1

1.1     ! misho       1: // InBuffer.cpp
        !             2: 
        !             3: #include "StdAfx.h"
        !             4: 
        !             5: #include "InBuffer.h"
        !             6: 
        !             7: #include "../../Common/Alloc.h"
        !             8: 
        !             9: CInBuffer::CInBuffer(): 
        !            10:   _bufferBase(0), 
        !            11:   _bufferSize(0),
        !            12:   _buffer(0), 
        !            13:   _bufferLimit(0), 
        !            14:   _stream(0) 
        !            15: {}
        !            16: 
        !            17: bool CInBuffer::Create(UInt32 bufferSize)
        !            18: {
        !            19:   const UInt32 kMinBlockSize = 1;
        !            20:   if (bufferSize < kMinBlockSize)
        !            21:     bufferSize = kMinBlockSize;
        !            22:   if (_bufferBase != 0 && _bufferSize == bufferSize)
        !            23:     return true;
        !            24:   Free();
        !            25:   _bufferSize = bufferSize;
        !            26:   _bufferBase = (Byte *)::BigAlloc(bufferSize);
        !            27:   return (_bufferBase != 0);
        !            28: }
        !            29: 
        !            30: void CInBuffer::Free()
        !            31: {
        !            32:   BigFree(_bufferBase);
        !            33:   _bufferBase = 0;
        !            34: }
        !            35: 
        !            36: void CInBuffer::SetStream(ISequentialInStream *stream)
        !            37: {
        !            38:   _stream = stream;
        !            39: }
        !            40: 
        !            41: void CInBuffer::Init()
        !            42: {
        !            43:   _processedSize = 0;
        !            44:   _buffer = _bufferBase;
        !            45:   _bufferLimit = _buffer;
        !            46:   _wasFinished = false;
        !            47:   #ifdef _NO_EXCEPTIONS
        !            48:   ErrorCode = S_OK;
        !            49:   #endif
        !            50: }
        !            51: 
        !            52: bool CInBuffer::ReadBlock()
        !            53: {
        !            54:   #ifdef _NO_EXCEPTIONS
        !            55:   if (ErrorCode != S_OK)
        !            56:     return false;
        !            57:   #endif
        !            58:   if (_wasFinished)
        !            59:     return false;
        !            60:   _processedSize += (_buffer - _bufferBase);
        !            61:   UInt32 numProcessedBytes;
        !            62:   HRESULT result = _stream->ReadPart(_bufferBase, _bufferSize, &numProcessedBytes);
        !            63:   #ifdef _NO_EXCEPTIONS
        !            64:   ErrorCode = result;
        !            65:   #else
        !            66:   if (result != S_OK)
        !            67:     throw CInBufferException(result);
        !            68:   #endif
        !            69:   _buffer = _bufferBase;
        !            70:   _bufferLimit = _buffer + numProcessedBytes;
        !            71:   _wasFinished = (numProcessedBytes == 0);
        !            72:   return (!_wasFinished);
        !            73: }