Mercurial > hg > nginx

comparison src/core/ngx_connection.c @ 218:05592fd7a436

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.0.1-2004-01-05-23:55:48 import
author Igor Sysoev <igor@sysoev.ru>
date Mon, 05 Jan 2004 20:55:48 +0000
parents
children f57597ec5249
comparison
equal deleted inserted replaced
217:c5d1cdcb04ec 218:05592fd7a436
1
2 #include <ngx_config.h>
3 #include <ngx_core.h>
4 #include <ngx_event.h>
5 /* STUB */
6 #include <nginx.h>
7
8
9 ngx_os_io_t ngx_io;
10
11
12 ngx_int_t ngx_set_inherited_sockets(ngx_cycle_t *cycle, char **envp)
13 {
14 char *p, *v;
15 ngx_socket_t s;
16 ngx_listening_t *ls;
17 struct sockaddr_in *addr_in;
18
19 for ( /* void */ ; *envp; envp++) {
20 if (ngx_strncmp(*envp, NGINX_VAR, NGINX_VAR_LEN) != 0) {
21 continue;
22 }
23
24 ngx_log_error(NGX_LOG_INFO, cycle->log, 0,
25 "using inherited sockets from \"%s\"", *envp);
26
27 ngx_init_array(cycle->listening, cycle->pool,
28 10, sizeof(ngx_listening_t), NGX_ERROR);
29
30 for (p = *envp + NGINX_VAR_LEN, v = p; *p; p++) {
31 if (*p == ':' || *p == ';') {
32 s = ngx_atoi(v, p - v);
33 if (s == NGX_ERROR) {
34 ngx_log_error(NGX_LOG_EMERG, cycle->log, 0,
35 "invalid socket number \"%s\" "
36 "in NGINX enviroment variable, "
37 "ignoring the rest of the variable", v);
38 break;
39 }
40 v = p + 1;
41
42 if (!(ls = ngx_push_array(&cycle->listening))) {
43 return NGX_ERROR;
44 }
45
46 ls->fd = s;
47
48 /* AF_INET only */
49
50 ls->sockaddr = ngx_palloc(cycle->pool,
51 sizeof(struct sockaddr_in));
52 if (ls->sockaddr == NULL) {
53 return NGX_ERROR;
54 }
55
56 ls->socklen = sizeof(struct sockaddr_in);
57 if (getsockname(s, ls->sockaddr, &ls->socklen) == -1) {
58 ngx_log_error(NGX_LOG_CRIT, cycle->log, ngx_socket_errno,
59 "getsockname() of the inherited "
60 "socket #%d failed", s);
61 ls->ignore = 1;
62 continue;
63 }
64
65 addr_in = (struct sockaddr_in *) ls->sockaddr;
66
67 if (addr_in->sin_family != AF_INET) {
68 ngx_log_error(NGX_LOG_CRIT, cycle->log, ngx_socket_errno,
69 "the inherited socket #%d has "
70 "unsupported family", s);
71 ls->ignore = 1;
72 continue;
73 }
74 ls->addr_text_max_len = INET_ADDRSTRLEN;
75
76 ls->addr_text.data = ngx_palloc(cycle->pool,
77 ls->addr_text_max_len);
78 if (ls->addr_text.data == NULL) {
79 return NGX_ERROR;
80 }
81
82 addr_in->sin_len = 0;
83
84 ls->family = addr_in->sin_family;
85 ls->addr_text.len = ngx_sock_ntop(ls->family, ls->sockaddr,
86 ls->addr_text.data,
87 ls->addr_text_max_len);
88 if (ls->addr_text.len == 0) {
89 return NGX_ERROR;
90 }
91 }
92 }
93
94 break;
95 }
96
97 return NGX_OK;
98 }
99
100
101 ngx_int_t ngx_open_listening_sockets(ngx_cycle_t *cycle)
102 {
103 int tries, failed, reuseaddr, i;
104 ngx_err_t err;
105 ngx_log_t *log;
106 ngx_socket_t s;
107 ngx_listening_t *ls;
108
109 reuseaddr = 1;
110 #if (NGX_SUPPRESS_WARN)
111 failed = 0;
112 #endif
113
114 log = cycle->log;
115
116 /* TODO: tries configurable */
117
118 for (tries = 10; tries; tries--) {
119 failed = 0;
120
121 /* for each listening socket */
122
123 ls = cycle->listening.elts;
124 for (i = 0; i < cycle->listening.nelts; i++) {
125
126 if (ls[i].ignore) {
127 continue;
128 }
129
130 if (ls[i].fd != -1) {
131 continue;
132 }
133
134 if (ls[i].inherited) {
135
136 /* TODO: close on exit */
137 /* TODO: nonblocking */
138 /* TODO: deferred accept */
139
140 continue;
141 }
142
143 s = ngx_socket(ls[i].family, ls[i].type, ls[i].protocol,
144 ls[i].flags);
145
146 if (s == -1) {
147 ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno,
148 ngx_socket_n " %s failed", ls[i].addr_text.data);
149 return NGX_ERROR;
150 }
151
152 #if (WIN32)
153 /*
154 * Winsock assignes a socket number divisible by 4
155 * so to find a connection we divide a socket number by 4.
156 */
157
158 if (s % 4) {
159 ngx_log_error(NGX_LOG_EMERG, ls->log, 0,
160 ngx_socket_n " created socket %d", s);
161 return NGX_ERROR;
162 }
163 #endif
164
165 if (setsockopt(s, SOL_SOCKET, SO_REUSEADDR,
166 (const void *) &reuseaddr, sizeof(int)) == -1) {
167 ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno,
168 "setsockopt(SO_REUSEADDR) %s failed",
169 ls[i].addr_text.data);
170 return NGX_ERROR;
171 }
172
173 /* TODO: close on exit */
174
175 if (!(ngx_event_flags & NGX_USE_AIO_EVENT)) {
176 if (ngx_nonblocking(s) == -1) {
177 ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno,
178 ngx_nonblocking_n " %s failed",
179 ls[i].addr_text.data);
180 return NGX_ERROR;
181 }
182 }
183
184 #if 0
185 if (ls[i].nonblocking) {
186 if (ngx_nonblocking(s) == -1) {
187 ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno,
188 ngx_nonblocking_n " %s failed",
189 ls[i].addr_text.data);
190 return NGX_ERROR;
191 }
192 }
193 #endif
194
195 if (bind(s, ls[i].sockaddr, ls[i].socklen) == -1) {
196 err = ngx_socket_errno;
197 ngx_log_error(NGX_LOG_EMERG, log, err,
198 "bind() to %s failed", ls[i].addr_text.data);
199
200 if (err != NGX_EADDRINUSE)
201 return NGX_ERROR;
202
203 if (ngx_close_socket(s) == -1)
204 ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno,
205 ngx_close_socket_n " %s failed",
206 ls[i].addr_text.data);
207
208 failed = 1;
209 continue;
210 }
211
212 if (listen(s, ls[i].backlog) == -1) {
213 ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno,
214 "listen() to %s failed", ls[i].addr_text.data);
215 return NGX_ERROR;
216 }
217
218 /* TODO: deferred accept */
219
220 ls[i].fd = s;
221 }
222
223 if (!failed)
224 break;
225
226 /* TODO: delay configurable */
227
228 ngx_log_error(NGX_LOG_NOTICE, log, 0,
229 "try again to bind() after 500ms");
230 ngx_msleep(500);
231 }
232
233 if (failed) {
234 ngx_log_error(NGX_LOG_EMERG, log, 0, "still can not bind()");
235 return NGX_ERROR;
236 }
237
238 return NGX_OK;
239 }
240
241
242 void ngx_close_listening_sockets(ngx_cycle_t *cycle)
243 {
244 ngx_int_t i;
245 ngx_socket_t fd;
246 ngx_listening_t *ls;
247
248 if (ngx_event_flags & NGX_USE_IOCP_EVENT) {
249 return;
250 }
251
252 ls = cycle->listening.elts;
253 for (i = 0; i < cycle->listening.nelts; i++) {
254 fd = ls[i].fd;
255
256 #if (WIN32)
257 /*
258 * Winsock assignes a socket number divisible by 4
259 * so to find a connection we divide a socket number by 4.
260 */
261
262 fd /= 4;
263 #endif
264
265 ngx_del_event(&cycle->read_events[fd], NGX_READ_EVENT, NGX_CLOSE_EVENT);
266
267 if (ngx_close_socket(ls[i].fd) == -1) {
268 ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_socket_errno,
269 ngx_close_socket_n " %s failed",
270 ls[i].addr_text.data);
271 }
272
273 cycle->connections[fd].fd = -1;
274 }
275 }