| 1 |
root |
1.1 |
## $Id: //depot/libnet/Net/FTP/I.pm#13 $ |
| 2 |
|
|
## Package to read/write on BINARY data connections |
| 3 |
|
|
## |
| 4 |
|
|
|
| 5 |
|
|
package Net::FTP::I; |
| 6 |
|
|
|
| 7 |
|
|
use vars qw(@ISA $buf $VERSION); |
| 8 |
|
|
use Carp; |
| 9 |
|
|
|
| 10 |
|
|
require Net::FTP::dataconn; |
| 11 |
|
|
|
| 12 |
|
|
@ISA = qw(Net::FTP::dataconn); |
| 13 |
|
|
$VERSION = "1.12"; |
| 14 |
|
|
|
| 15 |
|
|
sub read { |
| 16 |
|
|
my $data = shift; |
| 17 |
|
|
local *buf = \$_[0]; shift; |
| 18 |
|
|
my $size = shift || croak 'read($buf,$size,[$timeout])'; |
| 19 |
|
|
my $timeout = @_ ? shift : $data->timeout; |
| 20 |
|
|
|
| 21 |
|
|
my $n; |
| 22 |
|
|
|
| 23 |
|
|
if ($size > length ${*$data} and !${*$data}{'net_ftp_eof'}) { |
| 24 |
|
|
$data->can_read($timeout) or |
| 25 |
|
|
croak "Timeout"; |
| 26 |
|
|
|
| 27 |
|
|
my $blksize = ${*$data}{'net_ftp_blksize'}; |
| 28 |
|
|
$blksize = $size if $size > $blksize; |
| 29 |
|
|
|
| 30 |
|
|
unless ($n = sysread($data, ${*$data}, $blksize, length ${*$data})) { |
| 31 |
|
|
return undef unless defined $n; |
| 32 |
|
|
${*$data}{'net_ftp_eof'} = 1; |
| 33 |
|
|
} |
| 34 |
|
|
} |
| 35 |
|
|
|
| 36 |
|
|
$buf = substr(${*$data},0,$size); |
| 37 |
|
|
|
| 38 |
|
|
$n = length($buf); |
| 39 |
|
|
|
| 40 |
|
|
substr(${*$data},0,$n) = ''; |
| 41 |
|
|
|
| 42 |
|
|
${*$data}{'net_ftp_bytesread'} += $n; |
| 43 |
|
|
|
| 44 |
|
|
$n; |
| 45 |
|
|
} |
| 46 |
|
|
|
| 47 |
|
|
sub write { |
| 48 |
|
|
my $data = shift; |
| 49 |
|
|
local *buf = \$_[0]; shift; |
| 50 |
|
|
my $size = shift || croak 'write($buf,$size,[$timeout])'; |
| 51 |
|
|
my $timeout = @_ ? shift : $data->timeout; |
| 52 |
|
|
|
| 53 |
|
|
# If the remote server has closed the connection we will be signal'd |
| 54 |
|
|
# when we write. This can happen if the disk on the remote server fills up |
| 55 |
|
|
|
| 56 |
|
|
local $SIG{PIPE} = 'IGNORE' unless $^O eq 'MacOS'; |
| 57 |
|
|
my $sent = $size; |
| 58 |
|
|
my $off = 0; |
| 59 |
|
|
|
| 60 |
|
|
my $blksize = ${*$data}{'net_ftp_blksize'}; |
| 61 |
|
|
while($sent > 0) { |
| 62 |
|
|
$data->can_write($timeout) or |
| 63 |
|
|
croak "Timeout"; |
| 64 |
|
|
|
| 65 |
|
|
my $n = syswrite($data, $buf, $sent > $blksize ? $blksize : $sent ,$off); |
| 66 |
|
|
return undef unless defined($n); |
| 67 |
|
|
$sent -= $n; |
| 68 |
|
|
$off += $n; |
| 69 |
|
|
} |
| 70 |
|
|
|
| 71 |
|
|
$size; |
| 72 |
|
|
} |
| 73 |
|
|
|
| 74 |
|
|
1; |
