Mercurial > hg > nginx-tests

comparison stream_udp_upstream.t @ 1237:e4974af3fb12

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Tests: adjusted udp ports to match allocated ports range.
author Andrey Zelenkov <zelenkov@nginx.com>
date Wed, 13 Sep 2017 19:04:25 +0300
parents ba26845f53ff
children 766bcbb632ee
comparison
equal deleted inserted replaced
1236:93f749c1d5c5 1237:e4974af3fb12
39 39
40 log_format bytes $upstream_addr! 40 log_format bytes $upstream_addr!
41 $upstream_bytes_sent!$upstream_bytes_received; 41 $upstream_bytes_sent!$upstream_bytes_received;
42 42
43 upstream u { 43 upstream u {
44 server 127.0.0.1:%%PORT_8084_UDP%%; 44 server 127.0.0.1:%%PORT_8984_UDP%%;
45 server 127.0.0.1:%%PORT_8085_UDP%%; 45 server 127.0.0.1:%%PORT_8985_UDP%%;
46 } 46 }
47 47
48 upstream u2 { 48 upstream u2 {
49 server 127.0.0.1:%%PORT_8086_UDP%% down; 49 server 127.0.0.1:%%PORT_8986_UDP%% down;
50 server 127.0.0.1:%%PORT_8086_UDP%%; 50 server 127.0.0.1:%%PORT_8986_UDP%%;
51 server 127.0.0.1:%%PORT_8084_UDP%%; 51 server 127.0.0.1:%%PORT_8984_UDP%%;
52 server 127.0.0.1:%%PORT_8085_UDP%%; 52 server 127.0.0.1:%%PORT_8985_UDP%%;
53 } 53 }
54 54
55 upstream u3 { 55 upstream u3 {
56 server 127.0.0.1:%%PORT_8084_UDP%%; 56 server 127.0.0.1:%%PORT_8984_UDP%%;
57 server 127.0.0.1:%%PORT_8085_UDP%% weight=2; 57 server 127.0.0.1:%%PORT_8985_UDP%% weight=2;
58 } 58 }
59 59
60 upstream u4 { 60 upstream u4 {
61 server 127.0.0.1:%%PORT_8086_UDP%%; 61 server 127.0.0.1:%%PORT_8986_UDP%%;
62 server 127.0.0.1:%%PORT_8084_UDP%% backup; 62 server 127.0.0.1:%%PORT_8984_UDP%% backup;
63 } 63 }
64 64
65 server { 65 server {
66 listen 127.0.0.1:%%PORT_8080_UDP%% udp; 66 listen 127.0.0.1:%%PORT_8980_UDP%% udp;
67 proxy_pass u; 67 proxy_pass u;
68 } 68 }
69 69
70 server { 70 server {
71 listen 127.0.0.1:%%PORT_8081_UDP%% udp; 71 listen 127.0.0.1:%%PORT_8981_UDP%% udp;
72 proxy_pass u2; 72 proxy_pass u2;
73 } 73 }
74 74
75 server { 75 server {
76 listen 127.0.0.1:%%PORT_8082_UDP%% udp; 76 listen 127.0.0.1:%%PORT_8982_UDP%% udp;
77 proxy_pass u3; 77 proxy_pass u3;
78 } 78 }
79 79
80 server { 80 server {
81 listen 127.0.0.1:%%PORT_8083_UDP%% udp; 81 listen 127.0.0.1:%%PORT_8983_UDP%% udp;
82 proxy_pass u4; 82 proxy_pass u4;
83 access_log %%TESTDIR%%/u.log bytes; 83 access_log %%TESTDIR%%/u.log bytes;
84 } 84 }
85 } 85 }
86 86
87 EOF 87 EOF
88 88
89 $t->run_daemon(\&udp_daemon, port(8084), $t); 89 $t->run_daemon(\&udp_daemon, port(8984), $t);
90 $t->run_daemon(\&udp_daemon, port(8085), $t); 90 $t->run_daemon(\&udp_daemon, port(8985), $t);
91 $t->try_run('no stream access_log')->plan(5); 91 $t->try_run('no stream access_log')->plan(5);
92 92
93 $t->waitforfile($t->testdir . '/' . port(8084)); 93 $t->waitforfile($t->testdir . '/' . port(8984));
94 $t->waitforfile($t->testdir . '/' . port(8085)); 94 $t->waitforfile($t->testdir . '/' . port(8985));
95 95
96 ############################################################################### 96 ###############################################################################
97 97
98 my @ports = my ($port4, $port5, $port6) = (port(8084), port(8085), port(8086)); 98 my @ports = my ($port4, $port5, $port6) = (port(8984), port(8985), port(8986));
99 99
100 is(many(10, port(8080)), "$port4: 5, $port5: 5", 'balanced'); 100 is(many(10, port(8980)), "$port4: 5, $port5: 5", 'balanced');
101 is(many(10, port(8081)), "$port4: 5, $port5: 5", 'failures'); 101 is(many(10, port(8981)), "$port4: 5, $port5: 5", 'failures');
102 is(many(9, port(8082)), "$port4: 3, $port5: 6", 'weight'); 102 is(many(9, port(8982)), "$port4: 3, $port5: 6", 'weight');
103 is(many(10, port(8083)), "$port4: 10", 'backup'); 103 is(many(10, port(8983)), "$port4: 10", 'backup');
104 104
105 $t->stop(); 105 $t->stop();
106 106
107 like($t->read_file('u.log'), qr/127.0.0.1:$port6, 127.0.0.1:$port4!1, 1!0, 4/, 107 like($t->read_file('u.log'), qr/127.0.0.1:$port6, 127.0.0.1:$port4!1, 1!0, 4/,
108 'per-upstream variables'); 108 'per-upstream variables');