diff options
author | Mike Buland <eichlan@xagasoft.com> | 2010-05-24 06:46:39 +0000 |
---|---|---|
committer | Mike Buland <eichlan@xagasoft.com> | 2010-05-24 06:46:39 +0000 |
commit | 71191e311d949b1b7bdd74fc36a14306f492c181 (patch) | |
tree | a3a8515f71d17d9672863b5715ea6e3c5590b036 /src/myriadstream.cpp | |
parent | 8b5f78d058407cb874cbd4a2d917757dc959a482 (diff) | |
download | libbu++-71191e311d949b1b7bdd74fc36a14306f492c181.tar.gz libbu++-71191e311d949b1b7bdd74fc36a14306f492c181.tar.bz2 libbu++-71191e311d949b1b7bdd74fc36a14306f492c181.tar.xz libbu++-71191e311d949b1b7bdd74fc36a14306f492c181.zip |
Myriad unit test. Seems like it's workin' well.
Diffstat (limited to 'src/myriadstream.cpp')
-rw-r--r-- | src/myriadstream.cpp | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/src/myriadstream.cpp b/src/myriadstream.cpp index d714c23..2218ae4 100644 --- a/src/myriadstream.cpp +++ b/src/myriadstream.cpp | |||
@@ -23,7 +23,7 @@ Bu::MyriadStream::MyriadStream( Bu::Myriad &rMyriad, | |||
23 | iPos( 0 ) | 23 | iPos( 0 ) |
24 | { | 24 | { |
25 | #ifdef MYRIAD_STREAM_DEBUG | 25 | #ifdef MYRIAD_STREAM_DEBUG |
26 | sio << "MyriadStream: Created, iId=" << pStream->iId << ", iSize=" | 26 | sio << "MyriadStream: " << __LINE__ << ": Created, iId=" << pStream->iId << ", iSize=" |
27 | << pStream->iSize << sio.nl; | 27 | << pStream->iSize << sio.nl; |
28 | #endif | 28 | #endif |
29 | //pCurBlock = rMyriad.newBlock(); | 29 | //pCurBlock = rMyriad.newBlock(); |
@@ -46,7 +46,7 @@ void Bu::MyriadStream::close() | |||
46 | size_t Bu::MyriadStream::read( void *pBuf, size_t nBytes ) | 46 | size_t Bu::MyriadStream::read( void *pBuf, size_t nBytes ) |
47 | { | 47 | { |
48 | #ifdef MYRIAD_STREAM_DEBUG | 48 | #ifdef MYRIAD_STREAM_DEBUG |
49 | sio << "MyriadStream: read: Started, asked to read " << nBytes << "b." | 49 | sio << "MyriadStream: read: " << __LINE__ << ": Started, asked to read " << nBytes << "b." |
50 | << sio.nl; | 50 | << sio.nl; |
51 | #endif | 51 | #endif |
52 | if( nBytes > pStream->iSize-iPos ) | 52 | if( nBytes > pStream->iSize-iPos ) |
@@ -55,13 +55,13 @@ size_t Bu::MyriadStream::read( void *pBuf, size_t nBytes ) | |||
55 | return 0; | 55 | return 0; |
56 | int iLeft = nBytes; | 56 | int iLeft = nBytes; |
57 | #ifdef MYRIAD_STREAM_DEBUG | 57 | #ifdef MYRIAD_STREAM_DEBUG |
58 | sio << "MyriadStream: read: Started, going to read " << nBytes << "b." | 58 | sio << "MyriadStream: read: " << __LINE__ << ": Started, going to read " << nBytes << "b." |
59 | << sio.nl; | 59 | << sio.nl; |
60 | #endif | 60 | #endif |
61 | if( pCurBlock == NULL ) | 61 | if( pCurBlock == NULL ) |
62 | { | 62 | { |
63 | #ifdef MYRIAD_STREAM_DEBUG | 63 | #ifdef MYRIAD_STREAM_DEBUG |
64 | sio << "MyriadStream: read: No block loaded, loading initial block." | 64 | sio << "MyriadStream: read: " << __LINE__ << ": No block loaded, loading initial block." |
65 | << sio.nl; | 65 | << sio.nl; |
66 | #endif | 66 | #endif |
67 | pCurBlock = rMyriad.getBlock( | 67 | pCurBlock = rMyriad.getBlock( |
@@ -74,7 +74,7 @@ size_t Bu::MyriadStream::read( void *pBuf, size_t nBytes ) | |||
74 | if( pCurBlock->iBlockIndex != iCurBlock ) | 74 | if( pCurBlock->iBlockIndex != iCurBlock ) |
75 | { | 75 | { |
76 | #ifdef MYRIAD_STREAM_DEBUG | 76 | #ifdef MYRIAD_STREAM_DEBUG |
77 | sio << "MyriadStream: read: Loading new block " << iCurBlock << "." | 77 | sio << "MyriadStream: read: " << __LINE__ << ": Loading new block " << iCurBlock << "." |
78 | << sio.nl; | 78 | << sio.nl; |
79 | #endif | 79 | #endif |
80 | rMyriad.releaseBlock( pCurBlock ); | 80 | rMyriad.releaseBlock( pCurBlock ); |
@@ -89,7 +89,7 @@ size_t Bu::MyriadStream::read( void *pBuf, size_t nBytes ) | |||
89 | pStream->iSize-iPos | 89 | pStream->iSize-iPos |
90 | ); | 90 | ); |
91 | #ifdef MYRIAD_STREAM_DEBUG | 91 | #ifdef MYRIAD_STREAM_DEBUG |
92 | sio << "MyriadStream: read: Copying out bytes: " | 92 | sio << "MyriadStream: read: " << __LINE__ << ": Copying out bytes: " |
93 | << iPos << "(" << (iPos%rMyriad.iBlockSize) << ")+" | 93 | << iPos << "(" << (iPos%rMyriad.iBlockSize) << ")+" |
94 | << iAmnt | 94 | << iAmnt |
95 | << ", " << iLeft << "b left." << sio.nl; | 95 | << ", " << iLeft << "b left." << sio.nl; |
@@ -112,7 +112,7 @@ size_t Bu::MyriadStream::write( const void *pBuf, size_t nBytes ) | |||
112 | return 0; | 112 | return 0; |
113 | 113 | ||
114 | #ifdef MYRIAD_STREAM_DEBUG | 114 | #ifdef MYRIAD_STREAM_DEBUG |
115 | sio << "MyriadStream: write: Started, asked to write " << nBytes << "b." | 115 | sio << "MyriadStream: write: " << __LINE__ << ": Started, asked to write " << nBytes << "b." |
116 | << sio.nl; | 116 | << sio.nl; |
117 | #endif | 117 | #endif |
118 | if( nBytes <= 0 ) | 118 | if( nBytes <= 0 ) |
@@ -143,7 +143,7 @@ size_t Bu::MyriadStream::write( const void *pBuf, size_t nBytes ) | |||
143 | pStream->aBlocks.append( iCurBlock ); | 143 | pStream->aBlocks.append( iCurBlock ); |
144 | rMyriad.bsBlockUsed.setBit( iCurBlock ); | 144 | rMyriad.bsBlockUsed.setBit( iCurBlock ); |
145 | #ifdef MYRIAD_STREAM_DEBUG | 145 | #ifdef MYRIAD_STREAM_DEBUG |
146 | sio << "MyriadStream: write: New block allocated and appended: " | 146 | sio << "MyriadStream: write: " << __LINE__ << ": New block allocated and appended: " |
147 | << iCurBlock << "." << sio.nl; | 147 | << iCurBlock << "." << sio.nl; |
148 | 148 | ||
149 | #endif | 149 | #endif |
@@ -151,7 +151,7 @@ size_t Bu::MyriadStream::write( const void *pBuf, size_t nBytes ) | |||
151 | if( !pCurBlock || pCurBlock->iBlockIndex != iCurBlock ) | 151 | if( !pCurBlock || pCurBlock->iBlockIndex != iCurBlock ) |
152 | { | 152 | { |
153 | #ifdef MYRIAD_STREAM_DEBUG | 153 | #ifdef MYRIAD_STREAM_DEBUG |
154 | sio << "MyriadStream: write: Loading new block " << iCurBlock << "." | 154 | sio << "MyriadStream: write: " << __LINE__ << ": Loading new block " << iCurBlock << "." |
155 | << sio.nl; | 155 | << sio.nl; |
156 | #endif | 156 | #endif |
157 | rMyriad.releaseBlock( pCurBlock ); | 157 | rMyriad.releaseBlock( pCurBlock ); |
@@ -172,7 +172,7 @@ size_t Bu::MyriadStream::write( const void *pBuf, size_t nBytes ) | |||
172 | pStream->iSize-iPos | 172 | pStream->iSize-iPos |
173 | ); | 173 | ); |
174 | #ifdef MYRIAD_STREAM_DEBUG | 174 | #ifdef MYRIAD_STREAM_DEBUG |
175 | sio << "MyriadStream: write (ovr): Copying in bytes: " | 175 | sio << "MyriadStream: write (ovr): " << __LINE__ << ": Copying in bytes: " |
176 | << (iPos%rMyriad.iBlockSize) << "+" | 176 | << (iPos%rMyriad.iBlockSize) << "+" |
177 | << iAmnt | 177 | << iAmnt |
178 | << ", " << iLeft << "b left." << sio.nl; | 178 | << ", " << iLeft << "b left." << sio.nl; |
@@ -193,7 +193,7 @@ size_t Bu::MyriadStream::write( const void *pBuf, size_t nBytes ) | |||
193 | iLeft | 193 | iLeft |
194 | ); | 194 | ); |
195 | #ifdef MYRIAD_STREAM_DEBUG | 195 | #ifdef MYRIAD_STREAM_DEBUG |
196 | sio << "MyriadStream: write (app): Copying in bytes: " | 196 | sio << "MyriadStream: write (app): " << __LINE__ << ": Copying in bytes: " |
197 | << (iPos%rMyriad.iBlockSize) << "+" | 197 | << (iPos%rMyriad.iBlockSize) << "+" |
198 | << iAmnt | 198 | << iAmnt |
199 | << ", " << iLeft << "b left." << sio.nl; | 199 | << ", " << iLeft << "b left." << sio.nl; |
@@ -230,7 +230,7 @@ void Bu::MyriadStream::setPos( long pos ) | |||
230 | 230 | ||
231 | void Bu::MyriadStream::setPosEnd( long pos ) | 231 | void Bu::MyriadStream::setPosEnd( long pos ) |
232 | { | 232 | { |
233 | iPos = pStream->iSize-pos-1; | 233 | iPos = pStream->iSize-pos; |
234 | } | 234 | } |
235 | 235 | ||
236 | bool Bu::MyriadStream::isEos() | 236 | bool Bu::MyriadStream::isEos() |