diff options
Diffstat (limited to 'urpm/parallel_ssh.pm')
| -rw-r--r-- | urpm/parallel_ssh.pm | 16 |
1 files changed, 3 insertions, 13 deletions
diff --git a/urpm/parallel_ssh.pm b/urpm/parallel_ssh.pm index 35b6e79a..d43c2fb8 100644 --- a/urpm/parallel_ssh.pm +++ b/urpm/parallel_ssh.pm @@ -41,20 +41,10 @@ sub parallel_register_rpms { #- parallel find_packages_to_remove sub parallel_find_remove { my ($parallel, $urpm, $state, $l, %options) = @_; - my ($test, %bad_nodes, %base_to_remove, %notfound); + my (%bad_nodes, %base_to_remove, %notfound); - #- keep in mind if the previous selection is still active, it avoids - #- to re-start urpme --test on each node. - if ($options{find_packages_to_remove}) { - delete $state->{rejected}; - delete $urpm->{error_remove}; - $test = '--test '; - } else { - @{$urpm->{error_remove} || []} and return @{$urpm->{error_remove}}; - #- no need to restart what has been started before. - $options{test} and return keys %{$state->{rejected}}; - $test = '--force '; - } + my ($test, $pkgs) = urpm::parallel::find_remove_pre($urpm, $state, %options); + $pkgs and return @$pkgs; #- now try an iteration of urpme. foreach my $node (keys %{$parallel->{nodes}}) { |