bufferediodevice.h

Go to the documentation of this file.

 
#pragma once
 
#include <promeki/core/iodevice.h>
#include <promeki/core/buffer.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class BufferedIODevice : public IODevice {
        PROMEKI_OBJECT(BufferedIODevice, IODevice)
        public:
                BufferedIODevice(ObjectBase *parent = nullptr);
 
                virtual ~BufferedIODevice();
 
                int64_t read(void *data, int64_t maxSize) override;
 
                int64_t bytesAvailable() const override;
 
                Error setReadBuffer(Buffer &&buf);
 
                const Buffer &readBuffer() const { return _readBuf; }
 
                size_t readBufferSize() const { return _readBuf.availSize(); }
 
                Buffer readLine(size_t maxLength = 0);
 
                Buffer readAll();
 
                Buffer readBytes(size_t maxBytes);
 
                bool canReadLine() const;
 
                int64_t peek(void *buf, size_t maxBytes) const;
 
                Buffer peek(size_t maxBytes) const;
 
                void setUnbuffered(bool enable);
 
                bool isUnbuffered() const { return _unbuffered; }
 
        protected:
 
                virtual int64_t readFromDevice(void *data, int64_t maxSize) = 0;
 
                virtual int64_t deviceBytesAvailable() const;
 
                size_t bufferedBytesUnconsumed() const {
                        return _readBufFill - _readBufPos;
                }
 
                void ensureReadBuffer();
 
                void resetReadBuffer();
 
        private:
                static constexpr size_t DefaultReadBufSize = 8192;
 
                bool    _unbuffered = false;              
                Buffer  _readBuf;                        
                size_t  _readBufPos = 0;                 
                size_t  _readBufFill = 0;                
                bool    _bufferAllocated = false;        
 
                int64_t fillBuffer();
 
                void compactBuffer();
};
 
PROMEKI_NAMESPACE_END