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
|
# Write timeout.
use warnings;
use strict;
use lib 't';
use IO::Stream::const ();
BEGIN {
local $SIG{__WARN__} = sub {}; # no 'constant redefined' warning
*IO::Stream::const::TOWRITE = sub () { 0.1 };
}
use share;
@CheckPoint = (
[ 'client', RESOLVED, undef ], 'client: RESOLVED',
[ 'client', CONNECTED, undef ], 'client: CONNECTED',
[ 'client', 0, 'write timeout' ], 'client: write timeout',
);
plan tests => @CheckPoint/2;
my $srv_sock = tcp_server('127.0.0.1', 0);
IO::Stream->new({
host => '127.0.0.1',
port => sockport($srv_sock),
cb => \&client,
wait_for => RESOLVED|CONNECTED|SENT,
out_buf => ('x' x 10_000_000),
});
EV::loop;
sub client {
my ($io, $e, $err) = @_;
checkpoint($e, $err);
EV::unloop if $err;
}
|
