#ifndef SOCKS_RINGBUFFER_H_
#define SOCKS_RINGBUFFER_H_

#include <socks/locks.h>
#include <socks/sched.h>

struct ringbuffer {
	unsigned char *r_buffer;
	size_t r_write_ptr;
	size_t r_read_ptr;
	size_t r_size;
	spin_lock_t r_lock;
	struct waitqueue r_wait_readers;
	struct waitqueue r_wait_writers;
};

enum ringbuffer_flags {
	RB_NORMAL = 0x00u,
	RB_NOBLOCK = 0x01u,
};

extern struct ringbuffer *ringbuffer_create(size_t size);
extern void ringbuffer_destroy(struct ringbuffer *buf);

extern kern_status_t ringbuffer_init(struct ringbuffer *buf, size_t size);
extern kern_status_t ringbuffer_deinit(struct ringbuffer *buf);

extern size_t ringbuffer_unread(struct ringbuffer *buf);
extern size_t ringbuffer_avail(struct ringbuffer *buf);
extern size_t ringbuffer_read(struct ringbuffer *buf, size_t size, void *buffer, enum ringbuffer_flags flags);
extern size_t ringbuffer_write(struct ringbuffer *buf, size_t size, const void *buffer, enum ringbuffer_flags flags);

extern int ringbuffer_write_would_block(struct ringbuffer *buf);

#endif