annotate src/win32/7zip/7z/CPP/7zip/Common/LockedStream.h @ 1:f9f4f1b99eed

importing src directory
author Robert McIntyre <rlm@mit.edu>
date Sat, 03 Mar 2012 10:31:27 -0600
parents
children
rev   line source
rlm@1 1 // LockedStream.h
rlm@1 2
rlm@1 3 #ifndef __LOCKEDSTREAM_H
rlm@1 4 #define __LOCKEDSTREAM_H
rlm@1 5
rlm@1 6 #include "../../Windows/Synchronization.h"
rlm@1 7 #include "../../Common/MyCom.h"
rlm@1 8 #include "../IStream.h"
rlm@1 9
rlm@1 10 class CLockedInStream
rlm@1 11 {
rlm@1 12 CMyComPtr<IInStream> _stream;
rlm@1 13 NWindows::NSynchronization::CCriticalSection _criticalSection;
rlm@1 14 public:
rlm@1 15 void Init(IInStream *stream)
rlm@1 16 { _stream = stream; }
rlm@1 17 HRESULT Read(UInt64 startPos, void *data, UInt32 size, UInt32 *processedSize);
rlm@1 18 };
rlm@1 19
rlm@1 20 class CLockedSequentialInStreamImp:
rlm@1 21 public ISequentialInStream,
rlm@1 22 public CMyUnknownImp
rlm@1 23 {
rlm@1 24 CLockedInStream *_lockedInStream;
rlm@1 25 UInt64 _pos;
rlm@1 26 public:
rlm@1 27 void Init(CLockedInStream *lockedInStream, UInt64 startPos)
rlm@1 28 {
rlm@1 29 _lockedInStream = lockedInStream;
rlm@1 30 _pos = startPos;
rlm@1 31 }
rlm@1 32
rlm@1 33 MY_UNKNOWN_IMP
rlm@1 34
rlm@1 35 STDMETHOD(Read)(void *data, UInt32 size, UInt32 *processedSize);
rlm@1 36 };
rlm@1 37
rlm@1 38 #endif