misc/libphysfs/lzma/CPP/7zip/Common/StreamUtils.cpp
changeset 12213 bb5522e88ab2
equal deleted inserted replaced
12212:ea891871f481 12213:bb5522e88ab2
       
     1 // StreamUtils.cpp
       
     2 
       
     3 #include "StdAfx.h"
       
     4 
       
     5 #include "../../Common/MyCom.h"
       
     6 #include "StreamUtils.h"
       
     7 
       
     8 HRESULT ReadStream(ISequentialInStream *stream, void *data, UInt32 size, UInt32 *processedSize)
       
     9 {
       
    10   if (processedSize != 0)
       
    11     *processedSize = 0;
       
    12   while(size != 0)
       
    13   {
       
    14     UInt32 processedSizeLoc; 
       
    15     HRESULT res = stream->Read(data, size, &processedSizeLoc);
       
    16     if (processedSize != 0)
       
    17       *processedSize += processedSizeLoc;
       
    18     data = (Byte *)((Byte *)data + processedSizeLoc);
       
    19     size -= processedSizeLoc;
       
    20     RINOK(res);
       
    21     if (processedSizeLoc == 0)
       
    22       return S_OK;
       
    23   }
       
    24   return S_OK;
       
    25 }
       
    26 
       
    27 HRESULT WriteStream(ISequentialOutStream *stream, const void *data, UInt32 size, UInt32 *processedSize)
       
    28 {
       
    29   if (processedSize != 0)
       
    30     *processedSize = 0;
       
    31   while(size != 0)
       
    32   {
       
    33     UInt32 processedSizeLoc; 
       
    34     HRESULT res = stream->Write(data, size, &processedSizeLoc);
       
    35     if (processedSize != 0)
       
    36       *processedSize += processedSizeLoc;
       
    37     data = (const void *)((const Byte *)data + processedSizeLoc);
       
    38     size -= processedSizeLoc;
       
    39     RINOK(res);
       
    40     if (processedSizeLoc == 0)
       
    41       return E_FAIL;
       
    42   }
       
    43   return S_OK;
       
    44 }