/*
 * Copyright 2008, Axel Dörfler, axeld@pinc-software.de.
 * Distributed under the terms of the MIT License.
 */
#ifndef ADAPTIVE_BUFFERING_H
#define ADAPTIVE_BUFFERING_H


#include <OS.h>


class AdaptiveBuffering {
public:
                                                        AdaptiveBuffering(size_t initialBufferSize,
                                                                size_t maxBufferSize, uint32 count);
        virtual                                 ~AdaptiveBuffering();

        virtual status_t                Init();

        virtual status_t                Read(uint8* buffer, size_t* _length);
        virtual status_t                Write(uint8* buffer, size_t length);

                        status_t                Run();

private:
                        void                    _QuitWriter();
                        status_t                _Writer();
        static  status_t                _Writer(void* self);

                        thread_id               fWriterThread;
                        uint8**                 fBuffers;
                        size_t*                 fReadBytes;
                        uint32                  fBufferCount;
                        uint32                  fReadIndex;
                        uint32                  fWriteIndex;
                        uint32                  fReadCount;
                        uint32                  fWriteCount;
                        size_t                  fMaxBufferSize;
                        size_t                  fCurrentBufferSize;
                        sem_id                  fReadSem;
                        sem_id                  fWriteSem;
                        sem_id                  fFinishedSem;
                        status_t                fWriteStatus;
                        uint32                  fWriteTime;
                        bool                    fFinished;
                        bool                    fQuit;
};

#endif  // ADAPTIVE_BUFFERING_H