aboutsummaryrefslogtreecommitdiff
path: root/src/myriadstream.cpp
diff options
context:
space:
mode:
authorMike Buland <eichlan@xagasoft.com>2010-05-24 06:46:39 +0000
committerMike Buland <eichlan@xagasoft.com>2010-05-24 06:46:39 +0000
commit71191e311d949b1b7bdd74fc36a14306f492c181 (patch)
treea3a8515f71d17d9672863b5715ea6e3c5590b036 /src/myriadstream.cpp
parent8b5f78d058407cb874cbd4a2d917757dc959a482 (diff)
downloadlibbu++-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 '')
-rw-r--r--src/myriadstream.cpp24
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()
46size_t Bu::MyriadStream::read( void *pBuf, size_t nBytes ) 46size_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
231void Bu::MyriadStream::setPosEnd( long pos ) 231void Bu::MyriadStream::setPosEnd( long pos )
232{ 232{
233 iPos = pStream->iSize-pos-1; 233 iPos = pStream->iSize-pos;
234} 234}
235 235
236bool Bu::MyriadStream::isEos() 236bool Bu::MyriadStream::isEos()