302 return fd->writev(fd, iovec, iovcnt); |
302 return fd->writev(fd, iovec, iovcnt); |
303 } |
303 } |
304 } |
304 } |
305 |
305 |
306 ssize_t net_http_read(HttpStream *st, void *buf, size_t nbytes) { |
306 ssize_t net_http_read(HttpStream *st, void *buf, size_t nbytes) { |
307 if(st->max_read != 0 && st->read >= st->max_read) { |
307 if(st->read >= st->max_read) { |
308 return 0; |
308 return 0; |
309 } |
309 } |
310 ssize_t r = st->fd->read(st->fd, buf, nbytes); |
310 ssize_t r = st->fd->read(st->fd, buf, nbytes); |
311 st->read += r; |
311 st->read += r; |
312 return r; |
312 return r; |