use strict;

use warnings;

use IO::Socket::INET;

use Test::More;

use Time::HiRes qw(sleep);

use t::Util;

my $MAX_CONN = 2;

my $WAIT = 0.1;

subtest "single-threaded" => sub {

doit(1);

};

subtest "multi-threaded" => sub {

doit(4);

};

done_testing;

sub doit {

my $num_threads = shift;

my $server = spawn_h2o(<< "EOT");

num-threads: $num_threads

max-connections: $MAX_CONN

hosts:

default:

paths:

/:

file.dir: @{[ DOC_ROOT ]}

EOT

my $port = $server->{port};

my $tls_port = $server->{tls_port};

# establish connections to the maximum (and write partial requests so that the server would accept(2) the connections)

my @conns;

for (1..$MAX_CONN) {

my $conn = IO::Socket::INET->new(

PeerAddr => "127.0.0.1:$port",

Proto => "tcp",

) or die "connection failed:$!";

syswrite($conn, "GET / HTTP/1.0\r\n")

or die "failed to write partial request:$!";

push @conns, $conn;

}

sleep $WAIT;

# create one more connection and send request

my $blocked_conn = IO::Socket::INET->new(

PeerAddr => "127.0.0.1:$port",

Proto => "tcp",

) or die "connection failed:$!";

syswrite($blocked_conn, "GET / HTTP/1.0\r\n\r\n")

or die "failed to write request:$!";

sleep $WAIT;

ok ! data_ready($blocked_conn), "succeeding conn is not handled";

# close the preceeding connections

while (@conns) {

close shift @conns;

}

sleep $WAIT;

ok data_ready($blocked_conn), "succeeding conn should have been handled";

my $resp = do { local $/; <$blocked_conn> };

like $resp, qr{^HTTP/1\.1 200 OK\r\n}s, "response is valid";

}

sub data_ready {

my $conn = shift;

my $rfds = '';

vec($rfds, fileno($conn), 1) = 1;

my $nfound = select $rfds, undef, undef, 0;

return $nfound != 0;

}