One Level Up Top Level

src/os/unix/ngx_udp_recv.c - nginx source code

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_udp_unix_recv(ngx_connection_t *c, u_char *buf, size_t size)
  15. {
  16.     ssize_t       n;
  17.     ngx_err_t     err;
  18.     ngx_event_t  *rev;

  20.     rev = c->read;

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

  25.         ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0,
  26.                        "recv: fd:%d %z of %uz", c->fd, n, size);

  28.         if (n >= 0) {

  30. #if (NGX_HAVE_KQUEUE)

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

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

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

  46. #endif

  48.             return n;
  49.         }

  51.         err = ngx_socket_errno;

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

  58.         } else {
  59.             n = ngx_connection_error(c, err, "recv() failed");
  60.             break;
  61.         }

  63.     } while (err == NGX_EINTR);

  65.     rev->ready = 0;

  67.     if (n == NGX_ERROR) {
  68.         rev->error = 1;
  69.     }

  71.     return n;
  72. }

One Level Up Top Level