nginx-quic: src/event/ngx_event

annotate src/event/ngx_event_accept.c @ 6469:7cdf612fd58c

Win32: replaced NGX_EXDEV with more appropriate error code. Correct error code for NGX_EXDEV on Windows is ERROR_NOT_SAME_DEVICE, "The system cannot move the file to a different disk drive". Previously used ERROR_WRONG_DISK is about wrong diskette in the drive and is not appropriate. There is no real difference though, as MoveFile() is able to copy files between disk drives, and will fail with ERROR_ACCESS_DENIED when asked to copy directories. The ERROR_NOT_SAME_DEVICE error is only used by MoveFileEx() when called without the MOVEFILE_COPY_ALLOWED flag.

author	Maxim Dounin <mdounin@mdounin.ru>
date	Tue, 29 Mar 2016 09:52:15 +0300
parents	8f038068f4bc
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 d620f497c50f Copyright updated. Maxim Konovalov <maxim@nginx.com> parents: 3813 diff changeset	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 58475592100c nginx-0.3.8-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 561 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	15 static void ngx_close_accepted_connection(ngx_connection_t *c);
6436 8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	16 #if (NGX_DEBUG)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	17 static void ngx_debug_accepted_connection(ngx_event_conf_t *ecf,
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	18 ngx_connection_t *c);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	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 975f62e77f02 nginx-0.1.21-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 487 diff changeset	22 void
975f62e77f02 nginx-0.1.21-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 487 diff changeset	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 698033350558 rename variable Igor Sysoev <igor@sysoev.ru> parents: 665 diff changeset	25 socklen_t socklen;
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	26 ngx_err_t err;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	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 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	29 ngx_socket_t s;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	30 ngx_event_t rev, wev;
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	31 ngx_listening_t *ls;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	32 ngx_connection_t c, lc;
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	53 lc = ev->data;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	54 ls = lc->listening;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 8a8eb335313d Linux accept4() support Igor Sysoev <igor@sysoev.ru> parents: 3263 diff changeset	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 8a8eb335313d Linux accept4() support Igor Sysoev <igor@sysoev.ru> parents: 3263 diff changeset	70 #else
714 698033350558 rename variable Igor Sysoev <igor@sysoev.ru> parents: 665 diff changeset	71 s = accept(lc->fd, (struct sockaddr *) sa, &socklen);
3786 8a8eb335313d Linux accept4() support Igor Sysoev <igor@sysoev.ru> parents: 3263 diff changeset	72 #endif
477 ad1e9ebf93bb nginx-0.1.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 461 diff changeset	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 295d97d70c69 nginx-0.1.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	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 fb7995c7bdd9 dynamic accept threshold Igor Sysoev <igor@sysoev.ru> parents: 2198 diff changeset	142 ngx_accept_disabled = ngx_cycle->connection_n / 8
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	143 - ngx_cycle->free_connection_n;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	144
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	147 if (c == NULL) {
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	148 if (ngx_close_socket(s) == -1) {
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	149 ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_socket_errno,
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	150 ngx_close_socket_n " failed");
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	153 return;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	154 }
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	155
6436 8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	156 c->type = SOCK_STREAM;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	157
635 18268abd340c nginx-0.3.39-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 617 diff changeset	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 18268abd340c nginx-0.3.39-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 617 diff changeset	160 #endif
18268abd340c nginx-0.3.39-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 617 diff changeset	161
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	162 c->pool = ngx_create_pool(ls->pool_size, ev->log);
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	163 if (c->pool == NULL) {
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	164 ngx_close_accepted_connection(c);
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	165 return;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 698033350558 rename variable Igor Sysoev <igor@sysoev.ru> parents: 665 diff changeset	168 c->sockaddr = ngx_palloc(c->pool, socklen);
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	169 if (c->sockaddr == NULL) {
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	170 ngx_close_accepted_connection(c);
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	171 return;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	172 }
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	173
714 698033350558 rename variable Igor Sysoev <igor@sysoev.ru> parents: 665 diff changeset	174 ngx_memcpy(c->sockaddr, sa, socklen);
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	175
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	176 log = ngx_palloc(c->pool, sizeof(ngx_log_t));
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	177 if (log == NULL) {
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	205 *log = ls->log;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	206
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	207 c->recv = ngx_recv;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	208 c->send = ngx_send;
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 573 diff changeset	209 c->recv_chain = ngx_recv_chain;
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	212 c->log = log;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	219
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	220 c->unexpected_eof = 1;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 543 diff changeset	233 rev = c->read;
e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 543 diff changeset	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 2019117e6b38 nginx-0.1.36-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	244 #if (NGX_HAVE_KQUEUE)
2019117e6b38 nginx-0.1.36-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	245 rev->available = 1;
2019117e6b38 nginx-0.1.36-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	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 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 543 diff changeset	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 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 543 diff changeset	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 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 543 diff changeset	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 fc9909c369b2 nginx-0.1.22-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 493 diff changeset	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 fc9909c369b2 nginx-0.1.22-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 493 diff changeset	265 #endif
fc9909c369b2 nginx-0.1.22-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 493 diff changeset	266
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	267 if (ls->addr_ntop) {
2049 2a92804f4109 ) back out r2040 Igor Sysoev <igor@sysoev.ru>* parents: 719 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 573 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	285 ngx_str_t addr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	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 8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 295d97d70c69 nginx-0.1.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	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 8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	322 #if !(NGX_WIN32)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	323
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	324 void
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	325 ngx_event_recvmsg(ngx_event_t *ev)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	326 {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	327 ssize_t n;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	328 ngx_log_t *log;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	329 ngx_err_t err;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	330 ngx_event_t rev, wev;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	331 struct iovec iov[1];
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	332 struct msghdr msg;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	333 ngx_listening_t *ls;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	334 ngx_event_conf_t *ecf;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	335 ngx_connection_t c, lc;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	336 u_char sa[NGX_SOCKADDRLEN];
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	337 static u_char buffer[65535];
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	338
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	339 #if (NGX_HAVE_MSGHDR_MSG_CONTROL)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	340
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	341 #if (NGX_HAVE_IP_RECVDSTADDR)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	342 u_char msg_control[CMSG_SPACE(sizeof(struct in_addr))];
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	343 #elif (NGX_HAVE_IP_PKTINFO)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	344 u_char msg_control[CMSG_SPACE(sizeof(struct in_pktinfo))];
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	345 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	346
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	347 #if (NGX_HAVE_INET6 && NGX_HAVE_IPV6_RECVPKTINFO)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	348 u_char msg_control6[CMSG_SPACE(sizeof(struct in6_pktinfo))];
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	349 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	350
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	351 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	352
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	353 if (ev->timedout) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	354 if (ngx_enable_accept_events((ngx_cycle_t *) ngx_cycle) != NGX_OK) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	355 return;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	356 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	357
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	358 ev->timedout = 0;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	359 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	360
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	361 ecf = ngx_event_get_conf(ngx_cycle->conf_ctx, ngx_event_core_module);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	362
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	363 if (!(ngx_event_flags & NGX_USE_KQUEUE_EVENT)) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	364 ev->available = ecf->multi_accept;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	365 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	366
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	367 lc = ev->data;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	368 ls = lc->listening;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	369 ev->ready = 0;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	370
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	371 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	372 "recvmsg on %V, ready: %d", &ls->addr_text, ev->available);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	373
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	374 do {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	375 ngx_memzero(&msg, sizeof(struct msghdr));
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	376
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	377 iov[0].iov_base = (void *) buffer;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	378 iov[0].iov_len = sizeof(buffer);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	379
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	380 msg.msg_name = &sa;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	381 msg.msg_namelen = sizeof(sa);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	382 msg.msg_iov = iov;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	383 msg.msg_iovlen = 1;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	384
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	385 #if (NGX_HAVE_MSGHDR_MSG_CONTROL)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	386
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	387 if (ls->wildcard) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	388
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	389 #if (NGX_HAVE_IP_RECVDSTADDR \|\| NGX_HAVE_IP_PKTINFO)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	390 if (ls->sockaddr->sa_family == AF_INET) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	391 msg.msg_control = &msg_control;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	392 msg.msg_controllen = sizeof(msg_control);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	393 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	394 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	395
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	396 #if (NGX_HAVE_INET6 && NGX_HAVE_IPV6_RECVPKTINFO)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	397 if (ls->sockaddr->sa_family == AF_INET6) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	398 msg.msg_control = &msg_control6;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	399 msg.msg_controllen = sizeof(msg_control6);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	400 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	401 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	402 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	403
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	404 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	405
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	406 n = recvmsg(lc->fd, &msg, 0);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	407
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	408 if (n == -1) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	409 err = ngx_socket_errno;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	410
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	411 if (err == NGX_EAGAIN) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	412 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, ev->log, err,
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	413 "recvmsg() not ready");
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	414 return;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	415 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	416
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	417 ngx_log_error(NGX_LOG_ALERT, ev->log, err, "recvmsg() failed");
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	418
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	419 return;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	420 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	421
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	422 #if (NGX_STAT_STUB)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	423 (void) ngx_atomic_fetch_add(ngx_stat_accepted, 1);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	424 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	425
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	426 #if (NGX_HAVE_MSGHDR_MSG_CONTROL)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	427 if (msg.msg_flags & (MSG_TRUNC\|MSG_CTRUNC)) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	428 ngx_log_error(NGX_LOG_ALERT, ev->log, 0,
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	429 "recvmsg() truncated data");
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	430 continue;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	431 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	432 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	433
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	434 ngx_accept_disabled = ngx_cycle->connection_n / 8
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	435 - ngx_cycle->free_connection_n;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	436
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	437 c = ngx_get_connection(lc->fd, ev->log);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	438 if (c == NULL) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	439 return;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	440 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	441
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	442 c->shared = 1;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	443 c->type = SOCK_DGRAM;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	444 c->socklen = msg.msg_namelen;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	445
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	446 #if (NGX_STAT_STUB)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	447 (void) ngx_atomic_fetch_add(ngx_stat_active, 1);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	448 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	449
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	450 c->pool = ngx_create_pool(ls->pool_size, ev->log);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	451 if (c->pool == NULL) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	452 ngx_close_accepted_connection(c);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	453 return;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	454 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	455
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	456 c->sockaddr = ngx_palloc(c->pool, c->socklen);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	457 if (c->sockaddr == NULL) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	458 ngx_close_accepted_connection(c);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	459 return;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	460 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	461
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	462 ngx_memcpy(c->sockaddr, msg.msg_name, c->socklen);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	463
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	464 log = ngx_palloc(c->pool, sizeof(ngx_log_t));
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	465 if (log == NULL) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	466 ngx_close_accepted_connection(c);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	467 return;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	468 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	469
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	470 *log = ls->log;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	471
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	472 c->send = ngx_udp_send;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	473
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	474 c->log = log;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	475 c->pool->log = log;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	476
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	477 c->listening = ls;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	478 c->local_sockaddr = ls->sockaddr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	479 c->local_socklen = ls->socklen;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	480
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	481 #if (NGX_HAVE_MSGHDR_MSG_CONTROL)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	482
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	483 if (ls->wildcard) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	484 struct cmsghdr *cmsg;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	485 struct sockaddr *sockaddr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	486
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	487 sockaddr = ngx_palloc(c->pool, c->local_socklen);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	488 if (sockaddr == NULL) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	489 ngx_close_accepted_connection(c);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	490 return;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	491 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	492
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	493 ngx_memcpy(sockaddr, c->local_sockaddr, c->local_socklen);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	494 c->local_sockaddr = sockaddr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	495
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	496 for (cmsg = CMSG_FIRSTHDR(&msg);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	497 cmsg != NULL;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	498 cmsg = CMSG_NXTHDR(&msg, cmsg))
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	499 {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	500
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	501 #if (NGX_HAVE_IP_RECVDSTADDR)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	502
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	503 if (cmsg->cmsg_level == IPPROTO_IP
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	504 && cmsg->cmsg_type == IP_RECVDSTADDR
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	505 && sockaddr->sa_family == AF_INET)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	506 {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	507 struct in_addr *addr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	508 struct sockaddr_in *sin;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	509
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	510 addr = (struct in_addr *) CMSG_DATA(cmsg);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	511 sin = (struct sockaddr_in *) sockaddr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	512 sin->sin_addr = *addr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	513
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	514 break;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	515 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	516
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	517 #elif (NGX_HAVE_IP_PKTINFO)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	518
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	519 if (cmsg->cmsg_level == IPPROTO_IP
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	520 && cmsg->cmsg_type == IP_PKTINFO
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	521 && sockaddr->sa_family == AF_INET)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	522 {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	523 struct in_pktinfo *pkt;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	524 struct sockaddr_in *sin;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	525
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	526 pkt = (struct in_pktinfo *) CMSG_DATA(cmsg);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	527 sin = (struct sockaddr_in *) sockaddr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	528 sin->sin_addr = pkt->ipi_addr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	529
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	530 break;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	531 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	532
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	533 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	534
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	535 #if (NGX_HAVE_INET6 && NGX_HAVE_IPV6_RECVPKTINFO)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	536
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	537 if (cmsg->cmsg_level == IPPROTO_IPV6
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	538 && cmsg->cmsg_type == IPV6_PKTINFO
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	539 && sockaddr->sa_family == AF_INET6)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	540 {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	541 struct in6_pktinfo *pkt6;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	542 struct sockaddr_in6 *sin6;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	543
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	544 pkt6 = (struct in6_pktinfo *) CMSG_DATA(cmsg);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	545 sin6 = (struct sockaddr_in6 *) sockaddr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	546 sin6->sin6_addr = pkt6->ipi6_addr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	547
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	548 break;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	549 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	550
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	551 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	552
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	553 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	554 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	555
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	556 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	557
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	558 c->buffer = ngx_create_temp_buf(c->pool, n);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	559 if (c->buffer == NULL) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	560 ngx_close_accepted_connection(c);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	561 return;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	562 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	563
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	564 c->buffer->last = ngx_cpymem(c->buffer->last, buffer, n);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	565
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	566 rev = c->read;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	567 wev = c->write;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	568
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	569 wev->ready = 1;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	570
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	571 rev->log = log;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	572 wev->log = log;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	573
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	574 /*
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	575 * TODO: MT: - ngx_atomic_fetch_add()
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	576 * or protection by critical section or light mutex
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	577 *
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	578 * TODO: MP: - allocated in a shared memory
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	579 * - ngx_atomic_fetch_add()
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	580 * or protection by critical section or light mutex
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	581 */
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	582
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	583 c->number = ngx_atomic_fetch_add(ngx_connection_counter, 1);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	584
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	585 #if (NGX_STAT_STUB)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	586 (void) ngx_atomic_fetch_add(ngx_stat_handled, 1);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	587 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	588
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	589 if (ls->addr_ntop) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	590 c->addr_text.data = ngx_pnalloc(c->pool, ls->addr_text_max_len);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	591 if (c->addr_text.data == NULL) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	592 ngx_close_accepted_connection(c);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	593 return;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	594 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	595
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	596 c->addr_text.len = ngx_sock_ntop(c->sockaddr, c->socklen,
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	597 c->addr_text.data,
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	598 ls->addr_text_max_len, 0);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	599 if (c->addr_text.len == 0) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	600 ngx_close_accepted_connection(c);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	601 return;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	602 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	603 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	604
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	605 #if (NGX_DEBUG)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	606 {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	607 ngx_str_t addr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	608 u_char text[NGX_SOCKADDR_STRLEN];
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	609
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	610 ngx_debug_accepted_connection(ecf, c);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	611
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	612 if (log->log_level & NGX_LOG_DEBUG_EVENT) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	613 addr.data = text;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	614 addr.len = ngx_sock_ntop(c->sockaddr, c->socklen, text,
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	615 NGX_SOCKADDR_STRLEN, 1);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	616
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	617 ngx_log_debug4(NGX_LOG_DEBUG_EVENT, log, 0,
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	618 "*%uA recvmsg: %V fd:%d n:%z",
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	619 c->number, &addr, c->fd, n);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	620 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	621
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	622 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	623 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	624
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	625 log->data = NULL;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	626 log->handler = NULL;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	627
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	628 ls->handler(c);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	629
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	630 if (ngx_event_flags & NGX_USE_KQUEUE_EVENT) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	631 ev->available -= n;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	632 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	633
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	634 } while (ev->available);
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	635 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	636
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	637 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	638
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	639
493 975f62e77f02 nginx-0.1.21-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 487 diff changeset	640 ngx_int_t
975f62e77f02 nginx-0.1.21-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 487 diff changeset	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 3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	643 if (ngx_shmtx_trylock(&ngx_accept_mutex)) {
3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	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 58475592100c nginx-0.3.8-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 561 diff changeset	649 return NGX_OK;
58475592100c nginx-0.3.8-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 561 diff changeset	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 58475592100c nginx-0.3.8-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 561 diff changeset	652 if (ngx_enable_accept_events(cycle) == NGX_ERROR) {
611 3f8a2132b93d nginx-0.3.27-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	653 ngx_shmtx_unlock(&ngx_accept_mutex);
573 58475592100c nginx-0.3.8-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 561 diff changeset	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 58475592100c nginx-0.3.8-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 561 diff changeset	658 ngx_accept_mutex_held = 1;
58475592100c nginx-0.3.8-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 561 diff changeset	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 58475592100c nginx-0.3.8-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 561 diff changeset	678 static ngx_int_t
493 975f62e77f02 nginx-0.1.21-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 487 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	681 ngx_uint_t i;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	682 ngx_listening_t *ls;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 58475592100c nginx-0.3.8-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 561 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	706 ngx_uint_t i;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	707 ngx_listening_t *ls;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	713 c = ls[i].connection;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	716 continue;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 975f62e77f02 nginx-0.1.21-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 487 diff changeset	743 static void
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	746 ngx_socket_t fd;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	747
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	748 ngx_free_connection(c);
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	749
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	750 fd = c->fd;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	751 c->fd = (ngx_socket_t) -1;
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	752
6436 8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	753 if (!c->shared && ngx_close_socket(fd) == -1) {
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 fc9909c369b2 nginx-0.1.22-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 493 diff changeset	757
543 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	758 if (c->pool) {
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	759 ngx_destroy_pool(c->pool);
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	760 }
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	761
495 fc9909c369b2 nginx-0.1.22-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 493 diff changeset	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 fc9909c369b2 nginx-0.1.22-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 493 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	768 u_char *
493 975f62e77f02 nginx-0.1.21-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 487 diff changeset	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 511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	771 return ngx_snprintf(buf, len, " while accepting new connection on %V",
511a89da35ad nginx-0.2.0-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 539 diff changeset	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 8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	774
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	775
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	776 #if (NGX_DEBUG)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	777
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	778 static void
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	779 ngx_debug_accepted_connection(ngx_event_conf_t ecf, ngx_connection_t c)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	780 {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	781 struct sockaddr_in *sin;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	782 ngx_cidr_t *cidr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	783 ngx_uint_t i;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	784 #if (NGX_HAVE_INET6)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	785 struct sockaddr_in6 *sin6;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	786 ngx_uint_t n;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	787 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	788
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	789 cidr = ecf->debug_connection.elts;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	790 for (i = 0; i < ecf->debug_connection.nelts; i++) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	791 if (cidr[i].family != (ngx_uint_t) c->sockaddr->sa_family) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	792 goto next;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	793 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	794
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	795 switch (cidr[i].family) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	796
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	797 #if (NGX_HAVE_INET6)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	798 case AF_INET6:
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	799 sin6 = (struct sockaddr_in6 *) c->sockaddr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	800 for (n = 0; n < 16; n++) {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	801 if ((sin6->sin6_addr.s6_addr[n]
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	802 & cidr[i].u.in6.mask.s6_addr[n])
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	803 != cidr[i].u.in6.addr.s6_addr[n])
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	804 {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	805 goto next;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	806 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	807 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	808 break;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	809 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	810
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	811 #if (NGX_HAVE_UNIX_DOMAIN)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	812 case AF_UNIX:
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	813 break;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	814 #endif
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	815
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	816 default: /* AF_INET */
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	817 sin = (struct sockaddr_in *) c->sockaddr;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	818 if ((sin->sin_addr.s_addr & cidr[i].u.in.mask)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	819 != cidr[i].u.in.addr)
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	820 {
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	821 goto next;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	822 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	823 break;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	824 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	825
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	826 c->log->log_level = NGX_LOG_DEBUG_CONNECTION\|NGX_LOG_DEBUG_ALL;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	827 break;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	828
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	829 next:
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	830 continue;
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	831 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	832 }
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	833
8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6153 diff changeset	834 #endif

Mercurial > hg > nginx-quic

annotate src/event/ngx_event_accept.c @ 6469:7cdf612fd58c