1 files changed, 162 insertions, 0 deletions

diff --git a/src/unstable/fifo.cpp b/src/unstable/fifo.cpp
new file mode 100644
index 0000000..b0cf1c7
--- /dev/null
+++ b/src/unstable/fifo.cpp
@@ -0,0 +1,162 @@
+/*
+ * Copyright (C) 2007-2011 Xagasoft, All rights reserved.
+ *
+ * This file is part of the libbu++ library and is released under the
+ * terms of the license contained in the file LICENSE.
+ */
+
+#include "bu/fifo.h"
+#include <errno.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <unistd.h>
+
+#include "bu/config.h"
+
+namespace Bu { subExceptionDef( FifoException ) }
+
+Bu::Fifo::Fifo( const Bu::String &sName, int iFlags, mode_t mAcc ) :
+        iFlags( iFlags ),
+        iIn( -1 ),
+        iOut( -1 )
+{
+#ifndef WIN32
+        if( iFlags&Create )
+        {
+                if( mkfifo( sName.getStr(), mAcc ) )
+                {
+                        throw FifoException("Error creating fifo: %s\n", strerror( errno ) );
+                }
+        }
+        if( iFlags&Read )
+        {
+                iIn = ::open(
+                        sName.getStr(),
+                        O_RDONLY|((iFlags&NonBlock)?O_NONBLOCK:0)
+                        );
+        }
+        if( iFlags&Write )
+        {
+                iOut = ::open(
+                        sName.getStr(),
+                        O_WRONLY
+                        );
+        }
+#else
+        #warning Bu::Fifo::Fifo IS A STUB for WIN32!!!! 
+#endif
+}
+
+Bu::Fifo::~Fifo()
+{
+        close();
+}
+
+void Bu::Fifo::close()
+{
+        if( iIn > -1 )
+        {
+                ::close( iIn );
+                iIn = -1;
+        }
+        if( iOut > -1 )
+        {
+                ::close( iOut );
+                iOut = -1;
+        }
+}
+
+Bu::size Bu::Fifo::read( void *pBuf, Bu::size nBytes )
+{
+        if( iIn < 0 )
+                throw FifoException("Fifo not open for reading.");
+
+        return TEMP_FAILURE_RETRY( ::read( iIn, pBuf, nBytes ) );
+}
+
+Bu::size Bu::Fifo::write( const void *pBuf, Bu::size nBytes )
+{
+        if( iOut < 0 )
+                throw FifoException("Fifo not open for writing.");
+
+        return TEMP_FAILURE_RETRY( ::write( iOut, pBuf, nBytes ) );
+}
+
+Bu::size Bu::Fifo::tell()
+{
+        return -1;
+}
+
+void Bu::Fifo::seek( Bu::size )
+{
+}
+
+void Bu::Fifo::setPos( Bu::size )
+{
+}
+
+void Bu::Fifo::setPosEnd( Bu::size )
+{
+}
+
+bool Bu::Fifo::isEos()
+{
+        return false;
+}
+
+bool Bu::Fifo::canRead()
+{
+        return (iIn>-1);
+}
+
+bool Bu::Fifo::canWrite()
+{
+        return (iOut>-1);
+}
+
+bool Bu::Fifo::isReadable()
+{
+        return (iIn>-1);
+}
+
+bool Bu::Fifo::isWritable()
+{
+        return (iOut>-1);
+}
+
+bool Bu::Fifo::isSeekable()
+{
+        return false;
+}
+
+bool Bu::Fifo::isBlocking()
+{
+#ifndef WIN32
+        return ((fcntl( iIn, F_GETFL, 0 )&O_NONBLOCK) == O_NONBLOCK);
+#else
+        #warning Bu::Fifo::isBlocking IS A STUB for WIN32!!!!
+#endif  
+}
+
+void Bu::Fifo::setBlocking( bool bBlocking )
+{
+#ifndef WIN32
+        if( bBlocking )
+                fcntl( iIn, F_SETFL, fcntl( iIn, F_GETFL, 0 )&(~O_NONBLOCK) );
+        else
+                fcntl( iIn, F_SETFL, fcntl( iIn, F_GETFL, 0 )|O_NONBLOCK );
+#else
+        #warning Bu::Fifo::setBlocking IS A STUB for WIN32!!!!
+#endif  
+}
+
+void Bu::Fifo::flush()
+{
+}
+
+bool Bu::Fifo::isOpen()
+{
+        return (iIn > -1) || (iOut > -1);
+}
+