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
87
|
use strict;
use warnings;
use AnyEvent;
use AnyEvent::Socket;
use AnyEvent::Handle;
use Protocol::HTTP2::Client;
use Protocol::HTTP2::Constants qw(const_name);
my $client = Protocol::HTTP2::Client->new(
on_change_state => sub {
my ( $stream_id, $previous_state, $current_state ) = @_;
printf "Stream %i changed state from %s to %s\n",
$stream_id, const_name( "states", $previous_state ),
const_name( "states", $current_state );
},
on_error => sub {
my $error = shift;
printf "Error occurred: %s\n", const_name( "errors", $error );
},
# Perform HTTP/1.1 Upgrade
upgrade => 1,
);
my $host = '127.0.0.1';
my $port = 8000;
# Prepare http/2 request
$client->request(
':scheme' => "http",
':authority' => $host . ":" . $port,
':path' => "/minil.toml",
':method' => "GET",
headers => [
'accept' => '*/*',
'user-agent' => 'perl-Protocol-HTTP2/0.01',
],
on_done => sub {
my ( $headers, $data ) = @_;
printf "Get headers. Count: %i\n", scalar(@$headers) / 2;
printf "Get data. Length: %i\n", length($data);
print $data;
},
);
my $w = AnyEvent->condvar;
tcp_connect $host, $port, sub {
my ($fh) = @_ or die "connection failed: $!";
my $handle;
$handle = AnyEvent::Handle->new(
fh => $fh,
autocork => 1,
on_error => sub {
$_[0]->destroy;
print "connection error\n";
$w->send;
},
on_eof => sub {
$handle->destroy;
$w->send;
}
);
# First write preface to peer
while ( my $frame = $client->next_frame ) {
$handle->push_write($frame);
}
$handle->on_read(
sub {
my $handle = shift;
$client->feed( $handle->{rbuf} );
$handle->{rbuf} = undef;
while ( my $frame = $client->next_frame ) {
$handle->push_write($frame);
}
$handle->push_shutdown if $client->shutdown;
}
);
};
$w->recv;
|
