factor/native/port.h

#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);