Standard Portable Library: spl/io/BlockingStream.h Source File

00001 /*
00002  *   This file is part of the Standard Portable Library (SPL).
00003  *
00004  *   SPL is free software: you can redistribute it and/or modify
00005  *   it under the terms of the GNU General Public License as published by
00006  *   the Free Software Foundation, either version 3 of the License, or
00007  *   (at your option) any later version.
00008  *
00009  *   SPL is distributed in the hope that it will be useful,
00010  *   but WITHOUT ANY WARRANTY; without even the implied warranty of
00011  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
00012  *   GNU General Public License for more details.
00013  *
00014  *   You should have received a copy of the GNU General Public License
00015  *   along with SPL.  If not, see <http://www.gnu.org/licenses/>.
00016  */
00017 #ifndef _blockingstream_h
00018 #define _blockingstream_h
00019 
00020 #include <spl/io/Stream.h>
00021 
00028 class BlockingStream;
00029 typedef RefCountPtrCast<BlockingStream, spl::IStream, spl::IStreamPtr> BlockingStreamPtr;
00030 typedef WeakReference<BlockingStream, spl::IStreamPtr> BlockingStreamRef;
00031 
00032 REGISTER_TYPEOF(72, BlockingStreamPtr);
00033 REGISTER_TYPEOF( 448, BlockingStreamRef );
00034 
00036 class BlockingStream : public spl::IStream
00037 {
00038 protected:
00039         spl::IStreamPtr m_strm;
00040         bool m_deleteStream;
00041         Mutex m_datalock;
00042         Event m_dataready;
00043 
00044 public:
00045         BlockingStream( spl::IStreamPtr strm );
00046         virtual ~BlockingStream();
00047 
00048         virtual int Read(Array<byte>& buffer, const int offset, int count);
00049         virtual int ReadByte();
00050         virtual void Write(const Array<byte>& buffer, const int offset, const int count);
00051         virtual void WriteByte(byte value);
00052 
00053         virtual void Close();
00054         virtual void Flush();
00055         virtual long Seek(const long offset, const SeekOrigin origin);
00056 
00057         virtual bool CanRead() const;
00058         virtual bool CanSeek() const;
00059         virtual bool CanWrite() const;
00060 
00061         virtual long Length() const;
00062         virtual long Position() const;
00063 
00064 #ifdef DEBUG
00065         virtual void ValidateMem() const;
00066         virtual void CheckMem() const;
00067 #endif
00068 };
00069 
00070 REGISTER_TYPEOF(74, BlockingStream);
00071 
00074 #endif