| line |
true |
false |
branch |
|
28
|
0 |
0 |
unless @{$status->{'queues'};} |
|
31
|
0 |
0 |
if $status->{'heartbeat_interval'} |
|
32
|
0 |
0 |
if $status->{'command_interval'} |
|
33
|
0 |
0 |
if ($status->{'repair_interval'}) |
|
39
|
0 |
0 |
if $fast |
|
49
|
0 |
0 |
if ($_[1] // '') =~ /^\d+$/ |
|
51
|
0 |
0 |
if $self->{'jobs'}{$_[1] // ''} |
|
56
|
0 |
0 |
unless eval {
do {
$self->_work until $self->{'finished'};
1
}
} |
|
64
|
0 |
0 |
unless $self->{'pid'} == $$ |
|
66
|
0 |
0 |
unless $self->{'graceful'} = $graceful |
|
77
|
0 |
0 |
if ($self->{'stopping'} and not $self->{'quit'}++) |
|
79
|
0 |
0 |
$self->{'graceful'} ? : |
|
83
|
0 |
0 |
unless $self->{'graceful'} |
|
88
|
0 |
0 |
if ($status->{'heartbeat_interval'} and $self->{'next_heartbeat'} < &steady_time()) |
|
95
|
0 |
0 |
if ($status->{'command_interval'} and $self->{'next_command'} < &steady_time()) |
|
102
|
0 |
0 |
if ($status->{'repair_interval'} and $self->{'next_repair'} < &steady_time()) |
|
114
|
0 |
0 |
if $self->{'stopping'} and not keys %{$$self{'jobs'};} |
|
117
|
0 |
0 |
if ($status->{'jobs'} <= keys %$jobs or $self->{'stopping'}) { } |
|
|
0 |
0 |
elsif (my $job = $worker->dequeue(5, {'queues', $status->{'queues'}})) { } |