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/conduit.cpp | 240 ++++++++++++++++++++++++------------------------- 1 file changed, 120 insertions(+), 120 deletions(-) (limited to 'src/stable/conduit.cpp') diff --git a/src/stable/conduit.cpp b/src/stable/conduit.cpp index 8f5eba5..4c2fda6 100644 --- a/src/stable/conduit.cpp +++ b/src/stable/conduit.cpp @@ -8,9 +8,9 @@ #include "bu/conduit.h" Bu::Conduit::Conduit( int iBlockSize ) : - qb( iBlockSize ), - bBlocking( true ), - bOpen( true ) + qb( iBlockSize ), + bBlocking( true ), + bOpen( true ) { } @@ -20,100 +20,100 @@ Bu::Conduit::~Conduit() void Bu::Conduit::close() { - im.lock(); -// qb.close(); - bOpen = false; - - cBlock.signal(); - im.unlock(); + im.lock(); +// qb.close(); + bOpen = false; + + cBlock.signal(); + im.unlock(); } #include Bu::size Bu::Conduit::read( void *pBuf, Bu::size nBytes ) { - if( !isOpen() ) - { - return 0; - } - im.lock(); - if( bBlocking ) - { - im.unlock(); - cBlock.lock(); - for(;;) - { - im.lock(); - if( qb.getSize() == 0 && bOpen == false ) - { - im.unlock(); - cBlock.unlock(); - return 0; - } - else if( qb.getSize() > 0 ) - { - im.unlock(); - break; - } - im.unlock(); - - cBlock.wait(); - } - - im.lock(); - Bu::size iRet = qb.read( pBuf, nBytes ); - im.unlock(); - - cBlock.unlock(); - return iRet; - } - else - { - Bu::size iRet = qb.read( pBuf, nBytes ); - im.unlock(); - - return iRet; - } + if( !isOpen() ) + { + return 0; + } + im.lock(); + if( bBlocking ) + { + im.unlock(); + cBlock.lock(); + for(;;) + { + im.lock(); + if( qb.getSize() == 0 && bOpen == false ) + { + im.unlock(); + cBlock.unlock(); + return 0; + } + else if( qb.getSize() > 0 ) + { + im.unlock(); + break; + } + im.unlock(); + + cBlock.wait(); + } + + im.lock(); + Bu::size iRet = qb.read( pBuf, nBytes ); + im.unlock(); + + cBlock.unlock(); + return iRet; + } + else + { + Bu::size iRet = qb.read( pBuf, nBytes ); + im.unlock(); + + return iRet; + } } Bu::size Bu::Conduit::peek( void *pBuf, Bu::size nBytes ) { - im.lock(); - Bu::size iRet = qb.peek( pBuf, nBytes ); - im.unlock(); + im.lock(); + Bu::size iRet = qb.peek( pBuf, nBytes ); + im.unlock(); - return iRet; + return iRet; } Bu::size Bu::Conduit::peek( void *pBuf, Bu::size nBytes, Bu::size nSkip ) { - im.lock(); - Bu::size iRet = qb.peek( pBuf, nBytes, nSkip ); - im.unlock(); + im.lock(); + Bu::size iRet = qb.peek( pBuf, nBytes, nSkip ); + im.unlock(); - return iRet; + return iRet; } Bu::size Bu::Conduit::write( const void *pBuf, Bu::size nBytes ) { - im.lock(); - if( bOpen == false ) - { - im.unlock(); - return 0; - } - Bu::size sRet = qb.write( pBuf, nBytes ); - cBlock.signal(); - im.unlock(); + im.lock(); + if( bOpen == false ) + { + im.unlock(); + return 0; + } + Bu::size sRet = qb.write( pBuf, nBytes ); + cBlock.signal(); + im.unlock(); - return sRet; + return sRet; } Bu::size Bu::Conduit::tell() { - im.lock(); - Bu::size sRet = qb.tell(); - im.unlock(); - return sRet; + im.lock(); + Bu::size sRet = qb.tell(); + im.unlock(); + return sRet; } void Bu::Conduit::seek( Bu::size ) @@ -130,18 +130,18 @@ void Bu::Conduit::setPosEnd( Bu::size ) bool Bu::Conduit::isEos() { - im.lock(); - bool bRet = qb.isEos(); - im.unlock(); - return bRet; + im.lock(); + bool bRet = qb.isEos(); + im.unlock(); + return bRet; } bool Bu::Conduit::isOpen() { - im.lock(); - bool bRet = bOpen || (qb.getSize() > 0); - im.unlock(); - return bRet; + im.lock(); + bool bRet = bOpen || (qb.getSize() > 0); + im.unlock(); + return bRet; } void Bu::Conduit::flush() @@ -150,57 +150,57 @@ void Bu::Conduit::flush() bool Bu::Conduit::canRead() { - im.lock(); - bool bRet = qb.canRead(); - im.unlock(); - return bRet; + im.lock(); + bool bRet = qb.canRead(); + im.unlock(); + return bRet; } bool Bu::Conduit::canWrite() { - im.lock(); - bool bRet = qb.canWrite(); - im.unlock(); - return bRet; + im.lock(); + bool bRet = qb.canWrite(); + im.unlock(); + return bRet; } bool Bu::Conduit::isReadable() { - im.lock(); - bool bRet = qb.isReadable(); - im.unlock(); - return bRet; + im.lock(); + bool bRet = qb.isReadable(); + im.unlock(); + return bRet; } bool Bu::Conduit::isWritable() { - im.lock(); - bool bRet = qb.isWritable(); - im.unlock(); - return bRet; + im.lock(); + bool bRet = qb.isWritable(); + im.unlock(); + return bRet; } bool Bu::Conduit::isSeekable() { - im.lock(); - bool bRet = qb.isSeekable(); - im.unlock(); - return bRet; + im.lock(); + bool bRet = qb.isSeekable(); + im.unlock(); + return bRet; } bool Bu::Conduit::isBlocking() { - im.lock(); - bool bRet = bBlocking; - im.unlock(); - return bRet; + im.lock(); + bool bRet = bBlocking; + im.unlock(); + return bRet; } void Bu::Conduit::setBlocking( bool bBlocking ) { - im.lock(); - this->bBlocking = bBlocking; - im.unlock(); + im.lock(); + this->bBlocking = bBlocking; + im.unlock(); } void Bu::Conduit::setSize( Bu::size ) @@ -209,25 +209,25 @@ void Bu::Conduit::setSize( Bu::size ) Bu::size Bu::Conduit::getSize() const { - im.lock(); - Bu::size sRet = qb.getSize(); - im.unlock(); - return sRet; + im.lock(); + Bu::size sRet = qb.getSize(); + im.unlock(); + return sRet; } Bu::size Bu::Conduit::getBlockSize() const { - im.lock(); - Bu::size sRet = qb.getBlockSize(); - im.unlock(); - return sRet; + im.lock(); + Bu::size sRet = qb.getBlockSize(); + im.unlock(); + return sRet; } Bu::String Bu::Conduit::getLocation() const { - im.lock(); - Bu::String sRet = qb.getLocation(); - im.unlock(); - return sRet; + im.lock(); + Bu::String sRet = qb.getLocation(); + im.unlock(); + return sRet; } -- cgit v1.2.3