Mercurial > hg > nginx-tests
view h2_priority.t @ 1184:89b4bdd1346a
Tests: added HTTP/2 SETTINGS test for no ack until queued DATA.
author | Sergey Kandaurov <pluknet@nginx.com> |
---|---|
date | Tue, 06 Jun 2017 18:42:35 +0300 |
parents | 882267679006 |
children | c4c2275cda55 |
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 $t->run(); # 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. $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 => 'RST_STREAM' }]); my ($frame) = grep { $_->{type} eq "RST_STREAM" } @$frames; is($frame->{sid}, $sid, 'dependency - PRIORITY self - RST_STREAM'); 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 => 'RST_STREAM' }]); ($frame) = grep { $_->{type} eq "RST_STREAM" } @$frames; is($frame->{sid}, $sid, 'dependency - HEADERS self - RST_STREAM'); 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'); ###############################################################################