Mercurial > hg > nginx-tests
view proxy_cache_lock.t @ 499:a3b03c333ad5
Tests: adjusted proxy cache lock TODO, improved its description.
author | Sergey Kandaurov <pluknet@nginx.com> |
---|---|
date | Tue, 18 Nov 2014 20:48:43 +0300 |
parents | 420fbf3555dd |
children | 071e8941e3bf |
line wrap: on
line source
#!/usr/bin/perl # (C) Maxim Dounin # Tests for http proxy cache lock. ############################################################################### use warnings; use strict; use Test::More; BEGIN { use FindBin; chdir($FindBin::Bin); } use lib 'lib'; use Test::Nginx qw/ :DEFAULT http_end /; ############################################################################### select STDERR; $| = 1; select STDOUT; $| = 1; plan(skip_all => 'win32') if $^O eq 'MSWin32'; my $t = Test::Nginx->new()->has(qw/http proxy cache/) ->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:10m; server { listen 127.0.0.1:8080; server_name localhost; location / { proxy_pass http://127.0.0.1:8081; proxy_cache NAME; proxy_cache_lock on; } location /timeout { proxy_pass http://127.0.0.1:8081; proxy_cache NAME; proxy_cache_lock on; proxy_cache_lock_timeout 200ms; } location /nolock { proxy_pass http://127.0.0.1:8081; proxy_cache NAME; } } } EOF $t->run_daemon(\&http_fake_daemon); $t->run()->plan(19); $t->waitforsocket('127.0.0.1:8081'); ############################################################################### # sequentional requests for my $i (1 .. 5) { like(http_get('/seq'), qr/request 1/, 'sequentional request ' . $i); } # parallel requests my @sockets; for my $i (1 .. 5) { $sockets[$i] = http_get('/par1', start => 1); } for my $i (1 .. 5) { like(http_end($sockets[$i]), qr/request 1/, 'parallel request ' . $i); } like(http_get('/par1'), qr/request 1/, 'first request cached'); # since 1.7.8, parallel requests with cache lock timeout expired are not cached for my $i (1 .. 3) { $sockets[$i] = http_get('/timeout', start => 1); } for my $i (1 .. 3) { like(http_end($sockets[$i]), qr/request $i/, 'lock timeout ' . $i); } TODO: { local $TODO = 'behavior change' unless $t->has_version('1.7.8'); like(http_get('/timeout'), qr/request 1/, 'lock timeout - first only cached'); } # no lock for my $i (1 .. 3) { $sockets[$i] = http_get('/nolock', start => 1); } for my $i (1 .. 3) { like(http_end($sockets[$i]), qr/request $i/, 'nolock ' . $i); } like(http_get('/nolock'), qr/request 3/, 'nolock - last cached'); ############################################################################### sub http_fake_daemon { my $server = IO::Socket::INET->new( Proto => 'tcp', LocalAddr => '127.0.0.1:8081', Listen => 5, Reuse => 1 ) or die "Can't create listening socket: $!\n"; my $num = 0; my $uri = ''; while (my $client = $server->accept()) { $client->autoflush(1); while (<$client>) { if (/GET (.*) HTTP/ && $1 ne $uri) { $uri = $1; $num = 0; } $uri = $1 if /GET (.*) HTTP/; last if /^\x0d?\x0a?$/; } next unless $uri; select(undef, undef, undef, 0.5); $num++; print $client <<"EOF"; HTTP/1.1 200 OK Cache-Control: max-age=300 Connection: close request $num EOF } } ###############################################################################