package ftp; # $Id$ use Net::FTP; use network; use log; my %hosts; 1; sub fromEnv() { #- now URLPREFIX is generated from what is given by mdk-stage1 which is only this 4 variables. $ENV{URLPREFIX} = "ftp://" . ($ENV{LOGIN} && ("$ENV{LOGIN}" . ($ENV{PASSWORD} && ":$ENV{PASSWORD}") . '@')) . "$ENV{HOST}/$ENV{PREFIX}"; @ENV{qw(HOST PREFIX LOGIN PASSWORD)}; } sub new { my ($host, $prefix, $login, $password) = @_; my @l = do { if ($hosts{"$host$prefix"}) { @{$hosts{"$host$prefix"}}; } else { 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::resolv($host), %options) or die; $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"; $ftp->binary; $ftp->cwd($prefix); my @l = ($ftp, \ (my $retr = undef)); $hosts{"$host$prefix"} = \@l; @l; }}; wantarray ? @l : $l[0]; } sub getFile { my ($f, @para) = @_; $f eq 'XXX' and rewindGetFile(), return; #- special case to force closing connection. foreach (1..3) { my ($ftp, $retr) = new(@para ? @para : fromEnv); eval { $$retr->close if $$retr }; $@ and rewindGetFile(); #- in case Timeout got us on "->close" $$retr = $ftp->retr($f) and return $$retr; ($ftp->code == 550) and log::l("FTP: 550 file unavailable"), return; rewindGetFile(); log::l("ftp get failed, sleeping before trying again"); 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) = @{$_ || []}; #- don't let Timeout kill us! eval { $$retr->close } if $$retr; eval { $ftp->close } if $ftp; } #- make sure to reconnect to server. %hosts = (); } re/rpm/urpmi/log/t/rpm-v3?h=8.118.2'>log</a><a href='/software/rpm/urpmi/tree/t/rpm-v3?h=8.118.2'>tree</a><a class='active' href='/software/rpm/urpmi/commit/t/rpm-v3?h=8.118.2'>commit</a><a href='/software/rpm/urpmi/diff/t/rpm-v3?h=8.118.2'>diff</a><a href='/software/rpm/urpmi/stats/t/rpm-v3?h=8.118.2'>stats</a></td><td class='form'><form class='right' method='get' action='/software/rpm/urpmi/log/t/rpm-v3'> <input type='hidden' name='h' value='8.118.2'/><select name='qt'> <option value='grep'>log msg</option> <option value='author'>author</option> <option value='committer'>committer</option> <option value='range'>range</option> </select> <input class='txt' type='search' size='10' name='q' value=''/> <input type='submit' value='search'/> </form> </td></tr></table> <div class='path'>path: <a href='/software/rpm/urpmi/commit/?h=8.118.2'>root</a>/<a href='/software/rpm/urpmi/commit/t?h=8.118.2'>t</a>/<a href='/software/rpm/urpmi/commit/t/rpm-v3?h=8.118.2'>rpm-v3</a></div><div class='content'><div class='cgit-panel'><b>diff options</b><form method='get'><input type='hidden' name='h' value='8.118.2'/><table><tr><td colspan='2'/></tr><tr><td class='label'>context:</td><td class='ctrl'><select name='context' onchange='this.form.submit();'><option value='1'>1</option><option value='2'>2</option><option value='3' selected='selected'>3</option><option value='4'>4</option><option value='5'>5</option><option value='6'>6</option><option value='7'>7</option><option value='8'>8</option><option value='9'>9</option><option value='10'>10</option><option value='15'>15</option><option value='20'>20</option><option value='25'>25</option><option value='30'>30</option><option value='35'>35</option><option value='40'>40</option></select></td></tr><tr><td class='label'>space:</td><td class='ctrl'><select name='ignorews' onchange='this.form.submit();'><option value='0' selected='selected'>include</option><option value='1'>ignore</option></select></td></tr><tr><td class='label'>mode:</td><td class='ctrl'><select name='dt' onchange='this.form.submit();'><option value='0' selected='selected'>unified</option><option value='1'>ssdiff</option><option value='2'>stat only</option></select></td></tr><tr><td/><td class='ctrl'><noscript><input type='submit' value='reload'/></noscript></td></tr></table></form></div><table summary='commit info' class='commit-info'> <tr><th>author</th><td>Martin Whitaker <mageia@martin-whitaker.me.uk></td><td class='right'>2019-10-21 17:13:46 +0100</td></tr> <tr><th>committer</th><td>Martin Whitaker <mageia@martin-whitaker.me.uk></td><td class='right'>2019-10-21 17:13:46 +0100</td></tr> <tr><th>commit</th><td colspan='2' class='sha1'><a href='/software/rpm/urpmi/commit/t/rpm-v3?h=8.118.2&id=69cc2b36c0a18513d24f2e53bd51bc2615fa69de'>69cc2b36c0a18513d24f2e53bd51bc2615fa69de</a> (<a href='/software/rpm/urpmi/patch/t/rpm-v3?id=69cc2b36c0a18513d24f2e53bd51bc2615fa69de'>patch</a>)</td></tr> <tr><th>tree</th><td colspan='2' class='sha1'><a href='/software/rpm/urpmi/tree/?h=8.118.2'>ed841b99f95686f29219a90260b89aa902942b99</a> /<a href='/software/rpm/urpmi/tree/t/rpm-v3?h=8.118.2'>t/rpm-v3</a></td></tr> <tr><th>parent</th><td colspan='2' class='sha1'><a href='/software/rpm/urpmi/commit/t/rpm-v3?h=8.118.2&id=64bb8dbff19ea55b772912686817fc15e9253e13'>64bb8dbff19ea55b772912686817fc15e9253e13</a> (<a href='/software/rpm/urpmi/diff/t/rpm-v3?h=8.118.2&id2=64bb8dbff19ea55b772912686817fc15e9253e13'>diff</a>)</td></tr><tr><th>download</th><td colspan='2' class='sha1'><a href='/software/rpm/urpmi/snapshot/urpmi-8.118.2.tar'>urpmi-8.118.2.tar</a><br/><a href='/software/rpm/urpmi/snapshot/urpmi-8.118.2.tar.gz'>urpmi-8.118.2.tar.gz</a><br/><a href='/software/rpm/urpmi/snapshot/urpmi-8.118.2.tar.bz2'>urpmi-8.118.2.tar.bz2</a><br/><a href='/software/rpm/urpmi/snapshot/urpmi-8.118.2.tar.xz'>urpmi-8.118.2.tar.xz</a><br/><a href='/software/rpm/urpmi/snapshot/urpmi-8.118.2.zip'>urpmi-8.118.2.zip</a><br/></td></tr></table> <div class='commit-subject'>8.118.2<span class='decoration'><a class='tag-deco' href='/software/rpm/urpmi/tag/?h=8.118.2'>8.118.2</a><a class='branch-deco' href='/software/rpm/urpmi/log/t/rpm-v3?h=distro/mga7'>distro/mga7</a></span></div><div class='commit-msg'></div><div class='diffstat-header'><a href='/software/rpm/urpmi/diff/?h=8.118.2'>Diffstat</a> (limited to 't/rpm-v3')</div><table summary='diffstat' class='diffstat'>