One Level Up Top Level

src/os/unix/ngx_send.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_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;

  20.     wev = c->write;

  22. #if (NGX_HAVE_KQUEUE)

  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.     }

  31. #endif

  33.     for ( ;; ) {
  34.         n = send(c->fd, buf, size, 0);

  36.         ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0,
  37.                        "send: fd:%d %d of %d", c->fd, n, size);

  39.         if (n > 0) {
  40.             if (n < (ssize_t) size) {
  41.                 wev->ready = 0;
  42.             }

  44.             c->sent += n;

  46.             return n;
  47.         }

  49.         err = ngx_socket_errno;

  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.         }

  57.         if (err == NGX_EAGAIN || err == NGX_EINTR) {
  58.             wev->ready = 0;

  60.             ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err,
  61.                            "send() not ready");

  63.             if (err == NGX_EAGAIN) {
  64.                 return NGX_AGAIN;
  65.             }

  67.         } else {
  68.             wev->error = 1;
  69.             (void) ngx_connection_error(c, err, "send() failed");
  70.             return NGX_ERROR;
  71.         }
  72.     }
  73. }

One Level Up Top Level