Mercurial > dovecot > core-2.2
annotate src/lib/istream-limit.c @ 23007:36e01285b5b8
lib: buffer - Improve header comment for buffer_insert() and buffer_delete().
author | Stephan Bosch <stephan.bosch@dovecot.fi> |
---|---|
date | Mon, 18 Mar 2019 00:52:37 +0100 |
parents | cb108f786fb4 |
children |
rev | line source |
---|---|
22713
cb108f786fb4
Updated copyright notices to include the year 2018.
Stephan Bosch <stephan.bosch@dovecot.fi>
parents:
21390
diff
changeset
|
1 /* Copyright (c) 2003-2018 Dovecot authors, see the included COPYING file */ |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
2 |
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
3 #include "lib.h" |
13529
cf77e448295c
Renamed lib/*-internal.h files to lib/*-private.h for consistency.
Timo Sirainen <tss@iki.fi>
parents:
12782
diff
changeset
|
4 #include "istream-private.h" |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
5 |
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
6 struct limit_istream { |
6415
b0096861c390
Renamed struct _[io]stream to struct [io]stream_private. Also removed _
Timo Sirainen <tss@iki.fi>
parents:
6411
diff
changeset
|
7 struct istream_private istream; |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
8 |
7032
85cf52f0bc64
i_stream_create() now takes parent stream as parameter and internally sets
Timo Sirainen <tss@iki.fi>
parents:
7031
diff
changeset
|
9 uoff_t v_size; |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
10 }; |
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
11 |
9525
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
12 static void i_stream_limit_destroy(struct iostream_private *stream) |
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
13 { |
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
14 struct limit_istream *lstream = (struct limit_istream *) stream; |
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
15 uoff_t v_offset; |
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
16 |
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
17 v_offset = lstream->istream.parent_start_offset + |
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
18 lstream->istream.istream.v_offset; |
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
19 if (lstream->istream.parent->seekable || |
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
20 v_offset > lstream->istream.parent->v_offset) { |
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
21 /* get to same position in parent stream */ |
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
22 i_stream_seek(lstream->istream.parent, v_offset); |
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
23 } |
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
24 i_stream_unref(&lstream->istream.parent); |
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
25 } |
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
26 |
6420
a8b515e1a26f
Removed _ prefixes from function names.
Timo Sirainen <tss@iki.fi>
parents:
6419
diff
changeset
|
27 static ssize_t i_stream_limit_read(struct istream_private *stream) |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
28 { |
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
29 struct limit_istream *lstream = (struct limit_istream *) stream; |
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
30 uoff_t left; |
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
31 ssize_t ret; |
10875
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
32 size_t pos; |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
33 |
14904
aba24a5cc9ff
istream-limit: Move parent stream to expected offset also at EOF.
Timo Sirainen <tss@iki.fi>
parents:
14701
diff
changeset
|
34 i_stream_seek(stream->parent, lstream->istream.parent_start_offset + |
aba24a5cc9ff
istream-limit: Move parent stream to expected offset also at EOF.
Timo Sirainen <tss@iki.fi>
parents:
14701
diff
changeset
|
35 stream->istream.v_offset); |
aba24a5cc9ff
istream-limit: Move parent stream to expected offset also at EOF.
Timo Sirainen <tss@iki.fi>
parents:
14701
diff
changeset
|
36 |
10875
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
37 if (stream->istream.v_offset + |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
38 (stream->pos - stream->skip) >= lstream->v_size) { |
2441
b65224a24696
When we reach the limit, set eof = true
Timo Sirainen <tss@iki.fi>
parents:
2431
diff
changeset
|
39 stream->istream.eof = TRUE; |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
40 return -1; |
2441
b65224a24696
When we reach the limit, set eof = true
Timo Sirainen <tss@iki.fi>
parents:
2431
diff
changeset
|
41 } |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
42 |
10875
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
43 stream->pos -= stream->skip; |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
44 stream->skip = 0; |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
45 |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
46 stream->buffer = i_stream_get_data(stream->parent, &pos); |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
47 if (pos > stream->pos) |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
48 ret = 0; |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
49 else do { |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
50 if ((ret = i_stream_read(stream->parent)) == -2) |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
51 return -2; |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
52 |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
53 stream->istream.stream_errno = stream->parent->stream_errno; |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
54 stream->istream.eof = stream->parent->eof; |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
55 stream->buffer = i_stream_get_data(stream->parent, &pos); |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
56 } while (pos <= stream->pos && ret > 0); |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
57 |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
58 if (lstream->v_size != (uoff_t)-1) { |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
59 left = lstream->v_size - stream->istream.v_offset; |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
60 if (pos >= left) { |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
61 pos = left; |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
62 stream->istream.eof = TRUE; |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
63 } |
2166 | 64 } |
10875
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
65 |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
66 ret = pos > stream->pos ? (ssize_t)(pos - stream->pos) : |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
67 (ret == 0 ? 0 : -1); |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
68 stream->pos = pos; |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
69 i_assert(ret != -1 || stream->istream.eof || |
1473de6ba383
Reverted recent istream-limit cleanup. It broke things.
Timo Sirainen <tss@iki.fi>
parents:
10854
diff
changeset
|
70 stream->istream.stream_errno != 0); |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
71 return ret; |
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
72 } |
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
73 |
14964 | 74 static int |
6420
a8b515e1a26f
Removed _ prefixes from function names.
Timo Sirainen <tss@iki.fi>
parents:
6419
diff
changeset
|
75 i_stream_limit_stat(struct istream_private *stream, bool exact) |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
76 { |
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
77 struct limit_istream *lstream = (struct limit_istream *) stream; |
3241
b79853b4b005
Replaced i_stream_get_size() with i_stream_stat(). Added i_stream_sync().
Timo Sirainen <tss@iki.fi>
parents:
3239
diff
changeset
|
78 const struct stat *st; |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
79 |
18896
ac64c307d179
istream filters: If parent's i_stream_stat() fails, copy the stream_errno.
Timo Sirainen <tss@iki.fi>
parents:
18137
diff
changeset
|
80 if (i_stream_stat(stream->parent, exact, &st) < 0) { |
ac64c307d179
istream filters: If parent's i_stream_stat() fails, copy the stream_errno.
Timo Sirainen <tss@iki.fi>
parents:
18137
diff
changeset
|
81 stream->istream.stream_errno = stream->parent->stream_errno; |
14964 | 82 return -1; |
18896
ac64c307d179
istream filters: If parent's i_stream_stat() fails, copy the stream_errno.
Timo Sirainen <tss@iki.fi>
parents:
18137
diff
changeset
|
83 } |
3241
b79853b4b005
Replaced i_stream_get_size() with i_stream_stat(). Added i_stream_sync().
Timo Sirainen <tss@iki.fi>
parents:
3239
diff
changeset
|
84 |
b79853b4b005
Replaced i_stream_get_size() with i_stream_stat(). Added i_stream_sync().
Timo Sirainen <tss@iki.fi>
parents:
3239
diff
changeset
|
85 stream->statbuf = *st; |
b79853b4b005
Replaced i_stream_get_size() with i_stream_stat(). Added i_stream_sync().
Timo Sirainen <tss@iki.fi>
parents:
3239
diff
changeset
|
86 if (lstream->v_size != (uoff_t)-1) |
b79853b4b005
Replaced i_stream_get_size() with i_stream_stat(). Added i_stream_sync().
Timo Sirainen <tss@iki.fi>
parents:
3239
diff
changeset
|
87 stream->statbuf.st_size = lstream->v_size; |
14964 | 88 return 0; |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
89 } |
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
90 |
8922
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
91 static int i_stream_limit_get_size(struct istream_private *stream, |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
92 bool exact, uoff_t *size_r) |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
93 { |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
94 struct limit_istream *lstream = (struct limit_istream *) stream; |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
95 const struct stat *st; |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
96 |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
97 if (lstream->v_size != (uoff_t)-1) { |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
98 *size_r = lstream->v_size; |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
99 return 1; |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
100 } |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
101 |
14964 | 102 if (i_stream_stat(&stream->istream, exact, &st) < 0) |
8922
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
103 return -1; |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
104 if (st->st_size == -1) |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
105 return 0; |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
106 |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
107 *size_r = st->st_size; |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
108 return 1; |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
109 } |
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
110 |
7031
4b51ee73ed51
Removed v_start_offset parameter from i_stream_create_limit(). We'll always
Timo Sirainen <tss@iki.fi>
parents:
7030
diff
changeset
|
111 struct istream *i_stream_create_limit(struct istream *input, uoff_t v_size) |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
112 { |
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
113 struct limit_istream *lstream; |
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
114 |
6142
6c0bfc35af03
Removed memory pool parameter from iostreams. Default pool was almost always
Timo Sirainen <tss@iki.fi>
parents:
5207
diff
changeset
|
115 lstream = i_new(struct limit_istream, 1); |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
116 lstream->v_size = v_size; |
6559
15a9ce2cc0ab
Always keep a usable value in stream->max_buffer_size.
Timo Sirainen <tss@iki.fi>
parents:
6557
diff
changeset
|
117 lstream->istream.max_buffer_size = input->real_stream->max_buffer_size; |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
118 |
9525
02badd89127e
istream: Changed default destroy() implementation not to do parent stream seeking.
Timo Sirainen <tss@iki.fi>
parents:
9519
diff
changeset
|
119 lstream->istream.iostream.destroy = i_stream_limit_destroy; |
6420
a8b515e1a26f
Removed _ prefixes from function names.
Timo Sirainen <tss@iki.fi>
parents:
6419
diff
changeset
|
120 lstream->istream.read = i_stream_limit_read; |
a8b515e1a26f
Removed _ prefixes from function names.
Timo Sirainen <tss@iki.fi>
parents:
6419
diff
changeset
|
121 lstream->istream.stat = i_stream_limit_stat; |
8922
5106852f552a
Added i_stream_get_size(). Use it instead of i_stream_stat() where possible.
Timo Sirainen <tss@iki.fi>
parents:
8590
diff
changeset
|
122 lstream->istream.get_size = i_stream_limit_get_size; |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
123 |
9540
622509c562e8
Added struct istream.readable_fd, which is used to determine if sendfile() can be used.
Timo Sirainen <tss@iki.fi>
parents:
9525
diff
changeset
|
124 lstream->istream.istream.readable_fd = input->readable_fd; |
5106
81394e71f92a
Added istream->blocking setting. It's now used to assert-crash early if a
Timo Sirainen <tss@iki.fi>
parents:
3879
diff
changeset
|
125 lstream->istream.istream.blocking = input->blocking; |
3239
904a268921af
Added seekable variable to struct istream.
Timo Sirainen <tss@iki.fi>
parents:
2983
diff
changeset
|
126 lstream->istream.istream.seekable = input->seekable; |
7032
85cf52f0bc64
i_stream_create() now takes parent stream as parameter and internally sets
Timo Sirainen <tss@iki.fi>
parents:
7031
diff
changeset
|
127 return i_stream_create(&lstream->istream, input, |
85cf52f0bc64
i_stream_create() now takes parent stream as parameter and internally sets
Timo Sirainen <tss@iki.fi>
parents:
7031
diff
changeset
|
128 i_stream_get_fd(input)); |
1870
c972ea085643
istream rewrite. instead of directly setting any limits to stream, you now
Timo Sirainen <tss@iki.fi>
parents:
diff
changeset
|
129 } |
14943 | 130 |
131 struct istream *i_stream_create_range(struct istream *input, | |
132 uoff_t v_offset, uoff_t v_size) | |
133 { | |
134 uoff_t orig_offset = input->v_offset; | |
135 struct istream *ret; | |
136 | |
137 input->v_offset = v_offset; | |
138 ret = i_stream_create_limit(input, v_size); | |
139 input->v_offset = orig_offset; | |
140 return ret; | |
141 } |