diff options
author | Pascal Rigaux <pixel@mandriva.com> | 2008-07-10 11:47:18 +0000 |
---|---|---|
committer | Pascal Rigaux <pixel@mandriva.com> | 2008-07-10 11:47:18 +0000 |
commit | 3bf21d8574c51ae6fcf8cb29d3344ecab1887154 (patch) | |
tree | c4d60c9b901bf821960d4274050372df7771b883 /urpm/parallel_ka_run.pm | |
parent | 3cf4af2f1bc0f043f512d676526779c94ad1451c (diff) | |
download | urpmi-3bf21d8574c51ae6fcf8cb29d3344ecab1887154.tar urpmi-3bf21d8574c51ae6fcf8cb29d3344ecab1887154.tar.gz urpmi-3bf21d8574c51ae6fcf8cb29d3344ecab1887154.tar.bz2 urpmi-3bf21d8574c51ae6fcf8cb29d3344ecab1887154.tar.xz urpmi-3bf21d8574c51ae6fcf8cb29d3344ecab1887154.zip |
normalize parameters ordering
Diffstat (limited to 'urpm/parallel_ka_run.pm')
-rw-r--r-- | urpm/parallel_ka_run.pm | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/urpm/parallel_ka_run.pm b/urpm/parallel_ka_run.pm index ba549e00..b9991618 100644 --- a/urpm/parallel_ka_run.pm +++ b/urpm/parallel_ka_run.pm @@ -26,16 +26,16 @@ if (!$rshp_command) { $rshp_command ||= 'rshp'; sub _rshp_urpm { - my ($urpm, $parallel, $rshp_option, $cmd, $para) = @_; + my ($parallel, $urpm, $rshp_option, $cmd, $para) = @_; my $command = "$rshp_command $rshp_option $parallel->{options} -- $cmd --no-locales $para"; $urpm->{log}("parallel_ka_run: $command"); $command; } sub _rshp_urpm_popen { - my ($urpm, $parallel, $cmd, $para) = @_; + my ($parallel, $urpm, $cmd, $para) = @_; - my $command = _rshp_urpm($urpm, $parallel, '-v', $cmd, $para); + my $command = _rshp_urpm($parallel, $urpm, '-v', $cmd, $para); open(my $fh, "$command |") or $urpm->{fatal}(1, "Can't fork $rshp_command: $!"); $fh; } @@ -43,7 +43,7 @@ sub _rshp_urpm_popen { sub urpm_popen { my ($parallel, $urpm, $cmd, $para, $do) = @_; - my $fh = _rshp_urpm_popen($urpm, $parallel, $cmd, $para); + my $fh = _rshp_urpm_popen($parallel, $urpm, $cmd, $para); while (my $s = <$fh>) { chomp $s; @@ -55,7 +55,7 @@ sub urpm_popen { } sub _run_mput { - my ($urpm, $parallel, @para) = @_; + my ($parallel, $urpm, @para) = @_; my @l = (split(' ', $parallel->{options}), '--', @para); $urpm->{log}("parallel_ka_run: $mput_command " . join(' ', @l)); @@ -67,7 +67,7 @@ sub _run_mput { sub parallel_register_rpms { my ($parallel, $urpm, @files) = @_; - _run_mput($urpm, $parallel, @files, "$urpm->{cachedir}/rpms/"); + _run_mput($parallel, $urpm, @files, "$urpm->{cachedir}/rpms/"); urpm::parallel::post_register_rpms($parallel, $urpm, @files); } @@ -77,7 +77,7 @@ sub parallel_resolve_dependencies { my ($parallel, $synthesis, $urpm, $state, $requested, %options) = @_; #- first propagate the synthesis file to all machines - _run_mput($urpm, $parallel, $synthesis, $synthesis); + _run_mput($parallel, $urpm, $synthesis, $synthesis); $parallel->{synthesis} = $synthesis; @@ -106,7 +106,7 @@ sub parallel_resolve_dependencies { sub parallel_install { my ($parallel, $urpm, undef, $install, $upgrade, %options) = @_; - _run_mput($urpm, $parallel, values %$install, values %$upgrade, "$urpm->{cachedir}/rpms/"); + _run_mput($parallel, $urpm, values %$install, values %$upgrade, "$urpm->{cachedir}/rpms/"); my (%bad_nodes); $parallel->urpm_popen($urpm, 'urpmi', "--pre-clean --test --no-verify-rpm --auto --synthesis $parallel->{synthesis} $parallel->{line}", sub { @@ -129,7 +129,7 @@ sub parallel_install { } else { my $line = $parallel->{line} . ($options{excludepath} ? " --excludepath '$options{excludepath}'" : ""); #- continue installation. - system(_rshp_urpm($urpm, $parallel, '', 'urpmi', "--no-verify-rpm --auto --synthesis $parallel->{synthesis} $line")) == 0; + system(_rshp_urpm($parallel, $urpm, '', 'urpmi', "--no-verify-rpm --auto --synthesis $parallel->{synthesis} $line")) == 0; } } |