Mercurial > hg > nginx-tests

comparison stream_access.t @ 952:e9064d691790

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Tests: converted tests to run in parallel.
author Andrey Zelenkov <zelenkov@nginx.com>
date Tue, 21 Jun 2016 16:39:13 +0300
parents 25bf03642a45
children 882267679006
comparison
equal deleted inserted replaced
951:9361c7eddfc1 952:e9064d691790
34 events { 34 events {
35 } 35 }
36 36
37 stream { 37 stream {
38 server { 38 server {
39 listen 127.0.0.1:8082; 39 listen 127.0.0.1:%%PORT_2%%;
40 proxy_pass [::1]:8080; 40 proxy_pass [::1]:%%PORT_0%%;
41 } 41 }
42 42
43 server { 43 server {
44 listen 127.0.0.1:8083; 44 listen 127.0.0.1:%%PORT_3%%;
45 proxy_pass unix:%%TESTDIR%%/unix.sock.0; 45 proxy_pass unix:%%TESTDIR%%/unix.sock.0;
46 } 46 }
47 47
48 server { 48 server {
49 listen 127.0.0.1:8085; 49 listen 127.0.0.1:%%PORT_5%%;
50 proxy_pass [::1]:8081; 50 proxy_pass [::1]:%%PORT_1%%;
51 } 51 }
52 52
53 server { 53 server {
54 listen 127.0.0.1:8086; 54 listen 127.0.0.1:%%PORT_6%%;
55 proxy_pass unix:%%TESTDIR%%/unix.sock.1; 55 proxy_pass unix:%%TESTDIR%%/unix.sock.1;
56 } 56 }
57 57
58 server { 58 server {
59 listen 127.0.0.1:8088; 59 listen 127.0.0.1:%%PORT_8%%;
60 proxy_pass [::1]:8082; 60 proxy_pass [::1]:%%PORT_2%%;
61 } 61 }
62 62
63 server { 63 server {
64 listen 127.0.0.1:8089; 64 listen 127.0.0.1:%%PORT_9%%;
65 proxy_pass unix:%%TESTDIR%%/unix.sock.2; 65 proxy_pass unix:%%TESTDIR%%/unix.sock.2;
66 } 66 }
67 67
68 server { 68 server {
69 listen 127.0.0.1:8091; 69 listen 127.0.0.1:%%PORT_11%%;
70 proxy_pass [::1]:8083; 70 proxy_pass [::1]:%%PORT_3%%;
71 } 71 }
72 72
73 server { 73 server {
74 listen 127.0.0.1:8092; 74 listen 127.0.0.1:%%PORT_12%%;
75 proxy_pass unix:%%TESTDIR%%/unix.sock.3; 75 proxy_pass unix:%%TESTDIR%%/unix.sock.3;
76 } 76 }
77 77
78 server { 78 server {
79 listen 127.0.0.1:8094; 79 listen 127.0.0.1:%%PORT_14%%;
80 proxy_pass [::1]:8084; 80 proxy_pass [::1]:%%PORT_4%%;
81 } 81 }
82 82
83 server { 83 server {
84 listen 127.0.0.1:8095; 84 listen 127.0.0.1:%%PORT_15%%;
85 proxy_pass unix:%%TESTDIR%%/unix.sock.4; 85 proxy_pass unix:%%TESTDIR%%/unix.sock.4;
86 } 86 }
87 87
88 server { 88 server {
89 listen 127.0.0.1:8097; 89 listen 127.0.0.1:%%PORT_17%%;
90 proxy_pass [::1]:8085; 90 proxy_pass [::1]:%%PORT_5%%;
91 } 91 }
92 92
93 server { 93 server {
94 listen 127.0.0.1:8098; 94 listen 127.0.0.1:%%PORT_18%%;
95 proxy_pass unix:%%TESTDIR%%/unix.sock.5; 95 proxy_pass unix:%%TESTDIR%%/unix.sock.5;
96 } 96 }
97 97
98 server { 98 server {
99 listen 127.0.0.1:8081; 99 listen 127.0.0.1:%%PORT_1%%;
100 listen [::1]:8080; 100 listen [::1]:%%PORT_0%%;
101 listen unix:%%TESTDIR%%/unix.sock.0; 101 listen unix:%%TESTDIR%%/unix.sock.0;
102 proxy_pass 127.0.0.1:8080; 102 proxy_pass 127.0.0.1:%%PORT_0%%;
103 allow all; 103 allow all;
104 } 104 }
105 105
106 server { 106 server {
107 listen 127.0.0.1:8084; 107 listen 127.0.0.1:%%PORT_4%%;
108 listen [::1]:8081; 108 listen [::1]:%%PORT_1%%;
109 listen unix:%%TESTDIR%%/unix.sock.1; 109 listen unix:%%TESTDIR%%/unix.sock.1;
110 proxy_pass 127.0.0.1:8080; 110 proxy_pass 127.0.0.1:%%PORT_0%%;
111 deny all; 111 deny all;
112 } 112 }
113 113
114 server { 114 server {
115 listen 127.0.0.1:8087; 115 listen 127.0.0.1:%%PORT_7%%;
116 listen [::1]:8082; 116 listen [::1]:%%PORT_2%%;
117 listen unix:%%TESTDIR%%/unix.sock.2; 117 listen unix:%%TESTDIR%%/unix.sock.2;
118 proxy_pass 127.0.0.1:8080; 118 proxy_pass 127.0.0.1:%%PORT_0%%;
119 allow unix:; 119 allow unix:;
120 } 120 }
121 121
122 server { 122 server {
123 listen 127.0.0.1:8090; 123 listen 127.0.0.1:%%PORT_10%%;
124 listen [::1]:8083; 124 listen [::1]:%%PORT_3%%;
125 listen unix:%%TESTDIR%%/unix.sock.3; 125 listen unix:%%TESTDIR%%/unix.sock.3;
126 proxy_pass 127.0.0.1:8080; 126 proxy_pass 127.0.0.1:%%PORT_0%%;
127 deny 127.0.0.1; 127 deny 127.0.0.1;
128 } 128 }
129 129
130 server { 130 server {
131 listen 127.0.0.1:8093; 131 listen 127.0.0.1:%%PORT_13%%;
132 listen [::1]:8084; 132 listen [::1]:%%PORT_4%%;
133 listen unix:%%TESTDIR%%/unix.sock.4; 133 listen unix:%%TESTDIR%%/unix.sock.4;
134 proxy_pass 127.0.0.1:8080; 134 proxy_pass 127.0.0.1:%%PORT_0%%;
135 deny ::1; 135 deny ::1;
136 } 136 }
137 137
138 server { 138 server {
139 listen 127.0.0.1:8096; 139 listen 127.0.0.1:%%PORT_16%%;
140 listen [::1]:8085; 140 listen [::1]:%%PORT_5%%;
141 listen unix:%%TESTDIR%%/unix.sock.5; 141 listen unix:%%TESTDIR%%/unix.sock.5;
142 proxy_pass 127.0.0.1:8080; 142 proxy_pass 127.0.0.1:%%PORT_0%%;
143 deny unix:; 143 deny unix:;
144 } 144 }
145 } 145 }
146 146
147 EOF 147 EOF
148 148
149 $t->try_run('no inet6 support')->plan(18); 149 $t->try_run('no inet6 support')->plan(18);
150 $t->run_daemon(\&stream_daemon); 150 $t->run_daemon(\&stream_daemon);
151 $t->waitforsocket('127.0.0.1:8080'); 151 $t->waitforsocket('127.0.0.1:' . port(0));
152 152
153 ############################################################################### 153 ###############################################################################
154 154
155 my $str = 'SEE-THIS'; 155 my $str = 'SEE-THIS';
156 156
157 # allow all 157 # allow all
158 158
159 is(stream('127.0.0.1:8081')->io($str), $str, 'inet allow all'); 159 is(stream('127.0.0.1:' . port(1))->io($str), $str, 'inet allow all');
160 is(stream('127.0.0.1:8082')->io($str), $str, 'inet6 allow all'); 160 is(stream('127.0.0.1:' . port(2))->io($str), $str, 'inet6 allow all');
161 is(stream('127.0.0.1:8083')->io($str), $str, 'unix allow all'); 161 is(stream('127.0.0.1:' . port(3))->io($str), $str, 'unix allow all');
162 162
163 # deny all 163 # deny all
164 164
165 is(stream('127.0.0.1:8084')->io($str), '', 'inet deny all'); 165 is(stream('127.0.0.1:' . port(4))->io($str), '', 'inet deny all');
166 is(stream('127.0.0.1:8085')->io($str), '', 'inet6 deny all'); 166 is(stream('127.0.0.1:' . port(5))->io($str), '', 'inet6 deny all');
167 is(stream('127.0.0.1:8086')->io($str), '', 'unix deny all'); 167 is(stream('127.0.0.1:' . port(6))->io($str), '', 'unix deny all');
168 168
169 # allow unix 169 # allow unix
170 170
171 is(stream('127.0.0.1:8087')->io($str), $str, 'inet allow unix'); 171 is(stream('127.0.0.1:' . port(7))->io($str), $str, 'inet allow unix');
172 is(stream('127.0.0.1:8088')->io($str), $str, 'inet6 allow unix'); 172 is(stream('127.0.0.1:' . port(8))->io($str), $str, 'inet6 allow unix');
173 is(stream('127.0.0.1:8089')->io($str), $str, 'unix allow unix'); 173 is(stream('127.0.0.1:' . port(9))->io($str), $str, 'unix allow unix');
174 174
175 # deny inet 175 # deny inet
176 176
177 is(stream('127.0.0.1:8090')->io($str), '', 'inet deny inet'); 177 is(stream('127.0.0.1:' . port(10))->io($str), '', 'inet deny inet');
178 is(stream('127.0.0.1:8091')->io($str), $str, 'inet6 deny inet'); 178 is(stream('127.0.0.1:' . port(11))->io($str), $str, 'inet6 deny inet');
179 is(stream('127.0.0.1:8092')->io($str), $str, 'unix deny inet'); 179 is(stream('127.0.0.1:' . port(12))->io($str), $str, 'unix deny inet');
180 180
181 # deny inet6 181 # deny inet6
182 182
183 is(stream('127.0.0.1:8093')->io($str), $str, 'inet deny inet6'); 183 is(stream('127.0.0.1:' . port(13))->io($str), $str, 'inet deny inet6');
184 is(stream('127.0.0.1:8094')->io($str), '', 'inet6 deny inet6'); 184 is(stream('127.0.0.1:' . port(14))->io($str), '', 'inet6 deny inet6');
185 is(stream('127.0.0.1:8095')->io($str), $str, 'unix deny inet6'); 185 is(stream('127.0.0.1:' . port(15))->io($str), $str, 'unix deny inet6');
186 186
187 # deny unix 187 # deny unix
188 188
189 is(stream('127.0.0.1:8096')->io($str), $str, 'inet deny unix'); 189 is(stream('127.0.0.1:' . port(16))->io($str), $str, 'inet deny unix');
190 is(stream('127.0.0.1:8097')->io($str), $str, 'inet6 deny unix'); 190 is(stream('127.0.0.1:' . port(17))->io($str), $str, 'inet6 deny unix');
191 is(stream('127.0.0.1:8098')->io($str), '', 'unix deny unix'); 191 is(stream('127.0.0.1:' . port(18))->io($str), '', 'unix deny unix');
192 192
193 ############################################################################### 193 ###############################################################################
194 194
195 sub stream_daemon { 195 sub stream_daemon {
196 my $server = IO::Socket::INET->new( 196 my $server = IO::Socket::INET->new(
197 Proto => 'tcp', 197 Proto => 'tcp',
198 LocalAddr => '127.0.0.1:8080', 198 LocalAddr => '127.0.0.1:' . port(0),
199 Listen => 5, 199 Listen => 5,
200 Reuse => 1 200 Reuse => 1
201 ) 201 )
202 or die "Can't create listening socket: $!\n"; 202 or die "Can't create listening socket: $!\n";
203 203