Mercurial > hg > nginx
annotate src/core/ngx_connection.c @ 635:18268abd340c release-0.3.39
nginx-0.3.39-RELEASE import
*) Feature: the "uninitialized_variable_warn" directive; the logging
level of the "uninitialized variable" message was lowered from
"alert" to "warn".
*) Feature: the "override_charset" directive.
*) Change: now if the unknown variable is used in the "echo" and "if
expr='$name'" SSI-commands, then the "unknown variable" message is
not logged.
*) Bugfix: the active connection counter increased on the exceeding of
the connection limit specified by the "worker_connections"
directive; the bug had appeared in 0.2.0.
*) Bugfix: the limit rate might not work on some condition; the bug had
appeared in 0.3.38.
| author | Igor Sysoev <igor@sysoev.ru> |
|---|---|
| date | Mon, 17 Apr 2006 19:55:41 +0000 |
| parents | 387450de0b4d |
| children | 91ae88fb2500 |
| 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 |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
6 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
7 #include <ngx_config.h> |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
8 #include <ngx_core.h> |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
9 #include <ngx_event.h> |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
10 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
11 |
|
236
86e473b5641e
nginx-0.0.1-2004-01-22-09:47:28 import
Igor Sysoev <igor@sysoev.ru>
parents:
219
diff
changeset
|
12 ngx_os_io_t ngx_io; |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
13 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
14 |
| 521 | 15 ngx_listening_t * |
| 16 ngx_listening_inet_stream_socket(ngx_conf_t *cf, in_addr_t addr, in_port_t port) | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
17 { |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
18 size_t len; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
19 ngx_listening_t *ls; |
| 479 | 20 struct sockaddr_in *sin; |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
21 |
| 501 | 22 ls = ngx_array_push(&cf->cycle->listening); |
| 23 if (ls == NULL) { | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
24 return NULL; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
25 } |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
26 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
27 ngx_memzero(ls, sizeof(ngx_listening_t)); |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
28 |
| 501 | 29 sin = ngx_pcalloc(cf->pool, sizeof(struct sockaddr_in)); |
| 30 if (sin == NULL) { | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
31 return NULL; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
32 } |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
33 |
| 479 | 34 sin->sin_family = AF_INET; |
| 35 sin->sin_addr.s_addr = addr; | |
| 36 sin->sin_port = htons(port); | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
37 |
| 461 | 38 |
| 39 ls->addr_text.data = ngx_palloc(cf->pool, | |
| 40 INET_ADDRSTRLEN - 1 + sizeof(":65535") - 1); | |
| 41 if (ls->addr_text.data == NULL) { | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
42 return NULL; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
43 } |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
44 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
45 len = ngx_inet_ntop(AF_INET, &addr, ls->addr_text.data, INET_ADDRSTRLEN); |
| 461 | 46 |
| 47 ls->addr_text.len = ngx_sprintf(ls->addr_text.data + len, ":%d", port) | |
| 48 - ls->addr_text.data; | |
| 49 | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
50 ls->fd = (ngx_socket_t) -1; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
51 ls->family = AF_INET; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
52 ls->type = SOCK_STREAM; |
| 479 | 53 ls->sockaddr = (struct sockaddr *) sin; |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
54 ls->socklen = sizeof(struct sockaddr_in); |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
55 ls->addr = offsetof(struct sockaddr_in, sin_addr); |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
56 ls->addr_text_max_len = INET_ADDRSTRLEN; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
57 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
58 return ls; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
59 } |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
60 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
61 |
| 521 | 62 ngx_int_t |
| 63 ngx_set_inherited_sockets(ngx_cycle_t *cycle) | |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
64 { |
| 523 | 65 size_t len; |
| 66 ngx_uint_t i; | |
| 67 ngx_listening_t *ls; | |
| 68 struct sockaddr_in *sin; | |
| 563 | 69 socklen_t olen; |
| 523 | 70 #if (NGX_HAVE_DEFERRED_ACCEPT && defined SO_ACCEPTFILTER) |
| 541 | 71 ngx_err_t err; |
| 523 | 72 struct accept_filter_arg af; |
| 73 #endif | |
| 74 #if (NGX_HAVE_DEFERRED_ACCEPT && defined TCP_DEFER_ACCEPT) | |
| 75 int timeout; | |
| 76 #endif | |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
77 |
|
219
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
78 ls = cycle->listening.elts; |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
79 for (i = 0; i < cycle->listening.nelts; i++) { |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
80 |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
81 /* AF_INET only */ |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
82 |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
83 ls[i].sockaddr = ngx_palloc(cycle->pool, sizeof(struct sockaddr_in)); |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
84 if (ls[i].sockaddr == NULL) { |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
85 return NGX_ERROR; |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
86 } |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
87 |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
88 ls[i].socklen = sizeof(struct sockaddr_in); |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
89 if (getsockname(ls[i].fd, ls[i].sockaddr, &ls[i].socklen) == -1) { |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
90 ngx_log_error(NGX_LOG_CRIT, cycle->log, ngx_socket_errno, |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
91 "getsockname() of the inherited " |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
92 "socket #%d failed", ls[i].fd); |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
93 ls[i].ignore = 1; |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
94 continue; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
95 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
96 |
| 479 | 97 sin = (struct sockaddr_in *) ls[i].sockaddr; |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
98 |
| 479 | 99 if (sin->sin_family != AF_INET) { |
|
219
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
100 ngx_log_error(NGX_LOG_CRIT, cycle->log, ngx_socket_errno, |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
101 "the inherited socket #%d has " |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
102 "unsupported family", ls[i].fd); |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
103 ls[i].ignore = 1; |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
104 continue; |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
105 } |
| 461 | 106 |
|
219
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
107 ls[i].addr_text_max_len = INET_ADDRSTRLEN; |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
108 |
| 461 | 109 ls[i].addr_text.data = ngx_palloc(cycle->pool, INET_ADDRSTRLEN - 1 |
| 110 + sizeof(":65535") - 1); | |
|
219
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
111 if (ls[i].addr_text.data == NULL) { |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
112 return NGX_ERROR; |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
113 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
114 |
| 479 | 115 ls[i].family = sin->sin_family; |
| 461 | 116 len = ngx_sock_ntop(ls[i].family, ls[i].sockaddr, |
| 117 ls[i].addr_text.data, INET_ADDRSTRLEN); | |
| 118 if (len == 0) { | |
|
219
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
119 return NGX_ERROR; |
|
f57597ec5249
nginx-0.0.1-2004-01-06-19:49:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
218
diff
changeset
|
120 } |
| 461 | 121 |
| 122 ls[i].addr_text.len = ngx_sprintf(ls[i].addr_text.data + len, ":%d", | |
| 479 | 123 ntohs(sin->sin_port)) |
| 461 | 124 - ls[i].addr_text.data; |
| 523 | 125 |
| 537 | 126 ls[i].backlog = -1; |
| 127 | |
| 563 | 128 olen = sizeof(int); |
| 129 | |
| 130 if (getsockopt(ls[i].fd, SOL_SOCKET, SO_RCVBUF, (void *) &ls[i].rcvbuf, | |
| 131 &olen) | |
| 132 == -1) | |
| 133 { | |
| 134 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_socket_errno, | |
| 135 "getsockopt(SO_RCVBUF) %V failed, ignored", | |
| 136 &ls[i].addr_text); | |
| 137 | |
| 138 ls[i].rcvbuf = -1; | |
| 139 } | |
| 140 | |
| 141 olen = sizeof(int); | |
| 142 | |
| 143 if (getsockopt(ls[i].fd, SOL_SOCKET, SO_SNDBUF, (void *) &ls[i].sndbuf, | |
| 144 &olen) | |
| 145 == -1) | |
| 146 { | |
| 147 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_socket_errno, | |
| 148 "getsockopt(SO_SNDBUF) %V failed, ignored", | |
| 149 &ls[i].addr_text); | |
| 150 | |
| 151 ls[i].sndbuf = -1; | |
| 152 } | |
| 153 | |
| 523 | 154 #if (NGX_HAVE_DEFERRED_ACCEPT && defined SO_ACCEPTFILTER) |
| 155 | |
| 156 ngx_memzero(&af, sizeof(struct accept_filter_arg)); | |
| 563 | 157 olen = sizeof(struct accept_filter_arg); |
| 523 | 158 |
| 563 | 159 if (getsockopt(ls[i].fd, SOL_SOCKET, SO_ACCEPTFILTER, &af, &olen) |
| 523 | 160 == -1) |
| 161 { | |
| 541 | 162 err = ngx_errno; |
| 163 | |
| 164 if (err == NGX_EINVAL) { | |
| 165 continue; | |
| 166 } | |
| 167 | |
| 168 ngx_log_error(NGX_LOG_NOTICE, cycle->log, err, | |
| 523 | 169 "getsockopt(SO_ACCEPTFILTER) for %V failed, ignored", |
| 170 &ls[i].addr_text); | |
| 171 continue; | |
| 172 } | |
| 173 | |
| 563 | 174 if (olen < sizeof(struct accept_filter_arg) || af.af_name[0] == '\0') { |
| 523 | 175 continue; |
| 176 } | |
| 177 | |
| 178 ls[i].accept_filter = ngx_palloc(cycle->pool, 16); | |
| 179 if (ls[i].accept_filter == NULL) { | |
| 180 return NGX_ERROR; | |
| 181 } | |
| 182 | |
| 183 (void) ngx_cpystrn((u_char *) ls[i].accept_filter, | |
| 184 (u_char *) af.af_name, 16); | |
| 185 #endif | |
| 186 | |
| 187 #if (NGX_HAVE_DEFERRED_ACCEPT && defined TCP_DEFER_ACCEPT) | |
| 188 | |
| 189 timeout = 0; | |
| 563 | 190 olen = sizeof(int); |
| 523 | 191 |
| 563 | 192 if (getsockopt(ls[i].fd, IPPROTO_TCP, TCP_DEFER_ACCEPT, &timeout, &olen) |
| 523 | 193 == -1) |
| 194 { | |
| 195 ngx_log_error(NGX_LOG_NOTICE, cycle->log, ngx_errno, | |
| 196 "getsockopt(TCP_DEFER_ACCEPT) for %V failed, ignored", | |
| 197 &ls[i].addr_text); | |
| 198 continue; | |
| 199 } | |
| 200 | |
| 565 | 201 if (olen < sizeof(int) || timeout == 0) { |
| 523 | 202 continue; |
| 203 } | |
| 204 | |
| 205 ls[i].deferred_accept = 1; | |
| 206 #endif | |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
207 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
208 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
209 return NGX_OK; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
210 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
211 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
212 |
| 521 | 213 ngx_int_t |
| 214 ngx_open_listening_sockets(ngx_cycle_t *cycle) | |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
215 { |
| 563 | 216 int reuseaddr; |
| 217 ngx_uint_t i, tries, failed; | |
|
253
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
218 ngx_err_t err; |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
219 ngx_log_t *log; |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
220 ngx_socket_t s; |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
221 ngx_listening_t *ls; |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
222 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
223 reuseaddr = 1; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
224 #if (NGX_SUPPRESS_WARN) |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
225 failed = 0; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
226 #endif |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
227 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
228 log = cycle->log; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
229 |
| 563 | 230 /* TODO: configurable try number */ |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
231 |
| 563 | 232 for (tries = 5 ; tries; tries--) { |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
233 failed = 0; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
234 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
235 /* for each listening socket */ |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
236 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
237 ls = cycle->listening.elts; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
238 for (i = 0; i < cycle->listening.nelts; i++) { |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
239 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
240 if (ls[i].ignore) { |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
241 continue; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
242 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
243 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
244 if (ls[i].fd != -1) { |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
245 continue; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
246 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
247 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
248 if (ls[i].inherited) { |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
249 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
250 /* TODO: close on exit */ |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
251 /* TODO: nonblocking */ |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
252 /* TODO: deferred accept */ |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
253 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
254 continue; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
255 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
256 |
| 479 | 257 s = ngx_socket(ls[i].family, ls[i].type, 0); |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
258 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
259 if (s == -1) { |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
260 ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno, |
| 461 | 261 ngx_socket_n " %V failed", &ls[i].addr_text); |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
262 return NGX_ERROR; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
263 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
264 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
265 if (setsockopt(s, SOL_SOCKET, SO_REUSEADDR, |
| 563 | 266 (const void *) &reuseaddr, sizeof(int)) |
| 267 == -1) | |
| 268 { | |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
269 ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno, |
| 461 | 270 "setsockopt(SO_REUSEADDR) %V failed", |
| 271 &ls[i].addr_text); | |
| 563 | 272 |
| 273 if (ngx_close_socket(s) == -1) | |
| 274 ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno, | |
| 275 ngx_close_socket_n " %V failed", | |
| 276 &ls[i].addr_text); | |
| 277 | |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
278 return NGX_ERROR; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
279 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
280 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
281 /* TODO: close on exit */ |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
282 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
283 if (!(ngx_event_flags & NGX_USE_AIO_EVENT)) { |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
284 if (ngx_nonblocking(s) == -1) { |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
285 ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno, |
| 461 | 286 ngx_nonblocking_n " %V failed", |
| 287 &ls[i].addr_text); | |
| 563 | 288 |
| 289 if (ngx_close_socket(s) == -1) | |
| 290 ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno, | |
| 291 ngx_close_socket_n " %V failed", | |
| 292 &ls[i].addr_text); | |
| 293 | |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
294 return NGX_ERROR; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
295 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
296 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
297 |
| 593 | 298 ngx_log_debug2(NGX_LOG_DEBUG_CORE, cycle->log, 0, |
| 299 "bind() %V #%d ", &ls[i].addr_text, s); | |
| 300 | |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
301 if (bind(s, ls[i].sockaddr, ls[i].socklen) == -1) { |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
302 err = ngx_socket_errno; |
| 563 | 303 |
| 304 if (err == NGX_EADDRINUSE && ngx_test_config) { | |
| 305 continue; | |
| 306 } | |
| 307 | |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
308 ngx_log_error(NGX_LOG_EMERG, log, err, |
| 461 | 309 "bind() to %V failed", &ls[i].addr_text); |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
310 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
311 if (ngx_close_socket(s) == -1) |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
312 ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno, |
| 461 | 313 ngx_close_socket_n " %V failed", |
| 314 &ls[i].addr_text); | |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
315 |
| 563 | 316 if (err != NGX_EADDRINUSE) { |
| 317 return NGX_ERROR; | |
| 318 } | |
| 319 | |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
320 failed = 1; |
| 563 | 321 |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
322 continue; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
323 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
324 |
| 563 | 325 ls[i].listen = 1; |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
326 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
327 ls[i].fd = s; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
328 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
329 |
| 563 | 330 if (!failed) { |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
331 break; |
| 563 | 332 } |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
333 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
334 /* TODO: delay configurable */ |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
335 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
336 ngx_log_error(NGX_LOG_NOTICE, log, 0, |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
337 "try again to bind() after 500ms"); |
| 563 | 338 |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
339 ngx_msleep(500); |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
340 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
341 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
342 if (failed) { |
| 477 | 343 ngx_log_error(NGX_LOG_EMERG, log, 0, "still could not bind()"); |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
344 return NGX_ERROR; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
345 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
346 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
347 return NGX_OK; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
348 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
349 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
350 |
| 521 | 351 void |
| 563 | 352 ngx_configure_listening_socket(ngx_cycle_t *cycle) |
| 353 { | |
| 354 ngx_uint_t i; | |
| 355 ngx_listening_t *ls; | |
| 356 | |
| 357 #if (NGX_HAVE_DEFERRED_ACCEPT && defined SO_ACCEPTFILTER) | |
| 358 struct accept_filter_arg af; | |
| 359 #endif | |
| 360 #if (NGX_HAVE_DEFERRED_ACCEPT && defined TCP_DEFER_ACCEPT) | |
| 361 int timeout; | |
| 362 #endif | |
| 363 | |
| 364 ls = cycle->listening.elts; | |
| 365 for (i = 0; i < cycle->listening.nelts; i++) { | |
| 366 | |
| 367 if (ls[i].rcvbuf != -1) { | |
| 368 if (setsockopt(ls[i].fd, SOL_SOCKET, SO_RCVBUF, | |
| 369 (const void *) &ls[i].rcvbuf, sizeof(int)) | |
| 370 == -1) | |
| 371 { | |
| 372 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_socket_errno, | |
| 569 | 373 "setsockopt(SO_RCVBUF, %d) %V failed, ignored", |
| 374 ls[i].rcvbuf, &ls[i].addr_text); | |
| 563 | 375 } |
| 376 } | |
| 377 | |
| 378 if (ls[i].sndbuf != -1) { | |
| 379 if (setsockopt(ls[i].fd, SOL_SOCKET, SO_SNDBUF, | |
| 380 (const void *) &ls[i].sndbuf, sizeof(int)) | |
| 381 == -1) | |
| 382 { | |
| 383 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_socket_errno, | |
| 569 | 384 "setsockopt(SO_SNDBUF, %d) %V failed, ignored", |
| 385 ls[i].sndbuf, &ls[i].addr_text); | |
| 563 | 386 } |
| 387 } | |
| 388 | |
| 635 | 389 #if 0 |
| 390 if (1) { | |
| 391 int tcp_nodelay = 1; | |
| 392 | |
| 393 if (setsockopt(ls[i].fd, IPPROTO_TCP, TCP_NODELAY, | |
| 394 (const void *) &tcp_nodelay, sizeof(int)) | |
| 395 == -1) | |
| 396 { | |
| 397 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_socket_errno, | |
| 398 "setsockopt(TCP_NODELAY) %V failed, ignored", | |
| 399 &ls[i].addr_text); | |
| 400 } | |
| 401 } | |
| 402 #endif | |
| 403 | |
| 563 | 404 if (ls[i].listen) { |
| 405 if (listen(ls[i].fd, ls[i].backlog) == -1) { | |
| 406 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_socket_errno, | |
| 407 "changing the listen() backlog to %d " | |
| 408 "for %V failed, ignored", | |
| 409 &ls[i].addr_text, ls[i].backlog); | |
| 410 } | |
| 411 } | |
| 412 | |
| 413 /* | |
| 414 * setting deferred mode should be last operation on socket, | |
| 415 * because code may prematurely continue cycle on failure | |
| 416 */ | |
| 417 | |
| 418 #if (NGX_HAVE_DEFERRED_ACCEPT) | |
| 419 | |
| 420 #ifdef SO_ACCEPTFILTER | |
| 421 | |
| 627 | 422 if (ls[i].delete_deferred) { |
| 423 if (setsockopt(ls[i].fd, SOL_SOCKET, SO_ACCEPTFILTER, NULL, 0) | |
| 424 == -1) | |
| 563 | 425 { |
| 426 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 427 "setsockopt(SO_ACCEPTFILTER, NULL) " | |
| 428 "for %V failed, ignored", | |
| 627 | 429 &ls[i].addr_text); |
| 563 | 430 |
| 627 | 431 if (ls[i].accept_filter) { |
| 563 | 432 ngx_log_error(NGX_LOG_ALERT, cycle->log, 0, |
| 433 "could not change the accept filter " | |
| 434 "to \"%s\" for %V, ignored", | |
| 627 | 435 ls[i].accept_filter, &ls[i].addr_text); |
| 563 | 436 } |
| 437 | |
| 438 continue; | |
| 439 } | |
| 440 | |
| 627 | 441 ls[i].deferred_accept = 0; |
| 563 | 442 } |
| 443 | |
| 627 | 444 if (ls[i].add_deferred) { |
| 563 | 445 ngx_memzero(&af, sizeof(struct accept_filter_arg)); |
| 446 (void) ngx_cpystrn((u_char *) af.af_name, | |
| 627 | 447 (u_char *) ls[i].accept_filter, 16); |
| 563 | 448 |
| 627 | 449 if (setsockopt(ls[i].fd, SOL_SOCKET, SO_ACCEPTFILTER, |
| 563 | 450 &af, sizeof(struct accept_filter_arg)) |
| 451 == -1) | |
| 452 { | |
| 453 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 454 "setsockopt(SO_ACCEPTFILTER, \"%s\") " | |
| 455 " for %V failed, ignored", | |
| 627 | 456 ls[i].accept_filter, &ls[i].addr_text); |
| 563 | 457 continue; |
| 458 } | |
| 459 | |
| 627 | 460 ls[i].deferred_accept = 1; |
| 563 | 461 } |
| 462 | |
| 463 #endif | |
| 464 | |
| 465 #ifdef TCP_DEFER_ACCEPT | |
| 466 | |
| 627 | 467 if (ls[i].add_deferred || ls[i].delete_deferred) { |
| 563 | 468 |
| 627 | 469 if (ls[i].add_deferred) { |
| 470 timeout = (int) (ls[i].post_accept_timeout / 1000); | |
| 563 | 471 |
| 472 } else { | |
| 473 timeout = 0; | |
| 474 } | |
| 475 | |
| 627 | 476 if (setsockopt(ls[i].fd, IPPROTO_TCP, TCP_DEFER_ACCEPT, |
| 563 | 477 &timeout, sizeof(int)) |
| 478 == -1) | |
| 479 { | |
| 480 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 481 "setsockopt(TCP_DEFER_ACCEPT, %d) for %V failed, " | |
| 482 "ignored", | |
| 627 | 483 timeout, &ls[i].addr_text); |
| 563 | 484 |
| 485 continue; | |
| 486 } | |
| 487 } | |
| 488 | |
| 627 | 489 if (ls[i].add_deferred) { |
| 490 ls[i].deferred_accept = 1; | |
| 563 | 491 } |
| 492 | |
| 493 #endif | |
| 494 | |
| 495 #endif /* NGX_HAVE_DEFERRED_ACCEPT */ | |
| 496 } | |
| 497 | |
| 498 return; | |
| 499 } | |
| 500 | |
| 501 | |
| 502 void | |
| 521 | 503 ngx_close_listening_sockets(ngx_cycle_t *cycle) |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
504 { |
| 543 | 505 ngx_uint_t i; |
| 506 ngx_listening_t *ls; | |
| 507 ngx_connection_t *c; | |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
508 |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
509 if (ngx_event_flags & NGX_USE_IOCP_EVENT) { |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
510 return; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
511 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
512 |
|
303
00c5660d2707
nginx-0.0.3-2004-04-01-20:20:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
513 ngx_accept_mutex_held = 0; |
| 611 | 514 ngx_use_accept_mutex = 0; |
|
303
00c5660d2707
nginx-0.0.3-2004-04-01-20:20:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
515 |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
516 ls = cycle->listening.elts; |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
517 for (i = 0; i < cycle->listening.nelts; i++) { |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
518 |
| 543 | 519 c = ls[i].connection; |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
520 |
|
346
55e496a8ece3
nginx-0.0.3-2004-06-06-23:49:18 import
Igor Sysoev <igor@sysoev.ru>
parents:
317
diff
changeset
|
521 if (ngx_event_flags & NGX_USE_RTSIG_EVENT) { |
| 543 | 522 if (c->read->active) { |
| 523 ngx_del_conn(c, NGX_CLOSE_EVENT); | |
|
317
1308b98496a2
nginx-0.0.3-2004-04-15-19:34:36 import
Igor Sysoev <igor@sysoev.ru>
parents:
303
diff
changeset
|
524 } |
|
1308b98496a2
nginx-0.0.3-2004-04-15-19:34:36 import
Igor Sysoev <igor@sysoev.ru>
parents:
303
diff
changeset
|
525 |
|
1308b98496a2
nginx-0.0.3-2004-04-15-19:34:36 import
Igor Sysoev <igor@sysoev.ru>
parents:
303
diff
changeset
|
526 } else { |
| 543 | 527 if (c->read->active) { |
| 528 ngx_del_event(c->read, NGX_READ_EVENT, NGX_CLOSE_EVENT); | |
|
317
1308b98496a2
nginx-0.0.3-2004-04-15-19:34:36 import
Igor Sysoev <igor@sysoev.ru>
parents:
303
diff
changeset
|
529 } |
|
1308b98496a2
nginx-0.0.3-2004-04-15-19:34:36 import
Igor Sysoev <igor@sysoev.ru>
parents:
303
diff
changeset
|
530 } |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
531 |
| 543 | 532 ngx_free_connection(c); |
| 533 | |
| 534 c->fd = (ngx_socket_t) -1; | |
| 535 | |
| 563 | 536 ngx_log_debug2(NGX_LOG_DEBUG_CORE, cycle->log, 0, |
| 537 "close listening %V #%d ", &ls[i].addr_text, ls[i].fd); | |
| 538 | |
| 543 | 539 if (ngx_close_socket(ls[i].fd) == -1) { |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
540 ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_socket_errno, |
| 461 | 541 ngx_close_socket_n " %V failed", &ls[i].addr_text); |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
542 } |
| 543 | 543 } |
| 544 } | |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
545 |
| 543 | 546 |
| 547 ngx_connection_t * | |
| 548 ngx_get_connection(ngx_socket_t s, ngx_log_t *log) | |
| 549 { | |
| 561 | 550 ngx_uint_t instance; |
| 551 ngx_event_t *rev, *wev; | |
| 552 ngx_connection_t *c; | |
| 543 | 553 |
| 554 /* disable warning: Win32 SOCKET is u_int while UNIX socket is int */ | |
| 555 | |
| 556 if (ngx_cycle->files && (ngx_uint_t) s >= ngx_cycle->files_n) { | |
| 557 ngx_log_error(NGX_LOG_ALERT, log, 0, | |
| 558 "the new socket has number %d, " | |
| 559 "but only %ui files are available", | |
| 560 s, ngx_cycle->files_n); | |
| 561 return NULL; | |
| 562 } | |
| 563 | |
| 564 /* ngx_mutex_lock */ | |
| 565 | |
| 566 c = ngx_cycle->free_connections; | |
| 567 | |
| 568 if (c == NULL) { | |
| 569 ngx_log_error(NGX_LOG_ALERT, log, 0, | |
| 570 "%ui worker_connections is not enough", | |
| 571 ngx_cycle->connection_n); | |
| 572 | |
| 573 /* ngx_mutex_unlock */ | |
| 574 | |
| 575 return NULL; | |
| 576 } | |
| 577 | |
| 578 ngx_cycle->free_connections = c->data; | |
| 579 ngx_cycle->free_connection_n--; | |
| 580 | |
| 581 /* ngx_mutex_unlock */ | |
| 582 | |
| 583 if (ngx_cycle->files) { | |
| 584 ngx_cycle->files[s] = c; | |
| 585 } | |
| 586 | |
| 561 | 587 rev = c->read; |
| 588 wev = c->write; | |
| 589 | |
| 590 ngx_memzero(c, sizeof(ngx_connection_t)); | |
| 591 | |
| 592 c->read = rev; | |
| 593 c->write = wev; | |
| 594 c->fd = s; | |
| 595 c->log = log; | |
| 596 | |
| 597 instance = rev->instance; | |
| 598 | |
| 599 ngx_memzero(rev, sizeof(ngx_event_t)); | |
| 600 ngx_memzero(wev, sizeof(ngx_event_t)); | |
| 601 | |
| 602 rev->instance = !instance; | |
| 603 wev->instance = !instance; | |
| 604 | |
| 605 rev->index = NGX_INVALID_INDEX; | |
| 606 wev->index = NGX_INVALID_INDEX; | |
| 607 | |
| 608 rev->data = c; | |
| 609 wev->data = c; | |
| 610 | |
| 611 wev->write = 1; | |
| 612 | |
| 543 | 613 return c; |
| 614 } | |
| 615 | |
| 616 | |
| 617 void | |
| 618 ngx_free_connection(ngx_connection_t *c) | |
| 619 { | |
| 620 /* ngx_mutex_lock */ | |
| 621 | |
| 622 c->data = ngx_cycle->free_connections; | |
| 623 ngx_cycle->free_connections = c; | |
| 624 ngx_cycle->free_connection_n++; | |
| 625 | |
| 626 /* ngx_mutex_unlock */ | |
| 627 | |
| 628 if (ngx_cycle->files) { | |
| 629 ngx_cycle->files[c->fd] = NULL; | |
|
218
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
630 } |
|
05592fd7a436
nginx-0.0.1-2004-01-05-23:55:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
631 } |
|
253
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
632 |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
633 |
| 521 | 634 void |
| 635 ngx_close_connection(ngx_connection_t *c) | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
636 { |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
637 ngx_socket_t fd; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
638 |
| 479 | 639 if (c->fd == -1) { |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
640 ngx_log_error(NGX_LOG_ALERT, c->log, 0, "connection already closed"); |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
641 return; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
642 } |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
643 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
644 if (c->read->timer_set) { |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
645 ngx_del_timer(c->read); |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
646 } |
| 577 | 647 |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
648 if (c->write->timer_set) { |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
649 ngx_del_timer(c->write); |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
650 } |
| 577 | 651 |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
652 if (ngx_del_conn) { |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
653 ngx_del_conn(c, NGX_CLOSE_EVENT); |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
654 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
655 } else { |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
656 if (c->read->active || c->read->disabled) { |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
657 ngx_del_event(c->read, NGX_READ_EVENT, NGX_CLOSE_EVENT); |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
658 } |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
659 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
660 if (c->write->active || c->write->disabled) { |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
661 ngx_del_event(c->write, NGX_WRITE_EVENT, NGX_CLOSE_EVENT); |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
662 } |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
663 } |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
664 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
665 #if (NGX_THREADS) |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
666 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
667 /* |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
668 * we have to clean the connection information before the closing |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
669 * because another thread may reopen the same file descriptor |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
670 * before we clean the connection |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
671 */ |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
672 |
| 563 | 673 ngx_mutex_lock(ngx_posted_events_mutex); |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
674 |
| 563 | 675 if (c->read->prev) { |
| 676 ngx_delete_posted_event(c->read); | |
| 677 } | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
678 |
| 563 | 679 if (c->write->prev) { |
| 680 ngx_delete_posted_event(c->write); | |
| 681 } | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
682 |
| 563 | 683 c->read->closed = 1; |
| 684 c->write->closed = 1; | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
685 |
| 563 | 686 if (c->single_connection) { |
| 687 ngx_unlock(&c->lock); | |
| 688 c->read->locked = 0; | |
| 689 c->write->locked = 0; | |
| 690 } | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
691 |
| 563 | 692 ngx_mutex_unlock(ngx_posted_events_mutex); |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
693 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
694 #else |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
695 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
696 if (c->read->prev) { |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
697 ngx_delete_posted_event(c->read); |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
698 } |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
699 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
700 if (c->write->prev) { |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
701 ngx_delete_posted_event(c->write); |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
702 } |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
703 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
704 c->read->closed = 1; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
705 c->write->closed = 1; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
706 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
707 #endif |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
708 |
| 543 | 709 ngx_free_connection(c); |
| 710 | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
711 fd = c->fd; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
712 c->fd = (ngx_socket_t) -1; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
713 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
714 if (ngx_close_socket(fd) == -1) { |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
715 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
716 /* we use ngx_cycle->log because c->log was in c->pool */ |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
717 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
718 ngx_log_error(NGX_LOG_ALERT, ngx_cycle->log, ngx_socket_errno, |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
719 ngx_close_socket_n " failed"); |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
720 } |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
721 } |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
722 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
346
diff
changeset
|
723 |
| 521 | 724 ngx_int_t |
| 725 ngx_connection_error(ngx_connection_t *c, ngx_err_t err, char *text) | |
|
253
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
726 { |
|
257
70e1c7d2b83d
nginx-0.0.2-2004-02-11-20:08:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
256
diff
changeset
|
727 ngx_uint_t level; |
|
253
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
728 |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
729 if (err == NGX_ECONNRESET |
|
256
8e39cab6abd5
nginx-0.0.2-2004-02-10-19:23:38 import
Igor Sysoev <igor@sysoev.ru>
parents:
253
diff
changeset
|
730 && c->log_error == NGX_ERROR_IGNORE_ECONNRESET) |
|
253
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
731 { |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
732 return 0; |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
733 } |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
734 |
| 537 | 735 if (err == 0 |
| 736 || err == NGX_ECONNRESET | |
| 461 | 737 #if !(NGX_WIN32) |
|
278
0ba4821f4460
nginx-0.0.2-2004-03-04-10:04:55 import
Igor Sysoev <igor@sysoev.ru>
parents:
257
diff
changeset
|
738 || err == NGX_EPIPE |
|
0ba4821f4460
nginx-0.0.2-2004-03-04-10:04:55 import
Igor Sysoev <igor@sysoev.ru>
parents:
257
diff
changeset
|
739 #endif |
|
288
f81d075ad172
nginx-0.0.2-2004-03-14-23:46:25 import
Igor Sysoev <igor@sysoev.ru>
parents:
282
diff
changeset
|
740 || err == NGX_ENOTCONN |
| 587 | 741 || err == NGX_ETIMEDOUT |
|
288
f81d075ad172
nginx-0.0.2-2004-03-14-23:46:25 import
Igor Sysoev <igor@sysoev.ru>
parents:
282
diff
changeset
|
742 || err == NGX_ECONNREFUSED |
|
f81d075ad172
nginx-0.0.2-2004-03-14-23:46:25 import
Igor Sysoev <igor@sysoev.ru>
parents:
282
diff
changeset
|
743 || err == NGX_EHOSTUNREACH) |
|
278
0ba4821f4460
nginx-0.0.2-2004-03-04-10:04:55 import
Igor Sysoev <igor@sysoev.ru>
parents:
257
diff
changeset
|
744 { |
|
256
8e39cab6abd5
nginx-0.0.2-2004-02-10-19:23:38 import
Igor Sysoev <igor@sysoev.ru>
parents:
253
diff
changeset
|
745 switch (c->log_error) { |
|
253
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
746 |
|
257
70e1c7d2b83d
nginx-0.0.2-2004-02-11-20:08:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
256
diff
changeset
|
747 case NGX_ERROR_IGNORE_ECONNRESET: |
|
253
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
748 case NGX_ERROR_INFO: |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
749 level = NGX_LOG_INFO; |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
750 break; |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
751 |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
752 case NGX_ERROR_ERR: |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
753 level = NGX_LOG_ERR; |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
754 break; |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
755 |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
756 default: |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
757 level = NGX_LOG_CRIT; |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
758 } |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
759 |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
760 } else { |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
761 level = NGX_LOG_CRIT; |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
762 } |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
763 |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
764 ngx_log_error(level, c->log, err, text); |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
765 |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
766 return NGX_ERROR; |
|
b6793bc5034b
nginx-0.0.2-2004-02-09-10:46:43 import
Igor Sysoev <igor@sysoev.ru>
parents:
242
diff
changeset
|
767 } |