Mercurial > hg > nginx-tests

comparison stream_proxy_next_upstream.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 77359b849cd5
children 882267679006
comparison
equal deleted inserted replaced
951:9361c7eddfc1 952:e9064d691790
34 events { 34 events {
35 } 35 }
36 36
37 stream { 37 stream {
38 upstream u { 38 upstream u {
39 server 127.0.0.1:8087 max_fails=0; 39 server 127.0.0.1:%%PORT_3%% max_fails=0;
40 server 127.0.0.1:8088 max_fails=0; 40 server 127.0.0.1:%%PORT_4%% max_fails=0;
41 server 127.0.0.1:8089 backup; 41 server 127.0.0.1:%%PORT_5%% backup;
42 } 42 }
43 43
44 upstream u2 { 44 upstream u2 {
45 server 127.0.0.1:8087; 45 server 127.0.0.1:%%PORT_3%%;
46 server 127.0.0.1:8089 backup; 46 server 127.0.0.1:%%PORT_5%% backup;
47 } 47 }
48 48
49 proxy_connect_timeout 1s; 49 proxy_connect_timeout 1s;
50 50
51 server { 51 server {
52 listen 127.0.0.1:8081; 52 listen 127.0.0.1:%%PORT_0%%;
53 proxy_pass u; 53 proxy_pass u;
54 proxy_next_upstream off; 54 proxy_next_upstream off;
55 } 55 }
56 56
57 server { 57 server {
58 listen 127.0.0.1:8082; 58 listen 127.0.0.1:%%PORT_1%%;
59 proxy_pass u2; 59 proxy_pass u2;
60 proxy_next_upstream on; 60 proxy_next_upstream on;
61 } 61 }
62 62
63 server { 63 server {
64 listen 127.0.0.1:8083; 64 listen 127.0.0.1:%%PORT_2%%;
65 proxy_pass u; 65 proxy_pass u;
66 proxy_next_upstream on; 66 proxy_next_upstream on;
67 proxy_next_upstream_tries 2; 67 proxy_next_upstream_tries 2;
68 } 68 }
69 } 69 }
70 70
71 EOF 71 EOF
72 72
73 $t->run_daemon(\&stream_daemon); 73 $t->run_daemon(\&stream_daemon);
74 $t->run()->waitforsocket('127.0.0.1:8089'); 74 $t->run()->waitforsocket('127.0.0.1:' . port(5));
75 75
76 ############################################################################### 76 ###############################################################################
77 77
78 is(stream('127.0.0.1:8081')->io('.'), '', 'next off'); 78 is(stream('127.0.0.1:' . port(0))->io('.'), '', 'next off');
79 is(stream('127.0.0.1:8082')->io('.'), 'SEE-THIS', 'next on'); 79 is(stream('127.0.0.1:' . port(1))->io('.'), 'SEE-THIS', 'next on');
80 80
81 # make sure backup is not tried 81 # make sure backup is not tried
82 82
83 is(stream('127.0.0.1:8083')->io('.'), '', 'next tries'); 83 is(stream('127.0.0.1:' . port(2))->io('.'), '', 'next tries');
84 84
85 ############################################################################### 85 ###############################################################################
86 86
87 sub stream_daemon { 87 sub stream_daemon {
88 my $server = IO::Socket::INET->new( 88 my $server = IO::Socket::INET->new(
89 Proto => 'tcp', 89 Proto => 'tcp',
90 LocalHost => '127.0.0.1:8089', 90 LocalHost => '127.0.0.1:' . port(5),
91 Listen => 5, 91 Listen => 5,
92 Reuse => 1 92 Reuse => 1
93 ) 93 )
94 or die "Can't create listening socket: $!\n"; 94 or die "Can't create listening socket: $!\n";
95 95