line |
stmt |
bran |
cond |
sub |
pod |
time |
code |
1
|
|
|
|
|
|
|
# No-op plugin example. |
2
|
|
|
|
|
|
|
package IO::Stream::Noop; |
3
|
1
|
|
|
1
|
|
1503
|
use 5.010001; |
|
1
|
|
|
|
|
3
|
|
4
|
1
|
|
|
1
|
|
5
|
use warnings; |
|
1
|
|
|
|
|
2
|
|
|
1
|
|
|
|
|
28
|
|
5
|
1
|
|
|
1
|
|
3
|
use strict; |
|
1
|
|
|
|
|
2
|
|
|
1
|
|
|
|
|
15
|
|
6
|
1
|
|
|
1
|
|
11
|
use utf8; |
|
1
|
|
|
|
|
2
|
|
|
1
|
|
|
|
|
6
|
|
7
|
1
|
|
|
1
|
|
26
|
use Carp; |
|
1
|
|
|
|
|
1
|
|
|
1
|
|
|
|
|
68
|
|
8
|
|
|
|
|
|
|
|
9
|
|
|
|
|
|
|
our $VERSION = 'v2.0.3'; |
10
|
|
|
|
|
|
|
|
11
|
1
|
|
|
1
|
|
6
|
use IO::Stream::const; |
|
1
|
|
|
|
|
1
|
|
|
1
|
|
|
|
|
27
|
|
12
|
|
|
|
|
|
|
|
13
|
|
|
|
|
|
|
sub new { |
14
|
2
|
|
|
2
|
0
|
921
|
my ($class) = @_; |
15
|
2
|
|
|
|
|
11
|
my $self = bless { |
16
|
|
|
|
|
|
|
out_buf => q{}, # modified on: OUT |
17
|
|
|
|
|
|
|
out_pos => undef, # modified on: OUT |
18
|
|
|
|
|
|
|
out_bytes => 0, # modified on: OUT |
19
|
|
|
|
|
|
|
in_buf => q{}, # modified on: IN |
20
|
|
|
|
|
|
|
in_bytes => 0, # modified on: IN |
21
|
|
|
|
|
|
|
ip => undef, # modified on: RESOLVED |
22
|
|
|
|
|
|
|
is_eof => undef, # modified on: EOF |
23
|
|
|
|
|
|
|
}, $class; |
24
|
2
|
|
|
|
|
15
|
return $self; |
25
|
|
|
|
|
|
|
} |
26
|
|
|
|
|
|
|
|
27
|
|
|
|
|
|
|
sub PREPARE { |
28
|
2
|
|
|
2
|
0
|
3
|
my ($self, $fh, $host, $port) = @_; |
29
|
2
|
|
|
|
|
11
|
$self->{_slave}->PREPARE($fh, $host, $port); |
30
|
2
|
|
|
|
|
3
|
return; |
31
|
|
|
|
|
|
|
} |
32
|
|
|
|
|
|
|
|
33
|
|
|
|
|
|
|
sub WRITE { |
34
|
2
|
|
|
2
|
|
762
|
my ($self) = @_; |
35
|
2
|
|
|
|
|
5
|
my $m = $self->{_master}; |
36
|
2
|
|
|
|
|
3
|
$self->{out_buf} = $m->{out_buf}; |
37
|
2
|
|
|
|
|
4
|
$self->{out_pos} = $m->{out_pos}; |
38
|
2
|
|
|
|
|
3
|
$self->{out_bytes} = $m->{out_bytes}; |
39
|
2
|
|
|
|
|
6
|
$self->{_slave}->WRITE(); |
40
|
2
|
|
|
|
|
3
|
return; |
41
|
|
|
|
|
|
|
} |
42
|
|
|
|
|
|
|
|
43
|
|
|
|
|
|
|
sub EVENT { |
44
|
8
|
|
|
8
|
0
|
3917
|
my ($self, $e, $err) = @_; |
45
|
8
|
|
|
|
|
13
|
my $m = $self->{_master}; |
46
|
8
|
100
|
|
|
|
15
|
if ($e & OUT) { |
47
|
2
|
|
|
|
|
6
|
$m->{out_buf} = $self->{out_buf}; |
48
|
2
|
|
|
|
|
4
|
$m->{out_pos} = $self->{out_pos}; |
49
|
2
|
|
|
|
|
2
|
$m->{out_bytes} = $self->{out_bytes}; |
50
|
|
|
|
|
|
|
} |
51
|
8
|
100
|
|
|
|
14
|
if ($e & IN) { |
52
|
2
|
|
|
|
|
4
|
$m->{in_buf} .= $self->{in_buf}; |
53
|
2
|
|
|
|
|
5
|
$m->{in_bytes} += $self->{in_bytes}; |
54
|
2
|
|
|
|
|
3
|
$self->{in_buf} = q{}; |
55
|
2
|
|
|
|
|
3
|
$self->{in_bytes}= 0; |
56
|
|
|
|
|
|
|
} |
57
|
8
|
100
|
|
|
|
13
|
if ($e & RESOLVED) { |
58
|
2
|
|
|
|
|
3
|
$m->{ip} = $self->{ip}; |
59
|
|
|
|
|
|
|
} |
60
|
8
|
100
|
|
|
|
11
|
if ($e & EOF) { |
61
|
2
|
|
|
|
|
3
|
$m->{is_eof} = $self->{is_eof}; |
62
|
|
|
|
|
|
|
} |
63
|
8
|
|
|
|
|
21
|
$m->EVENT($e, $err); |
64
|
8
|
|
|
|
|
14
|
return; |
65
|
|
|
|
|
|
|
} |
66
|
|
|
|
|
|
|
|
67
|
|
|
|
|
|
|
|
68
|
|
|
|
|
|
|
1; |