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