--- a/src/server/io.h Wed Dec 28 10:57:36 2011 +0100 +++ b/src/server/io.h Wed Dec 28 22:02:08 2011 +0100 @@ -50,6 +50,17 @@ int fd; } SystemIOStream; +typedef struct NetIOStream { + IOStream st; + int fd; + size_t max_read; + size_t rd; +} NetIOStream; + + +/* net_ functions */ +ssize_t net_read(SYS_NETFD fd, void *buf, size_t nbytes); + /* iovec buffer */ typedef struct iovec_buf{ @@ -66,6 +77,11 @@ ssize_t system_write(IOStream *st, void *buf, size_t nbytes); ssize_t system_read(IOStream *st, void *buf, size_t nbytes); +/* net stream */ +IOStream* net_stream_from_fd(int fd); + +ssize_t net_stream_write(IOStream *st, void *buf, size_t nbytes); +ssize_t net_stream_read(IOStream *st, void *buf, size_t nbytes); /* iovec buffer */ iovec_buf_t *iovec_buf_create(pool_handle_t *pool);