Mercurial > hg > nginx-tests

comparison stream_realip.t @ 1055:8979f0d86c29

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Tests: reduced diff to stream_ssl_realip.t, no functional changes.
author Sergey Kandaurov <pluknet@nginx.com>
date Wed, 12 Oct 2016 17:38:11 +0300
parents 094e1247740f
children cf14cfe9ec8c
comparison
equal deleted inserted replaced
1054:9b8e13e2ee67 1055:8979f0d86c29
85 $t->try_run('no stream proxy_protocol and/or inet6 support')->plan(8); 85 $t->try_run('no stream proxy_protocol and/or inet6 support')->plan(8);
86 $t->waitforsocket('127.0.0.1:' . port(8081)); 86 $t->waitforsocket('127.0.0.1:' . port(8081));
87 87
88 ############################################################################### 88 ###############################################################################
89 89
90 is(stream('127.0.0.1:' . port(8083)) 90 is(pp_get(8083, "PROXY TCP4 192.0.2.1 192.0.2.2 1234 5678${CRLF}"),
91 ->io("PROXY TCP4 192.0.2.1 192.0.2.2 1234 5678${CRLF}"),
92 '192.0.2.1:1234', 'server'); 91 '192.0.2.1:1234', 'server');
93 92
94 is(stream('127.0.0.1:' . port(8084))->read(), ':', 'server off'); 93 is(stream('127.0.0.1:' . port(8084))->read(), ':', 'server off');
95 94
96 is(stream('127.0.0.1:' . port(8085)) 95 is(pp_get(8085, "PROXY TCP4 192.0.2.1 192.0.2.2 1234 5678${CRLF}close"),
97 ->io("PROXY TCP4 192.0.2.1 192.0.2.2 1234 5678${CRLF}close"),
98 'close', 'server payload'); 96 'close', 'server payload');
99 97
100 like(stream('127.0.0.1:' . port(8086)) 98 like(pp_get(8086, "PROXY TCP4 192.0.2.1 192.0.2.2 1234 5678${CRLF}"),
101 ->io("PROXY TCP4 192.0.2.1 192.0.2.2 1234 5678${CRLF}"),
102 qr/^(\Q127.0.0.1:\E\d+):\s+\1$/, 'server ipv6 realip - no match'); 99 qr/^(\Q127.0.0.1:\E\d+):\s+\1$/, 'server ipv6 realip - no match');
103 100
104 like(stream('127.0.0.1:' . port(8087)) 101 like(pp_get(8087, "PROXY TCP4 192.0.2.1 192.0.2.2 1234 5678${CRLF}"),
105 ->io("PROXY TCP4 192.0.2.1 192.0.2.2 1234 5678${CRLF}"),
106 qr/\Q192.0.2.1:1234:\E\s+\Q::1:\E\d+/, 'server ipv6 realip'); 102 qr/\Q192.0.2.1:1234:\E\s+\Q::1:\E\d+/, 'server ipv6 realip');
107 103
108 like(stream('127.0.0.1:' . port(8088)) 104 like(pp_get(8088, "PROXY TCP4 192.0.2.1 192.0.2.2 1234 5678${CRLF}"),
109 ->io("PROXY TCP4 192.0.2.1 192.0.2.2 1234 5678${CRLF}"),
110 qr/\Q192.0.2.1:1234:\E\s+\Q127.0.0.1:\E\d+/, 'server ipv4 realip'); 105 qr/\Q192.0.2.1:1234:\E\s+\Q127.0.0.1:\E\d+/, 'server ipv4 realip');
111 106
112 like(stream('127.0.0.1:' . port(8089)) 107 like(pp_get(8089, "PROXY TCP4 192.0.2.1 192.0.2.2 1234 5678${CRLF}"),
113 ->io("PROXY TCP4 192.0.2.1 192.0.2.2 1234 5678${CRLF}"),
114 qr/^(::1:\d+):\s+\1$/, 'server ipv4 realip - no match'); 108 qr/^(::1:\d+):\s+\1$/, 'server ipv4 realip - no match');
115 109
116 like(stream('127.0.0.1:' . port(8088)) 110 like(pp_get(8088, "PROXY UNKNOWN TCP4 192.0.2.1 192.0.2.2 1234 5678${CRLF}"),
117 ->io("PROXY UNKNOWN TCP4 192.0.2.1 192.0.2.2 1234 5678${CRLF}"),
118 qr/^(\Q127.0.0.1:\E\d+):\s+\1$/, 'server unknown'); 111 qr/^(\Q127.0.0.1:\E\d+):\s+\1$/, 'server unknown');
112
113 ###############################################################################
114
115 sub pp_get {
116 my ($port, $proxy) = @_;
117 stream(PeerPort => port($port))->io($proxy);
118 }
119 119
120 ############################################################################### 120 ###############################################################################
121 121
122 sub stream_daemon { 122 sub stream_daemon {
123 my $server = IO::Socket::INET->new( 123 my $server = IO::Socket::INET->new(