One Level Up Top Level

src/os/unix/ngx_udp_recv.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. #if (NGX_HAVE_KQUEUE)

  15. ssize_t
  16. ‌ngx_udp_unix_recv(ngx_connection_t *c, u_char *buf, size_t size)
  17. {
  18.     ssize_t       n;
  19.     ngx_err_t     err;
  20.     ngx_event_t  *rev;

  22.     rev = c->read;

  24.     do {
  25.         n = recv(c->fd, buf, size, 0);

  27.         ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0,
  28.                        "recv: fd:%d %d of %d", c->fd, n, size);

  30.         if (n >= 0) {
  31.             if (ngx_event_flags & NGX_USE_KQUEUE_EVENT) {
  32.                 rev->available -= n;

  34.                 /*
  35.                  * rev->available may be negative here because some additional
  36.                  * bytes may be received between kevent() and recv()
  37.                  */

  39.                 if (rev->available <= 0) {
  40.                     rev->ready = 0;
  41.                     rev->available = 0;
  42.                 }
  43.             }

  45.             return n;
  46.         }

  48.         err = ngx_socket_errno;

  50.         if (err == NGX_EAGAIN || err == NGX_EINTR) {
  51.             ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err,
  52.                            "recv() not ready");
  53.             n = NGX_AGAIN;

  55.         } else {
  56.             n = ngx_connection_error(c, err, "recv() failed");
  57.             break;
  58.         }

  60.     } while (err == NGX_EINTR);

  62.     rev->ready = 0;

  64.     if (n == NGX_ERROR) {
  65.         rev->error = 1;
  66.     }

  68.     return n;
  69. }

  71. #else /* ! NGX_HAVE_KQUEUE */

  73. ssize_t
  74. ‌ngx_udp_unix_recv(ngx_connection_t *c, u_char *buf, size_t size)
  75. {
  76.     ssize_t       n;
  77.     ngx_err_t     err;
  78.     ngx_event_t  *rev;

  80.     rev = c->read;

  82.     do {
  83.         n = recv(c->fd, buf, size, 0);

  85.         ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0,
  86.                        "recv: fd:%d %d of %d", c->fd, n, size);

  88.         if (n >= 0) {
  89.             return n;
  90.         }

  92.         err = ngx_socket_errno;

  94.         if (err == NGX_EAGAIN || err == NGX_EINTR) {
  95.             ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err,
  96.                            "recv() not ready");
  97.             n = NGX_AGAIN;

  99.         } else {
  100.             n = ngx_connection_error(c, err, "recv() failed");
  101.             break;
  102.         }

  104.     } while (err == NGX_EINTR);

  106.     rev->ready = 0;

  108.     if (n == NGX_ERROR) {
  109.         rev->error = 1;
  110.     }

  112.     return n;
  113. }

  115. #endif /* NGX_HAVE_KQUEUE */

One Level Up Top Level