diff options
| -rw-r--r-- | urpm.pm | 7 | ||||
| -rwxr-xr-x | urpmi | 8 |
2 files changed, 5 insertions, 10 deletions
@@ -2918,13 +2918,6 @@ sub install { @l; } -#- install all files to node as remembered according to resolving done. -sub parallel_install { - my @para = @_; - my ($urpm, $_remove, $_install, $_upgrade, %_options) = @para; - $urpm->{parallel_handler}->parallel_install(@para); -} - #- find packages to remove. #- options: #- bundle @@ -693,9 +693,11 @@ foreach my $set (@{$state->{transaction} || []}) { print N("distributing %s", join(' ', values %transaction_sources_install, values %transaction_sources)), "\n"; #- no remove are handle here, automatically done by each distant node. $urpm->{log}("starting distributed install"); - $urpm->parallel_install([ keys %{$state->{rejected} || {}} ], \%transaction_sources_install, \%transaction_sources, - test => $test, - excludepath => $urpm->{options}{excludepath}, excludedocs => $urpm->{options}{excludedocs}); + $urpm->{parallel_handler}->parallel_install( + [ keys %{$state->{rejected} || {}} ], \%transaction_sources_install, \%transaction_sources, + test => $test, + excludepath => $urpm->{options}{excludepath}, excludedocs => $urpm->{options}{excludedocs}, + ); } else { my @packnames = (values %transaction_sources_install, values %transaction_sources); (my $common_prefix) = $packnames[0] =~ m!^(.*)/!; |