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