46 lines
1000 B
C
46 lines
1000 B
C
|
typedef enum {
|
||
|
|
IO_TASK_READ_LINE,
|
||
|
|
IO_TASK_READ_COUNT,
|
||
|
|
IO_TASK_WRITE,
|
||
|
|
IO_TASK_ACCEPT
|
||
|
|
} IO_TASK_TYPE;
|
||
|
|
|
||
|
|
typedef struct {
|
||
|
|
IO_TASK_TYPE type;
|
||
|
|
CELL port;
|
||
|
|
CELL callback;
|
||
|
|
} IO_TASK;
|
||
|
|
|
||
|
|
fd_set read_fd_set;
|
||
|
|
IO_TASK read_io_tasks[FD_SETSIZE];
|
||
|
|
int read_fd_count;
|
||
|
|
|
||
|
|
fd_set write_fd_set;
|
||
|
|
IO_TASK write_io_tasks[FD_SETSIZE];
|
||
|
|
int write_fd_count;
|
||
|
|
|
||
|
|
fd_set except_fd_set;
|
||
|
|
|
||
|
|
void init_io_tasks(fd_set* fd_set, IO_TASK* io_tasks);
|
||
|
|
void init_io(void);
|
||
|
|
IO_TASK* add_io_task(
|
||
|
|
IO_TASK_TYPE type,
|
||
|
|
PORT* port,
|
||
|
|
CELL callback,
|
||
|
|
IO_TASK* io_tasks,
|
||
|
|
int* fd_count);
|
||
|
|
void primitive_add_accept_io_task(void);
|
||
|
|
void remove_io_task(
|
||
|
|
IO_TASK_TYPE type,
|
||
|
|
PORT* port,
|
||
|
|
IO_TASK* io_tasks,
|
||
|
|
int* fd_count);
|
||
|
|
void remove_io_tasks(PORT* port);
|
||
|
|
bool set_up_fd_set(fd_set* fdset, int fd_count, IO_TASK* io_tasks);
|
||
|
|
CELL perform_io_task(IO_TASK* task);
|
||
|
|
CELL perform_io_tasks(fd_set* fdset, int fd_count, IO_TASK* io_tasks);
|
||
|
|
CELL next_io_task(void);
|
||
|
|
void primitive_next_io_task(void);
|
||
|
|
void primitive_close(void);
|
||
|
|
void collect_io_tasks(void);
|