ring_buffer
ring_buffer primary_ring_buffer;
ring_buffer primary_ring_buffer;
struct ring_buffer *create_ring_buffer(size_t size);
struct ring_buffer *create_ring_buffer_etc(void *memory, size_t size,
void delete_ring_buffer(struct ring_buffer *buffer);
void ring_buffer_clear(struct ring_buffer *buffer);
size_t ring_buffer_readable(struct ring_buffer *buffer);
size_t ring_buffer_writable(struct ring_buffer *buffer);
void ring_buffer_flush(struct ring_buffer *buffer, size_t bytes);
size_t ring_buffer_read(struct ring_buffer *buffer, uint8 *data, ssize_t length);
size_t ring_buffer_write(struct ring_buffer *buffer, const uint8 *data, ssize_t length);
ssize_t ring_buffer_user_read(struct ring_buffer *buffer, uint8 *data, ssize_t length);
ssize_t ring_buffer_user_write(struct ring_buffer *buffer, const uint8 *data, ssize_t length);
size_t ring_buffer_peek(struct ring_buffer *buffer, size_t offset, void *data, size_t length);
ssize_t ring_buffer_user_peek(struct ring_buffer *buffer, size_t offset, void *data, ssize_t length);
int32 ring_buffer_get_vecs(struct ring_buffer *buffer, struct iovec *vecs);
size_t ring_buffer_move(struct ring_buffer *to, ssize_t length, struct ring_buffer *from);
extern void uninit_ring_buffer(ring_buffer &ringBuffer);
extern void setup_ring_buffer(ring_buffer &ringBuffer, const char* name);
QueueCommands(ring_buffer &ring);
ring_buffer &fRingBuffer;
uninit_ring_buffer(ring_buffer &ringBuffer)
setup_ring_buffer(ring_buffer &ringBuffer, const char* name)
ring_buffer &ring = gInfo->shared_info->primary_ring_buffer;
QueueCommands::QueueCommands(ring_buffer &ring)
ring_buffer *fBuffer;
struct ring_buffer;
struct ring_buffer* buffer;
if (packet_buffer_read(cookie->ring_buffer, event_buffer,
cookie->ring_buffer = create_packet_buffer(
if (cookie->ring_buffer == NULL) {
delete_packet_buffer(cookie->ring_buffer);
delete_packet_buffer(cookie->ring_buffer);
if (packet_buffer_write(cookie->ring_buffer,
struct packet_buffer* ring_buffer;
cookie->ring_buffer = create_packet_buffer(
if (cookie->ring_buffer == NULL) {
delete_packet_buffer(cookie->ring_buffer);
delete_packet_buffer(cookie->ring_buffer);
if (packet_buffer_write(cookie->ring_buffer,
if (packet_buffer_read(cookie->ring_buffer, packet,
struct packet_buffer* ring_buffer;
ring_buffer &primary = info.shared_info->primary_ring_buffer;
struct ring_buffer *fRingBuffer;
struct ring_buffer* rbuf;
struct ring_buffer rb;
void rb_init(struct ring_buffer *rb, size_t size)
void rb_clear(struct ring_buffer *rb)
size_t rb_can_write(struct ring_buffer *rb)
size_t rb_can_read(struct ring_buffer *rb)
size_t rb_write(struct ring_buffer *rb, void *data, size_t len)
size_t rb_read(struct ring_buffer *rb, void *data, size_t len)
void rb_init(struct ring_buffer *rb, size_t size);
void rb_clear(struct ring_buffer *rb);
size_t rb_can_write(struct ring_buffer *rb);
size_t rb_can_read(struct ring_buffer *rb);
size_t rb_write(struct ring_buffer *rb, void *data, size_t len);
size_t rb_read(struct ring_buffer *rb, void *data, size_t len);
ring_buffer* newBuffer = create_ring_buffer(capacity);
ring_buffer* fBuffer;
struct ring_buffer;
ring_buffer* buffer = (ring_buffer*)gKernelArgs.debug_output.Pointer();
TextSource(ring_buffer* buffer)
ring_buffer* fBuffer;
ring_buffer* syslogBuffer
= (ring_buffer*)gKernelArgs.debug_output.Pointer();
ring_buffer* syslogBuffer
= (ring_buffer*)gKernelArgs.debug_output.Pointer();
static ring_buffer* sDebugSyslogBuffer = NULL;
static ring_buffer* sDebugSyslogBuffer = NULL;
static struct ring_buffer* sSyslogBuffer;
buffer_peek(struct ring_buffer* buffer, size_t offset, void* data,
struct ring_buffer*
struct ring_buffer*
ring_buffer* buffer = (ring_buffer*)malloc(sizeof(ring_buffer) + size);
size -= sizeof(ring_buffer);
ring_buffer* buffer = (ring_buffer*)memory;
delete_ring_buffer(struct ring_buffer *buffer)
ring_buffer_clear(struct ring_buffer *buffer)
ring_buffer_readable(struct ring_buffer *buffer)
ring_buffer_writable(struct ring_buffer *buffer)
ring_buffer_flush(struct ring_buffer *buffer, size_t length)
ring_buffer_read(struct ring_buffer *buffer, uint8 *data, ssize_t length)
ring_buffer_write(struct ring_buffer *buffer, const uint8 *data, ssize_t length)
ring_buffer_user_read(struct ring_buffer *buffer, uint8 *data, ssize_t length)
ring_buffer_user_write(struct ring_buffer *buffer, const uint8 *data, ssize_t length)
ring_buffer_peek(struct ring_buffer* buffer, size_t offset, void* data,
ring_buffer_user_peek(struct ring_buffer* buffer, size_t offset, void* data,
ring_buffer_get_vecs(struct ring_buffer* buffer, struct iovec* vecs)
space_left_in_buffer(struct ring_buffer *buffer)
ring_buffer_move(struct ring_buffer *to, ssize_t length,
struct ring_buffer *from)
ring_buffer_write_to_port(struct ring_buffer *buffer, port_id port, int32 code,
read_from_buffer(struct ring_buffer *buffer, uint8 *data, ssize_t length,
write_to_buffer(struct ring_buffer *buffer, const uint8 *data, ssize_t length,