nginx: src/event/ngx_event_connect.c annotate

annotate src/event/ngx_event_connect.c @ 4119:b66712cde67d

Upstream: pipe length and input_filter_init in buffered mode. As long as ngx_event_pipe() has more data read from upstream than specified in p->length it's passed to input filter even if buffer isn't yet full. This allows to process data with known length without relying on connection close to signal data end. By default p->length is set to -1 in upstream module, i.e. end of data is indicated by connection close. To set it from per-protocol handlers upstream input_filter_init() now called in buffered mode (as well as in unbuffered mode).

author	Maxim Dounin <mdounin@mdounin.ru>
date	Thu, 15 Sep 2011 19:00:47 +0000
parents	d518c65ff0d4
children	d620f497c50f

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: 417 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: 417 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
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: 417 diff changeset	4 */
da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 417 diff changeset	5
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	6
136 da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	7 #include <ngx_config.h>
da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	8 #include <ngx_core.h>
da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	9 #include <ngx_event.h>
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	10 #include <ngx_event_connect.h>
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	11
131 049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	12
487 31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	13 ngx_int_t
31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	14 ngx_event_connect_peer(ngx_peer_connection_t *pc)
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	15 {
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	16 int rc;
1470 92b5f20d54f4 64-bit update lost in r1355 Igor Sysoev <igor@sysoev.ru> parents: 1397 diff changeset	17 ngx_int_t event;
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	18 ngx_err_t err;
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	19 ngx_uint_t level;
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	20 ngx_socket_t s;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	21 ngx_event_t rev, wev;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	22 ngx_connection_t *c;
122 cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	23
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	24 rc = pc->get(pc, pc->data);
4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	25 if (rc != NGX_OK) {
4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	26 return rc;
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	27 }
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	28
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	29 s = ngx_socket(pc->sockaddr->sa_family, SOCK_STREAM, 0);
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	30
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	31 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, 0, "socket %d", s);
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 487 diff changeset	32
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	33 if (s == -1) {
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	34 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	35 ngx_socket_n " failed");
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	36 return NGX_ERROR;
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	37 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	38
323 ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	39
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	40 c = ngx_get_connection(s, pc->log);
323 ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	41
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	42 if (c == NULL) {
323 ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	43 if (ngx_close_socket(s) == -1) {
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	44 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	45 ngx_close_socket_n "failed");
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	46 }
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	47
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	48 return NGX_ERROR;
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	49 }
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	50
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	51 if (pc->rcvbuf) {
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	52 if (setsockopt(s, SOL_SOCKET, SO_RCVBUF,
563 9c2f3ed7a247 nginx-0.3.3-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 561 diff changeset	53 (const void *) &pc->rcvbuf, sizeof(int)) == -1)
9c2f3ed7a247 nginx-0.3.3-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 561 diff changeset	54 {
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	55 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	56 "setsockopt(SO_RCVBUF) failed");
3271 fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	57 goto failed;
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	58 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	59 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	60
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	61 if (ngx_nonblocking(s) == -1) {
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	62 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	63 ngx_nonblocking_n " failed");
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	64
3271 fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	65 goto failed;
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	66 }
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	67
3271 fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	68 if (pc->local) {
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	69 if (bind(s, pc->local->sockaddr, pc->local->socklen) == -1) {
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	70 ngx_log_error(NGX_LOG_CRIT, pc->log, ngx_socket_errno,
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	71 "bind(%V) failed", &pc->local->name);
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	72
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	73 goto failed;
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	74 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	75 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	76
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	77 c->recv = ngx_recv;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	78 c->send = ngx_send;
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 563 diff changeset	79 c->recv_chain = ngx_recv_chain;
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	80 c->send_chain = ngx_send_chain;
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	81
1397 6c25a49e548a upstream sendfile bit was overridden by r->connection->sendfile Igor Sysoev <igor@sysoev.ru> parents: 884 diff changeset	82 c->sendfile = 1;
6c25a49e548a upstream sendfile bit was overridden by r->connection->sendfile Igor Sysoev <igor@sysoev.ru> parents: 884 diff changeset	83
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	84 c->log_error = pc->log_error;
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	85
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	86 if (pc->sockaddr->sa_family != AF_INET) {
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	87 c->tcp_nopush = NGX_TCP_NOPUSH_DISABLED;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	88 c->tcp_nodelay = NGX_TCP_NODELAY_DISABLED;
583 4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	89
4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	90 #if (NGX_SOLARIS)
4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	91 /* Solaris's sendfilev() supports AF_NCA, AF_INET, and AF_INET6 */
4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	92 c->sendfile = 0;
4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	93 #endif
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	94 }
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	95
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 545 diff changeset	96 rev = c->read;
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 545 diff changeset	97 wev = c->write;
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	98
191 71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	99 rev->log = pc->log;
71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	100 wev->log = pc->log;
71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	101
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	102 pc->connection = c;
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	103
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 545 diff changeset	104 c->number = ngx_atomic_fetch_add(ngx_connection_counter, 1);
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	105
377 41437e4fd9b4 nginx-0.0.7-2004-07-05-19:08:23 import Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	106 #if (NGX_THREADS)
3365 d518c65ff0d4 update comments Igor Sysoev <igor@sysoev.ru> parents: 3271 diff changeset	107
d518c65ff0d4 update comments Igor Sysoev <igor@sysoev.ru> parents: 3271 diff changeset	108 /* TODO: lock event when call completion handler */
d518c65ff0d4 update comments Igor Sysoev <igor@sysoev.ru> parents: 3271 diff changeset	109
377 41437e4fd9b4 nginx-0.0.7-2004-07-05-19:08:23 import Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	110 rev->lock = pc->lock;
41437e4fd9b4 nginx-0.0.7-2004-07-05-19:08:23 import Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	111 wev->lock = pc->lock;
380 5ce6561246a5 nginx-0.0.7-2004-07-07-10:15:04 import Igor Sysoev <igor@sysoev.ru> parents: 379 diff changeset	112 rev->own_lock = &c->lock;
5ce6561246a5 nginx-0.0.7-2004-07-07-10:15:04 import Igor Sysoev <igor@sysoev.ru> parents: 379 diff changeset	113 wev->own_lock = &c->lock;
3365 d518c65ff0d4 update comments Igor Sysoev <igor@sysoev.ru> parents: 3271 diff changeset	114
377 41437e4fd9b4 nginx-0.0.7-2004-07-05-19:08:23 import Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	115 #endif
41437e4fd9b4 nginx-0.0.7-2004-07-05-19:08:23 import Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	116
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	117 if (ngx_add_conn) {
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	118 if (ngx_add_conn(c) == NGX_ERROR) {
3271 fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	119 goto failed;
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	120 }
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 563 diff changeset	121 }
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	122
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	123 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, pc->log, 0,
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	124 "connect to %V, fd:%d #%d", pc->name, s, c->number);
137 2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	125
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	126 rc = connect(s, pc->sockaddr, pc->socklen);
122 cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	127
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	128 if (rc == -1) {
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	129 err = ngx_socket_errno;
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 169 diff changeset	130
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 169 diff changeset	131
2117 9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	132 if (err != NGX_EINPROGRESS
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	133 #if (NGX_WIN32)
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	134 /* Winsock returns WSAEWOULDBLOCK (NGX_EAGAIN) */
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	135 && err != NGX_EAGAIN
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	136 #endif
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	137 )
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	138 {
1869 192443881e51 add NGX_ENETDOWN, NGX_ENETUNREACH, and NGX_EHOSTDOWN Igor Sysoev <igor@sysoev.ru> parents: 1470 diff changeset	139 if (err == NGX_ECONNREFUSED
2117 9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	140 #if (NGX_LINUX)
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	141 /*
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	142 * Linux returns EAGAIN instead of ECONNREFUSED
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	143 * for unix sockets if listen queue is full
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	144 */
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	145 \|\| err == NGX_EAGAIN
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	146 #endif
2540 042dcbaead66 lower ECONNRESET level Igor Sysoev <igor@sysoev.ru> parents: 2117 diff changeset	147 \|\| err == NGX_ECONNRESET
1869 192443881e51 add NGX_ENETDOWN, NGX_ENETUNREACH, and NGX_EHOSTDOWN Igor Sysoev <igor@sysoev.ru> parents: 1470 diff changeset	148 \|\| err == NGX_ENETDOWN
192443881e51 add NGX_ENETDOWN, NGX_ENETUNREACH, and NGX_EHOSTDOWN Igor Sysoev <igor@sysoev.ru> parents: 1470 diff changeset	149 \|\| err == NGX_ENETUNREACH
192443881e51 add NGX_ENETDOWN, NGX_ENETUNREACH, and NGX_EHOSTDOWN Igor Sysoev <igor@sysoev.ru> parents: 1470 diff changeset	150 \|\| err == NGX_EHOSTDOWN
192443881e51 add NGX_ENETDOWN, NGX_ENETUNREACH, and NGX_EHOSTDOWN Igor Sysoev <igor@sysoev.ru> parents: 1470 diff changeset	151 \|\| err == NGX_EHOSTUNREACH)
192443881e51 add NGX_ENETDOWN, NGX_ENETUNREACH, and NGX_EHOSTDOWN Igor Sysoev <igor@sysoev.ru> parents: 1470 diff changeset	152 {
541 b09ee85d0ac8 nginx-0.1.45-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	153 level = NGX_LOG_ERR;
1869 192443881e51 add NGX_ENETDOWN, NGX_ENETUNREACH, and NGX_EHOSTDOWN Igor Sysoev <igor@sysoev.ru> parents: 1470 diff changeset	154
541 b09ee85d0ac8 nginx-0.1.45-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	155 } else {
b09ee85d0ac8 nginx-0.1.45-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	156 level = NGX_LOG_CRIT;
b09ee85d0ac8 nginx-0.1.45-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	157 }
487 31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	158
541 b09ee85d0ac8 nginx-0.1.45-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	159 ngx_log_error(level, c->log, err, "connect() to %V failed",
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	160 pc->name);
139 54307053f185 nginx-0.0.1-2003-10-07-19:30:05 import Igor Sysoev <igor@sysoev.ru> parents: 137 diff changeset	161
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	162 return NGX_DECLINED;
122 cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	163 }
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	164 }
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	165
344 e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	166 if (ngx_add_conn) {
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	167 if (rc == -1) {
487 31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	168
344 e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	169 /* NGX_EINPROGRESS */
487 31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	170
344 e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	171 return NGX_AGAIN;
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	172 }
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 563 diff changeset	173
344 e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	174 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, pc->log, 0, "connected");
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	175
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	176 wev->ready = 1;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	177
344 e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	178 return NGX_OK;
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	179 }
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	180
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	181 if (ngx_event_flags & NGX_USE_AIO_EVENT) {
167 8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	182
455 295d97d70c69 nginx-0.1.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	183 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, ngx_socket_errno,
295d97d70c69 nginx-0.1.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	184 "connect(): %d", rc);
295d97d70c69 nginx-0.1.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	185
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	186 /* aio, iocp */
167 8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	187
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	188 if (ngx_blocking(s) == -1) {
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	189 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	190 ngx_blocking_n " failed");
3271 fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	191 goto failed;
167 8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	192 }
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	193
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	194 /*
487 31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	195 * FreeBSD's aio allows to post an operation on non-connected socket.
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 169 diff changeset	196 * NT does not support it.
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 563 diff changeset	197 *
169 edf29bb717da nginx-0.0.1-2003-10-31-19:05:33 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	198 * TODO: check in Win32, etc. As workaround we can use NGX_ONESHOT_EVENT
167 8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	199 */
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 563 diff changeset	200
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	201 rev->ready = 1;
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	202 wev->ready = 1;
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	203
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	204 return NGX_OK;
84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	205 }
84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	206
487 31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	207 if (ngx_event_flags & NGX_USE_CLEAR_EVENT) {
31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	208
31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	209 /* kqueue */
31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	210
137 2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	211 event = NGX_CLEAR_EVENT;
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	212
487 31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	213 } else {
31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	214
31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	215 /* select, poll, /dev/poll */
31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	216
137 2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	217 event = NGX_LEVEL_EVENT;
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	218 }
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	219
162 96993d4d5067 nginx-0.0.1-2003-10-28-00:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 161 diff changeset	220 if (ngx_add_event(rev, NGX_READ_EVENT, event) != NGX_OK) {
3271 fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	221 goto failed;
162 96993d4d5067 nginx-0.0.1-2003-10-28-00:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 161 diff changeset	222 }
96993d4d5067 nginx-0.0.1-2003-10-28-00:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 161 diff changeset	223
137 2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	224 if (rc == -1) {
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	225
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	226 /* NGX_EINPROGRESS */
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	227
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	228 if (ngx_add_event(wev, NGX_WRITE_EVENT, event) != NGX_OK) {
3271 fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	229 goto failed;
137 2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	230 }
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	231
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	232 return NGX_AGAIN;
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	233 }
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	234
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	235 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, pc->log, 0, "connected");
189 c966c09be66b nginx-0.0.1-2003-11-18-19:49:00 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	236
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	237 wev->ready = 1;
5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	238
136 da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	239 return NGX_OK;
3271 fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	240
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	241 failed:
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	242
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	243 ngx_free_connection(c);
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	244
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	245 if (ngx_close_socket(s) == -1) {
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	246 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	247 ngx_close_socket_n " failed");
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	248 }
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	249
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	250 return NGX_ERROR;
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	251 }
131 049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	252
049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	253
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	254 ngx_int_t
4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	255 ngx_event_get_peer(ngx_peer_connection_t pc, void data)
131 049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	256 {
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	257 return NGX_OK;
131 049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	258 }

Mercurial > hg > nginx

annotate src/event/ngx_event_connect.c @ 4119:b66712cde67d