1 files changed, 158 insertions, 158 deletions

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;
 }