nginx: src/event/ngx_event_connect.c annotate

annotate src/event/ngx_event_connect.c @ 5980:ccad84a174e0

Refactored sendfile() AIO preload. This reduces layering violation and simplifies the logic of AIO preread, since it's now triggered by the send chain function itself without falling back to the copy filter. The context of AIO operation is now stored per file buffer, which makes it possible to properly handle cases when multiple buffers come from different locations, each with its own configuration.

author	Valentin Bartenev <vbart@nginx.com>
date	Wed, 11 Feb 2015 17:52:15 +0300
parents	3377f9459e99
children	4dc8e7b62216

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
4412 d620f497c50f Copyright updated. Maxim Konovalov <maxim@nginx.com> parents: 3365 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: 417 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: 417 diff changeset	6
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	7
136 da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	8 #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	9 #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	10 #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	11 #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	12
131 049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	13
487 31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	14 ngx_int_t
31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	15 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	16 {
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	17 int rc;
1470 92b5f20d54f4 64-bit update lost in r1355 Igor Sysoev <igor@sysoev.ru> parents: 1397 diff changeset	18 ngx_int_t event;
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	19 ngx_err_t err;
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	20 ngx_uint_t level;
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	21 ngx_socket_t s;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	22 ngx_event_t rev, wev;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	23 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	24
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	25 rc = pc->get(pc, pc->data);
4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	26 if (rc != NGX_OK) {
4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	27 return rc;
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	28 }
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	29
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	30 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	31
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	32 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	33
5360 3d2d3e1cf427 Win32: MinGW GCC compatibility. Maxim Dounin <mdounin@mdounin.ru> parents: 5141 diff changeset	34 if (s == (ngx_socket_t) -1) {
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	35 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	36 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	37 return NGX_ERROR;
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	38 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	39
323 ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	40
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	41 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	42
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	43 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	44 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	45 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	46 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	47 }
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	48
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	49 return NGX_ERROR;
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	50 }
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	51
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	52 if (pc->rcvbuf) {
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	53 if (setsockopt(s, SOL_SOCKET, SO_RCVBUF,
563 9c2f3ed7a247 nginx-0.3.3-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 561 diff changeset	54 (const void *) &pc->rcvbuf, sizeof(int)) == -1)
9c2f3ed7a247 nginx-0.3.3-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 561 diff changeset	55 {
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	56 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	57 "setsockopt(SO_RCVBUF) failed");
3271 fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	58 goto failed;
86 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
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	62 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	63 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	64 ngx_nonblocking_n " failed");
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	65
3271 fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	66 goto failed;
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	67 }
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	68
3271 fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	69 if (pc->local) {
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	70 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	71 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	72 "bind(%V) failed", &pc->local->name);
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	73
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	74 goto failed;
86 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 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	77
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	78 c->recv = ngx_recv;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	79 c->send = ngx_send;
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 563 diff changeset	80 c->recv_chain = ngx_recv_chain;
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	81 c->send_chain = ngx_send_chain;
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	82
1397 6c25a49e548a upstream sendfile bit was overridden by r->connection->sendfile Igor Sysoev <igor@sysoev.ru> parents: 884 diff changeset	83 c->sendfile = 1;
6c25a49e548a upstream sendfile bit was overridden by r->connection->sendfile Igor Sysoev <igor@sysoev.ru> parents: 884 diff changeset	84
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	85 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	86
5141 87faa6b818bc Event connect: don't penalize AF_INET6 connections. Maxim Dounin <mdounin@mdounin.ru> parents: 4421 diff changeset	87 if (pc->sockaddr->sa_family == AF_UNIX) {
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	88 c->tcp_nopush = NGX_TCP_NOPUSH_DISABLED;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	89 c->tcp_nodelay = NGX_TCP_NODELAY_DISABLED;
583 4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	90
4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	91 #if (NGX_SOLARIS)
4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	92 /* 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	93 c->sendfile = 0;
4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	94 #endif
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	95 }
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	96
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 545 diff changeset	97 rev = c->read;
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 545 diff changeset	98 wev = c->write;
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	99
191 71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	100 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	101 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	102
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	103 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	104
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 545 diff changeset	105 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	106
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	107 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	108 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	109 goto failed;
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	110 }
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 563 diff changeset	111 }
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	112
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	113 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, pc->log, 0,
5600 957d734362ed Fixed format specifier in logging of "c->number". Sergey Kandaurov <pluknet@nginx.com> parents: 5360 diff changeset	114 "connect to %V, fd:%d #%uA", 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	115
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	116 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	117
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	118 if (rc == -1) {
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	119 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	120
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 169 diff changeset	121
2117 9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	122 if (err != NGX_EINPROGRESS
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	123 #if (NGX_WIN32)
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	124 /* Winsock returns WSAEWOULDBLOCK (NGX_EAGAIN) */
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	125 && err != NGX_EAGAIN
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	126 #endif
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	127 )
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	128 {
1869 192443881e51 add NGX_ENETDOWN, NGX_ENETUNREACH, and NGX_EHOSTDOWN Igor Sysoev <igor@sysoev.ru> parents: 1470 diff changeset	129 if (err == NGX_ECONNREFUSED
2117 9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	130 #if (NGX_LINUX)
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	131 /*
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	132 * Linux returns EAGAIN instead of ECONNREFUSED
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	133 * for unix sockets if listen queue is full
9d62abd76ea5 handle connect()'s EAGAIN on Linux Igor Sysoev <igor@sysoev.ru> parents: 1869 diff changeset	134 */
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
2540 042dcbaead66 lower ECONNRESET level Igor Sysoev <igor@sysoev.ru> parents: 2117 diff changeset	137 \|\| err == NGX_ECONNRESET
1869 192443881e51 add NGX_ENETDOWN, NGX_ENETUNREACH, and NGX_EHOSTDOWN Igor Sysoev <igor@sysoev.ru> parents: 1470 diff changeset	138 \|\| err == NGX_ENETDOWN
192443881e51 add NGX_ENETDOWN, NGX_ENETUNREACH, and NGX_EHOSTDOWN Igor Sysoev <igor@sysoev.ru> parents: 1470 diff changeset	139 \|\| err == NGX_ENETUNREACH
192443881e51 add NGX_ENETDOWN, NGX_ENETUNREACH, and NGX_EHOSTDOWN Igor Sysoev <igor@sysoev.ru> parents: 1470 diff changeset	140 \|\| err == NGX_EHOSTDOWN
192443881e51 add NGX_ENETDOWN, NGX_ENETUNREACH, and NGX_EHOSTDOWN Igor Sysoev <igor@sysoev.ru> parents: 1470 diff changeset	141 \|\| err == NGX_EHOSTUNREACH)
192443881e51 add NGX_ENETDOWN, NGX_ENETUNREACH, and NGX_EHOSTDOWN Igor Sysoev <igor@sysoev.ru> parents: 1470 diff changeset	142 {
541 b09ee85d0ac8 nginx-0.1.45-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	143 level = NGX_LOG_ERR;
1869 192443881e51 add NGX_ENETDOWN, NGX_ENETUNREACH, and NGX_EHOSTDOWN Igor Sysoev <igor@sysoev.ru> parents: 1470 diff changeset	144
541 b09ee85d0ac8 nginx-0.1.45-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	145 } else {
b09ee85d0ac8 nginx-0.1.45-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	146 level = NGX_LOG_CRIT;
b09ee85d0ac8 nginx-0.1.45-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	147 }
487 31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	148
541 b09ee85d0ac8 nginx-0.1.45-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	149 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	150 pc->name);
139 54307053f185 nginx-0.0.1-2003-10-07-19:30:05 import Igor Sysoev <igor@sysoev.ru> parents: 137 diff changeset	151
4421 fbae1a82de8b Fixed error handling in ngx_event_connect_peer(). Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	152 ngx_close_connection(c);
fbae1a82de8b Fixed error handling in ngx_event_connect_peer(). Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	153 pc->connection = NULL;
fbae1a82de8b Fixed error handling in ngx_event_connect_peer(). Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	154
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 541 diff changeset	155 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	156 }
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	157 }
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	158
344 e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	159 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	160 if (rc == -1) {
487 31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	161
344 e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	162 /* NGX_EINPROGRESS */
487 31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	163
344 e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	164 return NGX_AGAIN;
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	165 }
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 563 diff changeset	166
344 e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	167 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	168
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	169 wev->ready = 1;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 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_OK;
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	172 }
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	173
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	174 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	175
455 295d97d70c69 nginx-0.1.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	176 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	177 "connect(): %d", rc);
295d97d70c69 nginx-0.1.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	178
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	179 /* aio, iocp */
167 8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	180
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	181 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	182 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	183 ngx_blocking_n " failed");
3271 fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	184 goto failed;
167 8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	185 }
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	186
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	187 /*
487 31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	188 * 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	189 * NT does not support it.
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 563 diff changeset	190 *
169 edf29bb717da nginx-0.0.1-2003-10-31-19:05:33 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	191 * 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	192 */
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 563 diff changeset	193
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	194 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	195 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	196
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	197 return NGX_OK;
84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	198 }
84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	199
487 31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	200 if (ngx_event_flags & NGX_USE_CLEAR_EVENT) {
31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	201
31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	202 /* kqueue */
31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	203
137 2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	204 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	205
487 31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	206 } else {
31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	207
31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	208 /* select, poll, /dev/poll */
31ff3e943e16 nginx-0.1.18-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	209
137 2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	210 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	211 }
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	212
162 96993d4d5067 nginx-0.0.1-2003-10-28-00:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 161 diff changeset	213 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	214 goto failed;
162 96993d4d5067 nginx-0.0.1-2003-10-28-00:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 161 diff changeset	215 }
96993d4d5067 nginx-0.0.1-2003-10-28-00:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 161 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 if (rc == -1) {
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 /* NGX_EINPROGRESS */
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	220
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	221 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	222 goto failed;
137 2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	223 }
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	224
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	225 return NGX_AGAIN;
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	226 }
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	227
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	228 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	229
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	230 wev->ready = 1;
5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	231
136 da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	232 return NGX_OK;
3271 fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	233
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	234 failed:
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	235
4421 fbae1a82de8b Fixed error handling in ngx_event_connect_peer(). Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	236 ngx_close_connection(c);
fbae1a82de8b Fixed error handling in ngx_event_connect_peer(). Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	237 pc->connection = NULL;
3271 fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	238
fcd98af88df3 proxy_bind, fastcgi_bind, and memcached_bind Igor Sysoev <igor@sysoev.ru> parents: 2540 diff changeset	239 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	240 }
131 049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	241
049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	242
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	243 ngx_int_t
4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	244 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	245 {
884 4d68c486fcb0 upstream choice modules Igor Sysoev <igor@sysoev.ru> parents: 663 diff changeset	246 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	247 }

Mercurial > hg > nginx

annotate src/event/ngx_event_connect.c @ 5980:ccad84a174e0