From ec05778d5718a7912e506764d443a78d6a6179e3 Mon Sep 17 00:00:00 2001 From: Mike Buland Date: Mon, 5 Nov 2012 22:41:51 +0000 Subject: Converted tabs to spaces with tabconv. --- src/stable/queuebuf.cpp | 316 ++++++++++++++++++++++++------------------------ 1 file changed, 158 insertions(+), 158 deletions(-) (limited to 'src/stable/queuebuf.cpp') diff --git a/src/stable/queuebuf.cpp b/src/stable/queuebuf.cpp index 8a3397f..2d49684 100644 --- a/src/stable/queuebuf.cpp +++ b/src/stable/queuebuf.cpp @@ -11,181 +11,181 @@ using Bu::sio; Bu::QueueBuf::QueueBuf( int iBlockSize /*=256*/ ) : - iBlockSize( iBlockSize ), - iReadOffset( 0 ), - iWriteOffset( 0 ), - iTotalSize( 0 ) + iBlockSize( iBlockSize ), + iReadOffset( 0 ), + iWriteOffset( 0 ), + iTotalSize( 0 ) { } Bu::QueueBuf::~QueueBuf() { - for( BlockList::iterator i = lBlocks.begin(); i; i++ ) - delete[] *i; + for( BlockList::iterator i = lBlocks.begin(); i; i++ ) + delete[] *i; } void Bu::QueueBuf::close() { - for( BlockList::iterator i = lBlocks.begin(); i; i++ ) - delete[] *i; - lBlocks.clear(); - iReadOffset = iWriteOffset = iTotalSize = 0; + for( BlockList::iterator i = lBlocks.begin(); i; i++ ) + delete[] *i; + lBlocks.clear(); + iReadOffset = iWriteOffset = iTotalSize = 0; } Bu::size Bu::QueueBuf::read( void *pRawBuf, Bu::size nBytes ) { - if( nBytes <= 0 ) - return 0; - - if( lBlocks.isEmpty() ) - return 0; - - Bu::size iLeft = nBytes; - char *pBuf = (char *)pRawBuf; - - while( iLeft > 0 && iTotalSize > 0 ) - { - if( iReadOffset == iBlockSize ) - { - removeBlock(); - if( lBlocks.isEmpty() ) - { - return nBytes-iLeft; - } - iReadOffset = 0; - } - char *pBlock = lBlocks.first(); - Bu::size iCopy = iBlockSize-iReadOffset; - if( iLeft < iCopy ) - iCopy = iLeft; - if( iTotalSize < iCopy ) - iCopy = iTotalSize; - memcpy( pBuf, pBlock+iReadOffset, iCopy ); - iReadOffset += iCopy; - iLeft -= iCopy; - pBuf += iCopy; - iTotalSize -= iCopy; -// sio << "Read " << iCopy << " bytes, new size: " << iTotalSize << sio.nl; - } - - return nBytes - iLeft; + if( nBytes <= 0 ) + return 0; + + if( lBlocks.isEmpty() ) + return 0; + + Bu::size iLeft = nBytes; + char *pBuf = (char *)pRawBuf; + + while( iLeft > 0 && iTotalSize > 0 ) + { + if( iReadOffset == iBlockSize ) + { + removeBlock(); + if( lBlocks.isEmpty() ) + { + return nBytes-iLeft; + } + iReadOffset = 0; + } + char *pBlock = lBlocks.first(); + Bu::size iCopy = iBlockSize-iReadOffset; + if( iLeft < iCopy ) + iCopy = iLeft; + if( iTotalSize < iCopy ) + iCopy = iTotalSize; + memcpy( pBuf, pBlock+iReadOffset, iCopy ); + iReadOffset += iCopy; + iLeft -= iCopy; + pBuf += iCopy; + iTotalSize -= iCopy; +// sio << "Read " << iCopy << " bytes, new size: " << iTotalSize << sio.nl; + } + + return nBytes - iLeft; } Bu::size Bu::QueueBuf::peek( void *pBuf, Bu::size nBytes ) { - return peek( pBuf, nBytes, 0 ); + return peek( pBuf, nBytes, 0 ); } Bu::size Bu::QueueBuf::peek( void *pRawBuf, Bu::size nBytes, Bu::size nSkip ) { - if( nBytes <= 0 ) - return 0; - - if( lBlocks.isEmpty() ) - return 0; - - Bu::size iLeft = nBytes; - char *pBuf = (char *)pRawBuf; - - int iTmpReadOffset = iReadOffset + nSkip; - Bu::size iTmpRemSize = iTotalSize; - BlockList::iterator iBlock = lBlocks.begin(); - while( iTmpReadOffset > iBlockSize ) - { - iTmpReadOffset -= iBlockSize; - iBlock++; - } - while( iLeft > 0 && iTmpRemSize > 0 ) - { - if( iTmpReadOffset == iBlockSize ) - { - iBlock++; - if( iBlock == lBlocks.end() ) - { - return nBytes-iLeft; - } - iTmpReadOffset = 0; - } - char *pBlock = *iBlock; - Bu::size iCopy = iBlockSize-iTmpReadOffset; - if( iLeft < iCopy ) - iCopy = iLeft; - if( iTmpRemSize < iCopy ) - iCopy = iTmpRemSize; - memcpy( pBuf, pBlock+iTmpReadOffset, iCopy ); - iTmpReadOffset += iCopy; - iLeft -= iCopy; - pBuf += iCopy; - iTmpRemSize -= iCopy; -// sio << "Read (peek) " << iCopy << " bytes, new temp size: " -// << iTmpRemSize << sio.nl; - } - - return nBytes - iLeft; + if( nBytes <= 0 ) + return 0; + + if( lBlocks.isEmpty() ) + return 0; + + Bu::size iLeft = nBytes; + char *pBuf = (char *)pRawBuf; + + int iTmpReadOffset = iReadOffset + nSkip; + Bu::size iTmpRemSize = iTotalSize; + BlockList::iterator iBlock = lBlocks.begin(); + while( iTmpReadOffset > iBlockSize ) + { + iTmpReadOffset -= iBlockSize; + iBlock++; + } + while( iLeft > 0 && iTmpRemSize > 0 ) + { + if( iTmpReadOffset == iBlockSize ) + { + iBlock++; + if( iBlock == lBlocks.end() ) + { + return nBytes-iLeft; + } + iTmpReadOffset = 0; + } + char *pBlock = *iBlock; + Bu::size iCopy = iBlockSize-iTmpReadOffset; + if( iLeft < iCopy ) + iCopy = iLeft; + if( iTmpRemSize < iCopy ) + iCopy = iTmpRemSize; + memcpy( pBuf, pBlock+iTmpReadOffset, iCopy ); + iTmpReadOffset += iCopy; + iLeft -= iCopy; + pBuf += iCopy; + iTmpRemSize -= iCopy; +// sio << "Read (peek) " << iCopy << " bytes, new temp size: " +// << iTmpRemSize << sio.nl; + } + + return nBytes - iLeft; } Bu::size Bu::QueueBuf::write( const void *pRawBuf, Bu::size nBytes ) { - if( nBytes <= 0 ) - return 0; - - if( lBlocks.isEmpty() ) - { - addBlock(); - iWriteOffset = 0; - } - Bu::size iLeft = nBytes; - const char *pBuf = (const char *)pRawBuf; - - while( iLeft > 0 ) - { - if( iWriteOffset == iBlockSize ) - { - addBlock(); - iWriteOffset = 0; - } - char *pBlock = lBlocks.last(); - Bu::size iCopy = iBlockSize-iWriteOffset; - if( iLeft < iCopy ) - iCopy = iLeft; - memcpy( pBlock+iWriteOffset, pBuf, iCopy ); - iWriteOffset += iCopy; - iLeft -= iCopy; - pBuf += iCopy; - iTotalSize += iCopy; -// sio << "Wrote " << iCopy << " bytes, new size: " << iTotalSize -// << sio.nl; - } - - return nBytes; + if( nBytes <= 0 ) + return 0; + + if( lBlocks.isEmpty() ) + { + addBlock(); + iWriteOffset = 0; + } + Bu::size iLeft = nBytes; + const char *pBuf = (const char *)pRawBuf; + + while( iLeft > 0 ) + { + if( iWriteOffset == iBlockSize ) + { + addBlock(); + iWriteOffset = 0; + } + char *pBlock = lBlocks.last(); + Bu::size iCopy = iBlockSize-iWriteOffset; + if( iLeft < iCopy ) + iCopy = iLeft; + memcpy( pBlock+iWriteOffset, pBuf, iCopy ); + iWriteOffset += iCopy; + iLeft -= iCopy; + pBuf += iCopy; + iTotalSize += iCopy; +// sio << "Wrote " << iCopy << " bytes, new size: " << iTotalSize +// << sio.nl; + } + + return nBytes; } Bu::size Bu::QueueBuf::tell() { - return -1; + return -1; } void Bu::QueueBuf::seek( Bu::size iAmnt ) { - if( iAmnt <= 0 ) - return; - - if( (Bu::size)iAmnt >= iTotalSize ) - { -// sio << "seek: clear all data (" << iAmnt << ">=" << iTotalSize -// << ")." << sio.nl; - close(); - return; - } - - iReadOffset += iAmnt; - iTotalSize -= iAmnt; - while( iReadOffset >= iBlockSize ) - { - removeBlock(); - iReadOffset -= iBlockSize; -// sio << "seek: removal step (" << iReadOffset << ")" << sio.nl; - } + if( iAmnt <= 0 ) + return; + + if( (Bu::size)iAmnt >= iTotalSize ) + { +// sio << "seek: clear all data (" << iAmnt << ">=" << iTotalSize +// << ")." << sio.nl; + close(); + return; + } + + iReadOffset += iAmnt; + iTotalSize -= iAmnt; + while( iReadOffset >= iBlockSize ) + { + removeBlock(); + iReadOffset -= iBlockSize; +// sio << "seek: removal step (" << iReadOffset << ")" << sio.nl; + } } void Bu::QueueBuf::setPos( Bu::size ) @@ -198,12 +198,12 @@ void Bu::QueueBuf::setPosEnd( Bu::size ) bool Bu::QueueBuf::isEos() { - return iTotalSize == 0; + return iTotalSize == 0; } bool Bu::QueueBuf::isOpen() { - return true; + return true; } void Bu::QueueBuf::flush() @@ -212,32 +212,32 @@ void Bu::QueueBuf::flush() bool Bu::QueueBuf::canRead() { - return iTotalSize > 0; + return iTotalSize > 0; } bool Bu::QueueBuf::canWrite() { - return true; + return true; } bool Bu::QueueBuf::isReadable() { - return true; + return true; } bool Bu::QueueBuf::isWritable() { - return true; + return true; } bool Bu::QueueBuf::isSeekable() { - return false; + return false; } bool Bu::QueueBuf::isBlocking() { - return false; + return false; } void Bu::QueueBuf::setBlocking( bool ) @@ -250,29 +250,29 @@ void Bu::QueueBuf::setSize( Bu::size ) Bu::size Bu::QueueBuf::getSize() const { - return iTotalSize; + return iTotalSize; } Bu::size Bu::QueueBuf::getBlockSize() const { - return iBlockSize; + return iBlockSize; } Bu::String Bu::QueueBuf::getLocation() const { - return ""; + return ""; } void Bu::QueueBuf::addBlock() { - lBlocks.append( new char[iBlockSize] ); -// sio << "Added new block." << sio.nl; + lBlocks.append( new char[iBlockSize] ); +// sio << "Added new block." << sio.nl; } void Bu::QueueBuf::removeBlock() { - delete[] lBlocks.first(); - lBlocks.erase( lBlocks.begin() ); -// sio << "Removed block." << sio.nl; + delete[] lBlocks.first(); + lBlocks.erase( lBlocks.begin() ); +// sio << "Removed block." << sio.nl; } -- cgit v1.2.3