126 |
return; |
return; |
127 |
} |
} |
128 |
chomp( my $size = <$sock> ); |
chomp( my $size = <$sock> ); |
129 |
warn "[$port] <<<< $node $size bytes\n"; |
warn "[$port] <<<< $node $size bytes\n" if $debug || $size > 1024; |
130 |
my $data; |
my $data; |
131 |
read $sock, $data, $size; |
read $sock, $data, $size; |
132 |
return $data; |
return $data; |
135 |
sub send_sock { |
sub send_sock { |
136 |
my ( $sock, $data ) = @_; |
my ( $sock, $data ) = @_; |
137 |
my $size = length $data; |
my $size = length $data; |
138 |
warn "[$port] >>>> ", $sock->peerhost, " $size bytes\n"; |
warn "[$port] >>>> $size bytes\n" if $debug || $size > 1024; |
139 |
print $sock "$size\n$data" || warn "can't send $size bytes to ", $sock->peerhost; |
print $sock "$size\n$data" || warn "can't send $size bytes to ", $sock->peerhost; |
140 |
} |
} |
141 |
|
|