summaryrefslogtreecommitdiffstats
path: root/urpm/parallel_ssh.pm
diff options
context:
space:
mode:
authorFrancois Pons <fpons@mandriva.com>2002-08-27 11:53:11 +0000
committerFrancois Pons <fpons@mandriva.com>2002-08-27 11:53:11 +0000
commitf81bbee311b3be991a13a2aaa3bef8183294e8b2 (patch)
tree526b508e5b91bc2153147f1273935719a7b2cdec /urpm/parallel_ssh.pm
parent6987d4315ab303a662f93c982795ac1d47c76ba6 (diff)
downloadurpmi-f81bbee311b3be991a13a2aaa3bef8183294e8b2.tar
urpmi-f81bbee311b3be991a13a2aaa3bef8183294e8b2.tar.gz
urpmi-f81bbee311b3be991a13a2aaa3bef8183294e8b2.tar.bz2
urpmi-f81bbee311b3be991a13a2aaa3bef8183294e8b2.tar.xz
urpmi-f81bbee311b3be991a13a2aaa3bef8183294e8b2.zip
4.0-5mdk
Diffstat (limited to 'urpm/parallel_ssh.pm')
-rw-r--r--urpm/parallel_ssh.pm28
1 files changed, 15 insertions, 13 deletions
diff --git a/urpm/parallel_ssh.pm b/urpm/parallel_ssh.pm
index 46a21b34..bd7ee200 100644
--- a/urpm/parallel_ssh.pm
+++ b/urpm/parallel_ssh.pm
@@ -77,29 +77,30 @@ sub parallel_install {
system "scp $sources $_:$urpm->{cachedir}/rpms";
}
- my (%good_nodes, $bad);
+ my %bad_nodes;
foreach my $node (keys %{$parallel->{nodes}}) {
local (*F, $_);
$urpm->{log}("parallel_ssh: ssh $node urpmi --no-locales --test --no-verify-rpm --auto --synthesis $parallel->{synthesis} $parallel->{line}");
open F, "ssh $node urpmi --no-locales --test --no-verify-rpm --auto --synthesis $parallel->{synthesis} $parallel->{line} |";
while ($_ = <F>) {
- chomp;
- /Installation is possible/ and $good_nodes{$node} = undef;
+ $bad_nodes{$node} .= $_;
+ /Installation failed/ and $bad_nodes{$node} = '';
+ /Installation is possible/ and delete $bad_nodes{$node}, last;
}
close F;
}
foreach (keys %{$parallel->{nodes}}) {
- exists $good_nodes{$_} and next;
- $urpm->{error}(_("Installation failed on node %s", $_) . ":\n" . ""); #TODO
- $bad = 1;
+ exists $bad_nodes{$_} or next;
+ $urpm->{error}(_("Installation failed on node %s", $_) . ":\n" . $bad_nodes{$_});
}
- unless ($bad) {
- foreach my $node (keys %{$parallel->{nodes}}) {
- #- continue installation.
- $urpm->{log}("parallel_ssh: ssh $node urpmi --no-locales --no-verify-rpm --auto --synthesis $parallel->{synthesis} $parallel->{line}");
- system "ssh $node urpmi --no-locales --no-verify-rpm --auto --synthesis $parallel->{synthesis} $parallel->{line}";
- }
+ %bad_nodes and return;
+
+ #- continue installation on each nodes.
+ foreach my $node (keys %{$parallel->{nodes}}) {
+ $urpm->{log}("parallel_ssh: ssh $node urpmi --no-locales --no-verify-rpm --auto --synthesis $parallel->{synthesis} $parallel->{line}");
+ system "ssh $node urpmi --no-locales --no-verify-rpm --auto --synthesis $parallel->{synthesis} $parallel->{line}";
}
+ 1;
}
@@ -109,10 +110,11 @@ sub handle_parallel_options {
my ($urpm, $options) = @_;
my ($id, @nodes) = split ':', $options;
- if ($id eq 'ssh') {
+ if ($id =~ /^ssh(?:\(([^\)]*)\))?$/) {
my %nodes; @nodes{@nodes} = undef;
return bless {
+ media => $1,
nodes => \%nodes,
}, "urpm::parallel_ssh";
}