One Level Up Top Level

src/os/unix/ngx_aio_read_chain.c - nginx-1.7.10

Functions defined

Source code


  2. /*
  3. * Copyright (C) Igor Sysoev
  4. * Copyright (C) Nginx, Inc.
  5. */


  8. #include <ngx_config.h>
  9. #include <ngx_core.h>
  10. #include <ngx_event.h>


  13. ssize_t
  14. ‌ngx_aio_read_chain(ngx_connection_t *c, ngx_chain_t *cl, off_t limit)
  15. {
  16.     int           n;
  17.     u_char       *buf, *prev;
  18.     size_t        size;
  19.     ssize_t       total;

  21.     if (c->read->pending_eof) {
  22.         c->read->ready = 0;
  23.         return 0;
  24.     }

  26.     total = 0;

  28.     while (cl) {

  30.         /* we can post the single aio operation only */

  32.         if (!c->read->ready) {
  33.             return total ? total : NGX_AGAIN;
  34.         }

  36.         buf = cl->buf->last;
  37.         prev = cl->buf->last;
  38.         size = 0;

  40.         /* coalesce the neighbouring bufs */

  42.         while (cl && prev == cl->buf->last) {
  43.             size += cl->buf->end - cl->buf->last;
  44.             prev = cl->buf->end;
  45.             cl = cl->next;
  46.         }

  48.         n = ngx_aio_read(c, buf, size);

  50.         ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "aio_read: %d", n);

  52.         if (n == NGX_AGAIN) {
  53.             return total ? total : NGX_AGAIN;
  54.         }

  56.         if (n == NGX_ERROR) {
  57.             return NGX_ERROR;
  58.         }

  60.         if (n == 0) {
  61.             c->read->pending_eof = 1;
  62.             if (total) {
  63.                 c->read->eof = 0;
  64.                 c->read->ready = 1;
  65.             }
  66.             return total;
  67.         }

  69.         if (n > 0) {
  70.             total += n;
  71.         }

  73.         ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
  74.                        "aio_read total: %d", total);
  75.     }

  77.     return total ? total : NGX_AGAIN;
  78. }

One Level Up Top Level