1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
|
use strict;
use warnings;
use Furl::HTTP;
use Socket ();
use Test::More;
use Test::Requires 'Starlet::Server', 'Plack::Loader';
use Test::TCP;
{
no warnings 'redefine';
my $orig = *Starlet::Server::_get_acceptor{CODE};
*Starlet::Server::_get_acceptor = sub {
my $acceptor = shift->$orig(@_);
return sub {
my ($conn, $peer, $listen) = $acceptor->();
if ($conn) {
setsockopt($conn, Socket::SOL_SOCKET, Socket::SO_LINGER, pack('ii', 1, 0))
or warn "failed to set SO_LINGER: $!";
return ($conn, $peer, $listen);
} else {
return ();
}
}
};
}
test_tcp(
client => sub {
my $port = shift;
my $furl = Furl::HTTP->new(timeout => 1);
my ($code, $msg);
(undef, $code, $msg) = $furl->request(port => $port, host => '127.0.0.1');
is $code, 200;
is $msg, 'OK';
sleep 2;
(undef, $code, $msg) = $furl->request(port => $port, host => '127.0.0.1');
is $code, 200;
is $msg, 'OK';
},
server => sub {
my $port = shift;
my %args = (
port => $port,
keepalive_timeout => 1,
max_keepalive_reqs => 100,
max_reqs_per_child => 100,
max_workers => 1,
);
my $app = sub { [200, ['Content-Length' => 2], ['ok']] };
Plack::Loader->load('Starlet', %args)->run($app);
exit;
},
);
done_testing;
|
