/*
 * Copyright 2009, Haiku, Inc.
 * Distributed under the terms of the MIT License.
 *
 * Authors:
 *		Michael Lotz <mmlr@mlotz.ch>
 */
#ifndef STREAMING_RING_BUFFER_H
#define STREAMING_RING_BUFFER_H

#include <OS.h>
#include <SupportDefs.h>
#include <Locker.h>

class StreamingRingBuffer {
public:
								StreamingRingBuffer(size_t bufferSize);
								~StreamingRingBuffer();

		status_t				InitCheck();

		// blocking read and write
		int32					Read(void *buffer, size_t length,
									bool onlyBlockOnNoData = false);
		status_t				Write(const void *buffer, size_t length);

		void					MakeEmpty();

private:
		bool					fReaderWaiting;
		bool					fWriterWaiting;
		bool					fCancelRead;
		bool					fCancelWrite;
		sem_id					fReaderNotifier;
		sem_id					fWriterNotifier;

		BLocker					fReaderLocker;
		BLocker					fWriterLocker;
		BLocker					fDataLocker;

		uint8 *					fBuffer;
		size_t					fBufferSize;
		size_t					fReadable;
		int32					fReadPosition;
		int32					fWritePosition;
};

#endif // STREAMING_RING_BUFFER_H