Mark
34 lines
817 B
C
34 lines
817 B
C
#pragma once
|
|
#include "sys/types.h"
|
|
#include "sys/wait.h"
|
|
#include "sys/spin.h"
|
|
|
|
struct thread;
|
|
|
|
#define RING_SIGNAL_BRK (1 << 0)
|
|
#define RING_SIGNAL_EOF (1 << 1)
|
|
#define RING_SIGNAL_RET (1 << 2)
|
|
#define RING_RAW (1 << 3)
|
|
|
|
// Ring buffer
|
|
struct ring {
|
|
size_t rd, wr;
|
|
size_t cap;
|
|
char *base;
|
|
int flags;
|
|
|
|
// Reader notification
|
|
struct io_notify wait;
|
|
// Writer notification
|
|
struct io_notify writer_wait;
|
|
};
|
|
|
|
int ring_readable(struct ring *b);
|
|
int ring_getc(struct thread *ctx, struct ring *b, char *c, int err);
|
|
|
|
void ring_signal(struct ring *b, int type);
|
|
int ring_putc(struct thread *ctx, struct ring *b, char c, int wait);
|
|
int ring_write(struct thread *ctx, struct ring *b, const void *data, size_t count, int wait);
|
|
|
|
int ring_init(struct ring *b, size_t cap);
|