diff options
| -rw-r--r-- | urpm/parallel.pm | 8 | ||||
| -rw-r--r-- | urpm/parallel_ka_run.pm | 9 | ||||
| -rw-r--r-- | urpm/parallel_ssh.pm | 8 |
3 files changed, 8 insertions, 17 deletions
diff --git a/urpm/parallel.pm b/urpm/parallel.pm index 0b6edba5..0feed52c 100644 --- a/urpm/parallel.pm +++ b/urpm/parallel.pm @@ -104,6 +104,14 @@ sub parallel_find_remove { keys %{$state->{rejected}}; } + +#- parallel copy +sub parallel_register_rpms { + my ($parallel, $urpm, @files) = @_; + + copy_to_dir($parallel, $urpm, @files, "$urpm->{cachedir}/rpms"); + urpm::parallel::post_register_rpms($parallel, $urpm, @files); +} sub post_register_rpms { my ($parallel, $urpm, @files) = @_; diff --git a/urpm/parallel_ka_run.pm b/urpm/parallel_ka_run.pm index ca3a86a4..d915e8c4 100644 --- a/urpm/parallel_ka_run.pm +++ b/urpm/parallel_ka_run.pm @@ -65,15 +65,6 @@ sub _run_mput { $? == 0 || $? == 256 or $urpm->{fatal}(1, N("mput failed, maybe a node is unreacheable")); } -#- parallel copy -sub parallel_register_rpms { - my ($parallel, $urpm, @files) = @_; - - copy_to_dir($parallel, $urpm, @files, "$urpm->{cachedir}/rpms/"); - - urpm::parallel::post_register_rpms($parallel, $urpm, @files); -} - #- parallel resolve_dependencies sub parallel_resolve_dependencies { my ($parallel, $synthesis, $urpm, $state, $requested, %options) = @_; diff --git a/urpm/parallel_ssh.pm b/urpm/parallel_ssh.pm index 4c2f7ab1..1c416f2b 100644 --- a/urpm/parallel_ssh.pm +++ b/urpm/parallel_ssh.pm @@ -74,14 +74,6 @@ sub urpm_popen { } } -#- parallel copy -sub parallel_register_rpms { - my ($parallel, $urpm, @files) = @_; - - copy_to_dir($parallel, $urpm, @files, "$urpm->{cachedir}/rpms"); - urpm::parallel::post_register_rpms($parallel, $urpm, @files); -} - #- parallel resolve_dependencies sub parallel_resolve_dependencies { my ($parallel, $synthesis, $urpm, $state, $requested, %options) = @_; |