nginx: src/os/win32/ngx_wsarecv

annotate src/os/win32/ngx_wsarecv_chain.c @ 8111:56819a9491fe

Win32: event flags handling edge cases in ngx_wsarecv(). Fixed event flags handling edge cases in ngx_wsarecv() and ngx_wsarecv_chain(), notably to always reset rev->ready in case of errors (which wasn't the case after ngx_socket_nread() errors), and after EOF (rev->ready was not cleared if due to a misconfiguration a zero-sized buffer was used for reading).

author	Maxim Dounin <mdounin@mdounin.ru>
date	Thu, 01 Dec 2022 04:22:36 +0300
parents	ecf2a9002b37
children

rev	line source
441 da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 343 diff changeset	1
da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 343 diff changeset	2 /*
444 42d11f017717 nginx-0.1.0-2004-09-29-20:00:49 import; remove years from copyright Igor Sysoev <igor@sysoev.ru> parents: 441 diff changeset	3 * Copyright (C) Igor Sysoev
4412 d620f497c50f Copyright updated. Maxim Konovalov <maxim@nginx.com> parents: 577 diff changeset	4 * Copyright (C) Nginx, Inc.
441 da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 343 diff changeset	5 */
da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 343 diff changeset	6
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	7
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	8 #include <ngx_config.h>
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	9 #include <ngx_core.h>
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	10 #include <ngx_event.h>
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	11
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	12
7887 ecf2a9002b37 Win32: use only preallocated memory in send/recv chain functions. Ruslan Ermilov <ru@nginx.com> parents: 7583 diff changeset	13 #define NGX_WSABUFS 64
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	14
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	15
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	16 ssize_t
5882 ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	17 ngx_wsarecv_chain(ngx_connection_t c, ngx_chain_t chain, off_t limit)
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	18 {
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	19 int rc;
292 a472bfb778b3 nginx-0.0.3-2004-03-17-00:26:01 import Igor Sysoev <igor@sysoev.ru> parents: 280 diff changeset	20 u_char *prev;
280 7c7183b3ea8b nginx-0.0.2-2004-03-05-11:34:24 import Igor Sysoev <igor@sysoev.ru> parents: 278 diff changeset	21 u_long bytes, flags;
5882 ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	22 size_t n, size;
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	23 ngx_err_t err;
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	24 ngx_array_t vec;
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	25 ngx_event_t *rev;
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	26 LPWSABUF wsabuf;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	27 WSABUF wsabufs[NGX_WSABUFS];
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	28
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	29 prev = NULL;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	30 wsabuf = NULL;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	31 flags = 0;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	32 size = 0;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	33 bytes = 0;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	34
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	35 vec.elts = wsabufs;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	36 vec.nelts = 0;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	37 vec.size = sizeof(WSABUF);
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	38 vec.nalloc = NGX_WSABUFS;
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	39 vec.pool = c->pool;
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	40
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 292 diff changeset	41 /* coalesce the neighbouring bufs */
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	42
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	43 while (chain) {
5882 ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	44 n = chain->buf->end - chain->buf->last;
ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	45
ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	46 if (limit) {
ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	47 if (size >= (size_t) limit) {
ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	48 break;
ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	49 }
ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	50
ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	51 if (size + n > (size_t) limit) {
ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	52 n = (size_t) limit - size;
ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	53 }
ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	54 }
ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	55
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 292 diff changeset	56 if (prev == chain->buf->last) {
5882 ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	57 wsabuf->len += n;
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	58
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	59 } else {
7887 ecf2a9002b37 Win32: use only preallocated memory in send/recv chain functions. Ruslan Ermilov <ru@nginx.com> parents: 7583 diff changeset	60 if (vec.nelts == vec.nalloc) {
ecf2a9002b37 Win32: use only preallocated memory in send/recv chain functions. Ruslan Ermilov <ru@nginx.com> parents: 7583 diff changeset	61 break;
ecf2a9002b37 Win32: use only preallocated memory in send/recv chain functions. Ruslan Ermilov <ru@nginx.com> parents: 7583 diff changeset	62 }
ecf2a9002b37 Win32: use only preallocated memory in send/recv chain functions. Ruslan Ermilov <ru@nginx.com> parents: 7583 diff changeset	63
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	64 wsabuf = ngx_array_push(&vec);
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	65 if (wsabuf == NULL) {
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	66 return NGX_ERROR;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	67 }
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	68
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 292 diff changeset	69 wsabuf->buf = (char *) chain->buf->last;
5882 ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	70 wsabuf->len = n;
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	71 }
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	72
5882 ec81934727a1 Core: added limit to recv_chain(). Roman Arutyunyan <arut@nginx.com> parents: 4412 diff changeset	73 size += n;
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 292 diff changeset	74 prev = chain->buf->end;
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	75 chain = chain->next;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	76 }
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	77
278 0ba4821f4460 nginx-0.0.2-2004-03-04-10:04:55 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	78 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0,
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	79 "WSARecv: %d:%d", vec.nelts, wsabuf->len);
278 0ba4821f4460 nginx-0.0.2-2004-03-04-10:04:55 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	80
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	81
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	82 rc = WSARecv(c->fd, vec.elts, vec.nelts, &bytes, &flags, NULL, NULL);
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	83
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	84 rev = c->read;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	85
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	86 if (rc == -1) {
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	87 rev->ready = 0;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	88 err = ngx_socket_errno;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	89
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	90 if (err == WSAEWOULDBLOCK) {
278 0ba4821f4460 nginx-0.0.2-2004-03-04-10:04:55 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	91 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err,
0ba4821f4460 nginx-0.0.2-2004-03-04-10:04:55 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	92 "WSARecv() not ready");
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	93 return NGX_AGAIN;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	94 }
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	95
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	96 rev->error = 1;
278 0ba4821f4460 nginx-0.0.2-2004-03-04-10:04:55 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	97 ngx_connection_error(c, err, "WSARecv() failed");
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	98 return NGX_ERROR;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	99 }
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	100
7583 efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	101 #if (NGX_HAVE_FIONREAD)
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	102
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	103 if (rev->available >= 0 && bytes > 0) {
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	104 rev->available -= bytes;
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	105
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	106 /*
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	107 * negative rev->available means some additional bytes
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	108 * were received between kernel notification and WSARecv(),
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	109 * and therefore ev->ready can be safely reset even for
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	110 * edge-triggered event methods
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	111 */
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	112
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	113 if (rev->available < 0) {
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	114 rev->available = 0;
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	115 rev->ready = 0;
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	116 }
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	117
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	118 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	119 "WSARecv: avail:%d", rev->available);
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	120
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	121 } else if (bytes == size) {
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	122
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	123 if (ngx_socket_nread(c->fd, &rev->available) == -1) {
8111 56819a9491fe Win32: event flags handling edge cases in ngx_wsarecv(). Maxim Dounin <mdounin@mdounin.ru> parents: 7887 diff changeset	124 rev->ready = 0;
7583 efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	125 rev->error = 1;
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	126 ngx_connection_error(c, ngx_socket_errno,
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	127 ngx_socket_nread_n " failed");
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	128 return NGX_ERROR;
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	129 }
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	130
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	131 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	132 "WSARecv: avail:%d", rev->available);
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	133 }
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	134
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	135 #endif
efd71d49bde0 Events: available bytes calculation via ioctl(FIONREAD). Maxim Dounin <mdounin@mdounin.ru> parents: 5882 diff changeset	136
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	137 if (bytes < size) {
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	138 rev->ready = 0;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	139 }
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	140
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	141 if (bytes == 0) {
8111 56819a9491fe Win32: event flags handling edge cases in ngx_wsarecv(). Maxim Dounin <mdounin@mdounin.ru> parents: 7887 diff changeset	142 rev->ready = 0;
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	143 rev->eof = 1;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	144 }
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	145
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	146 return bytes;
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	147 }

Mercurial > hg > nginx

annotate src/os/win32/ngx_wsarecv_chain.c @ 8111:56819a9491fe