diff options
Diffstat (limited to 'src/stable/substream.cpp')
-rw-r--r-- | src/stable/substream.cpp | 88 |
1 files changed, 44 insertions, 44 deletions
diff --git a/src/stable/substream.cpp b/src/stable/substream.cpp index 7e3729b..c55dc04 100644 --- a/src/stable/substream.cpp +++ b/src/stable/substream.cpp | |||
@@ -8,12 +8,12 @@ | |||
8 | #include "bu/substream.h" | 8 | #include "bu/substream.h" |
9 | 9 | ||
10 | Bu::SubStream::SubStream( Bu::Stream &rNext, Bu::size iSize ) : | 10 | Bu::SubStream::SubStream( Bu::Stream &rNext, Bu::size iSize ) : |
11 | Bu::Filter( rNext ), | 11 | Bu::Filter( rNext ), |
12 | iStart( 0 ), | 12 | iStart( 0 ), |
13 | iPos( 0 ), | 13 | iPos( 0 ), |
14 | iSize( iSize ) | 14 | iSize( iSize ) |
15 | { | 15 | { |
16 | iStart = rNext.tell(); | 16 | iStart = rNext.tell(); |
17 | } | 17 | } |
18 | 18 | ||
19 | Bu::SubStream::~SubStream() | 19 | Bu::SubStream::~SubStream() |
@@ -22,88 +22,88 @@ Bu::SubStream::~SubStream() | |||
22 | 22 | ||
23 | Bu::size Bu::SubStream::read( void *pBuf, Bu::size nBytes ) | 23 | Bu::size Bu::SubStream::read( void *pBuf, Bu::size nBytes ) |
24 | { | 24 | { |
25 | if( (Bu::size)nBytes > iSize-iPos ) | 25 | if( (Bu::size)nBytes > iSize-iPos ) |
26 | nBytes = iSize-iPos; | 26 | nBytes = iSize-iPos; |
27 | nBytes = rNext.read( pBuf, nBytes ); | 27 | nBytes = rNext.read( pBuf, nBytes ); |
28 | iPos += nBytes; | 28 | iPos += nBytes; |
29 | return nBytes; | 29 | return nBytes; |
30 | } | 30 | } |
31 | 31 | ||
32 | Bu::size Bu::SubStream::write( const void *pBuf, Bu::size nBytes ) | 32 | Bu::size Bu::SubStream::write( const void *pBuf, Bu::size nBytes ) |
33 | { | 33 | { |
34 | if( (Bu::size)nBytes > iSize-iPos ) | 34 | if( (Bu::size)nBytes > iSize-iPos ) |
35 | nBytes = iSize-iPos; | 35 | nBytes = iSize-iPos; |
36 | nBytes = rNext.write( pBuf, nBytes ); | 36 | nBytes = rNext.write( pBuf, nBytes ); |
37 | iPos += nBytes; | 37 | iPos += nBytes; |
38 | return nBytes; | 38 | return nBytes; |
39 | } | 39 | } |
40 | 40 | ||
41 | void Bu::SubStream::start() | 41 | void Bu::SubStream::start() |
42 | { | 42 | { |
43 | // doesn't mean anything... | 43 | // doesn't mean anything... |
44 | } | 44 | } |
45 | 45 | ||
46 | Bu::size Bu::SubStream::stop() | 46 | Bu::size Bu::SubStream::stop() |
47 | { | 47 | { |
48 | // doesn't mean anything... | 48 | // doesn't mean anything... |
49 | return 0; | 49 | return 0; |
50 | } | 50 | } |
51 | 51 | ||
52 | void Bu::SubStream::close() | 52 | void Bu::SubStream::close() |
53 | { | 53 | { |
54 | // don't do anything? maybe... | 54 | // don't do anything? maybe... |
55 | } | 55 | } |
56 | 56 | ||
57 | Bu::size Bu::SubStream::tell() | 57 | Bu::size Bu::SubStream::tell() |
58 | { | 58 | { |
59 | return iPos; | 59 | return iPos; |
60 | } | 60 | } |
61 | 61 | ||
62 | void Bu::SubStream::seek( Bu::size offset ) | 62 | void Bu::SubStream::seek( Bu::size offset ) |
63 | { | 63 | { |
64 | if( iPos+offset < 0 ) | 64 | if( iPos+offset < 0 ) |
65 | offset = -iPos; | 65 | offset = -iPos; |
66 | else if( iPos+offset > iSize ) | 66 | else if( iPos+offset > iSize ) |
67 | offset = iSize-iPos; | 67 | offset = iSize-iPos; |
68 | rNext.seek( offset ); | 68 | rNext.seek( offset ); |
69 | iPos += offset; | 69 | iPos += offset; |
70 | } | 70 | } |
71 | 71 | ||
72 | void Bu::SubStream::setPos( Bu::size pos ) | 72 | void Bu::SubStream::setPos( Bu::size pos ) |
73 | { | 73 | { |
74 | if( pos < 0 ) | 74 | if( pos < 0 ) |
75 | pos = 0; | 75 | pos = 0; |
76 | else if( pos > iSize ) | 76 | else if( pos > iSize ) |
77 | pos = iSize; | 77 | pos = iSize; |
78 | iPos = pos; | 78 | iPos = pos; |
79 | pos += iStart; | 79 | pos += iStart; |
80 | rNext.setPos( pos ); | 80 | rNext.setPos( pos ); |
81 | } | 81 | } |
82 | 82 | ||
83 | void Bu::SubStream::setPosEnd( Bu::size pos ) | 83 | void Bu::SubStream::setPosEnd( Bu::size pos ) |
84 | { | 84 | { |
85 | if( iSize-pos < 0 ) | 85 | if( iSize-pos < 0 ) |
86 | pos = 0; | 86 | pos = 0; |
87 | else if( iSize-pos > iSize ) | 87 | else if( iSize-pos > iSize ) |
88 | pos = iSize; | 88 | pos = iSize; |
89 | else | 89 | else |
90 | pos = iSize-pos; | 90 | pos = iSize-pos; |
91 | iPos = pos; | 91 | iPos = pos; |
92 | rNext.setPos( iStart+pos ); | 92 | rNext.setPos( iStart+pos ); |
93 | } | 93 | } |
94 | 94 | ||
95 | bool Bu::SubStream::isEos() | 95 | bool Bu::SubStream::isEos() |
96 | { | 96 | { |
97 | return rNext.isEos() || iPos == iSize; | 97 | return rNext.isEos() || iPos == iSize; |
98 | } | 98 | } |
99 | 99 | ||
100 | bool Bu::SubStream::canRead() | 100 | bool Bu::SubStream::canRead() |
101 | { | 101 | { |
102 | return rNext.canRead() && (iPos < iSize); | 102 | return rNext.canRead() && (iPos < iSize); |
103 | } | 103 | } |
104 | 104 | ||
105 | bool Bu::SubStream::canWrite() | 105 | bool Bu::SubStream::canWrite() |
106 | { | 106 | { |
107 | return rNext.canWrite() && (iPos < iSize); | 107 | return rNext.canWrite() && (iPos < iSize); |
108 | } | 108 | } |
109 | 109 | ||