our %hosts;
-sub mainquery () {
+sub mainquery ($) {
+ my ($host) = @_;
+
our $runvarq //= db_prepare(<<END);
SELECT flight, job, name, status
FROM runvars
ORDER BY flight DESC
LIMIT $limit * 2
END
- foreach my $host (sort keys %hosts) {
- print DEBUG "MAINQUERY $host...\n";
- $runvarq->execute($host, $minflight);
- $hosts{$host} = $runvarq->fetchall_arrayref({});
- print DEBUG "MAINQUERY $host got ".(scalar @{ $hosts{$host} })."\n";
- }
+ print DEBUG "MAINQUERY $host...\n";
+ $runvarq->execute($host, $minflight);
+
+ $hosts{$host} = $runvarq->fetchall_arrayref({});
+ print DEBUG "MAINQUERY $host got ".(scalar @{ $hosts{$host} })."\n";
}
sub reporthost ($) {
});
db_retry($dbh_tests, [], sub {
- mainquery();
+ foreach my $host (sort keys %hosts) {
+ mainquery($host);
+ }
});
foreach my $host (sort keys %hosts) {