commit 924cd97802b229a26b10b7dc2766a65bf18a0516
author Sergey Kandaurov <pluknet@nginx.com> Thu Jun 03 14:38:58 2021 +0300
committer Sergey Kandaurov <pluknet@nginx.com> Thu Jun 03 14:38:58 2021 +0300
tree 53c3f1f7fdf12ad471ce82b4fa5dba3b1a0ec6dd
parent 384aef1770d16c027346b33ecb34a3eb9d322305

Tests: added grpc request body test with a special last buffer.

grpc.t

diff --git a/grpc.t b/grpc.t
index 68c6091..3635344 100644
--- a/grpc.t
+++ b/grpc.t
@@ -24,7 +24,7 @@
 select STDOUT; $| = 1;
 
 my $t = Test::Nginx->new()->has(qw/http rewrite http_v2 grpc/)
-	->has(qw/upstream_keepalive/)->plan(123);
+	->has(qw/upstream_keepalive/)->plan(130);
 
 $t->write_file_expand('nginx.conf', <<'EOF');
 
@@ -154,6 +154,23 @@
 ($frame) = grep { $_->{type} eq "HEADERS" } @$frames;
 cmp_ok($frame->{headers}{'x-connection'}, '>', $c, 'response 2 - connection');
 
+# request body - special last buffer
+
+$f->{http_start}('/SayHello');
+$frames = $f->{data}('Hello', body_more => 1);
+($frame) = grep { $_->{type} eq "DATA" } @$frames;
+is($frame->{data}, 'Hello', 'request body first - DATA');
+is($frame->{length}, 5, 'request body first - DATA length');
+is($frame->{flags}, 0, 'request body first - DATA flags');
+$frames = $f->{data}('');
+($frame) = grep { $_->{type} eq "DATA" } @$frames;
+is($frame->{data}, '', 'special buffer last - DATA');
+is($frame->{length}, 0, 'special buffer last - DATA length');
+is($frame->{flags}, 1, 'special buffer last - DATA flags');
+$frames = $f->{http_end}();
+($frame) = grep { $_->{type} eq "HEADERS" } @$frames;
+is($frame->{headers}{':status'}, '200', 'special buffer last - response');
+
 # upstream keepalive
 
 $frames = $f->{http_start}('/KeepAlive');