# HG changeset patch
# User Sergey Kandaurov <pluknet@nginx.com>
# Date 1416837685 -10800
# Node ID 0ee2899fbe3ec08150a2274f9d400af341b0daae
# Parent  b4d657ba1a62c13a59b4796d0d4abadf72e06341
Tests: proxy_cache_lock_age tests.

diff --git a/proxy_cache_lock_age.t b/proxy_cache_lock_age.t
new file mode 100644
--- /dev/null
+++ b/proxy_cache_lock_age.t
@@ -0,0 +1,153 @@
+#!/usr/bin/perl
+
+# (C) Sergey Kandaurov
+# (C) Nginx, Inc.
+
+# Tests for http proxy cache lock aged.
+
+###############################################################################
+
+use warnings;
+use strict;
+
+use Test::More;
+
+use IO::Select;
+
+BEGIN { use FindBin; chdir($FindBin::Bin); }
+
+use lib 'lib';
+use Test::Nginx;
+
+###############################################################################
+
+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;
+            proxy_cache_lock_age 100ms;
+        }
+    }
+}
+
+EOF
+
+$t->run_daemon(\&http_daemon, 8081);
+
+$t->try_run('no proxy_cache_lock_age')->plan(2);
+
+$t->waitforsocket('127.0.0.1:8081');
+
+###############################################################################
+
+my $s = http_get('/', start => 1);
+
+like(http_get('/'), qr/request 2/, 'request');
+like(http_get('/'), qr/request 2/, 'request cached');
+
+http_get('/close');
+
+###############################################################################
+
+sub http_daemon {
+	my (@ports) = @_;
+	my @socks;
+
+	for my $port (@ports) {
+		my $server = IO::Socket::INET->new(
+			Proto => 'tcp',
+			LocalHost => "127.0.0.1:$port",
+			Listen => 5,
+			Reuse => 1
+		)
+			or die "Can't create listening socket: $!\n";
+		push @socks, $server;
+	}
+
+	my $sel = IO::Select->new(@socks);
+	my $num = 0;
+	my $s;
+
+	local $SIG{PIPE} = 'IGNORE';
+
+	while (my @ready = $sel->can_read) {
+		foreach my $fh (@ready) {
+			if (grep $_ == $fh, @socks) {
+				my $new = $fh->accept;
+				$new->autoflush(1);
+				$sel->add($new);
+
+			} elsif (process_socket($fh, \$num, \$s)) {
+				$sel->remove($fh);
+				$fh->close;
+			}
+		}
+	}
+}
+
+# Returns true to close connection
+
+sub process_socket {
+	my ($client, $num, $s) = @_;
+
+	my $headers = '';
+	my $uri = '';
+
+	while (<$client>) {
+		$headers .= $_;
+		last if (/^\x0d?\x0a?$/);
+	}
+	return 1 if $headers eq '';
+
+	$uri = $1 if $headers =~ /^\S+\s+([^ ]+)\s+HTTP/i;
+	return 1 if $uri eq '';
+
+	# finish a previously saved socket
+	close $$s if $uri eq '/close';
+
+	$$num++;
+
+	print $client <<EOF;
+HTTP/1.1 200 OK
+Cache-Control: max-age=300
+Connection: close
+
+request $$num
+EOF
+
+	# save socket and wait
+	if ($$num == 1) {
+		$$s = $client;
+		return 0;
+	}
+
+	return 1;
+}
+
+###############################################################################