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
|
# No-op plugin example.
package IO::Stream::Noop;
use 5.010001;
use warnings;
use strict;
use utf8;
use Carp;
our $VERSION = 'v2.0.3';
use IO::Stream::const;
sub new {
my ($class) = @_;
my $self = bless {
out_buf => q{}, # modified on: OUT
out_pos => undef, # modified on: OUT
out_bytes => 0, # modified on: OUT
in_buf => q{}, # modified on: IN
in_bytes => 0, # modified on: IN
ip => undef, # modified on: RESOLVED
is_eof => undef, # modified on: EOF
}, $class;
return $self;
}
sub PREPARE {
my ($self, $fh, $host, $port) = @_;
$self->{_slave}->PREPARE($fh, $host, $port);
return;
}
sub WRITE {
my ($self) = @_;
my $m = $self->{_master};
$self->{out_buf} = $m->{out_buf};
$self->{out_pos} = $m->{out_pos};
$self->{out_bytes} = $m->{out_bytes};
$self->{_slave}->WRITE();
return;
}
sub EVENT {
my ($self, $e, $err) = @_;
my $m = $self->{_master};
if ($e & OUT) {
$m->{out_buf} = $self->{out_buf};
$m->{out_pos} = $self->{out_pos};
$m->{out_bytes} = $self->{out_bytes};
}
if ($e & IN) {
$m->{in_buf} .= $self->{in_buf};
$m->{in_bytes} += $self->{in_bytes};
$self->{in_buf} = q{};
$self->{in_bytes}= 0;
}
if ($e & RESOLVED) {
$m->{ip} = $self->{ip};
}
if ($e & EOF) {
$m->{is_eof} = $self->{is_eof};
}
$m->EVENT($e, $err);
return;
}
1;
|
