comparison stream_tcp_nodelay.t @ 812:acec03d44976

Tests: close connection on last write in stream_tcp_nodelay.t.
author Andrey Zelenkov <zelenkov@nginx.com>
date Thu, 17 Dec 2015 20:40:48 +0300
parents 824754da4afc
children 77359b849cd5
comparison
equal deleted inserted replaced
811:dba758c045ed 812:acec03d44976
59 $t->run_daemon(\&stream_daemon); 59 $t->run_daemon(\&stream_daemon);
60 $t->run()->waitforsocket('127.0.0.1:8080'); 60 $t->run()->waitforsocket('127.0.0.1:8080');
61 61
62 ############################################################################### 62 ###############################################################################
63 63
64 my $str = '1234567890' x 10; 64 my $str = '1234567890' x 10 . 'F';
65 65
66 is(stream_get($str, '127.0.0.1:8081'), $str, 'tcp_nodelay off'); 66 is(stream_get($str, '127.0.0.1:8081'), $str, 'tcp_nodelay off');
67 is(stream_get($str, '127.0.0.1:8082'), $str, 'tcp_nodelay on'); 67 is(stream_get($str, '127.0.0.1:8082'), $str, 'tcp_nodelay on');
68 68
69 ############################################################################### 69 ###############################################################################
162 162
163 $client->sysread(my $buffer, 65536) or return 1; 163 $client->sysread(my $buffer, 65536) or return 1;
164 164
165 log2i("$client $buffer"); 165 log2i("$client $buffer");
166 166
167 my $close = $buffer =~ /F/;
168
167 log2o("$client $buffer"); 169 log2o("$client $buffer");
168 170
169 $client->syswrite($buffer); 171 $client->syswrite($buffer);
170 172
171 return 0; 173 return $close;
172 } 174 }
173 175
174 sub log2i { Test::Nginx::log_core('|| <<', @_); } 176 sub log2i { Test::Nginx::log_core('|| <<', @_); }
175 sub log2o { Test::Nginx::log_core('|| >>', @_); } 177 sub log2o { Test::Nginx::log_core('|| >>', @_); }
176 sub log2c { Test::Nginx::log_core('||', @_); } 178 sub log2c { Test::Nginx::log_core('||', @_); }