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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
#!/usr/bin/perl -w
use strict;
use lib 't/lib';
use Test::More tests => 8;
use Test::HexString;
use Test::Refcount;
use IO::Async::Loop;
use IO::Async::Test;
use FCGI::Async;
use TestFCGI;
my $request;
my ( $S, $selfaddr ) = make_server_sock;
my $loop = IO::Async::Loop->new();
testing_loop( $loop );
my $fcgi = FCGI::Async->new(
loop => $loop,
handle => $S,
on_request => sub { $request = $_[1] },
);
ok( defined $fcgi, 'defined $fcgi' );
isa_ok( $fcgi, "FCGI::Async", '$fcgi isa FCGI::Async' );
# One ref in the Loop as well as this lexical variable
is_refcount( $fcgi, 2, '$fcgi has refcount 2 initially' );
my $C = connect_client_sock( $selfaddr );
# Got it - now pretend to be an FCGI client, such as how a webserver would
# behave.
$C->syswrite(
# Begin
fcgi_trans( type => 1, id => 1, data => "\0\1\0\0\0\0\0\0" ) .
# No parameters
fcgi_trans( type => 4, id => 1, data => "" ) .
# No STDIN
fcgi_trans( type => 5, id => 1, data => "" )
);
wait_for { defined $request };
is_deeply( $request->params,
{},
'$request has empty params hash' );
is( $request->read_stdin_line,
undef,
'$request has empty STDIN' );
$request->finish;
undef $request; # for refcount
my $expect;
$expect =
# End of STDOUT
fcgi_trans( type => 6, id => 1, data => "" ) .
# End request
fcgi_trans( type => 3, id => 1, data => "\0\0\0\0\0\0\0\0" );
my $buffer;
$buffer = "";
wait_for_stream { length $buffer >= length $expect } $C => $buffer;
is_hexstr( $buffer, $expect, 'FastCGI end request record' );
# Since we didn't specify FCGI_KEEP_CONN, we expect that $C should now be
# closed, and that reading any more will give us EOF
my $l = $C->sysread( $buffer, 8192 );
is( $l, 0, 'Client connection now closed' );
is_refcount( $fcgi, 2, '$fcgi has refcount 2 finally' );
|
