Mercurial > hg > nginx-tests
annotate grpc_ssl.t @ 1897:38f1fd9ca3e6
Tests: unbreak reading new stderr data after eof.
Tests don't expect to stop reading redirected stderr when end of file is
reached, but rather to read new data being appended, similar to "tail -f".
The behaviour is found changed in Ubuntu 23.04's Perl 5.36, which applies
the upstream patch [1] expected for inclusion in the upcoming Perl 5.38.
The fix is to clear the filehandle's error state to continue reading.
[1] https://github.com/Perl/perl5/commit/80c1f1e45e8e
Updated mail_error_log.t and stream_error_log.t for consistency.
| author | Sergey Kandaurov <pluknet@nginx.com> |
|---|---|
| date | Mon, 29 May 2023 17:27:11 +0400 |
| parents | 58951cf933e1 |
| children | 236d038dc04a |
| rev | line source |
|---|---|
| 1303 | 1 #!/usr/bin/perl |
| 2 | |
| 3 # (C) Sergey Kandaurov | |
| 4 # (C) Nginx, Inc. | |
| 5 | |
| 6 # Tests for grpc backend with ssl. | |
| 7 | |
| 8 ############################################################################### | |
| 9 | |
| 10 use warnings; | |
| 11 use strict; | |
| 12 | |
| 13 use Test::More; | |
| 14 | |
| 15 BEGIN { use FindBin; chdir($FindBin::Bin); } | |
| 16 | |
| 17 use lib 'lib'; | |
| 18 use Test::Nginx; | |
| 19 use Test::Nginx::HTTP2; | |
| 20 | |
| 21 ############################################################################### | |
| 22 | |
| 23 select STDERR; $| = 1; | |
| 24 select STDOUT; $| = 1; | |
| 25 | |
|
1312
6f95c0ed2335
Tests: removed proxy prerequisite from grpc tests.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1303
diff
changeset
|
26 my $t = Test::Nginx->new()->has(qw/http rewrite http_v2 grpc/) |
|
1860
58951cf933e1
Tests: added has_feature() test for SSL libraries.
Maxim Dounin <mdounin@mdounin.ru>
parents:
1748
diff
changeset
|
27 ->has(qw/upstream_keepalive http_ssl openssl:1.0.2/) |
|
58951cf933e1
Tests: added has_feature() test for SSL libraries.
Maxim Dounin <mdounin@mdounin.ru>
parents:
1748
diff
changeset
|
28 ->has_daemon('openssl') |
|
58951cf933e1
Tests: added has_feature() test for SSL libraries.
Maxim Dounin <mdounin@mdounin.ru>
parents:
1748
diff
changeset
|
29 ->write_file_expand('nginx.conf', <<'EOF')->plan(38); |
| 1303 | 30 |
| 31 %%TEST_GLOBALS%% | |
| 32 | |
| 33 daemon off; | |
| 34 | |
| 35 events { | |
| 36 } | |
| 37 | |
| 38 http { | |
| 39 %%TEST_GLOBALS_HTTP%% | |
| 40 | |
| 41 upstream u { | |
| 42 server 127.0.0.1:8081; | |
| 43 keepalive 1; | |
| 44 } | |
| 45 | |
| 46 server { | |
| 47 listen 127.0.0.1:8081 http2 ssl; | |
| 48 server_name localhost; | |
| 49 | |
| 50 ssl_certificate_key localhost.key; | |
| 51 ssl_certificate localhost.crt; | |
| 52 | |
|
1313
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
53 ssl_verify_client optional; |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
54 ssl_client_certificate client.crt; |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
55 |
|
1725
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
56 http2_body_preread_size 128k; |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
57 |
| 1303 | 58 location / { |
| 59 grpc_pass 127.0.0.1:8082; | |
| 60 add_header X-Connection $connection; | |
| 61 } | |
| 62 } | |
| 63 | |
| 64 server { | |
| 65 listen 127.0.0.1:8080 http2; | |
| 66 server_name localhost; | |
| 67 | |
|
1725
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
68 http2_body_preread_size 128k; |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
69 |
| 1303 | 70 location / { |
| 71 grpc_pass grpcs://127.0.0.1:8081; | |
|
1313
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
72 grpc_ssl_name localhost; |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
73 grpc_ssl_verify on; |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
74 grpc_ssl_trusted_certificate localhost.crt; |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
75 |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
76 grpc_ssl_certificate client.crt; |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
77 grpc_ssl_certificate_key client.key; |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
78 grpc_ssl_password_file password; |
| 1303 | 79 |
| 80 if ($arg_if) { | |
| 81 # nothing | |
| 82 } | |
| 83 | |
| 84 limit_except GET { | |
| 85 # nothing | |
| 86 } | |
| 87 } | |
| 88 | |
| 89 location /KeepAlive { | |
| 90 grpc_pass grpcs://u; | |
| 91 } | |
| 92 } | |
| 93 } | |
| 94 | |
| 95 EOF | |
| 96 | |
| 97 $t->write_file('openssl.conf', <<EOF); | |
| 98 [ req ] | |
|
1488
dbce8fb5f5f8
Tests: align with OpenSSL security level 2.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1415
diff
changeset
|
99 default_bits = 2048 |
| 1303 | 100 encrypt_key = no |
| 101 distinguished_name = req_distinguished_name | |
| 102 [ req_distinguished_name ] | |
| 103 EOF | |
| 104 | |
| 105 my $d = $t->testdir(); | |
| 106 | |
| 107 foreach my $name ('localhost') { | |
| 108 system('openssl req -x509 -new ' | |
| 109 . "-config $d/openssl.conf -subj /CN=$name/ " | |
| 110 . "-out $d/$name.crt -keyout $d/$name.key " | |
| 111 . ">>$d/openssl.out 2>&1") == 0 | |
| 112 or die "Can't create certificate for $name: $!\n"; | |
| 113 } | |
| 114 | |
|
1313
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
115 foreach my $name ('client') { |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
116 system("openssl genrsa -out $d/$name.key -passout pass:$name " |
|
1488
dbce8fb5f5f8
Tests: align with OpenSSL security level 2.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1415
diff
changeset
|
117 . "-aes128 2048 >>$d/openssl.out 2>&1") == 0 |
|
1313
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
118 or die "Can't create private key: $!\n"; |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
119 system('openssl req -x509 -new ' |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
120 . "-config $d/openssl.conf -subj /CN=$name/ " |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
121 . "-out $d/$name.crt " |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
122 . "-key $d/$name.key -passin pass:$name" |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
123 . ">>$d/openssl.out 2>&1") == 0 |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
124 or die "Can't create certificate for $name: $!\n"; |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
125 } |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
126 |
|
1323
6eb3dd2d4d5a
Tests: postponed grpc_ssl.t startup on win32, see eadd24ccfda1.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1321
diff
changeset
|
127 sleep 1 if $^O eq 'MSWin32'; |
|
6eb3dd2d4d5a
Tests: postponed grpc_ssl.t startup on win32, see eadd24ccfda1.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1321
diff
changeset
|
128 |
|
1313
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
129 $t->write_file('password', 'client'); |
|
cc2f17cd9677
Tests: very basic grpc ssl verify and passphrase tests added.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1312
diff
changeset
|
130 |
|
1381
97c8280de681
Tests: removed TODO and try_run() checks for legacy versions.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1378
diff
changeset
|
131 $t->run(); |
| 1303 | 132 |
| 133 ############################################################################### | |
| 134 | |
| 135 my $p = port(8082); | |
| 136 my $f = grpc(); | |
| 137 | |
| 138 my $frames = $f->{http_start}('/SayHello'); | |
| 139 my ($frame) = grep { $_->{type} eq "HEADERS" } @$frames; | |
| 140 is($frame->{flags}, 4, 'request - HEADERS flags'); | |
| 141 ok((my $sid = $frame->{sid}) % 2, 'request - HEADERS sid odd'); | |
| 142 is($frame->{headers}{':method'}, 'POST', 'request - method'); | |
| 143 is($frame->{headers}{':scheme'}, 'http', 'request - scheme'); | |
| 144 is($frame->{headers}{':path'}, '/SayHello', 'request - path'); | |
| 145 is($frame->{headers}{':authority'}, "127.0.0.1:$p", 'request - authority'); | |
| 146 is($frame->{headers}{'content-type'}, 'application/grpc', | |
| 147 'request - content type'); | |
| 148 is($frame->{headers}{te}, 'trailers', 'request - te'); | |
| 149 | |
| 150 $frames = $f->{data}('Hello'); | |
| 151 ($frame) = grep { $_->{type} eq "SETTINGS" } @$frames; | |
| 152 is($frame->{flags}, 1, 'request - SETTINGS ack'); | |
| 153 is($frame->{sid}, 0, 'request - SETTINGS sid'); | |
| 154 is($frame->{length}, 0, 'request - SETTINGS length'); | |
| 155 | |
| 156 ($frame) = grep { $_->{type} eq "DATA" } @$frames; | |
| 157 is($frame->{data}, 'Hello', 'request - DATA'); | |
| 158 is($frame->{length}, 5, 'request - DATA length'); | |
| 159 is($frame->{flags}, 1, 'request - DATA flags'); | |
| 160 is($frame->{sid}, $sid, 'request - DATA sid match'); | |
| 161 | |
| 162 $frames = $f->{http_end}(); | |
| 163 ($frame) = grep { $_->{type} eq "HEADERS" } @$frames; | |
| 164 is($frame->{flags}, 4, 'response - HEADERS flags'); | |
| 165 is($frame->{sid}, 1, 'response - HEADERS sid'); | |
| 166 is($frame->{headers}{':status'}, '200', 'response - status'); | |
| 167 is($frame->{headers}{'content-type'}, 'application/grpc', | |
| 168 'response - content type'); | |
| 169 ok($frame->{headers}{server}, 'response - server'); | |
| 170 ok($frame->{headers}{date}, 'response - date'); | |
| 171 ok(my $c = $frame->{headers}{'x-connection'}, 'response - connection'); | |
| 172 | |
| 173 ($frame) = grep { $_->{type} eq "DATA" } @$frames; | |
| 174 is($frame->{data}, 'Hello world', 'response - DATA'); | |
| 175 is($frame->{length}, 11, 'response - DATA length'); | |
| 176 is($frame->{flags}, 0, 'response - DATA flags'); | |
| 177 is($frame->{sid}, 1, 'response - DATA sid'); | |
| 178 | |
| 179 (undef, $frame) = grep { $_->{type} eq "HEADERS" } @$frames; | |
| 180 is($frame->{flags}, 5, 'response - trailers flags'); | |
| 181 is($frame->{sid}, 1, 'response - trailers sid'); | |
| 182 is($frame->{headers}{'grpc-message'}, '', 'response - trailers message'); | |
| 183 is($frame->{headers}{'grpc-status'}, '0', 'response - trailers status'); | |
| 184 | |
| 185 # next request is on a new backend connection, no sid incremented | |
| 186 | |
| 187 $f->{http_start}('/SayHello'); | |
| 188 $f->{data}('Hello'); | |
| 189 $frames = $f->{http_end}(); | |
| 190 ($frame) = grep { $_->{type} eq "HEADERS" } @$frames; | |
| 191 cmp_ok($frame->{headers}{'x-connection'}, '>', $c, 'response 2 - connection'); | |
| 192 | |
|
1725
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
193 # flow control |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
194 |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
195 $f->{http_start}('/FlowControl'); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
196 $frames = $f->{data_len}(('Hello' x 13000) . ('x' x 550), 65535); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
197 my $sum = eval join '+', map { $_->{type} eq "DATA" && $_->{length} } @$frames; |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
198 is($sum, 65535, 'flow control - iws length'); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
199 |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
200 $f->{update}(10); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
201 $f->{update_sid}(10); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
202 |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
203 $frames = $f->{data_len}(undef, 10); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
204 ($frame) = grep { $_->{type} eq "DATA" } @$frames; |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
205 is($frame->{length}, 10, 'flow control - update length'); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
206 is($frame->{flags}, 0, 'flow control - update flags'); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
207 |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
208 $f->{update_sid}(10); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
209 $f->{update}(10); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
210 |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
211 $frames = $f->{data_len}(undef, 5); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
212 ($frame) = grep { $_->{type} eq "DATA" } @$frames; |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
213 is($frame->{length}, 5, 'flow control - rest length'); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
214 is($frame->{flags}, 1, 'flow control - rest flags'); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
215 |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
216 $f->{http_end}(); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
217 |
| 1303 | 218 # upstream keepalive |
| 219 | |
| 220 $f->{http_start}('/KeepAlive'); | |
| 221 $f->{data}('Hello'); | |
| 222 $frames = $f->{http_end}(); | |
| 223 ($frame) = grep { $_->{type} eq "HEADERS" } @$frames; | |
| 224 ok($c = $frame->{headers}{'x-connection'}, 'keepalive - connection'); | |
| 225 | |
| 226 $f->{http_start}('/KeepAlive'); | |
| 227 $f->{data}('Hello'); | |
| 228 $frames = $f->{http_end}(); | |
| 229 ($frame) = grep { $_->{type} eq "HEADERS" } @$frames; | |
| 230 is($frame->{headers}{'x-connection'}, $c, 'keepalive - connection reuse'); | |
| 231 | |
| 232 ############################################################################### | |
| 233 | |
| 234 sub grpc { | |
| 235 my ($server, $client, $f, $s, $c, $sid, $uri); | |
| 236 | |
| 237 $server = IO::Socket::INET->new( | |
| 238 Proto => 'tcp', | |
| 239 LocalHost => '127.0.0.1', | |
| 240 LocalPort => $p, | |
| 241 Listen => 5, | |
| 242 Reuse => 1 | |
| 243 ) | |
| 244 or die "Can't create listening socket: $!\n"; | |
| 245 | |
| 246 $f->{http_start} = sub { | |
| 247 ($uri, my %extra) = @_; | |
| 248 my $body_more = 1 if $uri !~ /LongHeader/; | |
| 249 $s = Test::Nginx::HTTP2->new() if !defined $s; | |
| 250 $s->new_stream({ body_more => $body_more, headers => [ | |
| 251 { name => ':method', value => 'POST', mode => 0 }, | |
| 252 { name => ':scheme', value => 'http', mode => 0 }, | |
| 253 { name => ':path', value => $uri, }, | |
| 254 { name => ':authority', value => 'localhost' }, | |
| 255 { name => 'content-type', value => 'application/grpc' }, | |
| 256 { name => 'te', value => 'trailers', mode => 2 }]}); | |
| 257 | |
| 258 if (!$extra{reuse}) { | |
|
1321
351b95be742b
Tests: fixed grpc tests hang in accept() on internal nginx error.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1313
diff
changeset
|
259 eval { |
|
351b95be742b
Tests: fixed grpc tests hang in accept() on internal nginx error.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1313
diff
changeset
|
260 local $SIG{ALRM} = sub { die "timeout\n" }; |
|
351b95be742b
Tests: fixed grpc tests hang in accept() on internal nginx error.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1313
diff
changeset
|
261 alarm(5); |
|
351b95be742b
Tests: fixed grpc tests hang in accept() on internal nginx error.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1313
diff
changeset
|
262 |
|
351b95be742b
Tests: fixed grpc tests hang in accept() on internal nginx error.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1313
diff
changeset
|
263 $client = $server->accept() or return; |
|
351b95be742b
Tests: fixed grpc tests hang in accept() on internal nginx error.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1313
diff
changeset
|
264 |
|
351b95be742b
Tests: fixed grpc tests hang in accept() on internal nginx error.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1313
diff
changeset
|
265 alarm(0); |
|
351b95be742b
Tests: fixed grpc tests hang in accept() on internal nginx error.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1313
diff
changeset
|
266 }; |
|
351b95be742b
Tests: fixed grpc tests hang in accept() on internal nginx error.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1313
diff
changeset
|
267 alarm(0); |
|
351b95be742b
Tests: fixed grpc tests hang in accept() on internal nginx error.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1313
diff
changeset
|
268 if ($@) { |
|
351b95be742b
Tests: fixed grpc tests hang in accept() on internal nginx error.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1313
diff
changeset
|
269 log_in("died: $@"); |
|
351b95be742b
Tests: fixed grpc tests hang in accept() on internal nginx error.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1313
diff
changeset
|
270 return undef; |
|
351b95be742b
Tests: fixed grpc tests hang in accept() on internal nginx error.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1313
diff
changeset
|
271 } |
|
351b95be742b
Tests: fixed grpc tests hang in accept() on internal nginx error.
Sergey Kandaurov <pluknet@nginx.com>
parents:
1313
diff
changeset
|
272 |
| 1303 | 273 log2c("(new connection $client)"); |
| 274 | |
| 275 $client->sysread(my $buf, 24) == 24 or return; # preface | |
| 276 | |
| 277 $c = Test::Nginx::HTTP2->new(1, socket => $client, | |
| 278 pure => 1, preface => "") or return; | |
| 279 } | |
| 280 | |
| 281 my $frames = $c->read(all => [{ fin => 4 }]); | |
| 282 | |
| 283 if (!$extra{reuse}) { | |
| 284 $c->h2_settings(0); | |
| 285 $c->h2_settings(1); | |
| 286 } | |
| 287 | |
| 288 my ($frame) = grep { $_->{type} eq "HEADERS" } @$frames; | |
| 289 $sid = $frame->{sid}; | |
| 290 return $frames; | |
| 291 }; | |
|
1725
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
292 $f->{data_len} = sub { |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
293 my ($body, $len) = @_; |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
294 $s->h2_body($body) if defined $body; |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
295 return $c->read(all => [{ sid => $sid, length => $len }]); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
296 }; |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
297 $f->{update} = sub { |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
298 $c->h2_window(shift); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
299 }; |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
300 $f->{update_sid} = sub { |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
301 $c->h2_window(shift, $sid); |
|
f4c79ee52d8f
Tests: added grpcs tests with flow control (ticket #2229).
Sergey Kandaurov <pluknet@nginx.com>
parents:
1645
diff
changeset
|
302 }; |
| 1303 | 303 $f->{data} = sub { |
| 304 my ($body, %extra) = @_; | |
| 305 $s->h2_body($body, { %extra }); | |
| 306 return $c->read(all => [{ sid => $sid, | |
| 307 length => length($body) }]); | |
| 308 }; | |
| 309 $f->{http_end} = sub { | |
| 310 $c->new_stream({ body_more => 1, headers => [ | |
| 311 { name => ':status', value => '200', mode => 0 }, | |
| 312 { name => 'content-type', value => 'application/grpc', | |
| 313 mode => 1, huff => 1 }, | |
| 314 ]}, $sid); | |
| 315 $c->h2_body('Hello world', { body_more => 1 }); | |
| 316 $c->new_stream({ headers => [ | |
| 317 { name => 'grpc-status', value => '0', | |
| 318 mode => 2, huff => 1 }, | |
| 319 { name => 'grpc-message', value => '', | |
| 320 mode => 2, huff => 1 }, | |
| 321 ]}, $sid); | |
| 322 | |
| 323 return $s->read(all => [{ fin => 1 }]); | |
| 324 }; | |
| 325 return $f; | |
| 326 } | |
| 327 | |
| 328 sub log2i { Test::Nginx::log_core('|| <<', @_); } | |
| 329 sub log2o { Test::Nginx::log_core('|| >>', @_); } | |
| 330 sub log2c { Test::Nginx::log_core('||', @_); } | |
| 331 | |
| 332 ############################################################################### |