Return to ngx_send.c CVS log

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

Annotation of embedaddon/nginx/src/os/unix/ngx_send.c, revision 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_unix_send(ngx_connection_t *c, u_char *buf, size_t size)
        !            15: {
        !            16:     ssize_t       n;
        !            17:     ngx_err_t     err;
        !            18:     ngx_event_t  *wev;
        !            19: 
        !            20:     wev = c->write;
        !            21: 
        !            22: #if (NGX_HAVE_KQUEUE)
        !            23: 
        !            24:     if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) {
        !            25:         (void) ngx_connection_error(c, wev->kq_errno,
        !            26:                                "kevent() reported about an closed connection");
        !            27:         wev->error = 1;
        !            28:         return NGX_ERROR;
        !            29:     }
        !            30: 
        !            31: #endif
        !            32: 
        !            33:     for ( ;; ) {
        !            34:         n = send(c->fd, buf, size, 0);
        !            35: 
        !            36:         ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0,
        !            37:                        "send: fd:%d %d of %d", c->fd, n, size);
        !            38: 
        !            39:         if (n > 0) {
        !            40:             if (n < (ssize_t) size) {
        !            41:                 wev->ready = 0;
        !            42:             }
        !            43: 
        !            44:             c->sent += n;
        !            45: 
        !            46:             return n;
        !            47:         }
        !            48: 
        !            49:         err = ngx_socket_errno;
        !            50: 
        !            51:         if (n == 0) {
        !            52:             ngx_log_error(NGX_LOG_ALERT, c->log, err, "send() returned zero");
        !            53:             wev->ready = 0;
        !            54:             return n;
        !            55:         }
        !            56: 
        !            57:         if (err == NGX_EAGAIN || err == NGX_EINTR) {
        !            58:             wev->ready = 0;
        !            59: 
        !            60:             ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err,
        !            61:                            "send() not ready");
        !            62: 
        !            63:             if (err == NGX_EAGAIN) {
        !            64:                 return NGX_AGAIN;
        !            65:             }
        !            66: 
        !            67:         } else {
        !            68:             wev->error = 1;
        !            69:             (void) ngx_connection_error(c, err, "send() failed");
        !            70:             return NGX_ERROR;
        !            71:         }
        !            72:     }
        !            73: }