diff options
| -rw-r--r-- | urpm/parallel.pm | 10 | ||||
| -rw-r--r-- | urpm/parallel_ka_run.pm | 6 | ||||
| -rw-r--r-- | urpm/parallel_ssh.pm | 6 |
3 files changed, 12 insertions, 10 deletions
diff --git a/urpm/parallel.pm b/urpm/parallel.pm index 442dd29d..441da68a 100644 --- a/urpm/parallel.pm +++ b/urpm/parallel.pm @@ -66,4 +66,14 @@ sub remove { ); } +sub post_register_rpms { + my ($parallel, $urpm, @files) = @_; + + #- keep trace of direct files. + $parallel->{line} .= + join(' ', + map { "'$_'" } + map { "$urpm->{cachedir}/rpms/" . basename($_) } @files); +} + 1; diff --git a/urpm/parallel_ka_run.pm b/urpm/parallel_ka_run.pm index 1d02cdbc..3a0c79f5 100644 --- a/urpm/parallel_ka_run.pm +++ b/urpm/parallel_ka_run.pm @@ -32,11 +32,7 @@ sub parallel_register_rpms { system $mput_command, split(' ', $parallel->{options}), '--', @files, "$urpm->{cachedir}/rpms/"; $? == 0 || $? == 256 or $urpm->{fatal}(1, N("mput failed, maybe a node is unreacheable")); - #- keep trace of direct files. - $parallel->{line} .= - join(' ', - map { "'$_'" } - map { "$urpm->{cachedir}/rpms/" . basename($_) } @files); + urpm::parallel::post_register_rpms($parallel, $urpm, @files); } #- parallel find_packages_to_remove diff --git a/urpm/parallel_ssh.pm b/urpm/parallel_ssh.pm index d17bb061..722112eb 100644 --- a/urpm/parallel_ssh.pm +++ b/urpm/parallel_ssh.pm @@ -34,11 +34,7 @@ sub parallel_register_rpms { $? == 0 or $urpm->{fatal}(1, N("scp failed on host %s (%d)", $host, $? >> 8)); } - #- keep trace of direct files. - $parallel->{line} .= - join(' ', - map { "'$_'" } - map { "$urpm->{cachedir}/rpms/" . basename($_) } @files); + urpm::parallel::post_register_rpms($parallel, $urpm, @files); } #- parallel find_packages_to_remove |