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
88
89
90
91
92
93
94
95
96
97
98
99
100
|
package install::ftp; # $Id$
use Net::FTP;
use network::network;
use log;
my %hosts;
1;
sub parse_ftp_url {
my ($url) = @_;
$url =~ m!^ftp://(?:(.*?)(?::(.*?))?\@)?([^/]+)/(.*)! &&
($3, $4, $1, $2);
}
sub _new {
my ($url) = @_;
my ($host, $prefix, $login, $password) = parse_ftp_url($url);
if ($hosts{"$host$prefix"}) {
return @{$hosts{"$host$prefix"}};
}
my %options = (Passive => 1, Timeout => 60, Port => 21);
$options{Firewall} = $ENV{PROXY} if $ENV{PROXY};
$options{Port} = $ENV{PROXYPORT} if $ENV{PROXYPORT};
unless ($login) {
$login = 'anonymous';
$password = '-drakx@';
}
my $ftp;
foreach (1..10) {
$ftp = Net::FTP->new(network::network::resolv($host), %options) or die "Can't resolve hostname '$host'\n";
$ftp && $ftp->login($login, $password) and last;
log::l("ftp login failed, sleeping before trying again");
sleep 5 * $_;
}
$ftp or die "unable to open ftp connection to $host\n";
$ftp->binary;
$ftp->cwd($prefix);
my @l = ($ftp, \ (my $_retr));
$hosts{"$host$prefix"} = \@l;
@l;
}
sub getFile {
my ($f, $url) = @_;
my ($_size, $fh) = get_file_and_size($f, $url) or return;
$fh;
}
sub get_file_and_size {
my ($f, $url) = @_;
foreach (1..3) {
my ($ftp, $retr) = _new($url);
eval { $$retr->close if $$retr };
if ($@) {
log::l("FTP: closing previous retr failed ($@)");
_rewindGetFile(); #- in case Timeout got us on "->close"
redo;
}
my $size = $ftp->size($f);
$$retr = $ftp->retr($f) and return $size, $$retr;
my $error = $ftp->code;
$error == 550 and log::l("FTP: 550 file unavailable"), return;
_rewindGetFile();
log::l("ftp get failed, sleeping before trying again (error:$error)");
sleep 1;
}
}
#-sub closeFiles() {
#- #- close any existing connections
#- foreach (values %hosts) {
#- my $retr = $_->[1] if ref $_;
#- $$retr->close if $$retr;
#- undef $$retr;
#- }
#-}
sub _rewindGetFile() {
#- close any existing connection.
foreach (values %hosts) {
my ($ftp, $retr) = @{$_ || []};
#- do not let Timeout kill us!
eval { $$retr->close } if $$retr;
eval { $ftp->close } if $ftp;
}
#- make sure to reconnect to server.
%hosts = ();
}
|
