50 lines
1.0 KiB
C
50 lines
1.0 KiB
C
#define BUF_SIZE (8 * 1024)
|
|
|
|
typedef enum {
|
|
PORT_READ,
|
|
PORT_RECV,
|
|
PORT_WRITE,
|
|
PORT_SPECIAL
|
|
} PORT_MODE;
|
|
|
|
typedef struct {
|
|
CELL header;
|
|
PORT_MODE type;
|
|
bool closed;
|
|
FIXNUM fd;
|
|
STRING* buffer;
|
|
|
|
/* top of buffer */
|
|
CELL buf_fill;
|
|
/* current read/write position */
|
|
CELL buf_pos;
|
|
|
|
/* tagged partial line used by read_line_fd */
|
|
CELL line;
|
|
/* is it ready to be returned? */
|
|
/* with the read# IO_TASK, this means that the operation is done */
|
|
bool line_ready;
|
|
|
|
/* count for read# */
|
|
FIXNUM count;
|
|
|
|
/* tagged client info used by accept_fd */
|
|
CELL client_host;
|
|
CELL client_port;
|
|
/* untagged fd of accepted connection */
|
|
CELL client_socket;
|
|
|
|
/* a pending I/O error or F */
|
|
CELL io_error;
|
|
} PORT;
|
|
|
|
PORT* untag_port(CELL tagged);
|
|
PORT* port(PORT_MODE type, CELL fd);
|
|
void init_line_buffer(PORT* port, FIXNUM count);
|
|
void fixup_port(PORT* port);
|
|
void collect_port(PORT* port);
|
|
void postpone_io_error(PORT* port, const char* func);
|
|
void io_error(const char* func);
|
|
void pending_io_error(PORT* port);
|
|
void primitive_pending_io_error(void);
|