* Copyright 2022 Haiku, Inc. All rights reserved.
* Distributed under the terms of the MIT License.
*/
#ifndef _MEMORY_RING_IO_H
#define _MEMORY_RING_IO_H
#include <pthread.h>
#include <DataIO.h>
#include <Locker.h>
class BMemoryRingIO : public BDataIO {
public:
BMemoryRingIO(size_t size);
virtual ~BMemoryRingIO();
status_t InitCheck() const;
virtual ssize_t Read(void* buffer, size_t size);
virtual ssize_t Write(const void* buffer, size_t size);
status_t SetSize(size_t size);
void Clear();
size_t BytesAvailable();
size_t SpaceAvailable();
size_t BufferSize();
status_t WaitForRead(
bigtime_t timeout = B_INFINITE_TIMEOUT);
status_t WaitForWrite(
bigtime_t timeout = B_INFINITE_TIMEOUT);
void SetWriteDisabled(bool disabled);
bool WriteDisabled();
private:
template<typename Condition>
status_t _WaitForCondition(bigtime_t timeout);
private:
pthread_mutex_t fLock;
pthread_cond_t fEvent;
uint8* fBuffer;
size_t fBufferSize;
size_t fWriteAtNext;
size_t fReadAtNext;
bool fBufferFull;
bool fWriteDisabled;
uint32 _reserved[4];
};
#endif
