nginx: src/core/ngx_proxy_protocol.c annotate

annotate src/core/ngx_proxy_protocol.c @ 9045:c6580dce98a8 quic

QUIC: fixed triggering stream read event (ticket #2409). If a client packet carrying a stream data frame is not acked due to packet loss, the stream data is retransmitted later by client. It's also possible that the retransmitted range is bigger than before due to more stream data being available by then. If the original data was read out by the application, there would be no read event triggered by the retransmitted frame, even though it contains new data.

author	Roman Arutyunyan <arut@nginx.com>
date	Wed, 23 Nov 2022 18:50:26 +0400
parents	aa663cc2a77d
children	17d6a537fb1b

rev	line source
5605 3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	1
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	2 /*
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	3 * Copyright (C) Roman Arutyunyan
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	4 * Copyright (C) Nginx, Inc.
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	5 */
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	6
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	7
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	8 #include <ngx_config.h>
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	9 #include <ngx_core.h>
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	10
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	11
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	12 #define NGX_PROXY_PROTOCOL_AF_INET 1
63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	13 #define NGX_PROXY_PROTOCOL_AF_INET6 2
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	14
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	15
8073 aa663cc2a77d Added type cast to ngx_proxy_protocol_parse_uint16(). Roman Arutyunyan <arut@nginx.com> parents: 8072 diff changeset	16 #define ngx_proxy_protocol_parse_uint16(p) \
aa663cc2a77d Added type cast to ngx_proxy_protocol_parse_uint16(). Roman Arutyunyan <arut@nginx.com> parents: 8072 diff changeset	17 ( ((uint16_t) (p)[0] << 8) \
aa663cc2a77d Added type cast to ngx_proxy_protocol_parse_uint16(). Roman Arutyunyan <arut@nginx.com> parents: 8072 diff changeset	18 + ( (p)[1]) )
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	19
8072 cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	20 #define ngx_proxy_protocol_parse_uint32(p) \
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	21 ( ((uint32_t) (p)[0] << 24) \
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	22 + ( (p)[1] << 16) \
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	23 + ( (p)[2] << 8) \
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	24 + ( (p)[3]) )
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	25
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	26
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	27 typedef struct {
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	28 u_char signature[12];
63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	29 u_char version_command;
63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	30 u_char family_transport;
63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	31 u_char len[2];
63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	32 } ngx_proxy_protocol_header_t;
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	33
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	34
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	35 typedef struct {
7254 1fd992589ffe Core: fixed build, broken by 63e91f263a49. Vladimir Homutov <vl@nginx.com> parents: 7253 diff changeset	36 u_char src_addr[4];
1fd992589ffe Core: fixed build, broken by 63e91f263a49. Vladimir Homutov <vl@nginx.com> parents: 7253 diff changeset	37 u_char dst_addr[4];
1fd992589ffe Core: fixed build, broken by 63e91f263a49. Vladimir Homutov <vl@nginx.com> parents: 7253 diff changeset	38 u_char src_port[2];
1fd992589ffe Core: fixed build, broken by 63e91f263a49. Vladimir Homutov <vl@nginx.com> parents: 7253 diff changeset	39 u_char dst_port[2];
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	40 } ngx_proxy_protocol_inet_addrs_t;
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	41
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	42
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	43 typedef struct {
7254 1fd992589ffe Core: fixed build, broken by 63e91f263a49. Vladimir Homutov <vl@nginx.com> parents: 7253 diff changeset	44 u_char src_addr[16];
1fd992589ffe Core: fixed build, broken by 63e91f263a49. Vladimir Homutov <vl@nginx.com> parents: 7253 diff changeset	45 u_char dst_addr[16];
1fd992589ffe Core: fixed build, broken by 63e91f263a49. Vladimir Homutov <vl@nginx.com> parents: 7253 diff changeset	46 u_char src_port[2];
1fd992589ffe Core: fixed build, broken by 63e91f263a49. Vladimir Homutov <vl@nginx.com> parents: 7253 diff changeset	47 u_char dst_port[2];
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	48 } ngx_proxy_protocol_inet6_addrs_t;
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	49
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	50
8072 cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	51 typedef struct {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	52 u_char type;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	53 u_char len[2];
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	54 } ngx_proxy_protocol_tlv_t;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	55
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	56
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	57 typedef struct {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	58 u_char client;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	59 u_char verify[4];
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	60 } ngx_proxy_protocol_tlv_ssl_t;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	61
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	62
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	63 typedef struct {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	64 ngx_str_t name;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	65 ngx_uint_t type;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	66 } ngx_proxy_protocol_tlv_entry_t;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	67
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	68
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	69 static u_char ngx_proxy_protocol_read_addr(ngx_connection_t c, u_char *p,
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	70 u_char last, ngx_str_t addr);
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	71 static u_char ngx_proxy_protocol_read_port(u_char p, u_char *last,
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	72 in_port_t *port, u_char sep);
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	73 static u_char ngx_proxy_protocol_v2_read(ngx_connection_t c, u_char *buf,
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	74 u_char *last);
8072 cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	75 static ngx_int_t ngx_proxy_protocol_lookup_tlv(ngx_connection_t *c,
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	76 ngx_str_t tlvs, ngx_uint_t type, ngx_str_t value);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	77
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	78
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	79 static ngx_proxy_protocol_tlv_entry_t ngx_proxy_protocol_tlv_entries[] = {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	80 { ngx_string("alpn"), 0x01 },
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	81 { ngx_string("authority"), 0x02 },
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	82 { ngx_string("unique_id"), 0x05 },
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	83 { ngx_string("ssl"), 0x20 },
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	84 { ngx_string("netns"), 0x30 },
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	85 { ngx_null_string, 0x00 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	86 };
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	87
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	88
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	89 static ngx_proxy_protocol_tlv_entry_t ngx_proxy_protocol_tlv_ssl_entries[] = {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	90 { ngx_string("version"), 0x21 },
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	91 { ngx_string("cn"), 0x22 },
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	92 { ngx_string("cipher"), 0x23 },
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	93 { ngx_string("sig_alg"), 0x24 },
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	94 { ngx_string("key_alg"), 0x25 },
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	95 { ngx_null_string, 0x00 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	96 };
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	97
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	98
5605 3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	99 u_char *
6185 a420cb1c170b Core: renamed ngx_proxy_protocol_parse to ngx_proxy_protocol_read. Roman Arutyunyan <arut@nginx.com> parents: 6184 diff changeset	100 ngx_proxy_protocol_read(ngx_connection_t c, u_char buf, u_char *last)
5605 3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	101 {
7590 06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	102 size_t len;
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	103 u_char *p;
7590 06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	104 ngx_proxy_protocol_t *pp;
5605 3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	105
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	106 static const u_char signature[] = "\r\n\r\n\0\r\nQUIT\n";
63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	107
5605 3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	108 p = buf;
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	109 len = last - buf;
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	110
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	111 if (len >= sizeof(ngx_proxy_protocol_header_t)
63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	112 && memcmp(p, signature, sizeof(signature) - 1) == 0)
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	113 {
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	114 return ngx_proxy_protocol_v2_read(c, buf, last);
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	115 }
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	116
5605 3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	117 if (len < 8 \|\| ngx_strncmp(p, "PROXY ", 6) != 0) {
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	118 goto invalid;
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	119 }
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	120
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	121 p += 6;
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	122 len -= 6;
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	123
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	124 if (len >= 7 && ngx_strncmp(p, "UNKNOWN", 7) == 0) {
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	125 ngx_log_debug0(NGX_LOG_DEBUG_CORE, c->log, 0,
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	126 "PROXY protocol unknown protocol");
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	127 p += 7;
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	128 goto skip;
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	129 }
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	130
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	131 if (len < 5 \|\| ngx_strncmp(p, "TCP", 3) != 0
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	132 \|\| (p[3] != '4' && p[3] != '6') \|\| p[4] != ' ')
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	133 {
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	134 goto invalid;
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	135 }
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	136
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	137 p += 5;
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	138
7590 06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	139 pp = ngx_pcalloc(c->pool, sizeof(ngx_proxy_protocol_t));
06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	140 if (pp == NULL) {
5605 3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	141 return NULL;
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	142 }
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	143
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	144 p = ngx_proxy_protocol_read_addr(c, p, last, &pp->src_addr);
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	145 if (p == NULL) {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	146 goto invalid;
7590 06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	147 }
06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	148
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	149 p = ngx_proxy_protocol_read_addr(c, p, last, &pp->dst_addr);
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	150 if (p == NULL) {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	151 goto invalid;
6561 28c76d9d75b7 Added the $proxy_protocol_port variable. Dmitry Volyntsev <xeioex@nginx.com> parents: 6185 diff changeset	152 }
28c76d9d75b7 Added the $proxy_protocol_port variable. Dmitry Volyntsev <xeioex@nginx.com> parents: 6185 diff changeset	153
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	154 p = ngx_proxy_protocol_read_port(p, last, &pp->src_port, ' ');
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	155 if (p == NULL) {
6561 28c76d9d75b7 Added the $proxy_protocol_port variable. Dmitry Volyntsev <xeioex@nginx.com> parents: 6185 diff changeset	156 goto invalid;
28c76d9d75b7 Added the $proxy_protocol_port variable. Dmitry Volyntsev <xeioex@nginx.com> parents: 6185 diff changeset	157 }
28c76d9d75b7 Added the $proxy_protocol_port variable. Dmitry Volyntsev <xeioex@nginx.com> parents: 6185 diff changeset	158
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	159 p = ngx_proxy_protocol_read_port(p, last, &pp->dst_port, CR);
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	160 if (p == NULL) {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	161 goto invalid;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	162 }
6561 28c76d9d75b7 Added the $proxy_protocol_port variable. Dmitry Volyntsev <xeioex@nginx.com> parents: 6185 diff changeset	163
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	164 if (p == last) {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	165 goto invalid;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	166 }
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	167
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	168 if (*p++ != LF) {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	169 goto invalid;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	170 }
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	171
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	172 ngx_log_debug4(NGX_LOG_DEBUG_CORE, c->log, 0,
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	173 "PROXY protocol src: %V %d, dst: %V %d",
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	174 &pp->src_addr, pp->src_port, &pp->dst_addr, pp->dst_port);
7590 06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	175
06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	176 c->proxy_protocol = pp;
5605 3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	177
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	178 return p;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	179
5605 3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	180 skip:
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	181
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	182 for ( /* void */ ; p < last - 1; p++) {
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	183 if (p[0] == CR && p[1] == LF) {
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	184 return p + 2;
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	185 }
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	186 }
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	187
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	188 invalid:
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	189
8071 017fd847f4f7 Log only the first line of user input on PROXY protocol v1 error. Roman Arutyunyan <arut@nginx.com> parents: 7591 diff changeset	190 for (p = buf; p < last; p++) {
017fd847f4f7 Log only the first line of user input on PROXY protocol v1 error. Roman Arutyunyan <arut@nginx.com> parents: 7591 diff changeset	191 if (p == CR \|\| p == LF) {
017fd847f4f7 Log only the first line of user input on PROXY protocol v1 error. Roman Arutyunyan <arut@nginx.com> parents: 7591 diff changeset	192 break;
017fd847f4f7 Log only the first line of user input on PROXY protocol v1 error. Roman Arutyunyan <arut@nginx.com> parents: 7591 diff changeset	193 }
017fd847f4f7 Log only the first line of user input on PROXY protocol v1 error. Roman Arutyunyan <arut@nginx.com> parents: 7591 diff changeset	194 }
017fd847f4f7 Log only the first line of user input on PROXY protocol v1 error. Roman Arutyunyan <arut@nginx.com> parents: 7591 diff changeset	195
5605 3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	196 ngx_log_error(NGX_LOG_ERR, c->log, 0,
8071 017fd847f4f7 Log only the first line of user input on PROXY protocol v1 error. Roman Arutyunyan <arut@nginx.com> parents: 7591 diff changeset	197 "broken header: \"%*s\"", (size_t) (p - buf), buf);
5605 3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	198
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	199 return NULL;
3a72b1805c52 Added server-side support for PROXY protocol v1 (ticket #355). Roman Arutyunyan <arut@nginx.com> parents: diff changeset	200 }
6184 fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	201
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	202
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	203 static u_char *
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	204 ngx_proxy_protocol_read_addr(ngx_connection_t c, u_char p, u_char *last,
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	205 ngx_str_t *addr)
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	206 {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	207 size_t len;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	208 u_char ch, *pos;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	209
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	210 pos = p;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	211
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	212 for ( ;; ) {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	213 if (p == last) {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	214 return NULL;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	215 }
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	216
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	217 ch = *p++;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	218
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	219 if (ch == ' ') {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	220 break;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	221 }
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	222
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	223 if (ch != ':' && ch != '.'
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	224 && (ch < 'a' \|\| ch > 'f')
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	225 && (ch < 'A' \|\| ch > 'F')
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	226 && (ch < '0' \|\| ch > '9'))
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	227 {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	228 return NULL;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	229 }
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	230 }
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	231
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	232 len = p - pos - 1;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	233
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	234 addr->data = ngx_pnalloc(c->pool, len);
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	235 if (addr->data == NULL) {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	236 return NULL;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	237 }
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	238
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	239 ngx_memcpy(addr->data, pos, len);
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	240 addr->len = len;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	241
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	242 return p;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	243 }
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	244
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	245
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	246 static u_char *
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	247 ngx_proxy_protocol_read_port(u_char p, u_char last, in_port_t *port,
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	248 u_char sep)
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	249 {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	250 size_t len;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	251 u_char *pos;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	252 ngx_int_t n;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	253
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	254 pos = p;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	255
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	256 for ( ;; ) {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	257 if (p == last) {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	258 return NULL;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	259 }
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	260
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	261 if (*p++ == sep) {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	262 break;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	263 }
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	264 }
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	265
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	266 len = p - pos - 1;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	267
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	268 n = ngx_atoi(pos, len);
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	269 if (n < 0 \|\| n > 65535) {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	270 return NULL;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	271 }
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	272
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	273 *port = (in_port_t) n;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	274
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	275 return p;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	276 }
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	277
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	278
6184 fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	279 u_char *
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	280 ngx_proxy_protocol_write(ngx_connection_t c, u_char buf, u_char *last)
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	281 {
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	282 ngx_uint_t port, lport;
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	283
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	284 if (last - buf < NGX_PROXY_PROTOCOL_MAX_HEADER) {
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	285 return NULL;
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	286 }
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	287
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	288 if (ngx_connection_local_sockaddr(c, NULL, 0) != NGX_OK) {
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	289 return NULL;
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	290 }
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	291
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	292 switch (c->sockaddr->sa_family) {
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	293
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	294 case AF_INET:
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	295 buf = ngx_cpymem(buf, "PROXY TCP4 ", sizeof("PROXY TCP4 ") - 1);
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	296 break;
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	297
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	298 #if (NGX_HAVE_INET6)
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	299 case AF_INET6:
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	300 buf = ngx_cpymem(buf, "PROXY TCP6 ", sizeof("PROXY TCP6 ") - 1);
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	301 break;
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	302 #endif
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	303
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	304 default:
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	305 return ngx_cpymem(buf, "PROXY UNKNOWN" CRLF,
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	306 sizeof("PROXY UNKNOWN" CRLF) - 1);
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	307 }
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	308
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	309 buf += ngx_sock_ntop(c->sockaddr, c->socklen, buf, last - buf, 0);
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	310
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	311 *buf++ = ' ';
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	312
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	313 buf += ngx_sock_ntop(c->local_sockaddr, c->local_socklen, buf, last - buf,
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	314 0);
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	315
6593 b3b7e33083ac Introduced ngx_inet_get_port() and ngx_inet_set_port() functions. Roman Arutyunyan <arut@nginx.com> parents: 6561 diff changeset	316 port = ngx_inet_get_port(c->sockaddr);
b3b7e33083ac Introduced ngx_inet_get_port() and ngx_inet_set_port() functions. Roman Arutyunyan <arut@nginx.com> parents: 6561 diff changeset	317 lport = ngx_inet_get_port(c->local_sockaddr);
b3b7e33083ac Introduced ngx_inet_get_port() and ngx_inet_set_port() functions. Roman Arutyunyan <arut@nginx.com> parents: 6561 diff changeset	318
6184 fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	319 return ngx_slprintf(buf, last, " %ui %ui" CRLF, port, lport);
fa663739e115 Stream: client-side PROXY protocol. Roman Arutyunyan <arut@nginx.com> parents: 5605 diff changeset	320 }
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	321
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	322
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	323 static u_char *
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	324 ngx_proxy_protocol_v2_read(ngx_connection_t c, u_char buf, u_char *last)
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	325 {
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	326 u_char *end;
63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	327 size_t len;
63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	328 socklen_t socklen;
63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	329 ngx_uint_t version, command, family, transport;
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	330 ngx_sockaddr_t src_sockaddr, dst_sockaddr;
7590 06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	331 ngx_proxy_protocol_t *pp;
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	332 ngx_proxy_protocol_header_t *header;
7254 1fd992589ffe Core: fixed build, broken by 63e91f263a49. Vladimir Homutov <vl@nginx.com> parents: 7253 diff changeset	333 ngx_proxy_protocol_inet_addrs_t *in;
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	334 #if (NGX_HAVE_INET6)
7254 1fd992589ffe Core: fixed build, broken by 63e91f263a49. Vladimir Homutov <vl@nginx.com> parents: 7253 diff changeset	335 ngx_proxy_protocol_inet6_addrs_t *in6;
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	336 #endif
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	337
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	338 header = (ngx_proxy_protocol_header_t *) buf;
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	339
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	340 buf += sizeof(ngx_proxy_protocol_header_t);
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	341
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	342 version = header->version_command >> 4;
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	343
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	344 if (version != 2) {
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	345 ngx_log_error(NGX_LOG_ERR, c->log, 0,
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	346 "unknown PROXY protocol version: %ui", version);
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	347 return NULL;
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	348 }
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	349
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	350 len = ngx_proxy_protocol_parse_uint16(header->len);
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	351
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	352 if ((size_t) (last - buf) < len) {
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	353 ngx_log_error(NGX_LOG_ERR, c->log, 0, "header is too large");
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	354 return NULL;
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	355 }
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	356
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	357 end = buf + len;
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	358
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	359 command = header->version_command & 0x0f;
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	360
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	361 /* only PROXY is supported */
63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	362 if (command != 1) {
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	363 ngx_log_debug1(NGX_LOG_DEBUG_CORE, c->log, 0,
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	364 "PROXY protocol v2 unsupported command %ui", command);
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	365 return end;
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	366 }
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	367
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	368 transport = header->family_transport & 0x0f;
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	369
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	370 /* only STREAM is supported */
63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	371 if (transport != 1) {
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	372 ngx_log_debug1(NGX_LOG_DEBUG_CORE, c->log, 0,
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	373 "PROXY protocol v2 unsupported transport %ui",
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	374 transport);
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	375 return end;
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	376 }
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	377
7590 06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	378 pp = ngx_pcalloc(c->pool, sizeof(ngx_proxy_protocol_t));
06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	379 if (pp == NULL) {
06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	380 return NULL;
06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	381 }
06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	382
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	383 family = header->family_transport >> 4;
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	384
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	385 switch (family) {
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	386
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	387 case NGX_PROXY_PROTOCOL_AF_INET:
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	388
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	389 if ((size_t) (end - buf) < sizeof(ngx_proxy_protocol_inet_addrs_t)) {
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	390 return NULL;
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	391 }
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	392
7254 1fd992589ffe Core: fixed build, broken by 63e91f263a49. Vladimir Homutov <vl@nginx.com> parents: 7253 diff changeset	393 in = (ngx_proxy_protocol_inet_addrs_t *) buf;
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	394
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	395 src_sockaddr.sockaddr_in.sin_family = AF_INET;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	396 src_sockaddr.sockaddr_in.sin_port = 0;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	397 memcpy(&src_sockaddr.sockaddr_in.sin_addr, in->src_addr, 4);
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	398
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	399 dst_sockaddr.sockaddr_in.sin_family = AF_INET;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	400 dst_sockaddr.sockaddr_in.sin_port = 0;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	401 memcpy(&dst_sockaddr.sockaddr_in.sin_addr, in->dst_addr, 4);
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	402
7590 06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	403 pp->src_port = ngx_proxy_protocol_parse_uint16(in->src_port);
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	404 pp->dst_port = ngx_proxy_protocol_parse_uint16(in->dst_port);
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	405
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	406 socklen = sizeof(struct sockaddr_in);
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	407
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	408 buf += sizeof(ngx_proxy_protocol_inet_addrs_t);
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	409
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	410 break;
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	411
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	412 #if (NGX_HAVE_INET6)
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	413
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	414 case NGX_PROXY_PROTOCOL_AF_INET6:
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	415
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	416 if ((size_t) (end - buf) < sizeof(ngx_proxy_protocol_inet6_addrs_t)) {
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	417 return NULL;
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	418 }
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	419
7254 1fd992589ffe Core: fixed build, broken by 63e91f263a49. Vladimir Homutov <vl@nginx.com> parents: 7253 diff changeset	420 in6 = (ngx_proxy_protocol_inet6_addrs_t *) buf;
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	421
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	422 src_sockaddr.sockaddr_in6.sin6_family = AF_INET6;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	423 src_sockaddr.sockaddr_in6.sin6_port = 0;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	424 memcpy(&src_sockaddr.sockaddr_in6.sin6_addr, in6->src_addr, 16);
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	425
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	426 dst_sockaddr.sockaddr_in6.sin6_family = AF_INET6;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	427 dst_sockaddr.sockaddr_in6.sin6_port = 0;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	428 memcpy(&dst_sockaddr.sockaddr_in6.sin6_addr, in6->dst_addr, 16);
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	429
7590 06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	430 pp->src_port = ngx_proxy_protocol_parse_uint16(in6->src_port);
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	431 pp->dst_port = ngx_proxy_protocol_parse_uint16(in6->dst_port);
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	432
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	433 socklen = sizeof(struct sockaddr_in6);
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	434
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	435 buf += sizeof(ngx_proxy_protocol_inet6_addrs_t);
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	436
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	437 break;
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	438
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	439 #endif
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	440
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	441 default:
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	442 ngx_log_debug1(NGX_LOG_DEBUG_CORE, c->log, 0,
7253 63e91f263a49 Core: revised the PROXY protocol v2 code. Ruslan Ermilov <ru@nginx.com> parents: 7252 diff changeset	443 "PROXY protocol v2 unsupported address family %ui",
7252 7bdab16c55f1 Core: style. Vladimir Homutov <vl@nginx.com> parents: 7251 diff changeset	444 family);
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	445 return end;
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	446 }
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	447
7590 06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	448 pp->src_addr.data = ngx_pnalloc(c->pool, NGX_SOCKADDR_STRLEN);
06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	449 if (pp->src_addr.data == NULL) {
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	450 return NULL;
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	451 }
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	452
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	453 pp->src_addr.len = ngx_sock_ntop(&src_sockaddr.sockaddr, socklen,
7590 06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	454 pp->src_addr.data, NGX_SOCKADDR_STRLEN, 0);
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	455
7591 89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	456 pp->dst_addr.data = ngx_pnalloc(c->pool, NGX_SOCKADDR_STRLEN);
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	457 if (pp->dst_addr.data == NULL) {
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	458 return NULL;
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	459 }
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	460
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	461 pp->dst_addr.len = ngx_sock_ntop(&dst_sockaddr.sockaddr, socklen,
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	462 pp->dst_addr.data, NGX_SOCKADDR_STRLEN, 0);
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	463
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	464 ngx_log_debug4(NGX_LOG_DEBUG_CORE, c->log, 0,
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	465 "PROXY protocol v2 src: %V %d, dst: %V %d",
89adf49fe76a Parsing server PROXY protocol address and port (ticket #1206). Roman Arutyunyan <arut@nginx.com> parents: 7590 diff changeset	466 &pp->src_addr, pp->src_port, &pp->dst_addr, pp->dst_port);
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	467
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	468 if (buf < end) {
8072 cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	469 pp->tlvs.data = ngx_pnalloc(c->pool, end - buf);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	470 if (pp->tlvs.data == NULL) {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	471 return NULL;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	472 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	473
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	474 ngx_memcpy(pp->tlvs.data, buf, end - buf);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	475 pp->tlvs.len = end - buf;
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	476 }
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	477
7590 06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	478 c->proxy_protocol = pp;
06b01840bd42 Core: moved PROXY protocol fields out of ngx_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 7254 diff changeset	479
7251 416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	480 return end;
416953ef0428 Core: added processing of version 2 of the PROXY protocol. Vladimir Homutov <vl@nginx.com> parents: 6593 diff changeset	481 }
8072 cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	482
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	483
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	484 ngx_int_t
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	485 ngx_proxy_protocol_get_tlv(ngx_connection_t c, ngx_str_t name,
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	486 ngx_str_t *value)
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	487 {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	488 u_char *p;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	489 size_t n;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	490 uint32_t verify;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	491 ngx_str_t ssl, *tlvs;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	492 ngx_int_t rc, type;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	493 ngx_proxy_protocol_tlv_ssl_t *tlv_ssl;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	494 ngx_proxy_protocol_tlv_entry_t *te;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	495
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	496 if (c->proxy_protocol == NULL) {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	497 return NGX_DECLINED;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	498 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	499
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	500 ngx_log_debug1(NGX_LOG_DEBUG_CORE, c->log, 0,
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	501 "PROXY protocol v2 get tlv \"%V\"", name);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	502
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	503 te = ngx_proxy_protocol_tlv_entries;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	504 tlvs = &c->proxy_protocol->tlvs;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	505
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	506 p = name->data;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	507 n = name->len;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	508
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	509 if (n >= 4 && p[0] == 's' && p[1] == 's' && p[2] == 'l' && p[3] == '_') {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	510
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	511 rc = ngx_proxy_protocol_lookup_tlv(c, tlvs, 0x20, &ssl);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	512 if (rc != NGX_OK) {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	513 return rc;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	514 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	515
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	516 if (ssl.len < sizeof(ngx_proxy_protocol_tlv_ssl_t)) {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	517 return NGX_ERROR;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	518 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	519
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	520 p += 4;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	521 n -= 4;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	522
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	523 if (n == 6 && ngx_strncmp(p, "verify", 6) == 0) {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	524
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	525 tlv_ssl = (ngx_proxy_protocol_tlv_ssl_t *) ssl.data;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	526 verify = ngx_proxy_protocol_parse_uint32(tlv_ssl->verify);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	527
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	528 value->data = ngx_pnalloc(c->pool, NGX_INT32_LEN);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	529 if (value->data == NULL) {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	530 return NGX_ERROR;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	531 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	532
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	533 value->len = ngx_sprintf(value->data, "%uD", verify)
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	534 - value->data;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	535 return NGX_OK;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	536 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	537
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	538 ssl.data += sizeof(ngx_proxy_protocol_tlv_ssl_t);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	539 ssl.len -= sizeof(ngx_proxy_protocol_tlv_ssl_t);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	540
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	541 te = ngx_proxy_protocol_tlv_ssl_entries;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	542 tlvs = &ssl;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	543 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	544
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	545 if (n >= 2 && p[0] == '0' && p[1] == 'x') {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	546
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	547 type = ngx_hextoi(p + 2, n - 2);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	548 if (type == NGX_ERROR) {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	549 ngx_log_error(NGX_LOG_ERR, c->log, 0,
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	550 "invalid PROXY protocol TLV \"%V\"", name);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	551 return NGX_ERROR;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	552 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	553
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	554 return ngx_proxy_protocol_lookup_tlv(c, tlvs, type, value);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	555 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	556
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	557 for ( /* void */ ; te->type; te++) {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	558 if (te->name.len == n && ngx_strncmp(te->name.data, p, n) == 0) {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	559 return ngx_proxy_protocol_lookup_tlv(c, tlvs, te->type, value);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	560 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	561 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	562
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	563 ngx_log_error(NGX_LOG_ERR, c->log, 0,
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	564 "unknown PROXY protocol TLV \"%V\"", name);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	565
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	566 return NGX_DECLINED;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	567 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	568
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	569
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	570 static ngx_int_t
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	571 ngx_proxy_protocol_lookup_tlv(ngx_connection_t c, ngx_str_t tlvs,
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	572 ngx_uint_t type, ngx_str_t *value)
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	573 {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	574 u_char *p;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	575 size_t n, len;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	576 ngx_proxy_protocol_tlv_t *tlv;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	577
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	578 ngx_log_debug1(NGX_LOG_DEBUG_CORE, c->log, 0,
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	579 "PROXY protocol v2 lookup tlv:%02xi", type);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	580
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	581 p = tlvs->data;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	582 n = tlvs->len;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	583
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	584 while (n) {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	585 if (n < sizeof(ngx_proxy_protocol_tlv_t)) {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	586 ngx_log_error(NGX_LOG_ERR, c->log, 0, "broken PROXY protocol TLV");
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	587 return NGX_ERROR;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	588 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	589
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	590 tlv = (ngx_proxy_protocol_tlv_t *) p;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	591 len = ngx_proxy_protocol_parse_uint16(tlv->len);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	592
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	593 p += sizeof(ngx_proxy_protocol_tlv_t);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	594 n -= sizeof(ngx_proxy_protocol_tlv_t);
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	595
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	596 if (n < len) {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	597 ngx_log_error(NGX_LOG_ERR, c->log, 0, "broken PROXY protocol TLV");
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	598 return NGX_ERROR;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	599 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	600
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	601 if (tlv->type == type) {
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	602 value->data = p;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	603 value->len = len;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	604 return NGX_OK;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	605 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	606
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	607 p += len;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	608 n -= len;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	609 }
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	610
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	611 return NGX_DECLINED;
cca4c8a715de PROXY protocol v2 TLV variables. Roman Arutyunyan <arut@nginx.com> parents: 8071 diff changeset	612 }

Mercurial > hg > nginx

annotate src/core/ngx_proxy_protocol.c @ 9045:c6580dce98a8 quic