35 lines
1.1 KiB
C
35 lines
1.1 KiB
C
|
#ifndef KERNEL_RINGBUFFER_H_
|
||
|
|
#define KERNEL_RINGBUFFER_H_
|
||
|
|
|
||
|
|
#include <kernel/locks.h>
|
||
|
|
#include <kernel/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;
|
||
|
|
};
|
||
|
|
|
||
|
|
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, mango_flags_t flags);
|
||
|
|
extern size_t ringbuffer_write(struct ringbuffer *buf, size_t size, const void *buffer, mango_flags_t flags);
|
||
|
|
|
||
|
|
/* TODO */
|
||
|
|
//extern size_t ringbuffer_peek(struct ringbuffer *buf, size_t at, size_t size, void *buffer);
|
||
|
|
//extern size_t ringbuffer_skip(struct ringbuffer *buf, size_t count);
|
||
|
|
|
||
|
|
extern int ringbuffer_write_would_block(struct ringbuffer *buf);
|
||
|
|
|
||
|
|
#endif
|