Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/kornelski/7z.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to '7zip/Common/InOutTempBuffer.cpp')
-rwxr-xr-x7zip/Common/InOutTempBuffer.cpp35
1 files changed, 5 insertions, 30 deletions
diff --git a/7zip/Common/InOutTempBuffer.cpp b/7zip/Common/InOutTempBuffer.cpp
index d7fb79d7..d24212de 100755
--- a/7zip/Common/InOutTempBuffer.cpp
+++ b/7zip/Common/InOutTempBuffer.cpp
@@ -6,6 +6,8 @@
#include "../../Common/Defs.h"
// #include "Windows/Defs.h"
+#include "StreamUtils.h"
+
using namespace NWindows;
using namespace NFile;
using namespace NDirectory;
@@ -86,34 +88,12 @@ bool CInOutTempBuffer::InitReading()
return true;
}
-/*
-bool CInOutTempBuffer::Read(void *data, UInt32 maxSize, UInt32 &processedSize)
-{
- processedSize = 0;
- if (_currentPositionInBuffer < _bufferPosition)
- {
- UInt32 sizeToRead = MyMin(_bufferPosition - _currentPositionInBuffer, maxSize);
- memmove(data, _buffer + _currentPositionInBuffer, sizeToRead);
- data = ((Byte *)data) + sizeToRead;
- _currentPositionInBuffer += sizeToRead;
- processedSize += sizeToRead;
- maxSize -= sizeToRead;
- }
- if (maxSize == 0 || !_tmpFileCreated)
- return true;
- UInt32 localProcessedSize;
- bool result = _inFile.Read(data, maxSize, localProcessedSize);
- processedSize += localProcessedSize;
- return result;
-}
-*/
-
HRESULT CInOutTempBuffer::WriteToStream(ISequentialOutStream *stream)
{
if (_currentPositionInBuffer < _bufferPosition)
{
UInt32 sizeToWrite = _bufferPosition - _currentPositionInBuffer;
- RINOK(stream->Write(_buffer + _currentPositionInBuffer, sizeToWrite, NULL));
+ RINOK(WriteStream(stream, _buffer + _currentPositionInBuffer, sizeToWrite, NULL));
_currentPositionInBuffer += sizeToWrite;
}
if (!_tmpFileCreated)
@@ -121,11 +101,11 @@ HRESULT CInOutTempBuffer::WriteToStream(ISequentialOutStream *stream)
while(true)
{
UInt32 localProcessedSize;
- if (!_inFile.Read(_buffer, kTmpBufferMemorySize, localProcessedSize))
+ if (!_inFile.ReadPart(_buffer, kTmpBufferMemorySize, localProcessedSize))
return E_FAIL;
if (localProcessedSize == 0)
return S_OK;
- RINOK(stream->Write(_buffer, localProcessedSize, NULL));
+ RINOK(WriteStream(stream, _buffer, localProcessedSize, NULL));
}
}
@@ -141,8 +121,3 @@ STDMETHODIMP CSequentialOutTempBufferImp::Write(const void *data, UInt32 size, U
*processedSize = size;
return S_OK;
}
-
-STDMETHODIMP CSequentialOutTempBufferImp::WritePart(const void *data, UInt32 size, UInt32 *processedSize)
-{
- return Write(data, size, processedSize);
-}