asyncbufferqueue.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_CORE
#include <promeki/namespace.h>
#include <promeki/buffer.h>
#include <promeki/iodevice.h>
#include <promeki/list.h>
#include <promeki/mutex.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class AsyncBufferQueue : public IODevice {
                PROMEKI_OBJECT(AsyncBufferQueue, IODevice)
        public:
                explicit AsyncBufferQueue(ObjectBase *parent = nullptr);
 
                ~AsyncBufferQueue() override;
 
                Error open(OpenMode mode) override;
 
                Error close() override;
 
                bool isOpen() const override;
 
                int64_t read(void *data, int64_t maxSize) override;
 
                int64_t write(const void *data, int64_t maxSize) override;
 
                int64_t bytesAvailable() const override;
 
                bool isSequential() const override;
 
                Error seek(int64_t pos) override;
 
                int64_t pos() const override;
 
                Result<int64_t> size() const override;
 
                bool atEnd() const override;
 
                // ----------------------------------------------------
                // Producer-side API (thread-safe)
                // ----------------------------------------------------
 
                Error enqueue(const Buffer &segment);
 
                void closeWriting();
 
                bool isWritingClosed() const;
 
                size_t segmentCount() const;
 
        private:
                struct Segment {
                                Buffer buffer;
                                size_t      offset = 0; 
                };
 
                mutable Mutex _mutex;
                List<Segment> _segments;
                int64_t       _queuedBytes = 0;
                int64_t       _readPos = 0;
                bool          _writingClosed = false;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_CORE