Mercurial > hg > nginx
annotate src/event/ngx_event_accept.c @ 7408:8af6dceeb648 stable-1.14
Events: fixed handling zero-length client address.
On Linux recvmsg() syscall may return a zero-length client address when
receiving a datagram from an unbound unix datagram socket. It is usually
assumed that socket address has at least the sa_family member. Zero-length
socket address caused buffer over-read in functions which receive socket
address, for example ngx_sock_ntop(). Typically the over-read resulted in
unexpected socket family followed by session close. Now a fake socket address
is allocated instead of a zero-length client address.
| author | Roman Arutyunyan <arut@nginx.com> |
|---|---|
| date | Fri, 01 Jun 2018 16:53:02 +0300 |
| parents | fef61d26da39 |
| children | 52aacc8ddcc5 |
| 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:
431
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:
431
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 | 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:
431
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:
431
diff
changeset
|
6 |
|
97
70d2345a903f
nginx-0.0.1-2003-05-29-17:02:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
96
diff
changeset
|
7 |
|
70d2345a903f
nginx-0.0.1-2003-05-29-17:02:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
96
diff
changeset
|
8 #include <ngx_config.h> |
|
70d2345a903f
nginx-0.0.1-2003-05-29-17:02:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
96
diff
changeset
|
9 #include <ngx_core.h> |
|
99
a059e1aa65d4
nginx-0.0.1-2003-06-02-19:24:30 import
Igor Sysoev <igor@sysoev.ru>
parents:
98
diff
changeset
|
10 #include <ngx_event.h> |
|
0
4eff17414a43
nginx-0.0.1-2002-08-06-20:39:45 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
11 |
|
4eff17414a43
nginx-0.0.1-2002-08-06-20:39:45 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
12 |
| 573 | 13 static ngx_int_t ngx_enable_accept_events(ngx_cycle_t *cycle); |
|
6153
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
14 static ngx_int_t ngx_disable_accept_events(ngx_cycle_t *cycle, ngx_uint_t all); |
| 543 | 15 static void ngx_close_accepted_connection(ngx_connection_t *c); |
| 6436 | 16 #if (NGX_DEBUG) |
| 17 static void ngx_debug_accepted_connection(ngx_event_conf_t *ecf, | |
| 18 ngx_connection_t *c); | |
| 19 #endif | |
|
191
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
20 |
|
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
21 |
| 493 | 22 void |
| 23 ngx_event_accept(ngx_event_t *ev) | |
|
0
4eff17414a43
nginx-0.0.1-2002-08-06-20:39:45 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
24 { |
| 714 | 25 socklen_t socklen; |
| 483 | 26 ngx_err_t err; |
| 27 ngx_log_t *log; | |
|
4618
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
28 ngx_uint_t level; |
| 483 | 29 ngx_socket_t s; |
| 30 ngx_event_t *rev, *wev; | |
|
6559
adf25b8d0431
Introduced the ngx_sockaddr_t type.
Ruslan Ermilov <ru@nginx.com>
parents:
6532
diff
changeset
|
31 ngx_sockaddr_t sa; |
| 543 | 32 ngx_listening_t *ls; |
| 33 ngx_connection_t *c, *lc; | |
| 483 | 34 ngx_event_conf_t *ecf; |
|
3812
ef27dc1a7832
fallback to accept() if accept4() is not implemented,
Igor Sysoev <igor@sysoev.ru>
parents:
3786
diff
changeset
|
35 #if (NGX_HAVE_ACCEPT4) |
|
ef27dc1a7832
fallback to accept() if accept4() is not implemented,
Igor Sysoev <igor@sysoev.ru>
parents:
3786
diff
changeset
|
36 static ngx_uint_t use_accept4 = 1; |
|
ef27dc1a7832
fallback to accept() if accept4() is not implemented,
Igor Sysoev <igor@sysoev.ru>
parents:
3786
diff
changeset
|
37 #endif |
|
26
53cb81681040
nginx-0.0.1-2002-12-15-09:25:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
24
diff
changeset
|
38 |
|
4618
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
39 if (ev->timedout) { |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
40 if (ngx_enable_accept_events((ngx_cycle_t *) ngx_cycle) != NGX_OK) { |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
41 return; |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
42 } |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
43 |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
44 ev->timedout = 0; |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
45 } |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
46 |
|
114
ac69ab96328d
nginx-0.0.1-2003-07-07-10:11:50 import
Igor Sysoev <igor@sysoev.ru>
parents:
113
diff
changeset
|
47 ecf = ngx_event_get_conf(ngx_cycle->conf_ctx, ngx_event_core_module); |
|
97
70d2345a903f
nginx-0.0.1-2003-05-29-17:02:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
96
diff
changeset
|
48 |
|
6126
adba26ff70b5
Removed the obsolete rtsig module.
Ruslan Ermilov <ru@nginx.com>
parents:
6125
diff
changeset
|
49 if (!(ngx_event_flags & NGX_USE_KQUEUE_EVENT)) { |
|
248
e885208c518b
nginx-0.0.2-2004-02-03-00:19:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
247
diff
changeset
|
50 ev->available = ecf->multi_accept; |
|
e885208c518b
nginx-0.0.2-2004-02-03-00:19:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
247
diff
changeset
|
51 } |
|
e885208c518b
nginx-0.0.2-2004-02-03-00:19:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
247
diff
changeset
|
52 |
| 543 | 53 lc = ev->data; |
| 54 ls = lc->listening; | |
| 55 ev->ready = 0; | |
|
57
a499e0d1f16e
nginx-0.0.1-2003-01-30-10:28:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
44
diff
changeset
|
56 |
|
257
70e1c7d2b83d
nginx-0.0.2-2004-02-11-20:08:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
253
diff
changeset
|
57 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, |
| 543 | 58 "accept on %V, ready: %d", &ls->addr_text, ev->available); |
|
57
a499e0d1f16e
nginx-0.0.1-2003-01-30-10:28:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
44
diff
changeset
|
59 |
|
0
4eff17414a43
nginx-0.0.1-2002-08-06-20:39:45 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
60 do { |
|
6559
adf25b8d0431
Introduced the ngx_sockaddr_t type.
Ruslan Ermilov <ru@nginx.com>
parents:
6532
diff
changeset
|
61 socklen = sizeof(ngx_sockaddr_t); |
|
191
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
62 |
| 3786 | 63 #if (NGX_HAVE_ACCEPT4) |
|
3812
ef27dc1a7832
fallback to accept() if accept4() is not implemented,
Igor Sysoev <igor@sysoev.ru>
parents:
3786
diff
changeset
|
64 if (use_accept4) { |
|
6559
adf25b8d0431
Introduced the ngx_sockaddr_t type.
Ruslan Ermilov <ru@nginx.com>
parents:
6532
diff
changeset
|
65 s = accept4(lc->fd, &sa.sockaddr, &socklen, SOCK_NONBLOCK); |
|
3812
ef27dc1a7832
fallback to accept() if accept4() is not implemented,
Igor Sysoev <igor@sysoev.ru>
parents:
3786
diff
changeset
|
66 } else { |
|
6559
adf25b8d0431
Introduced the ngx_sockaddr_t type.
Ruslan Ermilov <ru@nginx.com>
parents:
6532
diff
changeset
|
67 s = accept(lc->fd, &sa.sockaddr, &socklen); |
|
3812
ef27dc1a7832
fallback to accept() if accept4() is not implemented,
Igor Sysoev <igor@sysoev.ru>
parents:
3786
diff
changeset
|
68 } |
| 3786 | 69 #else |
|
6559
adf25b8d0431
Introduced the ngx_sockaddr_t type.
Ruslan Ermilov <ru@nginx.com>
parents:
6532
diff
changeset
|
70 s = accept(lc->fd, &sa.sockaddr, &socklen); |
| 3786 | 71 #endif |
| 477 | 72 |
|
5360
3d2d3e1cf427
Win32: MinGW GCC compatibility.
Maxim Dounin <mdounin@mdounin.ru>
parents:
5359
diff
changeset
|
73 if (s == (ngx_socket_t) -1) { |
|
0
4eff17414a43
nginx-0.0.1-2002-08-06-20:39:45 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
74 err = ngx_socket_errno; |
|
57
a499e0d1f16e
nginx-0.0.1-2003-01-30-10:28:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
44
diff
changeset
|
75 |
|
0
4eff17414a43
nginx-0.0.1-2002-08-06-20:39:45 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
76 if (err == NGX_EAGAIN) { |
|
719
f30b1a75fd3b
Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
714
diff
changeset
|
77 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, ev->log, err, |
|
f30b1a75fd3b
Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
714
diff
changeset
|
78 "accept() not ready"); |
|
87
5f6d848dcbef
nginx-0.0.1-2003-05-13-20:02:32 import
Igor Sysoev <igor@sysoev.ru>
parents:
86
diff
changeset
|
79 return; |
|
0
4eff17414a43
nginx-0.0.1-2002-08-06-20:39:45 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
80 } |
|
6
669801705ab1
nginx-0.0.1-2002-08-26-19:18:19 import
Igor Sysoev <igor@sysoev.ru>
parents:
3
diff
changeset
|
81 |
|
4618
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
82 level = NGX_LOG_ALERT; |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
83 |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
84 if (err == NGX_ECONNABORTED) { |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
85 level = NGX_LOG_ERR; |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
86 |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
87 } else if (err == NGX_EMFILE || err == NGX_ENFILE) { |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
88 level = NGX_LOG_CRIT; |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
89 } |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
90 |
|
3813
c870fb78550c
fix building by msvc8 introduced by the previous commit
Igor Sysoev <igor@sysoev.ru>
parents:
3812
diff
changeset
|
91 #if (NGX_HAVE_ACCEPT4) |
|
4618
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
92 ngx_log_error(level, ev->log, err, |
|
3812
ef27dc1a7832
fallback to accept() if accept4() is not implemented,
Igor Sysoev <igor@sysoev.ru>
parents:
3786
diff
changeset
|
93 use_accept4 ? "accept4() failed" : "accept() failed"); |
|
ef27dc1a7832
fallback to accept() if accept4() is not implemented,
Igor Sysoev <igor@sysoev.ru>
parents:
3786
diff
changeset
|
94 |
|
ef27dc1a7832
fallback to accept() if accept4() is not implemented,
Igor Sysoev <igor@sysoev.ru>
parents:
3786
diff
changeset
|
95 if (use_accept4 && err == NGX_ENOSYS) { |
|
ef27dc1a7832
fallback to accept() if accept4() is not implemented,
Igor Sysoev <igor@sysoev.ru>
parents:
3786
diff
changeset
|
96 use_accept4 = 0; |
|
ef27dc1a7832
fallback to accept() if accept4() is not implemented,
Igor Sysoev <igor@sysoev.ru>
parents:
3786
diff
changeset
|
97 ngx_inherited_nonblocking = 0; |
|
ef27dc1a7832
fallback to accept() if accept4() is not implemented,
Igor Sysoev <igor@sysoev.ru>
parents:
3786
diff
changeset
|
98 continue; |
|
ef27dc1a7832
fallback to accept() if accept4() is not implemented,
Igor Sysoev <igor@sysoev.ru>
parents:
3786
diff
changeset
|
99 } |
|
3813
c870fb78550c
fix building by msvc8 introduced by the previous commit
Igor Sysoev <igor@sysoev.ru>
parents:
3812
diff
changeset
|
100 #else |
|
4618
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
101 ngx_log_error(level, ev->log, err, "accept() failed"); |
|
3812
ef27dc1a7832
fallback to accept() if accept4() is not implemented,
Igor Sysoev <igor@sysoev.ru>
parents:
3786
diff
changeset
|
102 #endif |
|
97
70d2345a903f
nginx-0.0.1-2003-05-29-17:02:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
96
diff
changeset
|
103 |
|
248
e885208c518b
nginx-0.0.2-2004-02-03-00:19:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
247
diff
changeset
|
104 if (err == NGX_ECONNABORTED) { |
| 455 | 105 if (ngx_event_flags & NGX_USE_KQUEUE_EVENT) { |
|
248
e885208c518b
nginx-0.0.2-2004-02-03-00:19:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
247
diff
changeset
|
106 ev->available--; |
|
e885208c518b
nginx-0.0.2-2004-02-03-00:19:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
247
diff
changeset
|
107 } |
|
e885208c518b
nginx-0.0.2-2004-02-03-00:19:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
247
diff
changeset
|
108 |
|
e885208c518b
nginx-0.0.2-2004-02-03-00:19:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
247
diff
changeset
|
109 if (ev->available) { |
|
e885208c518b
nginx-0.0.2-2004-02-03-00:19:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
247
diff
changeset
|
110 continue; |
|
e885208c518b
nginx-0.0.2-2004-02-03-00:19:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
247
diff
changeset
|
111 } |
|
e885208c518b
nginx-0.0.2-2004-02-03-00:19:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
247
diff
changeset
|
112 } |
|
e885208c518b
nginx-0.0.2-2004-02-03-00:19:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
247
diff
changeset
|
113 |
|
4618
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
114 if (err == NGX_EMFILE || err == NGX_ENFILE) { |
|
6153
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
115 if (ngx_disable_accept_events((ngx_cycle_t *) ngx_cycle, 1) |
|
4618
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
116 != NGX_OK) |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
117 { |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
118 return; |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
119 } |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
120 |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
121 if (ngx_use_accept_mutex) { |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
122 if (ngx_accept_mutex_held) { |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
123 ngx_shmtx_unlock(&ngx_accept_mutex); |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
124 ngx_accept_mutex_held = 0; |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
125 } |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
126 |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
127 ngx_accept_disabled = 1; |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
128 |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
129 } else { |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
130 ngx_add_timer(ev, ecf->accept_mutex_delay); |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
131 } |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
132 } |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
133 |
|
97
70d2345a903f
nginx-0.0.1-2003-05-29-17:02:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
96
diff
changeset
|
134 return; |
|
70d2345a903f
nginx-0.0.1-2003-05-29-17:02:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
96
diff
changeset
|
135 } |
|
70d2345a903f
nginx-0.0.1-2003-05-29-17:02:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
96
diff
changeset
|
136 |
|
426
3f88935a02e8
nginx-0.0.10-2004-09-14-23:39:54 import
Igor Sysoev <igor@sysoev.ru>
parents:
425
diff
changeset
|
137 #if (NGX_STAT_STUB) |
|
2951
5acd98486a33
ignore ngx_atomic_fetch_add() result
Igor Sysoev <igor@sysoev.ru>
parents:
2723
diff
changeset
|
138 (void) ngx_atomic_fetch_add(ngx_stat_accepted, 1); |
|
426
3f88935a02e8
nginx-0.0.10-2004-09-14-23:39:54 import
Igor Sysoev <igor@sysoev.ru>
parents:
425
diff
changeset
|
139 #endif |
|
323
ba876b26b76d
nginx-0.0.3-2004-04-21-22:54:33 import
Igor Sysoev <igor@sysoev.ru>
parents:
315
diff
changeset
|
140 |
| 2255 | 141 ngx_accept_disabled = ngx_cycle->connection_n / 8 |
| 543 | 142 - ngx_cycle->free_connection_n; |
| 143 | |
| 144 c = ngx_get_connection(s, ev->log); | |
|
323
ba876b26b76d
nginx-0.0.3-2004-04-21-22:54:33 import
Igor Sysoev <igor@sysoev.ru>
parents:
315
diff
changeset
|
145 |
| 543 | 146 if (c == NULL) { |
| 147 if (ngx_close_socket(s) == -1) { | |
| 148 ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_socket_errno, | |
| 149 ngx_close_socket_n " failed"); | |
| 150 } | |
|
119
cd54bcbaf3b5
nginx-0.0.1-2003-07-21-01:15:59 import
Igor Sysoev <igor@sysoev.ru>
parents:
117
diff
changeset
|
151 |
| 543 | 152 return; |
| 153 } | |
| 154 | |
| 6436 | 155 c->type = SOCK_STREAM; |
| 156 | |
| 635 | 157 #if (NGX_STAT_STUB) |
|
2951
5acd98486a33
ignore ngx_atomic_fetch_add() result
Igor Sysoev <igor@sysoev.ru>
parents:
2723
diff
changeset
|
158 (void) ngx_atomic_fetch_add(ngx_stat_active, 1); |
| 635 | 159 #endif |
| 160 | |
| 543 | 161 c->pool = ngx_create_pool(ls->pool_size, ev->log); |
| 162 if (c->pool == NULL) { | |
| 163 ngx_close_accepted_connection(c); | |
| 164 return; | |
| 165 } | |
|
97
70d2345a903f
nginx-0.0.1-2003-05-29-17:02:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
96
diff
changeset
|
166 |
|
7119
fef61d26da39
Fixed buffer overread with unix sockets after accept().
Maxim Dounin <mdounin@mdounin.ru>
parents:
7005
diff
changeset
|
167 if (socklen > (socklen_t) sizeof(ngx_sockaddr_t)) { |
|
fef61d26da39
Fixed buffer overread with unix sockets after accept().
Maxim Dounin <mdounin@mdounin.ru>
parents:
7005
diff
changeset
|
168 socklen = sizeof(ngx_sockaddr_t); |
|
fef61d26da39
Fixed buffer overread with unix sockets after accept().
Maxim Dounin <mdounin@mdounin.ru>
parents:
7005
diff
changeset
|
169 } |
|
fef61d26da39
Fixed buffer overread with unix sockets after accept().
Maxim Dounin <mdounin@mdounin.ru>
parents:
7005
diff
changeset
|
170 |
| 714 | 171 c->sockaddr = ngx_palloc(c->pool, socklen); |
| 543 | 172 if (c->sockaddr == NULL) { |
| 173 ngx_close_accepted_connection(c); | |
| 174 return; | |
| 175 } | |
| 176 | |
|
6559
adf25b8d0431
Introduced the ngx_sockaddr_t type.
Ruslan Ermilov <ru@nginx.com>
parents:
6532
diff
changeset
|
177 ngx_memcpy(c->sockaddr, &sa, socklen); |
| 543 | 178 |
| 179 log = ngx_palloc(c->pool, sizeof(ngx_log_t)); | |
| 180 if (log == NULL) { | |
| 181 ngx_close_accepted_connection(c); | |
|
87
5f6d848dcbef
nginx-0.0.1-2003-05-13-20:02:32 import
Igor Sysoev <igor@sysoev.ru>
parents:
86
diff
changeset
|
182 return; |
|
0
4eff17414a43
nginx-0.0.1-2002-08-06-20:39:45 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
183 } |
|
6
669801705ab1
nginx-0.0.1-2002-08-26-19:18:19 import
Igor Sysoev <igor@sysoev.ru>
parents:
3
diff
changeset
|
184 |
|
6125
4dc8e7b62216
Removed the obsolete aio module.
Ruslan Ermilov <ru@nginx.com>
parents:
5820
diff
changeset
|
185 /* set a blocking mode for iocp and non-blocking mode for others */ |
|
59
e8cdc2989cee
nginx-0.0.1-2003-02-06-20:21:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
57
diff
changeset
|
186 |
|
93
738fe44c70d5
nginx-0.0.1-2003-05-21-17:28:21 import
Igor Sysoev <igor@sysoev.ru>
parents:
92
diff
changeset
|
187 if (ngx_inherited_nonblocking) { |
|
6125
4dc8e7b62216
Removed the obsolete aio module.
Ruslan Ermilov <ru@nginx.com>
parents:
5820
diff
changeset
|
188 if (ngx_event_flags & NGX_USE_IOCP_EVENT) { |
|
93
738fe44c70d5
nginx-0.0.1-2003-05-21-17:28:21 import
Igor Sysoev <igor@sysoev.ru>
parents:
92
diff
changeset
|
189 if (ngx_blocking(s) == -1) { |
| 543 | 190 ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_socket_errno, |
|
191
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
191 ngx_blocking_n " failed"); |
| 543 | 192 ngx_close_accepted_connection(c); |
|
93
738fe44c70d5
nginx-0.0.1-2003-05-21-17:28:21 import
Igor Sysoev <igor@sysoev.ru>
parents:
92
diff
changeset
|
193 return; |
|
738fe44c70d5
nginx-0.0.1-2003-05-21-17:28:21 import
Igor Sysoev <igor@sysoev.ru>
parents:
92
diff
changeset
|
194 } |
|
738fe44c70d5
nginx-0.0.1-2003-05-21-17:28:21 import
Igor Sysoev <igor@sysoev.ru>
parents:
92
diff
changeset
|
195 } |
|
738fe44c70d5
nginx-0.0.1-2003-05-21-17:28:21 import
Igor Sysoev <igor@sysoev.ru>
parents:
92
diff
changeset
|
196 |
|
738fe44c70d5
nginx-0.0.1-2003-05-21-17:28:21 import
Igor Sysoev <igor@sysoev.ru>
parents:
92
diff
changeset
|
197 } else { |
|
6126
adba26ff70b5
Removed the obsolete rtsig module.
Ruslan Ermilov <ru@nginx.com>
parents:
6125
diff
changeset
|
198 if (!(ngx_event_flags & NGX_USE_IOCP_EVENT)) { |
|
93
738fe44c70d5
nginx-0.0.1-2003-05-21-17:28:21 import
Igor Sysoev <igor@sysoev.ru>
parents:
92
diff
changeset
|
199 if (ngx_nonblocking(s) == -1) { |
| 543 | 200 ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_socket_errno, |
|
191
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
201 ngx_nonblocking_n " failed"); |
| 543 | 202 ngx_close_accepted_connection(c); |
|
93
738fe44c70d5
nginx-0.0.1-2003-05-21-17:28:21 import
Igor Sysoev <igor@sysoev.ru>
parents:
92
diff
changeset
|
203 return; |
|
738fe44c70d5
nginx-0.0.1-2003-05-21-17:28:21 import
Igor Sysoev <igor@sysoev.ru>
parents:
92
diff
changeset
|
204 } |
|
59
e8cdc2989cee
nginx-0.0.1-2003-02-06-20:21:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
57
diff
changeset
|
205 } |
|
e8cdc2989cee
nginx-0.0.1-2003-02-06-20:21:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
57
diff
changeset
|
206 } |
|
e8cdc2989cee
nginx-0.0.1-2003-02-06-20:21:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
57
diff
changeset
|
207 |
| 543 | 208 *log = ls->log; |
| 209 | |
| 210 c->recv = ngx_recv; | |
| 211 c->send = ngx_send; | |
| 577 | 212 c->recv_chain = ngx_recv_chain; |
| 543 | 213 c->send_chain = ngx_send_chain; |
|
103
6dfda4cf5200
nginx-0.0.1-2003-06-11-19:28:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
100
diff
changeset
|
214 |
| 543 | 215 c->log = log; |
| 216 c->pool->log = log; | |
|
103
6dfda4cf5200
nginx-0.0.1-2003-06-11-19:28:34 import
Igor Sysoev <igor@sysoev.ru>
parents:
100
diff
changeset
|
217 |
|
2512
2e91aecb9e57
a prelimiary IPv6 support, HTTP listen
Igor Sysoev <igor@sysoev.ru>
parents:
2255
diff
changeset
|
218 c->socklen = socklen; |
| 543 | 219 c->listening = ls; |
|
2512
2e91aecb9e57
a prelimiary IPv6 support, HTTP listen
Igor Sysoev <igor@sysoev.ru>
parents:
2255
diff
changeset
|
220 c->local_sockaddr = ls->sockaddr; |
|
5463
1ab1cf63f885
Core: keep the length of the local sockaddr.
Ruslan Ermilov <ru@nginx.com>
parents:
5360
diff
changeset
|
221 c->local_socklen = ls->socklen; |
| 543 | 222 |
|
3230
a7491af45540
http listen unix domain sockets
Igor Sysoev <igor@sysoev.ru>
parents:
2951
diff
changeset
|
223 #if (NGX_HAVE_UNIX_DOMAIN) |
|
a7491af45540
http listen unix domain sockets
Igor Sysoev <igor@sysoev.ru>
parents:
2951
diff
changeset
|
224 if (c->sockaddr->sa_family == AF_UNIX) { |
|
a7491af45540
http listen unix domain sockets
Igor Sysoev <igor@sysoev.ru>
parents:
2951
diff
changeset
|
225 c->tcp_nopush = NGX_TCP_NOPUSH_DISABLED; |
|
a7491af45540
http listen unix domain sockets
Igor Sysoev <igor@sysoev.ru>
parents:
2951
diff
changeset
|
226 c->tcp_nodelay = NGX_TCP_NODELAY_DISABLED; |
|
a7491af45540
http listen unix domain sockets
Igor Sysoev <igor@sysoev.ru>
parents:
2951
diff
changeset
|
227 #if (NGX_SOLARIS) |
|
a7491af45540
http listen unix domain sockets
Igor Sysoev <igor@sysoev.ru>
parents:
2951
diff
changeset
|
228 /* Solaris's sendfilev() supports AF_NCA, AF_INET, and AF_INET6 */ |
|
a7491af45540
http listen unix domain sockets
Igor Sysoev <igor@sysoev.ru>
parents:
2951
diff
changeset
|
229 c->sendfile = 0; |
|
a7491af45540
http listen unix domain sockets
Igor Sysoev <igor@sysoev.ru>
parents:
2951
diff
changeset
|
230 #endif |
|
a7491af45540
http listen unix domain sockets
Igor Sysoev <igor@sysoev.ru>
parents:
2951
diff
changeset
|
231 } |
|
a7491af45540
http listen unix domain sockets
Igor Sysoev <igor@sysoev.ru>
parents:
2951
diff
changeset
|
232 #endif |
|
a7491af45540
http listen unix domain sockets
Igor Sysoev <igor@sysoev.ru>
parents:
2951
diff
changeset
|
233 |
| 561 | 234 rev = c->read; |
| 235 wev = c->write; | |
|
86
3973260705cc
nginx-0.0.1-2003-05-12-19:52:24 import
Igor Sysoev <igor@sysoev.ru>
parents:
75
diff
changeset
|
236 |
|
164
84036764e215
nginx-0.0.1-2003-10-29-11:30:44 import
Igor Sysoev <igor@sysoev.ru>
parents:
121
diff
changeset
|
237 wev->ready = 1; |
|
0
4eff17414a43
nginx-0.0.1-2002-08-06-20:39:45 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
238 |
|
6126
adba26ff70b5
Removed the obsolete rtsig module.
Ruslan Ermilov <ru@nginx.com>
parents:
6125
diff
changeset
|
239 if (ngx_event_flags & NGX_USE_IOCP_EVENT) { |
|
164
84036764e215
nginx-0.0.1-2003-10-29-11:30:44 import
Igor Sysoev <igor@sysoev.ru>
parents:
121
diff
changeset
|
240 rev->ready = 1; |
|
59
e8cdc2989cee
nginx-0.0.1-2003-02-06-20:21:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
57
diff
changeset
|
241 } |
|
e8cdc2989cee
nginx-0.0.1-2003-02-06-20:21:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
57
diff
changeset
|
242 |
|
245
e6c005b66b3a
nginx-0.0.1-2004-01-30-00:45:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
236
diff
changeset
|
243 if (ev->deferred_accept) { |
|
e6c005b66b3a
nginx-0.0.1-2004-01-30-00:45:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
236
diff
changeset
|
244 rev->ready = 1; |
|
7005
3e2d90073adf
Fixed deferred accept with EPOLLRDHUP enabled (ticket #1278).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
245 #if (NGX_HAVE_KQUEUE || NGX_HAVE_EPOLLRDHUP) |
| 523 | 246 rev->available = 1; |
| 247 #endif | |
|
245
e6c005b66b3a
nginx-0.0.1-2004-01-30-00:45:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
236
diff
changeset
|
248 } |
|
e6c005b66b3a
nginx-0.0.1-2004-01-30-00:45:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
236
diff
changeset
|
249 |
|
191
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
250 rev->log = log; |
|
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
251 wev->log = log; |
|
57
a499e0d1f16e
nginx-0.0.1-2003-01-30-10:28:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
44
diff
changeset
|
252 |
|
208
0b67be7d4489
nginx-0.0.1-2003-12-08-23:48:12 import
Igor Sysoev <igor@sysoev.ru>
parents:
206
diff
changeset
|
253 /* |
| 561 | 254 * TODO: MT: - ngx_atomic_fetch_add() |
|
266
5238e93961a1
nginx-0.0.2-2004-02-23-23:57:12 import
Igor Sysoev <igor@sysoev.ru>
parents:
260
diff
changeset
|
255 * or protection by critical section or light mutex |
|
208
0b67be7d4489
nginx-0.0.1-2003-12-08-23:48:12 import
Igor Sysoev <igor@sysoev.ru>
parents:
206
diff
changeset
|
256 * |
|
0b67be7d4489
nginx-0.0.1-2003-12-08-23:48:12 import
Igor Sysoev <igor@sysoev.ru>
parents:
206
diff
changeset
|
257 * TODO: MP: - allocated in a shared memory |
| 561 | 258 * - ngx_atomic_fetch_add() |
|
266
5238e93961a1
nginx-0.0.2-2004-02-23-23:57:12 import
Igor Sysoev <igor@sysoev.ru>
parents:
260
diff
changeset
|
259 * or protection by critical section or light mutex |
|
208
0b67be7d4489
nginx-0.0.1-2003-12-08-23:48:12 import
Igor Sysoev <igor@sysoev.ru>
parents:
206
diff
changeset
|
260 */ |
|
212
679f60139863
nginx-0.0.1-2003-12-19-11:15:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
208
diff
changeset
|
261 |
| 561 | 262 c->number = ngx_atomic_fetch_add(ngx_connection_counter, 1); |
|
26
53cb81681040
nginx-0.0.1-2002-12-15-09:25:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
24
diff
changeset
|
263 |
| 495 | 264 #if (NGX_STAT_STUB) |
|
2951
5acd98486a33
ignore ngx_atomic_fetch_add() result
Igor Sysoev <igor@sysoev.ru>
parents:
2723
diff
changeset
|
265 (void) ngx_atomic_fetch_add(ngx_stat_handled, 1); |
| 495 | 266 #endif |
| 267 | |
| 543 | 268 if (ls->addr_ntop) { |
| 2049 | 269 c->addr_text.data = ngx_pnalloc(c->pool, ls->addr_text_max_len); |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
270 if (c->addr_text.data == NULL) { |
| 543 | 271 ngx_close_accepted_connection(c); |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
272 return; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
273 } |
| 577 | 274 |
|
5263
05ba5bce31e0
Core: extended ngx_sock_ntop() with socklen parameter.
Vladimir Homutov <vl@nginx.com>
parents:
4618
diff
changeset
|
275 c->addr_text.len = ngx_sock_ntop(c->sockaddr, c->socklen, |
|
05ba5bce31e0
Core: extended ngx_sock_ntop() with socklen parameter.
Vladimir Homutov <vl@nginx.com>
parents:
4618
diff
changeset
|
276 c->addr_text.data, |
|
2512
2e91aecb9e57
a prelimiary IPv6 support, HTTP listen
Igor Sysoev <igor@sysoev.ru>
parents:
2255
diff
changeset
|
277 ls->addr_text_max_len, 0); |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
278 if (c->addr_text.len == 0) { |
| 543 | 279 ngx_close_accepted_connection(c); |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
280 return; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
281 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
282 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
283 |
|
307
ce375c313e96
nginx-0.0.3-2004-04-08-19:58:25 import
Igor Sysoev <igor@sysoev.ru>
parents:
306
diff
changeset
|
284 #if (NGX_DEBUG) |
|
ce375c313e96
nginx-0.0.3-2004-04-08-19:58:25 import
Igor Sysoev <igor@sysoev.ru>
parents:
306
diff
changeset
|
285 { |
| 6436 | 286 ngx_str_t addr; |
| 287 u_char text[NGX_SOCKADDR_STRLEN]; | |
|
307
ce375c313e96
nginx-0.0.3-2004-04-08-19:58:25 import
Igor Sysoev <igor@sysoev.ru>
parents:
306
diff
changeset
|
288 |
| 6436 | 289 ngx_debug_accepted_connection(ecf, c); |
|
307
ce375c313e96
nginx-0.0.3-2004-04-08-19:58:25 import
Igor Sysoev <igor@sysoev.ru>
parents:
306
diff
changeset
|
290 |
|
5704
524741fd50ed
Core: output client port number when logging accept event.
Ruslan Ermilov <ru@nginx.com>
parents:
5600
diff
changeset
|
291 if (log->log_level & NGX_LOG_DEBUG_EVENT) { |
|
524741fd50ed
Core: output client port number when logging accept event.
Ruslan Ermilov <ru@nginx.com>
parents:
5600
diff
changeset
|
292 addr.data = text; |
|
524741fd50ed
Core: output client port number when logging accept event.
Ruslan Ermilov <ru@nginx.com>
parents:
5600
diff
changeset
|
293 addr.len = ngx_sock_ntop(c->sockaddr, c->socklen, text, |
|
524741fd50ed
Core: output client port number when logging accept event.
Ruslan Ermilov <ru@nginx.com>
parents:
5600
diff
changeset
|
294 NGX_SOCKADDR_STRLEN, 1); |
|
524741fd50ed
Core: output client port number when logging accept event.
Ruslan Ermilov <ru@nginx.com>
parents:
5600
diff
changeset
|
295 |
|
524741fd50ed
Core: output client port number when logging accept event.
Ruslan Ermilov <ru@nginx.com>
parents:
5600
diff
changeset
|
296 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, log, 0, |
|
524741fd50ed
Core: output client port number when logging accept event.
Ruslan Ermilov <ru@nginx.com>
parents:
5600
diff
changeset
|
297 "*%uA accept: %V fd:%d", c->number, &addr, s); |
|
524741fd50ed
Core: output client port number when logging accept event.
Ruslan Ermilov <ru@nginx.com>
parents:
5600
diff
changeset
|
298 } |
|
524741fd50ed
Core: output client port number when logging accept event.
Ruslan Ermilov <ru@nginx.com>
parents:
5600
diff
changeset
|
299 |
|
307
ce375c313e96
nginx-0.0.3-2004-04-08-19:58:25 import
Igor Sysoev <igor@sysoev.ru>
parents:
306
diff
changeset
|
300 } |
|
ce375c313e96
nginx-0.0.3-2004-04-08-19:58:25 import
Igor Sysoev <igor@sysoev.ru>
parents:
306
diff
changeset
|
301 #endif |
|
ce375c313e96
nginx-0.0.3-2004-04-08-19:58:25 import
Igor Sysoev <igor@sysoev.ru>
parents:
306
diff
changeset
|
302 |
|
381
02a511569afb
nginx-0.0.7-2004-07-07-19:01:00 import
Igor Sysoev <igor@sysoev.ru>
parents:
380
diff
changeset
|
303 if (ngx_add_conn && (ngx_event_flags & NGX_USE_EPOLL_EVENT) == 0) { |
|
97
70d2345a903f
nginx-0.0.1-2003-05-29-17:02:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
96
diff
changeset
|
304 if (ngx_add_conn(c) == NGX_ERROR) { |
| 543 | 305 ngx_close_accepted_connection(c); |
|
87
5f6d848dcbef
nginx-0.0.1-2003-05-13-20:02:32 import
Igor Sysoev <igor@sysoev.ru>
parents:
86
diff
changeset
|
306 return; |
|
64
34d647deb1da
nginx-0.0.1-2003-03-04-09:33:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
63
diff
changeset
|
307 } |
|
34d647deb1da
nginx-0.0.1-2003-03-04-09:33:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
63
diff
changeset
|
308 } |
|
34d647deb1da
nginx-0.0.1-2003-03-04-09:33:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
63
diff
changeset
|
309 |
|
191
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
310 log->data = NULL; |
|
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
311 log->handler = NULL; |
|
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
312 |
| 543 | 313 ls->handler(c); |
|
57
a499e0d1f16e
nginx-0.0.1-2003-01-30-10:28:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
44
diff
changeset
|
314 |
| 455 | 315 if (ngx_event_flags & NGX_USE_KQUEUE_EVENT) { |
|
0
4eff17414a43
nginx-0.0.1-2002-08-06-20:39:45 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
316 ev->available--; |
|
57
a499e0d1f16e
nginx-0.0.1-2003-01-30-10:28:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
44
diff
changeset
|
317 } |
|
191
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
318 |
|
0
4eff17414a43
nginx-0.0.1-2002-08-06-20:39:45 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
319 } while (ev->available); |
|
4eff17414a43
nginx-0.0.1-2002-08-06-20:39:45 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
320 } |
|
191
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
321 |
|
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
322 |
| 6436 | 323 #if !(NGX_WIN32) |
| 324 | |
| 325 void | |
| 326 ngx_event_recvmsg(ngx_event_t *ev) | |
| 327 { | |
| 328 ssize_t n; | |
| 329 ngx_log_t *log; | |
| 330 ngx_err_t err; | |
| 331 ngx_event_t *rev, *wev; | |
| 332 struct iovec iov[1]; | |
| 333 struct msghdr msg; | |
|
6559
adf25b8d0431
Introduced the ngx_sockaddr_t type.
Ruslan Ermilov <ru@nginx.com>
parents:
6532
diff
changeset
|
334 ngx_sockaddr_t sa; |
| 6436 | 335 ngx_listening_t *ls; |
| 336 ngx_event_conf_t *ecf; | |
| 337 ngx_connection_t *c, *lc; | |
| 338 static u_char buffer[65535]; | |
| 339 | |
| 340 #if (NGX_HAVE_MSGHDR_MSG_CONTROL) | |
| 341 | |
| 342 #if (NGX_HAVE_IP_RECVDSTADDR) | |
| 343 u_char msg_control[CMSG_SPACE(sizeof(struct in_addr))]; | |
| 344 #elif (NGX_HAVE_IP_PKTINFO) | |
| 345 u_char msg_control[CMSG_SPACE(sizeof(struct in_pktinfo))]; | |
| 346 #endif | |
| 347 | |
| 348 #if (NGX_HAVE_INET6 && NGX_HAVE_IPV6_RECVPKTINFO) | |
| 349 u_char msg_control6[CMSG_SPACE(sizeof(struct in6_pktinfo))]; | |
| 350 #endif | |
| 351 | |
| 352 #endif | |
| 353 | |
| 354 if (ev->timedout) { | |
| 355 if (ngx_enable_accept_events((ngx_cycle_t *) ngx_cycle) != NGX_OK) { | |
| 356 return; | |
| 357 } | |
| 358 | |
| 359 ev->timedout = 0; | |
| 360 } | |
| 361 | |
| 362 ecf = ngx_event_get_conf(ngx_cycle->conf_ctx, ngx_event_core_module); | |
| 363 | |
| 364 if (!(ngx_event_flags & NGX_USE_KQUEUE_EVENT)) { | |
| 365 ev->available = ecf->multi_accept; | |
| 366 } | |
| 367 | |
| 368 lc = ev->data; | |
| 369 ls = lc->listening; | |
| 370 ev->ready = 0; | |
| 371 | |
| 372 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, | |
| 373 "recvmsg on %V, ready: %d", &ls->addr_text, ev->available); | |
| 374 | |
| 375 do { | |
| 376 ngx_memzero(&msg, sizeof(struct msghdr)); | |
| 377 | |
| 378 iov[0].iov_base = (void *) buffer; | |
| 379 iov[0].iov_len = sizeof(buffer); | |
| 380 | |
| 381 msg.msg_name = &sa; | |
|
6559
adf25b8d0431
Introduced the ngx_sockaddr_t type.
Ruslan Ermilov <ru@nginx.com>
parents:
6532
diff
changeset
|
382 msg.msg_namelen = sizeof(ngx_sockaddr_t); |
| 6436 | 383 msg.msg_iov = iov; |
| 384 msg.msg_iovlen = 1; | |
| 385 | |
| 386 #if (NGX_HAVE_MSGHDR_MSG_CONTROL) | |
| 387 | |
| 388 if (ls->wildcard) { | |
| 389 | |
| 390 #if (NGX_HAVE_IP_RECVDSTADDR || NGX_HAVE_IP_PKTINFO) | |
| 391 if (ls->sockaddr->sa_family == AF_INET) { | |
| 392 msg.msg_control = &msg_control; | |
| 393 msg.msg_controllen = sizeof(msg_control); | |
| 394 } | |
| 395 #endif | |
| 396 | |
| 397 #if (NGX_HAVE_INET6 && NGX_HAVE_IPV6_RECVPKTINFO) | |
| 398 if (ls->sockaddr->sa_family == AF_INET6) { | |
| 399 msg.msg_control = &msg_control6; | |
| 400 msg.msg_controllen = sizeof(msg_control6); | |
| 401 } | |
| 402 #endif | |
| 403 } | |
| 404 | |
| 405 #endif | |
| 406 | |
| 407 n = recvmsg(lc->fd, &msg, 0); | |
| 408 | |
| 409 if (n == -1) { | |
| 410 err = ngx_socket_errno; | |
| 411 | |
| 412 if (err == NGX_EAGAIN) { | |
| 413 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, ev->log, err, | |
| 414 "recvmsg() not ready"); | |
| 415 return; | |
| 416 } | |
| 417 | |
| 418 ngx_log_error(NGX_LOG_ALERT, ev->log, err, "recvmsg() failed"); | |
| 419 | |
| 420 return; | |
| 421 } | |
| 422 | |
| 423 #if (NGX_STAT_STUB) | |
| 424 (void) ngx_atomic_fetch_add(ngx_stat_accepted, 1); | |
| 425 #endif | |
| 426 | |
| 427 #if (NGX_HAVE_MSGHDR_MSG_CONTROL) | |
| 428 if (msg.msg_flags & (MSG_TRUNC|MSG_CTRUNC)) { | |
| 429 ngx_log_error(NGX_LOG_ALERT, ev->log, 0, | |
| 430 "recvmsg() truncated data"); | |
| 431 continue; | |
| 432 } | |
| 433 #endif | |
| 434 | |
| 435 ngx_accept_disabled = ngx_cycle->connection_n / 8 | |
| 436 - ngx_cycle->free_connection_n; | |
| 437 | |
| 438 c = ngx_get_connection(lc->fd, ev->log); | |
| 439 if (c == NULL) { | |
| 440 return; | |
| 441 } | |
| 442 | |
| 443 c->shared = 1; | |
| 444 c->type = SOCK_DGRAM; | |
| 445 c->socklen = msg.msg_namelen; | |
| 446 | |
|
7119
fef61d26da39
Fixed buffer overread with unix sockets after accept().
Maxim Dounin <mdounin@mdounin.ru>
parents:
7005
diff
changeset
|
447 if (c->socklen > (socklen_t) sizeof(ngx_sockaddr_t)) { |
|
fef61d26da39
Fixed buffer overread with unix sockets after accept().
Maxim Dounin <mdounin@mdounin.ru>
parents:
7005
diff
changeset
|
448 c->socklen = sizeof(ngx_sockaddr_t); |
|
fef61d26da39
Fixed buffer overread with unix sockets after accept().
Maxim Dounin <mdounin@mdounin.ru>
parents:
7005
diff
changeset
|
449 } |
|
fef61d26da39
Fixed buffer overread with unix sockets after accept().
Maxim Dounin <mdounin@mdounin.ru>
parents:
7005
diff
changeset
|
450 |
|
7408
8af6dceeb648
Events: fixed handling zero-length client address.
Roman Arutyunyan <arut@nginx.com>
parents:
7119
diff
changeset
|
451 if (c->socklen == 0) { |
|
8af6dceeb648
Events: fixed handling zero-length client address.
Roman Arutyunyan <arut@nginx.com>
parents:
7119
diff
changeset
|
452 |
|
8af6dceeb648
Events: fixed handling zero-length client address.
Roman Arutyunyan <arut@nginx.com>
parents:
7119
diff
changeset
|
453 /* |
|
8af6dceeb648
Events: fixed handling zero-length client address.
Roman Arutyunyan <arut@nginx.com>
parents:
7119
diff
changeset
|
454 * on Linux recvmsg() returns zero msg_namelen |
|
8af6dceeb648
Events: fixed handling zero-length client address.
Roman Arutyunyan <arut@nginx.com>
parents:
7119
diff
changeset
|
455 * when receiving packets from unbound AF_UNIX sockets |
|
8af6dceeb648
Events: fixed handling zero-length client address.
Roman Arutyunyan <arut@nginx.com>
parents:
7119
diff
changeset
|
456 */ |
|
8af6dceeb648
Events: fixed handling zero-length client address.
Roman Arutyunyan <arut@nginx.com>
parents:
7119
diff
changeset
|
457 |
|
8af6dceeb648
Events: fixed handling zero-length client address.
Roman Arutyunyan <arut@nginx.com>
parents:
7119
diff
changeset
|
458 c->socklen = sizeof(struct sockaddr); |
|
8af6dceeb648
Events: fixed handling zero-length client address.
Roman Arutyunyan <arut@nginx.com>
parents:
7119
diff
changeset
|
459 ngx_memzero(&sa, sizeof(struct sockaddr)); |
|
8af6dceeb648
Events: fixed handling zero-length client address.
Roman Arutyunyan <arut@nginx.com>
parents:
7119
diff
changeset
|
460 sa.sockaddr.sa_family = ls->sockaddr->sa_family; |
|
8af6dceeb648
Events: fixed handling zero-length client address.
Roman Arutyunyan <arut@nginx.com>
parents:
7119
diff
changeset
|
461 } |
|
8af6dceeb648
Events: fixed handling zero-length client address.
Roman Arutyunyan <arut@nginx.com>
parents:
7119
diff
changeset
|
462 |
| 6436 | 463 #if (NGX_STAT_STUB) |
| 464 (void) ngx_atomic_fetch_add(ngx_stat_active, 1); | |
| 465 #endif | |
| 466 | |
| 467 c->pool = ngx_create_pool(ls->pool_size, ev->log); | |
| 468 if (c->pool == NULL) { | |
| 469 ngx_close_accepted_connection(c); | |
| 470 return; | |
| 471 } | |
| 472 | |
| 473 c->sockaddr = ngx_palloc(c->pool, c->socklen); | |
| 474 if (c->sockaddr == NULL) { | |
| 475 ngx_close_accepted_connection(c); | |
| 476 return; | |
| 477 } | |
| 478 | |
| 479 ngx_memcpy(c->sockaddr, msg.msg_name, c->socklen); | |
| 480 | |
| 481 log = ngx_palloc(c->pool, sizeof(ngx_log_t)); | |
| 482 if (log == NULL) { | |
| 483 ngx_close_accepted_connection(c); | |
| 484 return; | |
| 485 } | |
| 486 | |
| 487 *log = ls->log; | |
| 488 | |
| 489 c->send = ngx_udp_send; | |
| 6692 | 490 c->send_chain = ngx_udp_send_chain; |
| 6436 | 491 |
| 492 c->log = log; | |
| 493 c->pool->log = log; | |
| 494 | |
| 495 c->listening = ls; | |
| 496 c->local_sockaddr = ls->sockaddr; | |
| 497 c->local_socklen = ls->socklen; | |
| 498 | |
| 499 #if (NGX_HAVE_MSGHDR_MSG_CONTROL) | |
| 500 | |
| 501 if (ls->wildcard) { | |
| 502 struct cmsghdr *cmsg; | |
| 503 struct sockaddr *sockaddr; | |
| 504 | |
| 505 sockaddr = ngx_palloc(c->pool, c->local_socklen); | |
| 506 if (sockaddr == NULL) { | |
| 507 ngx_close_accepted_connection(c); | |
| 508 return; | |
| 509 } | |
| 510 | |
| 511 ngx_memcpy(sockaddr, c->local_sockaddr, c->local_socklen); | |
| 512 c->local_sockaddr = sockaddr; | |
| 513 | |
| 514 for (cmsg = CMSG_FIRSTHDR(&msg); | |
| 515 cmsg != NULL; | |
| 516 cmsg = CMSG_NXTHDR(&msg, cmsg)) | |
| 517 { | |
| 518 | |
| 519 #if (NGX_HAVE_IP_RECVDSTADDR) | |
| 520 | |
| 521 if (cmsg->cmsg_level == IPPROTO_IP | |
| 522 && cmsg->cmsg_type == IP_RECVDSTADDR | |
| 523 && sockaddr->sa_family == AF_INET) | |
| 524 { | |
| 525 struct in_addr *addr; | |
| 526 struct sockaddr_in *sin; | |
| 527 | |
| 528 addr = (struct in_addr *) CMSG_DATA(cmsg); | |
| 529 sin = (struct sockaddr_in *) sockaddr; | |
| 530 sin->sin_addr = *addr; | |
| 531 | |
| 532 break; | |
| 533 } | |
| 534 | |
| 535 #elif (NGX_HAVE_IP_PKTINFO) | |
| 536 | |
| 537 if (cmsg->cmsg_level == IPPROTO_IP | |
| 538 && cmsg->cmsg_type == IP_PKTINFO | |
| 539 && sockaddr->sa_family == AF_INET) | |
| 540 { | |
| 541 struct in_pktinfo *pkt; | |
| 542 struct sockaddr_in *sin; | |
| 543 | |
| 544 pkt = (struct in_pktinfo *) CMSG_DATA(cmsg); | |
| 545 sin = (struct sockaddr_in *) sockaddr; | |
| 546 sin->sin_addr = pkt->ipi_addr; | |
| 547 | |
| 548 break; | |
| 549 } | |
| 550 | |
| 551 #endif | |
| 552 | |
| 553 #if (NGX_HAVE_INET6 && NGX_HAVE_IPV6_RECVPKTINFO) | |
| 554 | |
| 555 if (cmsg->cmsg_level == IPPROTO_IPV6 | |
| 556 && cmsg->cmsg_type == IPV6_PKTINFO | |
| 557 && sockaddr->sa_family == AF_INET6) | |
| 558 { | |
| 559 struct in6_pktinfo *pkt6; | |
| 560 struct sockaddr_in6 *sin6; | |
| 561 | |
| 562 pkt6 = (struct in6_pktinfo *) CMSG_DATA(cmsg); | |
| 563 sin6 = (struct sockaddr_in6 *) sockaddr; | |
| 564 sin6->sin6_addr = pkt6->ipi6_addr; | |
| 565 | |
| 566 break; | |
| 567 } | |
| 568 | |
| 569 #endif | |
| 570 | |
| 571 } | |
| 572 } | |
| 573 | |
| 574 #endif | |
| 575 | |
| 576 c->buffer = ngx_create_temp_buf(c->pool, n); | |
| 577 if (c->buffer == NULL) { | |
| 578 ngx_close_accepted_connection(c); | |
| 579 return; | |
| 580 } | |
| 581 | |
| 582 c->buffer->last = ngx_cpymem(c->buffer->last, buffer, n); | |
| 583 | |
| 584 rev = c->read; | |
| 585 wev = c->write; | |
| 586 | |
| 587 wev->ready = 1; | |
| 588 | |
| 589 rev->log = log; | |
| 590 wev->log = log; | |
| 591 | |
| 592 /* | |
| 593 * TODO: MT: - ngx_atomic_fetch_add() | |
| 594 * or protection by critical section or light mutex | |
| 595 * | |
| 596 * TODO: MP: - allocated in a shared memory | |
| 597 * - ngx_atomic_fetch_add() | |
| 598 * or protection by critical section or light mutex | |
| 599 */ | |
| 600 | |
| 601 c->number = ngx_atomic_fetch_add(ngx_connection_counter, 1); | |
| 602 | |
| 603 #if (NGX_STAT_STUB) | |
| 604 (void) ngx_atomic_fetch_add(ngx_stat_handled, 1); | |
| 605 #endif | |
| 606 | |
| 607 if (ls->addr_ntop) { | |
| 608 c->addr_text.data = ngx_pnalloc(c->pool, ls->addr_text_max_len); | |
| 609 if (c->addr_text.data == NULL) { | |
| 610 ngx_close_accepted_connection(c); | |
| 611 return; | |
| 612 } | |
| 613 | |
| 614 c->addr_text.len = ngx_sock_ntop(c->sockaddr, c->socklen, | |
| 615 c->addr_text.data, | |
| 616 ls->addr_text_max_len, 0); | |
| 617 if (c->addr_text.len == 0) { | |
| 618 ngx_close_accepted_connection(c); | |
| 619 return; | |
| 620 } | |
| 621 } | |
| 622 | |
| 623 #if (NGX_DEBUG) | |
| 624 { | |
| 625 ngx_str_t addr; | |
| 626 u_char text[NGX_SOCKADDR_STRLEN]; | |
| 627 | |
| 628 ngx_debug_accepted_connection(ecf, c); | |
| 629 | |
| 630 if (log->log_level & NGX_LOG_DEBUG_EVENT) { | |
| 631 addr.data = text; | |
| 632 addr.len = ngx_sock_ntop(c->sockaddr, c->socklen, text, | |
| 633 NGX_SOCKADDR_STRLEN, 1); | |
| 634 | |
| 635 ngx_log_debug4(NGX_LOG_DEBUG_EVENT, log, 0, | |
| 636 "*%uA recvmsg: %V fd:%d n:%z", | |
| 637 c->number, &addr, c->fd, n); | |
| 638 } | |
| 639 | |
| 640 } | |
| 641 #endif | |
| 642 | |
| 643 log->data = NULL; | |
| 644 log->handler = NULL; | |
| 645 | |
| 646 ls->handler(c); | |
| 647 | |
| 648 if (ngx_event_flags & NGX_USE_KQUEUE_EVENT) { | |
| 649 ev->available -= n; | |
| 650 } | |
| 651 | |
| 652 } while (ev->available); | |
| 653 } | |
| 654 | |
| 655 #endif | |
| 656 | |
| 657 | |
| 493 | 658 ngx_int_t |
| 659 ngx_trylock_accept_mutex(ngx_cycle_t *cycle) | |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
660 { |
| 611 | 661 if (ngx_shmtx_trylock(&ngx_accept_mutex)) { |
| 662 | |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
663 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0, |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
664 "accept mutex locked"); |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
665 |
|
6126
adba26ff70b5
Removed the obsolete rtsig module.
Ruslan Ermilov <ru@nginx.com>
parents:
6125
diff
changeset
|
666 if (ngx_accept_mutex_held && ngx_accept_events == 0) { |
| 573 | 667 return NGX_OK; |
| 668 } | |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
669 |
| 573 | 670 if (ngx_enable_accept_events(cycle) == NGX_ERROR) { |
| 611 | 671 ngx_shmtx_unlock(&ngx_accept_mutex); |
| 573 | 672 return NGX_ERROR; |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
673 } |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
674 |
|
719
f30b1a75fd3b
Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
714
diff
changeset
|
675 ngx_accept_events = 0; |
| 573 | 676 ngx_accept_mutex_held = 1; |
| 677 | |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
678 return NGX_OK; |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
679 } |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
680 |
|
719
f30b1a75fd3b
Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
714
diff
changeset
|
681 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0, |
|
f30b1a75fd3b
Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
714
diff
changeset
|
682 "accept mutex lock failed: %ui", ngx_accept_mutex_held); |
|
f30b1a75fd3b
Solaris 10 event ports support
Igor Sysoev <igor@sysoev.ru>
parents:
714
diff
changeset
|
683 |
|
302
1526e7686b20
nginx-0.0.3-2004-04-01-10:21:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
301
diff
changeset
|
684 if (ngx_accept_mutex_held) { |
|
6153
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
685 if (ngx_disable_accept_events(cycle, 0) == NGX_ERROR) { |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
686 return NGX_ERROR; |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
687 } |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
688 |
|
302
1526e7686b20
nginx-0.0.3-2004-04-01-10:21:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
301
diff
changeset
|
689 ngx_accept_mutex_held = 0; |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
690 } |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
691 |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
692 return NGX_OK; |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
693 } |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
694 |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
695 |
| 573 | 696 static ngx_int_t |
| 493 | 697 ngx_enable_accept_events(ngx_cycle_t *cycle) |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
698 { |
| 543 | 699 ngx_uint_t i; |
| 700 ngx_listening_t *ls; | |
| 701 ngx_connection_t *c; | |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
702 |
| 543 | 703 ls = cycle->listening.elts; |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
704 for (i = 0; i < cycle->listening.nelts; i++) { |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
705 |
| 543 | 706 c = ls[i].connection; |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
707 |
|
6153
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
708 if (c == NULL || c->read->active) { |
|
4618
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
709 continue; |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
710 } |
|
c05cfc46b3bc
Accept moderation in case of EMFILE/ENFILE.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4613
diff
changeset
|
711 |
|
6126
adba26ff70b5
Removed the obsolete rtsig module.
Ruslan Ermilov <ru@nginx.com>
parents:
6125
diff
changeset
|
712 if (ngx_add_event(c->read, NGX_READ_EVENT, 0) == NGX_ERROR) { |
|
adba26ff70b5
Removed the obsolete rtsig module.
Ruslan Ermilov <ru@nginx.com>
parents:
6125
diff
changeset
|
713 return NGX_ERROR; |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
714 } |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
715 } |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
716 |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
717 return NGX_OK; |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
718 } |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
719 |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
720 |
| 573 | 721 static ngx_int_t |
|
6153
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
722 ngx_disable_accept_events(ngx_cycle_t *cycle, ngx_uint_t all) |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
723 { |
| 543 | 724 ngx_uint_t i; |
| 725 ngx_listening_t *ls; | |
| 726 ngx_connection_t *c; | |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
727 |
| 543 | 728 ls = cycle->listening.elts; |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
729 for (i = 0; i < cycle->listening.nelts; i++) { |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
730 |
| 543 | 731 c = ls[i].connection; |
| 732 | |
|
6153
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
733 if (c == NULL || !c->read->active) { |
| 543 | 734 continue; |
| 735 } | |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
736 |
|
6153
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
737 #if (NGX_HAVE_REUSEPORT) |
|
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
738 |
|
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
739 /* |
|
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
740 * do not disable accept on worker's own sockets |
|
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
741 * when disabling accept events due to accept mutex |
|
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
742 */ |
|
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
743 |
|
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
744 if (ls[i].reuseport && !all) { |
|
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
745 continue; |
|
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
746 } |
|
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
747 |
|
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
748 #endif |
|
4f6efabcb09b
The "reuseport" option of the "listen" directive.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6126
diff
changeset
|
749 |
|
6126
adba26ff70b5
Removed the obsolete rtsig module.
Ruslan Ermilov <ru@nginx.com>
parents:
6125
diff
changeset
|
750 if (ngx_del_event(c->read, NGX_READ_EVENT, NGX_DISABLE_EVENT) |
|
adba26ff70b5
Removed the obsolete rtsig module.
Ruslan Ermilov <ru@nginx.com>
parents:
6125
diff
changeset
|
751 == NGX_ERROR) |
|
adba26ff70b5
Removed the obsolete rtsig module.
Ruslan Ermilov <ru@nginx.com>
parents:
6125
diff
changeset
|
752 { |
|
adba26ff70b5
Removed the obsolete rtsig module.
Ruslan Ermilov <ru@nginx.com>
parents:
6125
diff
changeset
|
753 return NGX_ERROR; |
|
301
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
754 } |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
755 } |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
756 |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
757 return NGX_OK; |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
758 } |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
759 |
|
744965ec6275
nginx-0.0.3-2004-03-31-19:26:46 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
760 |
| 493 | 761 static void |
| 543 | 762 ngx_close_accepted_connection(ngx_connection_t *c) |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
763 { |
| 543 | 764 ngx_socket_t fd; |
| 765 | |
| 766 ngx_free_connection(c); | |
| 767 | |
| 768 fd = c->fd; | |
| 769 c->fd = (ngx_socket_t) -1; | |
| 770 | |
| 6436 | 771 if (!c->shared && ngx_close_socket(fd) == -1) { |
| 543 | 772 ngx_log_error(NGX_LOG_ALERT, c->log, ngx_socket_errno, |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
773 ngx_close_socket_n " failed"); |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
774 } |
| 495 | 775 |
| 543 | 776 if (c->pool) { |
| 777 ngx_destroy_pool(c->pool); | |
| 778 } | |
| 779 | |
| 495 | 780 #if (NGX_STAT_STUB) |
|
2951
5acd98486a33
ignore ngx_atomic_fetch_add() result
Igor Sysoev <igor@sysoev.ru>
parents:
2723
diff
changeset
|
781 (void) ngx_atomic_fetch_add(ngx_stat_active, -1); |
| 495 | 782 #endif |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
783 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
784 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
785 |
| 543 | 786 u_char * |
| 493 | 787 ngx_accept_log_error(ngx_log_t *log, u_char *buf, size_t len) |
|
191
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
788 { |
| 543 | 789 return ngx_snprintf(buf, len, " while accepting new connection on %V", |
| 790 log->data); | |
|
191
71ce40b3c37b
nginx-0.0.1-2003-11-19-19:26:41 import
Igor Sysoev <igor@sysoev.ru>
parents:
164
diff
changeset
|
791 } |
| 6436 | 792 |
| 793 | |
| 794 #if (NGX_DEBUG) | |
| 795 | |
| 796 static void | |
| 797 ngx_debug_accepted_connection(ngx_event_conf_t *ecf, ngx_connection_t *c) | |
| 798 { | |
| 799 struct sockaddr_in *sin; | |
| 800 ngx_cidr_t *cidr; | |
| 801 ngx_uint_t i; | |
| 802 #if (NGX_HAVE_INET6) | |
| 803 struct sockaddr_in6 *sin6; | |
| 804 ngx_uint_t n; | |
| 805 #endif | |
| 806 | |
| 807 cidr = ecf->debug_connection.elts; | |
| 808 for (i = 0; i < ecf->debug_connection.nelts; i++) { | |
| 809 if (cidr[i].family != (ngx_uint_t) c->sockaddr->sa_family) { | |
| 810 goto next; | |
| 811 } | |
| 812 | |
| 813 switch (cidr[i].family) { | |
| 814 | |
| 815 #if (NGX_HAVE_INET6) | |
| 816 case AF_INET6: | |
| 817 sin6 = (struct sockaddr_in6 *) c->sockaddr; | |
| 818 for (n = 0; n < 16; n++) { | |
| 819 if ((sin6->sin6_addr.s6_addr[n] | |
| 820 & cidr[i].u.in6.mask.s6_addr[n]) | |
| 821 != cidr[i].u.in6.addr.s6_addr[n]) | |
| 822 { | |
| 823 goto next; | |
| 824 } | |
| 825 } | |
| 826 break; | |
| 827 #endif | |
| 828 | |
| 829 #if (NGX_HAVE_UNIX_DOMAIN) | |
| 830 case AF_UNIX: | |
| 831 break; | |
| 832 #endif | |
| 833 | |
| 834 default: /* AF_INET */ | |
| 835 sin = (struct sockaddr_in *) c->sockaddr; | |
| 836 if ((sin->sin_addr.s_addr & cidr[i].u.in.mask) | |
| 837 != cidr[i].u.in.addr) | |
| 838 { | |
| 839 goto next; | |
| 840 } | |
| 841 break; | |
| 842 } | |
| 843 | |
| 844 c->log->log_level = NGX_LOG_DEBUG_CONNECTION|NGX_LOG_DEBUG_ALL; | |
| 845 break; | |
| 846 | |
| 847 next: | |
| 848 continue; | |
| 849 } | |
| 850 } | |
| 851 | |
| 852 #endif |