One Level Up Top Level

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

Functions defined

Macros 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. ‌#define NGX_WSABUFS  64


  16. ngx_chain_t *
  17. ‌ngx_wsasend_chain(ngx_connection_t *c, ngx_chain_t *in, off_t limit)
  18. {
  19.     int           rc;
  20.     u_char       *prev;
  21.     u_long        size, sent, send, prev_send;
  22.     ngx_err_t     err;
  23.     ngx_event_t  *wev;
  24.     ngx_array_t   vec;
  25.     ngx_chain_t  *cl;
  26.     LPWSABUF      wsabuf;
  27.     WSABUF        wsabufs[NGX_WSABUFS];

  29.     wev = c->write;

  31.     if (!wev->ready) {
  32.         return in;
  33.     }

  35.     /* the maximum limit size is the maximum u_long value - the page size */

  37.     if (limit == 0 || limit > (off_t) (NGX_MAX_UINT32_VALUE - ngx_pagesize)) {
  38.         limit = NGX_MAX_UINT32_VALUE - ngx_pagesize;
  39.     }

  41.     send = 0;

  43.     /*
  44.      * WSABUFs must be 4-byte aligned otherwise
  45.      * WSASend() will return undocumented WSAEINVAL error.
  46.      */

  48.     vec.elts = wsabufs;
  49.     vec.size = sizeof(WSABUF);
  50.     vec.nalloc = ngx_min(NGX_WSABUFS, ngx_max_wsabufs);
  51.     vec.pool = c->pool;

  53.     for ( ;; ) {
  54.         prev = NULL;
  55.         wsabuf = NULL;
  56.         prev_send = send;

  58.         vec.nelts = 0;

  60.         /* create the WSABUF and coalesce the neighbouring bufs */

  62.         for (cl = in; cl && send < limit; cl = cl->next) {

  64.             if (ngx_buf_special(cl->buf)) {
  65.                 continue;
  66.             }

  68.             size = cl->buf->last - cl->buf->pos;

  70.             if (send + size > limit) {
  71.                 size = (u_long) (limit - send);
  72.             }

  74.             if (prev == cl->buf->pos) {
  75.                 wsabuf->len += cl->buf->last - cl->buf->pos;

  77.             } else {
  78.                 if (vec.nelts == vec.nalloc) {
  79.                     break;
  80.                 }

  82.                 wsabuf = ngx_array_push(&vec);
  83.                 if (wsabuf == NULL) {
  84.                     return NGX_CHAIN_ERROR;
  85.                 }

  87.                 wsabuf->buf = (char *) cl->buf->pos;
  88.                 wsabuf->len = cl->buf->last - cl->buf->pos;
  89.             }

  91.             prev = cl->buf->last;
  92.             send += size;
  93.         }

  95.         sent = 0;

  97.         rc = WSASend(c->fd, vec.elts, vec.nelts, &sent, 0, NULL, NULL);

  99.         if (rc == -1) {
  100.             err = ngx_errno;

  102.             if (err == WSAEWOULDBLOCK) {
  103.                 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err,
  104.                                "WSASend() not ready");

  106.             } else {
  107.                 wev->error = 1;
  108.                 ngx_connection_error(c, err, "WSASend() failed");
  109.                 return NGX_CHAIN_ERROR;
  110.             }
  111.         }

  113.         ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0,
  114.                        "WSASend: fd:%d, s:%ul", c->fd, sent);

  116.         c->sent += sent;

  118.         in = ngx_chain_update_sent(in, sent);

  120.         if (send - prev_send != sent) {
  121.             wev->ready = 0;
  122.             return in;
  123.         }

  125.         if (send >= limit || in == NULL) {
  126.             return in;
  127.         }
  128.     }
  129. }

One Level Up Top Level