Return to ngx_aio_read_chain.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / nginx / src / os / unix

Annotation of embedaddon/nginx/src/os/unix/ngx_aio_read_chain.c, revision 1.1.1.1

1.1       misho       1: 
                      2: /*
                      3:  * Copyright (C) Igor Sysoev
                      4:  * Copyright (C) Nginx, Inc.
                      5:  */
                      6: 
                      7: 
                      8: #include <ngx_config.h>
                      9: #include <ngx_core.h>
                     10: #include <ngx_event.h>
                     11: 
                     12: 
                     13: ssize_t
                     14: ngx_aio_read_chain(ngx_connection_t *c, ngx_chain_t *cl)
                     15: {
                     16:     int           n;
                     17:     u_char       *buf, *prev;
                     18:     size_t        size;
                     19:     ssize_t       total;
                     20: 
                     21:     if (c->read->pending_eof) {
                     22:         c->read->ready = 0;
                     23:         return 0;
                     24:     }
                     25: 
                     26:     total = 0;
                     27: 
                     28:     while (cl) {
                     29: 
                     30:         /* we can post the single aio operation only */
                     31: 
                     32:         if (!c->read->ready) {
                     33:             return total ? total : NGX_AGAIN;
                     34:         }
                     35: 
                     36:         buf = cl->buf->last;
                     37:         prev = cl->buf->last;
                     38:         size = 0;
                     39: 
                     40:         /* coalesce the neighbouring bufs */
                     41: 
                     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:         }
                     47: 
                     48:         n = ngx_aio_read(c, buf, size);
                     49: 
                     50:         ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "aio_read: %d", n);
                     51: 
                     52:         if (n == NGX_AGAIN) {
                     53:             return total ? total : NGX_AGAIN;
                     54:         }
                     55: 
                     56:         if (n == NGX_ERROR) {
                     57:             return NGX_ERROR;
                     58:         }
                     59: 
                     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:         }
                     68: 
                     69:         if (n > 0) {
                     70:             total += n;
                     71:         }
                     72: 
                     73:         ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
                     74:                        "aio_read total: %d", total);
                     75:     }
                     76: 
                     77:     return total ? total : NGX_AGAIN;
                     78: }