line |
true |
false |
branch |
66
|
0 |
0 |
$self->{'_log_level'} >= 9 ? : |
74
|
0 |
0 |
unless ($args{'beanstalk_watch'}) |
92
|
0 |
0 |
unless ($self->{'_running'}) |
97
|
0 |
0 |
unless ($self->job_count < $self->concurrency) |
105
|
0 |
0 |
if ($self->max_jobs and $self->handled_jobs >= $self->max_jobs) |
110
|
0 |
0 |
if (not $self->job_count and $self->{'_stop_tries'}) |
121
|
0 |
0 |
if ($qresp =~ /timed_out/iu) |
125
|
0 |
0 |
unless $self->{'_reserve_timeout'} >= $self->{'_reserve_timeout_max'} |
131
|
0 |
0 |
unless ($qresp =~ /reserved/iu) |
132
|
0 |
0 |
unless $qresp =~ /deadline_soon/iu |
139
|
0 |
0 |
if ($self->{'_jobs'}{$qjob->id}) |
156
|
0 |
0 |
if ($self->{'_initial_state'}) { } |
202
|
0 |
0 |
if (ref $cb ne 'CODE') |
210
|
0 |
0 |
if ($self->job_count == $self->concurrency - 1) |
222
|
0 |
0 |
if ($self->max_jobs and $self->handled_jobs >= $self->max_jobs and not $self->job_count) |
231
|
0 |
0 |
$args ? : |
235
|
0 |
0 |
if $@ |
243
|
0 |
0 |
if ($self->{'_stop_tries'} >= $self->{'_max_stop_tries'}) |
249
|
0 |
0 |
if ($self->job_count) |
268
|
0 |
0 |
if (ref $self->{'_cb'}{$evt} eq 'CODE') |
297
|
0 |
0 |
if @_ |
310
|
0 |
0 |
if (@_) |