Mercurial > hg > nginx-tests
view h2_priority.t @ 1905:f35824e75b66
Tests: fixed reading QUIC streams on Perl < 5.24.
The parse_stream() routine has had a missing explicit return if there were no
streams received. In Perl < 5.24 this used to return no value, or an empty
array in the list context. In modern Perl this returns an empty value, or an
array of 1 element, which made the check for last index of the returned array
work rather by accident.
The fix is to return explicitly and to check the array size in callers instead.
author | Sergey Kandaurov <pluknet@nginx.com> |
---|---|
date | Tue, 06 Jun 2023 18:50:07 +0400 |
parents | 236d038dc04a |
children |
line wrap: on
line source
#!/usr/bin/perl # (C) Sergey Kandaurov # (C) Nginx, Inc. # Tests for HTTP/2 protocol with priority. ############################################################################### use warnings; use strict; use Test::More; BEGIN { use FindBin; chdir($FindBin::Bin); } use lib 'lib'; use Test::Nginx; use Test::Nginx::HTTP2; ############################################################################### select STDERR; $| = 1; select STDOUT; $| = 1; my $t = Test::Nginx->new()->has(qw/http http_v2/)->plan(20) ->write_file_expand('nginx.conf', <<'EOF'); %%TEST_GLOBALS%% daemon off; events { } http { %%TEST_GLOBALS_HTTP%% server { listen 127.0.0.1:8080 http2; server_name localhost; } } EOF # suppress deprecation warning open OLDERR, ">&", \*STDERR; close STDERR; $t->run(); open STDERR, ">&", \*OLDERR; # file size is slightly beyond initial window size: 2**16 + 80 bytes $t->write_file('t1.html', join('', map { sprintf "X%04dXXX", $_ } (1 .. 8202))); $t->write_file('t2.html', 'SEE-THIS'); ############################################################################### # stream muliplexing + PRIORITY frames my $s = Test::Nginx::HTTP2->new(); my $sid = $s->new_stream({ path => '/t1.html' }); $s->read(all => [{ sid => $sid, length => 2**16 - 1 }]); my $sid2 = $s->new_stream({ path => '/t2.html' }); $s->read(all => [{ sid => $sid2, fin => 0x4 }]); $s->h2_priority(0, $sid); $s->h2_priority(255, $sid2); $s->h2_window(2**17, $sid); $s->h2_window(2**17, $sid2); $s->h2_window(2**17); my $frames = $s->read(all => [ { sid => $sid, fin => 1 }, { sid => $sid2, fin => 1 } ]); my @data = grep { $_->{type} eq "DATA" } @$frames; is(join(' ', map { $_->{sid} } @data), "$sid2 $sid", 'weight - PRIORITY 1'); # and vice versa $s = Test::Nginx::HTTP2->new(); $sid = $s->new_stream({ path => '/t1.html' }); $s->read(all => [{ sid => $sid, length => 2**16 - 1 }]); $sid2 = $s->new_stream({ path => '/t2.html' }); $s->read(all => [{ sid => $sid2, fin => 0x4 }]); $s->h2_priority(255, $sid); $s->h2_priority(0, $sid2); $s->h2_window(2**17, $sid); $s->h2_window(2**17, $sid2); $s->h2_window(2**17); $frames = $s->read(all => [ { sid => $sid, fin => 1 }, { sid => $sid2, fin => 1 } ]); @data = grep { $_->{type} eq "DATA" } @$frames; is(join(' ', map { $_->{sid} } @data), "$sid $sid2", 'weight - PRIORITY 2'); # stream muliplexing + HEADERS PRIORITY flag $s = Test::Nginx::HTTP2->new(); $sid = $s->new_stream({ path => '/t1.html', prio => 0 }); $s->read(all => [{ sid => $sid, length => 2**16 - 1 }]); $sid2 = $s->new_stream({ path => '/t2.html', prio => 255 }); $s->read(all => [{ sid => $sid2, fin => 0x4 }]); $s->h2_window(2**17, $sid); $s->h2_window(2**17, $sid2); $s->h2_window(2**17); $frames = $s->read(all => [ { sid => $sid, fin => 1 }, { sid => $sid2, fin => 1 } ]); @data = grep { $_->{type} eq "DATA" } @$frames; my $sids = join ' ', map { $_->{sid} } @data; is($sids, "$sid2 $sid", 'weight - HEADERS PRIORITY 1'); # and vice versa $s = Test::Nginx::HTTP2->new(); $sid = $s->new_stream({ path => '/t1.html', prio => 255 }); $s->read(all => [{ sid => $sid, length => 2**16 - 1 }]); $sid2 = $s->new_stream({ path => '/t2.html', prio => 0 }); $s->read(all => [{ sid => $sid2, fin => 0x4 }]); $s->h2_window(2**17, $sid); $s->h2_window(2**17, $sid2); $s->h2_window(2**17); $frames = $s->read(all => [ { sid => $sid, fin => 1 }, { sid => $sid2, fin => 1 } ]); @data = grep { $_->{type} eq "DATA" } @$frames; $sids = join ' ', map { $_->{sid} } @data; is($sids, "$sid $sid2", 'weight - HEADERS PRIORITY 2'); # 5.3.1. Stream Dependencies # PRIORITY frame $s = Test::Nginx::HTTP2->new(); $s->h2_priority(16, 3, 0); $s->h2_priority(16, 1, 3); $sid = $s->new_stream({ path => '/t1.html' }); $s->read(all => [{ sid => $sid, length => 2**16 - 1 }]); $sid2 = $s->new_stream({ path => '/t2.html' }); $s->read(all => [{ sid => $sid2, fin => 0x4 }]); $s->h2_window(2**17, $sid); $s->h2_window(2**17, $sid2); $s->h2_window(2**17); $frames = $s->read(all => [ { sid => $sid, fin => 1 }, { sid => $sid2, fin => 1 }, ]); @data = grep { $_->{type} eq "DATA" } @$frames; $sids = join ' ', map { $_->{sid} } @data; is($sids, "$sid2 $sid", 'dependency - PRIORITY 1'); # and vice versa $s = Test::Nginx::HTTP2->new(); $s->h2_priority(16, 1, 0); $s->h2_priority(16, 3, 1); $sid = $s->new_stream({ path => '/t1.html' }); $s->read(all => [{ sid => $sid, length => 2**16 - 1 }]); $sid2 = $s->new_stream({ path => '/t2.html' }); $s->read(all => [{ sid => $sid2, fin => 0x4 }]); $s->h2_window(2**17, $sid); $s->h2_window(2**17, $sid2); $s->h2_window(2**17); $frames = $s->read(all => [ { sid => $sid, fin => 1 }, { sid => $sid2, fin => 1 }, ]); @data = grep { $_->{type} eq "DATA" } @$frames; $sids = join ' ', map { $_->{sid} } @data; is($sids, "$sid $sid2", 'dependency - PRIORITY 2'); # PRIORITY - self dependency # 5.3.1. Stream Dependencies # A stream cannot depend on itself. An endpoint MUST treat this as a # stream error of type PROTOCOL_ERROR. # Instead, we respond with a connection error of type PROTOCOL_ERROR. $s = Test::Nginx::HTTP2->new(); $sid = $s->new_stream(); $s->read(all => [{ sid => $sid, fin => 1 }]); $s->h2_priority(0, $sid, $sid); $frames = $s->read(all => [{ type => 'GOAWAY' }]); my ($frame) = grep { $_->{type} eq "GOAWAY" } @$frames; is($frame->{last_sid}, $sid, 'dependency - PRIORITY self - GOAWAY'); is($frame->{code}, 1, 'dependency - PRIORITY self - PROTOCOL_ERROR'); # HEADERS PRIORITY flag, reprioritize prior PRIORITY frame records $s = Test::Nginx::HTTP2->new(); $s->h2_priority(16, 1, 0); $s->h2_priority(16, 3, 0); $sid = $s->new_stream({ path => '/t1.html', dep => 3 }); $s->read(all => [{ sid => $sid, length => 2**16 - 1 }]); $sid2 = $s->new_stream({ path => '/t2.html' }); $s->read(all => [{ sid => $sid2, fin => 0x4 }]); $s->h2_window(2**17, $sid); $s->h2_window(2**17, $sid2); $s->h2_window(2**17); $frames = $s->read(all => [ { sid => $sid, fin => 1 }, { sid => $sid2, fin => 1 }, ]); @data = grep { $_->{type} eq "DATA" } @$frames; $sids = join ' ', map { $_->{sid} } @data; is($sids, "$sid2 $sid", 'dependency - HEADERS PRIORITY 1'); # and vice versa $s = Test::Nginx::HTTP2->new(); $s->h2_priority(16, 1, 0); $s->h2_priority(16, 3, 0); $sid = $s->new_stream({ path => '/t1.html' }); $s->read(all => [{ sid => $sid, length => 2**16 - 1 }]); $sid2 = $s->new_stream({ path => '/t2.html', dep => 1 }); $s->read(all => [{ sid => $sid2, fin => 0x4 }]); $s->h2_window(2**17, $sid); $s->h2_window(2**17, $sid2); $s->h2_window(2**17); $frames = $s->read(all => [ { sid => $sid, fin => 1 }, { sid => $sid2, fin => 1 }, ]); @data = grep { $_->{type} eq "DATA" } @$frames; $sids = join ' ', map { $_->{sid} } @data; is($sids, "$sid $sid2", 'dependency - HEADERS PRIORITY 2'); # HEADERS - self dependency $s = Test::Nginx::HTTP2->new(); $sid = $s->new_stream({ dep => 1 }); $frames = $s->read(all => [{ type => 'GOAWAY' }]); ($frame) = grep { $_->{type} eq "GOAWAY" } @$frames; is($frame->{last_sid}, 0, 'dependency - HEADERS self - GOAWAY'); is($frame->{code}, 1, 'dependency - HEADERS self - PROTOCOL_ERROR'); # PRIORITY frame, weighted dependencies $s = Test::Nginx::HTTP2->new(); $s->h2_priority(16, 5, 0); $s->h2_priority(255, 1, 5); $s->h2_priority(0, 3, 5); $sid = $s->new_stream({ path => '/t1.html' }); $s->read(all => [{ sid => $sid, length => 2**16 - 1 }]); $sid2 = $s->new_stream({ path => '/t2.html' }); $s->read(all => [{ sid => $sid2, fin => 0x4 }]); my $sid3 = $s->new_stream({ path => '/t2.html' }); $s->read(all => [{ sid => $sid3, fin => 0x4 }]); $s->h2_window(2**16, 1); $s->h2_window(2**16, 3); $s->h2_window(2**16, 5); $s->h2_window(2**16); $frames = $s->read(all => [ { sid => $sid, fin => 1 }, { sid => $sid2, fin => 1 }, { sid => $sid3, fin => 1 }, ]); @data = grep { $_->{type} eq "DATA" } @$frames; $sids = join ' ', map { $_->{sid} } @data; is($sids, "$sid3 $sid $sid2", 'weighted dependency - PRIORITY 1'); # and vice versa $s = Test::Nginx::HTTP2->new(); $s->h2_priority(16, 5, 0); $s->h2_priority(0, 1, 5); $s->h2_priority(255, 3, 5); $sid = $s->new_stream({ path => '/t1.html' }); $s->read(all => [{ sid => $sid, length => 2**16 - 1 }]); $sid2 = $s->new_stream({ path => '/t2.html' }); $s->read(all => [{ sid => $sid2, fin => 0x4 }]); $sid3 = $s->new_stream({ path => '/t2.html' }); $s->read(all => [{ sid => $sid3, fin => 0x4 }]); $s->h2_window(2**16, 1); $s->h2_window(2**16, 3); $s->h2_window(2**16, 5); $s->h2_window(2**16); $frames = $s->read(all => [ { sid => $sid, fin => 1 }, { sid => $sid2, fin => 1 }, { sid => $sid3, fin => 1 }, ]); @data = grep { $_->{type} eq "DATA" } @$frames; $sids = join ' ', map { $_->{sid} } @data; is($sids, "$sid3 $sid2 $sid", 'weighted dependency - PRIORITY 2'); # PRIORITY - reprioritization with circular dependency - after [3] removed # initial dependency tree: # 1 <- [3] <- 5 $s = Test::Nginx::HTTP2->new(); $s->h2_window(2**18); $s->h2_priority(16, 1, 0); $s->h2_priority(16, 3, 1); $s->h2_priority(16, 5, 3); $sid = $s->new_stream({ path => '/t1.html' }); $s->read(all => [{ sid => $sid, length => 2**16 - 1 }]); $sid2 = $s->new_stream({ path => '/t1.html' }); $s->read(all => [{ sid => $sid2, length => 2**16 - 1 }]); $sid3 = $s->new_stream({ path => '/t1.html' }); $s->read(all => [{ sid => $sid3, length => 2**16 - 1 }]); $s->h2_window(2**16, $sid2); $frames = $s->read(all => [{ sid => $sid2, fin => 1 }]); $sids = join ' ', map { $_->{sid} } grep { $_->{type} eq "DATA" } @$frames; is($sids, $sid2, 'removed dependency'); for (1 .. 40) { $s->read(all => [{ sid => $s->new_stream(), fin => 1 }]); } # make circular dependency # 1 <- 5 -- current dependency tree before reprioritization # 5 <- 1 # 1 <- 5 $s->h2_priority(16, 1, 5); $s->h2_priority(16, 5, 1); $s->h2_window(2**16, $sid); $s->h2_window(2**16, $sid3); $frames = $s->read(all => [ { sid => $sid, fin => 1 }, { sid => $sid3, fin => 1 }, ]); ($frame) = grep { $_->{type} eq "DATA" && $_->{sid} == $sid } @$frames; is($frame->{length}, 81, 'removed dependency - first stream'); ($frame) = grep { $_->{type} eq "DATA" && $_->{sid} == $sid3 } @$frames; is($frame->{length}, 81, 'removed dependency - last stream'); # PRIORITY - reprioritization with circular dependency - exclusive [5] # 1 <- [5] <- 3 $s = Test::Nginx::HTTP2->new(); $s->h2_window(2**18); $s->h2_priority(16, 1, 0); $s->h2_priority(16, 3, 1); $s->h2_priority(16, 5, 1, excl => 1); $sid = $s->new_stream({ path => '/t1.html' }); $s->read(all => [{ sid => $sid, length => 2**16 - 1 }]); $sid2 = $s->new_stream({ path => '/t1.html' }); $s->read(all => [{ sid => $sid2, length => 2**16 - 1 }]); $sid3 = $s->new_stream({ path => '/t1.html' }); $s->read(all => [{ sid => $sid3, length => 2**16 - 1 }]); $s->h2_window(2**16, $sid); $frames = $s->read(all => [{ sid => $sid, fin => 1 }]); $sids = join ' ', map { $_->{sid} } grep { $_->{type} eq "DATA" } @$frames; is($sids, $sid, 'exclusive dependency - parent removed'); # make circular dependency # 5 <- 3 -- current dependency tree before reprioritization # 3 <- 5 $s->h2_priority(16, 5, 3); $s->h2_window(2**16, $sid2); $s->h2_window(2**16, $sid3); $frames = $s->read(all => [ { sid => $sid2, fin => 1 }, { sid => $sid3, fin => 1 }, ]); ($frame) = grep { $_->{type} eq "DATA" && $_->{sid} == $sid2 } @$frames; is($frame->{length}, 81, 'exclusive dependency - first stream'); ($frame) = grep { $_->{type} eq "DATA" && $_->{sid} == $sid3 } @$frames; is($frame->{length}, 81, 'exclusive dependency - last stream'); ###############################################################################