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
|
# please insert nothing before this line: -*- mode: cperl; cperl-indent-level: 4; cperl-continued-statement-offset: 4; indent-tabs-mode: nil -*-
package TestProtocol::echo_timeout;
# this test reads from/writes to the socket doing nonblocking IO but
# using the timeout
#
# see TestProtocol::echo_block for how to do the same with blocking IO
use strict;
use warnings FATAL => 'all';
use Apache2::Connection ();
use APR::Socket ();
use Apache2::Const -compile => 'OK';
use APR::Const -compile => qw(SO_NONBLOCK);
use APR::Status ();
use constant BUFF_LEN => 1024;
sub handler {
my Apache2::Connection $c = shift;
my APR::Socket $socket = $c->client_socket;
# starting from Apache 2.0.49 several platforms require you to set
# the socket to a blocking IO mode
$c->client_socket->opt_set(APR::Const::SO_NONBLOCK, 0);
# set timeout (20 sec) so later we can do error checking on
# read/write timeouts
$socket->timeout_set(20_000_000);
while (1) {
my $buff;
my $rlen = eval { $socket->recv($buff, BUFF_LEN) };
if ($@) {
die "timed out, giving up: $@" if APR::Status::is_TIMEUP($@);
die $@;
}
last unless $rlen; # EOF
my $wlen = eval { $socket->send($buff) };
if ($@) {
die "timed out, giving up: $@" if APR::Status::is_TIMEUP($@);
die $@;
}
}
Apache2::Const::OK;
}
1;
|
