1 /* 7zStream.c -- 7z Stream functions
\r
2 2013-11-12 : Igor Pavlov : Public domain */
\r
10 SRes SeqInStream_Read2(ISeqInStream *stream, void *buf, size_t size, SRes errorType)
\r
14 size_t processed = size;
\r
15 RINOK(stream->Read(stream, buf, &processed));
\r
18 buf = (void *)((Byte *)buf + processed);
\r
24 SRes SeqInStream_Read(ISeqInStream *stream, void *buf, size_t size)
\r
26 return SeqInStream_Read2(stream, buf, size, SZ_ERROR_INPUT_EOF);
\r
29 SRes SeqInStream_ReadByte(ISeqInStream *stream, Byte *buf)
\r
31 size_t processed = 1;
\r
32 RINOK(stream->Read(stream, buf, &processed));
\r
33 return (processed == 1) ? SZ_OK : SZ_ERROR_INPUT_EOF;
\r
36 SRes LookInStream_SeekTo(ILookInStream *stream, UInt64 offset)
\r
39 return stream->Seek(stream, &t, SZ_SEEK_SET);
\r
42 SRes LookInStream_LookRead(ILookInStream *stream, void *buf, size_t *size)
\r
44 const void *lookBuf;
\r
47 RINOK(stream->Look(stream, &lookBuf, size));
\r
48 memcpy(buf, lookBuf, *size);
\r
49 return stream->Skip(stream, *size);
\r
52 SRes LookInStream_Read2(ILookInStream *stream, void *buf, size_t size, SRes errorType)
\r
56 size_t processed = size;
\r
57 RINOK(stream->Read(stream, buf, &processed));
\r
60 buf = (void *)((Byte *)buf + processed);
\r
66 SRes LookInStream_Read(ILookInStream *stream, void *buf, size_t size)
\r
68 return LookInStream_Read2(stream, buf, size, SZ_ERROR_INPUT_EOF);
\r
71 static SRes LookToRead_Look_Lookahead(void *pp, const void **buf, size_t *size)
\r
74 CLookToRead *p = (CLookToRead *)pp;
\r
75 size_t size2 = p->size - p->pos;
\r
76 if (size2 == 0 && *size > 0)
\r
79 size2 = LookToRead_BUF_SIZE;
\r
80 res = p->realStream->Read(p->realStream, p->buf, &size2);
\r
85 *buf = p->buf + p->pos;
\r
89 static SRes LookToRead_Look_Exact(void *pp, const void **buf, size_t *size)
\r
92 CLookToRead *p = (CLookToRead *)pp;
\r
93 size_t size2 = p->size - p->pos;
\r
94 if (size2 == 0 && *size > 0)
\r
97 if (*size > LookToRead_BUF_SIZE)
\r
98 *size = LookToRead_BUF_SIZE;
\r
99 res = p->realStream->Read(p->realStream, p->buf, size);
\r
100 size2 = p->size = *size;
\r
104 *buf = p->buf + p->pos;
\r
108 static SRes LookToRead_Skip(void *pp, size_t offset)
\r
110 CLookToRead *p = (CLookToRead *)pp;
\r
115 static SRes LookToRead_Read(void *pp, void *buf, size_t *size)
\r
117 CLookToRead *p = (CLookToRead *)pp;
\r
118 size_t rem = p->size - p->pos;
\r
120 return p->realStream->Read(p->realStream, buf, size);
\r
123 memcpy(buf, p->buf + p->pos, rem);
\r
129 static SRes LookToRead_Seek(void *pp, Int64 *pos, ESzSeek origin)
\r
131 CLookToRead *p = (CLookToRead *)pp;
\r
132 p->pos = p->size = 0;
\r
133 return p->realStream->Seek(p->realStream, pos, origin);
\r
136 void LookToRead_CreateVTable(CLookToRead *p, int lookahead)
\r
138 p->s.Look = lookahead ?
\r
139 LookToRead_Look_Lookahead :
\r
140 LookToRead_Look_Exact;
\r
141 p->s.Skip = LookToRead_Skip;
\r
142 p->s.Read = LookToRead_Read;
\r
143 p->s.Seek = LookToRead_Seek;
\r
146 void LookToRead_Init(CLookToRead *p)
\r
148 p->pos = p->size = 0;
\r
151 static SRes SecToLook_Read(void *pp, void *buf, size_t *size)
\r
153 CSecToLook *p = (CSecToLook *)pp;
\r
154 return LookInStream_LookRead(p->realStream, buf, size);
\r
157 void SecToLook_CreateVTable(CSecToLook *p)
\r
159 p->s.Read = SecToLook_Read;
\r
162 static SRes SecToRead_Read(void *pp, void *buf, size_t *size)
\r
164 CSecToRead *p = (CSecToRead *)pp;
\r
165 return p->realStream->Read(p->realStream, buf, size);
\r
168 void SecToRead_CreateVTable(CSecToRead *p)
\r
170 p->s.Read = SecToRead_Read;
\r