| line |
true |
false |
branch |
|
76
|
0 |
0 |
if $_[0]->shutdown_please
|
|
84
|
0 |
0 |
if $self->has_autoconfig
|
|
85
|
0 |
0 |
if (not $self->paused and my $job = $self->reserve) { }
|
|
|
0 |
0 |
elsif (not $self->cant_poll and $self->interval) { }
|
|
91
|
0 |
0 |
unless ($waiting)
|
|
92
|
0 |
0 |
$self->paused ? :
|
|
109
|
0 |
0 |
if (not $self->cant_fork and my $pid = fork) { }
|
|
117
|
0 |
0 |
if ($?)
|
|
127
|
0 |
0 |
unless $self->cant_fork
|
|
131
|
0 |
0 |
unless $self->cant_fork
|
|
156
|
0 |
0 |
unless $self->child
|
|
158
|
0 |
0 |
if (kill 0, $self->child) { }
|
|
170
|
0 |
0 |
unless @_
|
|
176
|
0 |
0 |
unless $queue
|
|
181
|
0 |
0 |
$_ eq $queue ? :
|
|
187
|
0 |
0 |
if ($self->cant_poll) { }
|
|
192
|
0 |
0 |
if (my $job = $self->resque->pop($queue))
|
|
242
|
0 |
0 |
unless eval {
|
|
247
|
0 |
0 |
unless @_
|
|
249
|
0 |
0 |
ref $_ ? :
|
|
250
|
0 |
0 |
unless $_ and $self->encoder->decode($_)
|
|
266
|
0 |
0 |
$self->redis->exists($self->key('worker', $self->id)) ? :
|
|
292
|
0 |
0 |
if (my $str = shift())
|
|
322
|
0 |
0 |
if @all_workers
|
|
325
|
0 |
0 |
unless $host eq hostname()
|
|
326
|
0 |
0 |
if &any(sub {
|
|
346
|
0 |
0 |
if $id eq $self->id
|
|
367
|
0 |
0 |
if (%$hr)
|
|
397
|
0 |
0 |
if ($^O =~ /^(cygwin|MSWin32)$/i) { }
|
|
399
|
0 |
0 |
if s/^PID:\s*//
|
|
403
|
0 |
0 |
$^O eq 'solaris' ? :
|
|
408
|
0 |
0 |
if (/^\s*(\d+)\s(.+)$/)
|
|
413
|
0 |
0 |
wantarray ? :
|
|
419
|
0 |
0 |
unless $self->verbose
|
|
425
|
0 |
0 |
if (shift())
|
|
434
|
0 |
0 |
if (shift())
|
|
443
|
0 |
0 |
if ($self->exists($worker_id))
|
|
461
|
0 |
0 |
wantarray ? :
|