ByteStream.h

// $Id: ByteStream.h 21 2010-09-05 04:18:17Z cschwarz1 $

#ifndef BASE_BYTESTREAM_H
#define BASE_BYTESTREAM_H

#include "Condition.h"
#include "String.h"

namespace base {
    class PPBASE_EXPORT ByteStream {
    public:
        ByteStream(size_t size = 0);

        ~ByteStream();

        void allocate(size_t size);

        void clear();

        bool empty();

        bool eos();

        size_t getWaitsRead() const;

        size_t getWaitsWrite() const;

        size_t read(void *buffer, size_t len, bool exact = true);

        size_t read(base::String &buffer, size_t len, bool exact = true);

        void reset();

        void seteos(bool immediate);

        size_t write(const void *buffer, size_t len, bool exact = true);

        size_t write(const base::String &buffer, bool exact = true);

    private:
        char      *_buffer;    
        Condition  _condrd;    
        Condition  _condwr;    
        bool       _eos;       
        bool       _eosp;      
        bool       _full;      
        Mutex      _mutex;     
        size_t     _nwaitrd;   
        size_t     _nwaitwr;   
        char      *_readptr;   
        size_t     _size;      
        bool       _waitrd;    
        bool       _waitwr;    
        char      *_writeptr;  

        DISALLOW_COPY_CONSTRUCTOR_AND_ASSIGNMENT(ByteStream);
    };
}

#endif