src/server/util/io.h

changeset 65
14722c5f8856
parent 64
c7f5b062e622
child 66
74babc0082b7
equal deleted inserted replaced
64:c7f5b062e622 65:14722c5f8856
57 typedef struct NetIOStream { 57 typedef struct NetIOStream {
58 IOStream st; 58 IOStream st;
59 int fd; 59 int fd;
60 size_t max_read; 60 size_t max_read;
61 size_t rd; 61 size_t rd;
62 int chunkedenc;
63 int buffered;
62 } NetIOStream; 64 } NetIOStream;
63 65
64 66
65 /* net_ functions */ 67 /* net_ functions */
66 ssize_t net_read(SYS_NETFD fd, void *buf, size_t nbytes); 68 ssize_t net_read(SYS_NETFD fd, void *buf, size_t nbytes);
86 ssize_t system_read(IOStream *st, void *buf, size_t nbytes); 88 ssize_t system_read(IOStream *st, void *buf, size_t nbytes);
87 89
88 /* net stream */ 90 /* net stream */
89 IOStream* net_stream_from_fd(pool_handle_t *pool, int fd); 91 IOStream* net_stream_from_fd(pool_handle_t *pool, int fd);
90 92
91 ssize_t net_stream_write(IOStream *st, void *buf, size_t nbytes); 93 ssize_t net_stream_write(NetIOStream *st, void *buf, size_t nbytes);
92 ssize_t net_stream_writev(IOStream *st, struct iovec *iovec, int iovcnt); 94 ssize_t net_stream_writev(NetIOStream *st, struct iovec *iovec, int iovcnt);
93 ssize_t net_stream_read(IOStream *st, void *buf, size_t nbytes); 95 ssize_t net_stream_read(NetIOStream *st, void *buf, size_t nbytes);
94 ssize_t net_stream_sendfile(IOStream *st, sendfiledata *sfd); 96 ssize_t net_stream_sendfile(NetIOStream *st, sendfiledata *sfd);
95 97
96 /* iovec buffer */ 98 /* iovec buffer */
97 iovec_buf_t *iovec_buf_create(pool_handle_t *pool); 99 iovec_buf_t *iovec_buf_create(pool_handle_t *pool);
98 void iovec_buf_write(iovec_buf_t *io, void *buf, size_t nbyte); 100 void iovec_buf_write(iovec_buf_t *io, void *buf, size_t nbyte);
99 ssize_t iovec_buf_flush(iovec_buf_t *io, int fd); 101 ssize_t iovec_buf_flush(iovec_buf_t *io, int fd);

mercurial