Mercurial > hg > nginx-tests

comparison stream_tcp_nodelay.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 f4189a38c3a4
children 882267679006
comparison
equal deleted inserted replaced
951:9361c7eddfc1 952:e9064d691790
42 stream { 42 stream {
43 proxy_buffer_size 1; 43 proxy_buffer_size 1;
44 tcp_nodelay off; 44 tcp_nodelay off;
45 45
46 server { 46 server {
47 listen 127.0.0.1:8081; 47 listen 127.0.0.1:%%PORT_1%%;
48 proxy_pass 127.0.0.1:8080; 48 proxy_pass 127.0.0.1:%%PORT_0%%;
49 } 49 }
50 50
51 server { 51 server {
52 tcp_nodelay on; 52 tcp_nodelay on;
53 listen 127.0.0.1:8082; 53 listen 127.0.0.1:%%PORT_2%%;
54 proxy_pass 127.0.0.1:8080; 54 proxy_pass 127.0.0.1:%%PORT_0%%;
55 } 55 }
56 } 56 }
57 57
58 EOF 58 EOF
59 59
60 $t->run_daemon(\&stream_daemon); 60 $t->run_daemon(\&stream_daemon);
61 $t->run()->waitforsocket('127.0.0.1:8080'); 61 $t->run()->waitforsocket('127.0.0.1:' . port(0));
62 62
63 ############################################################################### 63 ###############################################################################
64 64
65 my $str = '1234567890' x 10 . 'F'; 65 my $str = '1234567890' x 10 . 'F';
66 my $length = length($str); 66 my $length = length($str);
67 67
68 is(stream('127.0.0.1:8081')->io($str, length => $length), $str, 68 is(stream('127.0.0.1:' . port(1))->io($str, length => $length), $str,
69 'tcp_nodelay off'); 69 'tcp_nodelay off');
70 is(stream('127.0.0.1:8082')->io($str, length => $length), $str, 70 is(stream('127.0.0.1:' . port(2))->io($str, length => $length), $str,
71 'tcp_nodelay on'); 71 'tcp_nodelay on');
72 72
73 ############################################################################### 73 ###############################################################################
74 74
75 sub stream_daemon { 75 sub stream_daemon {
76 my $server = IO::Socket::INET->new( 76 my $server = IO::Socket::INET->new(
77 Proto => 'tcp', 77 Proto => 'tcp',
78 LocalAddr => '127.0.0.1:8080', 78 LocalAddr => '127.0.0.1:' . port(0),
79 Listen => 5, 79 Listen => 5,
80 Reuse => 1 80 Reuse => 1
81 ) 81 )
82 or die "Can't create listening socket: $!\n"; 82 or die "Can't create listening socket: $!\n";
83 83