}
}
-sub processjob ($) {
- my ($j) = @_;
- processjobbranch($j,undef);
- processjobbranch($j,$_) foreach @branches;
+my @tasks;
+foreach my $j (@jobs) {
+ push @tasks, $j;
+ push @tasks, "$j $_" foreach @branches;
}
-parallel_by_fork('sg-report-job-history', $maxjobs, \@jobs, sub {
- my ($j) = @_;
+parallel_by_fork('sg-report-job-history', $maxjobs, \@tasks, sub {
+ my ($task) = @_;
+ my ($job, $branch) = split / /, $task; # $branch might be undef
db_retry($dbh_tests, [], sub {
- processjob($j);
+ processjobbranch($job, $branch);
});
});