Mercurial > hg > nginx-tests
view proxy_cache_use_stale.t @ 1236:93f749c1d5c5
Tests: fixed parallel tests execution with UDP.
Previously, when checking ports availability, a UDP socket was always created
first, then a TCP socket was created. On success, one of UDP and TCP sockets
was closed (depending on the "udp" option) and the second one was used to busy
this port in other scripts. This lead to the following problem: in an attempt
to reopen a UDP socket used in a given testing script it could be stolen by
another script as part of checking ports availability.
To solve this problem, UDP and TCP ports were split into two non-overlapping
ranges: TCP ports are only used in the range 8000-8499, and UDP ports - in
the range 8500-8999. In addition, the order of creating sockets in UDP tests
has been reversed: now a TCP socket used as a lock precedes a UDP socket.
author | Andrey Zelenkov <zelenkov@nginx.com> |
---|---|
date | Thu, 26 Oct 2017 18:00:21 +0300 |
parents | a3d23d16712d |
children | 766bcbb632ee |
line wrap: on
line source
#!/usr/bin/perl # (C) Sergey Kandaurov # (C) Nginx, Inc. # Tests for http proxy cache, proxy_cache_use_stale. ############################################################################### use warnings; use strict; use Test::More; use IO::Select; BEGIN { use FindBin; chdir($FindBin::Bin); } use lib 'lib'; use Test::Nginx qw/ :DEFAULT http_end /; ############################################################################### select STDERR; $| = 1; select STDOUT; $| = 1; my $t = Test::Nginx->new()->has(qw/http proxy cache rewrite limit_req ssi/) ->write_file_expand('nginx.conf', <<'EOF'); %%TEST_GLOBALS%% daemon off; events { } http { %%TEST_GLOBALS_HTTP%% proxy_cache_path %%TESTDIR%%/cache levels=1:2 keys_zone=NAME:1m; limit_req_zone $binary_remote_addr zone=one:1m rate=15r/m; server { listen 127.0.0.1:8080; server_name localhost; location /ssi.html { ssi on; sendfile_max_chunk 4k; } location / { proxy_pass http://127.0.0.1:8081; proxy_cache NAME; proxy_cache_key $uri; proxy_cache_revalidate on; proxy_cache_background_update on; add_header X-Cache-Status $upstream_cache_status; location /t4.html { proxy_pass http://127.0.0.1:8081/t.html; proxy_cache_revalidate off; } location /t5.html { proxy_pass http://127.0.0.1:8081/t.html; proxy_cache_background_update off; } location /updating/ { proxy_pass http://127.0.0.1:8081/; proxy_cache_use_stale updating; } location /t7.html { proxy_pass http://127.0.0.1:8081; sendfile_max_chunk 4k; } location /t8.html { proxy_pass http://127.0.0.1:8081/t.html; proxy_cache_valid 1s; } if ($arg_if) { # nothing } } } server { listen 127.0.0.1:8081; server_name localhost; add_header Cache-Control $http_x_cache_control; if ($arg_lim) { set $limit_rate 1k; } if ($arg_e) { return 500; } location / { } location /t6.html { limit_req zone=one burst=2; } location /t9.html { add_header Cache-Control "max-age=1, stale-while-revalidate=10"; } } } EOF $t->write_file('t.html', 'SEE-THIS'); $t->write_file('tt.html', 'SEE-THIS'); $t->write_file('t2.html', 'SEE-THIS'); $t->write_file('t3.html', 'SEE-THIS'); $t->write_file('t6.html', 'SEE-THIS'); $t->write_file('t7.html', 'SEE-THIS' x 1024); $t->write_file('t9.html', 'SEE-THIS' x 1024); $t->write_file('ssi.html', 'xxx <!--#include virtual="/t9.html" --> xxx'); $t->try_run('no proxy_cache_background_update')->plan(29); ############################################################################### like(get('/t.html', 'max-age=1, stale-if-error=5'), qr/MISS/, 'stale-if-error'); like(http_get('/t.html?e=1'), qr/HIT/, 's-i-e - cached'); like(get('/t2.html', 'max-age=1, stale-while-revalidate=10'), qr/MISS/, 'stale-while-revalidate'); like(http_get('/t2.html'), qr/HIT/, 's-w-r - cached'); get('/tt.html', 'max-age=1, stale-if-error=3'); get('/t3.html', 'max-age=1, stale-while-revalidate=2'); get('/t4.html', 'max-age=1, stale-while-revalidate=3'); get('/t5.html', 'max-age=1, stale-while-revalidate=3'); get('/t6.html', 'max-age=1, stale-while-revalidate=4'); get('/t7.html', 'max-age=1, stale-while-revalidate=10'); http_get('/ssi.html'); get('/updating/t.html', 'max-age=1'); get('/updating/t2.html', 'max-age=1, stale-while-revalidate=2'); get('/t8.html', 'stale-while-revalidate=10'); sleep 2; like(http_get('/t.html?e=1'), qr/STALE/, 's-i-e - stale'); like(http_get('/tt.html?e=1'), qr/STALE/, 's-i-e - stale 2'); like(http_get('/t.html'), qr/REVALIDATED/, 's-i-e - revalidated'); like(http_get('/t2.html?e=1'), qr/STALE/, 's-w-r - revalidate error'); like(http_get('/t2.html'), qr/STALE/, 's-w-r - stale while revalidate'); like(http_get('/t2.html'), qr/HIT/, 's-w-r - revalidated'); like(get('/t4.html', 'max-age=1, stale-while-revalidate=2'), qr/STALE/, 's-w-r - unconditional revalidate'); like(http_get('/t4.html'), qr/HIT/, 's-w-r - unconditional revalidated'); like(http_get('/t5.html?e=1'), qr/STALE/, 's-w-r - foreground revalidate error'); like(http_get('/t5.html'), qr/REVALIDATED/, 's-w-r - foreground revalidated'); # UPDATING while s-w-r $t->write_file('t6.html', 'SEE-THAT'); my $s = get('/t6.html', 'max-age=1, stale-while-revalidate=2', start => 1); select undef, undef, undef, 0.2; like(http_get('/t6.html'), qr/UPDATING.*SEE-THIS/s, 's-w-r - updating'); like(http_end($s), qr/STALE.*SEE-THIS/s, 's-w-r - updating stale'); like(http_get('/t6.html'), qr/HIT.*SEE-THAT/s, 's-w-r - updating revalidated'); # stale-while-revalidate with proxy_cache_use_stale updating like(http_get('/updating/t.html'), qr/STALE/, 's-w-r - use_stale updating stale'); like(http_get('/updating/t.html'), qr/HIT/, 's-w-r - use_stale updating revalidated'); # stale-while-revalidate with proxy_cache_valid like(http_get('/t8.html'), qr/STALE/, 's-w-r - proxy_cache_valid revalidate'); like(http_get('/t8.html'), qr/HIT/, 's-w-r - proxy_cache_valid revalidated'); sleep 2; like(http_get('/t2.html?e=1'), qr/STALE/, 's-w-r - stale after revalidate'); like(http_get('/t3.html?e=1'), qr/ 500 /, 's-w-r - ceased'); like(http_get('/tt.html?e=1'), qr/ 500 /, 's-i-e - ceased'); like(http_get('/updating/t2.html'), qr/STALE/, 's-w-r - overriden with use_stale updating'); # stale response not blocked by background update. # before 1.13.1, if stale response was not sent in one pass, its remaining # part was blocked and not sent until background update has been finished TODO: { local $TODO = 'not yet' unless $t->has_version('1.13.1'); $t->write_file('t7.html', 'SEE-THAT' x 1024); my $r = read_all(get('/t7.html?lim=1', 'max-age=1', start => 1)); like($r, qr/STALE.*^(SEE-THIS){1024}$/ms, 's-w-r - stale response not blocked'); $t->write_file('t9.html', 'SEE-THAT' x 1024); $t->write_file('ssi.html', 'xxx <!--#include virtual="/t9.html?lim=1" --> xxx'); $r = read_all(http_get('/ssi.html', start => 1)); like($r, qr/^xxx (SEE-THIS){1024} xxx$/ms, 's-w-r - not blocked in subrequest'); } # "aio_write" is used to produce "open socket ... left in connection" alerts. $t->todo_alerts() if $t->read_file('nginx.conf') =~ /aio_write on/ and $t->read_file('nginx.conf') =~ /aio threads/ and $^O eq 'freebsd'; # due to the missing content_handler inheritance in a cloned subrequest, # this used to access a static file in the update request like(http_get('/t2.html?if=1'), qr/STALE/, 'background update in if'); TODO: { local $TODO = 'not yet' unless $t->has_version('1.11.11'); like(http_get('/t2.html?if=1'), qr/HIT/, 'background update in if - updated'); } ############################################################################### sub get { my ($url, $extra, %extra) = @_; return http(<<EOF, %extra); GET $url HTTP/1.1 Host: localhost Connection: close X-Cache-Control: $extra EOF } # background update is known to postpone closing connection with client sub read_all { my ($s) = @_; my $r = ''; while (IO::Select->new($s)->can_read(1)) { $s->sysread(my $buf, 8192) or last; log_in($buf); $r .= $buf; } return $r; } ###############################################################################