Mercurial > hg > nginx
diff src/os/unix/ngx_readv_chain.c @ 93:738fe44c70d5
nginx-0.0.1-2003-05-21-17:28:21 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Wed, 21 May 2003 13:28:21 +0000 |
parents | src/os/unix/ngx_recv_chain.c@29bf798b583f |
children | 6dfda4cf5200 |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/os/unix/ngx_readv_chain.c Wed May 21 13:28:21 2003 +0000 @@ -0,0 +1,46 @@ + +#include <ngx_config.h> +#include <ngx_core.h> + + +ssize_t ngx_readv_chain(ngx_connection_t *c, ngx_chain_t *entry) +{ + ssize_t n; + struct iovec *iov; + ngx_err_t err; + ngx_array_t io; + +#if (NGX_SUPPRESS_WARN) + iov = NULL; +#endif + + ngx_init_array(io, c->pool, 10, sizeof(struct iovec), NGX_ERROR); + + while (entry) { + ngx_test_null(iov, ngx_push_array(&io), NGX_ERROR); + iov->iov_base = entry->hunk->pos; + iov->iov_len = entry->hunk->end - entry->hunk->last; + entry = entry->next; + } + +ngx_log_debug(c->log, "recv: %d:%d" _ io.nelts _ iov->iov_len); + + n = readv(c->fd, (struct iovec *) io.elts, io.nelts); + + ngx_destroy_array(&io); + + if (n == -1) { + c->read->ready = 0; + + err = ngx_errno; + if (err == NGX_EAGAIN) { + ngx_log_error(NGX_LOG_INFO, c->log, err, "readv() returned EAGAIN"); + return NGX_AGAIN; + } + + ngx_log_error(NGX_LOG_ERR, c->log, err, "readv() failed"); + return NGX_ERROR; + } + + return n; +}