line |
true |
false |
branch |
64
|
0 |
0 |
$$self{'_log_level'} >= 9 ? : |
72
|
0 |
0 |
unless ($args{'beanstalk_watch'}) |
90
|
0 |
0 |
unless ($$self{'_running'}) |
95
|
0 |
0 |
unless ($self->job_count < $self->concurrency) |
103
|
0 |
0 |
if ($self->max_jobs and $self->handled_jobs >= $self->max_jobs) |
108
|
0 |
0 |
if (not $self->job_count and $$self{'_stop_tries'}) |
119
|
0 |
0 |
if ($qresp =~ /timed_out/iu) |
120
|
0 |
0 |
unless $$self{'_reserve_timeout'} >= $$self{'_reserve_timeout_max'} |
129
|
0 |
0 |
unless ($qresp =~ /reserved/iu) |
130
|
0 |
0 |
unless $qresp =~ /deadline_soon/iu |
137
|
0 |
0 |
if ($$self{'_jobs'}{$qjob->id}) |
154
|
0 |
0 |
if ($$self{'_initial_state'}) { } |
200
|
0 |
0 |
if (ref $cb ne 'CODE') |
208
|
0 |
0 |
if ($self->job_count == $self->concurrency - 1) |
220
|
0 |
0 |
if ($self->max_jobs and $self->handled_jobs >= $self->max_jobs and not $self->job_count) |
229
|
0 |
0 |
$args ? : |
232
|
0 |
0 |
if $@ |
241
|
0 |
0 |
if ($$self{'_stop_tries'} >= $$self{'_max_stop_tries'}) |
247
|
0 |
0 |
if ($self->job_count) |
266
|
0 |
0 |
if (ref $$self{'_cb'}{$evt} eq 'CODE') |
295
|
0 |
0 |
if @_ |
308
|
0 |
0 |
if (@_) |