135/netdisco
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

only resolve fqdn once

Browse Source
This commit is contained in:
Oliver Gorwits
2017-05-23 19:37:58 +01:00
parent 4550b8a84c
commit 3d136a54de
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
lib/App/Netdisco/JobQueue/PostgreSQL.pm
View File

@@ -30,14 +30,15 @@ our @EXPORT_OK = qw/
/; /;
our %EXPORT_TAGS = ( all => \@EXPORT_OK ); our %EXPORT_TAGS = ( all => \@EXPORT_OK );
# this can take a few seconds - only do it once
our $fqdn = hostfqdn || 'localhost';
sub _getsome { sub _getsome {
my ($num_slots, $where) = @_; my ($num_slots, $where) = @_;
return () if ((!defined $num_slots) or ($num_slots < 1)); return () if ((!defined $num_slots) or ($num_slots < 1));
return () if ((!defined $where) or (ref {} ne ref $where)); return () if ((!defined $where) or (ref {} ne ref $where));
my $fqdn = hostfqdn || 'localhost';
my $jobs = schema('netdisco')->resultset('Admin'); my $jobs = schema('netdisco')->resultset('Admin');
my $rs = $jobs->search({ my $rs = $jobs->search({
status => 'queued', status => 'queued',
device => { '-not_in' => $jobs->skipped->columns('device')->as_query }, device => { '-not_in' => $jobs->skipped->columns('device')->as_query },
@@ -69,7 +70,6 @@ sub jq_getsomep {
} }
sub jq_locked { sub jq_locked {
my $fqdn = hostfqdn || 'localhost';
my @returned = (); my @returned = ();
my $rs = schema('netdisco')->resultset('Admin') my $rs = schema('netdisco')->resultset('Admin')
@@ -110,7 +110,6 @@ sub _get_denied_actions {
} }
sub jq_prime_skiplist { sub jq_prime_skiplist {
my $fqdn = hostfqdn || 'localhost';
my @devices = schema('netdisco')->resultset('Device')->all; my @devices = schema('netdisco')->resultset('Device')->all;
my $rs = schema('netdisco')->resultset('DeviceSkip'); my $rs = schema('netdisco')->resultset('DeviceSkip');
my %actionset = (); my %actionset = ();
@@ -134,7 +133,6 @@ sub jq_prime_skiplist {
sub jq_lock { sub jq_lock {
my $job = shift; my $job = shift;
my $fqdn = hostfqdn || 'localhost';
my $happy = false; my $happy = false;
# need to handle device discovered since backend daemon started # need to handle device discovered since backend daemon started
@@ -183,7 +181,6 @@ sub jq_lock {
sub jq_defer { sub jq_defer {
my $job = shift; my $job = shift;
my $fqdn = hostfqdn || 'localhost';
my $happy = false; my $happy = false;
# note this taints all actions on the device. for example if both # note this taints all actions on the device. for example if both