#ifndef KERNEL_RINGBUFFER_H_ #define KERNEL_RINGBUFFER_H_ #include #include #include #include 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