Return to ngx_aio_write.c CVS log

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

Annotation of embedaddon/nginx/src/os/unix/ngx_aio_write.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: extern int  ngx_kqueue;
                     14: 
                     15: 
                     16: ssize_t
                     17: ngx_aio_write(ngx_connection_t *c, u_char *buf, size_t size)
                     18: {
                     19:     int           n;
                     20:     ngx_event_t  *wev;
                     21: 
                     22:     wev = c->write;
                     23: 
                     24:     if (!wev->ready) {
                     25:         return NGX_AGAIN;
                     26:     }
                     27: 
                     28:     ngx_log_debug1(NGX_LOG_DEBUG_EVENT, wev->log, 0,
                     29:                    "aio: wev->complete: %d", wev->complete);
                     30: 
                     31:     if (!wev->complete) {
                     32:         ngx_memzero(&wev->aiocb, sizeof(struct aiocb));
                     33: 
                     34:         wev->aiocb.aio_fildes = c->fd;
                     35:         wev->aiocb.aio_buf = buf;
                     36:         wev->aiocb.aio_nbytes = size;
                     37: 
                     38: #if (NGX_HAVE_KQUEUE)
                     39:         wev->aiocb.aio_sigevent.sigev_notify_kqueue = ngx_kqueue;
                     40:         wev->aiocb.aio_sigevent.sigev_notify = SIGEV_KEVENT;
                     41:         wev->aiocb.aio_sigevent.sigev_value.sigval_ptr = wev;
                     42: #endif
                     43: 
                     44:         if (aio_write(&wev->aiocb) == -1) {
                     45:             ngx_log_error(NGX_LOG_CRIT, wev->log, ngx_errno,
                     46:                           "aio_write() failed");
                     47:             return NGX_ERROR;
                     48:         }
                     49: 
                     50:         ngx_log_debug0(NGX_LOG_DEBUG_EVENT, wev->log, 0, "aio_write: OK");
                     51: 
                     52:         wev->active = 1;
                     53:         wev->ready = 0;
                     54:     }
                     55: 
                     56:     wev->complete = 0;
                     57: 
                     58:     n = aio_error(&wev->aiocb);
                     59:     if (n == -1) {
                     60:         ngx_log_error(NGX_LOG_CRIT, wev->log, ngx_errno, "aio_error() failed");
                     61:         wev->error = 1;
                     62:         return NGX_ERROR;
                     63:     }
                     64: 
                     65:     if (n != 0) {
                     66:         if (n == NGX_EINPROGRESS) {
                     67:             if (wev->ready) {
                     68:                 ngx_log_error(NGX_LOG_ALERT, wev->log, n,
                     69:                               "aio_write() still in progress");
                     70:                 wev->ready = 0;
                     71:             }
                     72:             return NGX_AGAIN;
                     73:         }
                     74: 
                     75:         ngx_log_error(NGX_LOG_CRIT, wev->log, n, "aio_write() failed");
                     76:         wev->error = 1;
                     77:         wev->ready = 0;
                     78: 
                     79: #if 1
                     80:         n = aio_return(&wev->aiocb);
                     81:         if (n == -1) {
                     82:             ngx_log_error(NGX_LOG_ALERT, wev->log, ngx_errno,
                     83:                           "aio_return() failed");
                     84:         }
                     85: 
                     86:         ngx_log_error(NGX_LOG_CRIT, wev->log, n, "aio_return() %d", n);
                     87: #endif
                     88: 
                     89:         return NGX_ERROR;
                     90:     }
                     91: 
                     92:     n = aio_return(&wev->aiocb);
                     93:     if (n == -1) {
                     94:         ngx_log_error(NGX_LOG_ALERT, wev->log, ngx_errno,
                     95:                       "aio_return() failed");
                     96: 
                     97:         wev->error = 1;
                     98:         wev->ready = 0;
                     99:         return NGX_ERROR;
                    100:     }
                    101: 
                    102: 
                    103:     ngx_log_debug1(NGX_LOG_DEBUG_EVENT, wev->log, 0, "aio_write: %d", n);
                    104: 
                    105:     wev->active = 0;
                    106:     wev->ready = 1;
                    107: 
                    108:     return n;
                    109: }