One Level Up Top Level

src/os/win32/ngx_wsarecv.c - nginx-1.31.9 nginx/ @ 2a3a19c6f

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_wsarecv(ngx_connection_t *c, u_char *buf, size_t size)
  15. {
  16.     int           rc;
  17.     u_long        bytes, flags;
  18.     WSABUF        wsabuf[1];
  19.     ngx_err_t     err;
  20.     ngx_int_t     n;
  21.     ngx_event_t  *rev;

  23.     wsabuf[0].buf = (char *) buf;
  24.     wsabuf[0].len = size;
  25.     flags = 0;
  26.     bytes = 0;

  28.     rc = WSARecv(c->fd, wsabuf, 1, &bytes, &flags, NULL, NULL);

  30.     ngx_log_debug4(NGX_LOG_DEBUG_EVENT, c->log, 0,
  31.                    "WSARecv: fd:%d rc:%d %ul of %z", c->fd, rc, bytes, size);

  33.     rev = c->read;

  35.     if (rc == -1) {
  36.         rev->ready = 0;
  37.         err = ngx_socket_errno;

  39.         if (err == WSAEWOULDBLOCK) {
  40.             ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err,
  41.                            "WSARecv() not ready");
  42.             return NGX_AGAIN;
  43.         }

  45.         n = ngx_connection_error(c, err, "WSARecv() failed");

  47.         if (n == NGX_ERROR) {
  48.             rev->error = 1;
  49.         }

  51.         return n;
  52.     }

  54. #if (NGX_HAVE_FIONREAD)

  56.     if (rev->available >= 0 && bytes > 0) {
  57.         rev->available -= bytes;

  59.         /*
  60.          * negative rev->available means some additional bytes
  61.          * were received between kernel notification and WSARecv(),
  62.          * and therefore ev->ready can be safely reset even for
  63.          * edge-triggered event methods
  64.          */

  66.         if (rev->available < 0) {
  67.             rev->available = 0;
  68.             rev->ready = 0;
  69.         }

  71.         ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
  72.                        "WSARecv: avail:%d", rev->available);

  74.     } else if (bytes == size) {

  76.         if (ngx_socket_nread(c->fd, &rev->available) == -1) {
  77.             n = ngx_connection_error(c, ngx_socket_errno,
  78.                                      ngx_socket_nread_n " failed");

  80.             if (n == NGX_ERROR) {
  81.                 rev->ready = 0;
  82.                 rev->error = 1;
  83.             }

  85.             return n;
  86.         }

  88.         ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
  89.                        "WSARecv: avail:%d", rev->available);
  90.     }

  92. #endif

  94.     if (bytes < size) {
  95.         rev->ready = 0;
  96.     }

  98.     if (bytes == 0) {
  99.         rev->ready = 0;
  100.         rev->eof = 1;
  101.     }

  103.     return bytes;
  104. }

One Level Up Top Level