* 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
