Mercurial > hg > nginx
diff src/os/unix/ngx_aio_read_chain.c @ 164:84036764e215
nginx-0.0.1-2003-10-29-11:30:44 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Wed, 29 Oct 2003 08:30:44 +0000 |
parents | |
children | 389d7ee9fa60 |
line wrap: on
line diff
new file mode 100644 --- /dev/null +++ b/src/os/unix/ngx_aio_read_chain.c @@ -0,0 +1,57 @@ + +#include <ngx_config.h> +#include <ngx_core.h> +#include <ngx_event.h> +#include <ngx_aio.h> + + +ssize_t ngx_aio_read_chain(ngx_connection_t *c, ngx_chain_t *cl) +{ + int n; + char *buf, *prev; + size_t size, total; + ngx_err_t err; + + total = 0; + + while (cl) { + + /* we can post the single aio operation only */ + + if (c->read->active) { + return total ? total : NGX_AGAIN; + } + + buf = cl->hunk->pos; + prev = buf; + size = 0; + + /* coalesce the neighbouring hunks */ + + while (cl && prev == cl->hunk->pos) { + size += cl->hunk->last - cl->hunk->pos; + prev = cl->hunk->last; + cl = cl->next; + } + + n = ngx_aio_read(c, buf, size); + + ngx_log_debug(c->log, "aio_read: %d" _ n); + + if (n == NGX_AGAIN) { + return total ? total : NGX_AGAIN; + } + + if (n == NGX_ERROR) { + return NGX_ERROR; + } + + if (n > 0) { + total += n; + } + + ngx_log_debug(c->log, "aio_read total: %d" _ total); + } + + return total ? total : NGX_AGAIN; +}