line |
!l |
l&&!r |
l&&r |
condition |
126
|
0 |
0 |
0 |
not defined $value and $doblocking == 1 |
154
|
0 |
0 |
0 |
@items == 0 and $doblocking == 1 |
499
|
0 |
0 |
0 |
$process_all and $chunk <= 1 |
501
|
0 |
0 |
0 |
$pause and $chunk <= 1 |
532
|
0 |
0 |
0 |
$stop_time > 0 and time >= $stop_time |
540
|
0 |
0 |
0 |
$warn_on_error and $error |
568
|
0 |
0 |
0 |
$maxitems > 0 and --$maxitems == 0 |
|
0 |
0 |
0 |
$stop_time > 0 and time >= $stop_time |
572
|
0 |
0 |
0 |
$self->warn_on_requeue and $still_busy |
593
|
0 |
0 |
0 |
$stop_time > 0 and time >= $stop_time |
608
|
0 |
0 |
0 |
$warn_on_error and $error |
637
|
0 |
0 |
0 |
$warn_on_error and $error |
667
|
0 |
0 |
0 |
$self->warn_on_requeue and $count != @done |
684
|
0 |
0 |
0 |
$maxitems > 0 and ($maxitems -= @done) <= 0 |
|
0 |
0 |
0 |
$stop_time > 0 and time >= $stop_time |
703
|
0 |
0 |
0 |
$action and $action =~ /^(?:requeue|drop)$/ |
line |
l |
!l |
condition |
69
|
0 |
0 |
$self->{'redis_options'} ||= {'reconnect', 60} |
118
|
0 |
0 |
$n ||= 1 |
240
|
0 |
0 |
$error || '' |
299
|
0 |
0 |
delete $options{'Delay'} || 0 |
300
|
0 |
0 |
delete $options{'MaxFailCount'} || -1 |
301
|
0 |
0 |
delete $options{'Chunk'} || 100 |
336
|
0 |
0 |
delete $options{'MinAge'} || 0 |
337
|
0 |
0 |
delete $options{'MinFailCount'} || 0 |
338
|
0 |
0 |
delete $options{'Chunk'} || 100 |
339
|
0 |
0 |
delete $options{'LogLimit'} || 100 |
440
|
0 |
0 |
$n ||= 0 |
449
|
0 |
0 |
$$type ||= 'main' |
474
|
0 |
0 |
$error_action ||= 'requeue' |
487
|
0 |
0 |
delete $options->{'Chunk'} || 1 |
491
|
0 |
0 |
delete $options->{'ReturnOnDie'} || delete $options->{'DieOnError'} || 0 |
492
|
0 |
0 |
delete $options->{'MaxItems'} || -1 |
493
|
0 |
0 |
delete $options->{'MaxSeconds'} || 0 |
494
|
0 |
0 |
delete $options->{'Pause'} || 0 |
495
|
0 |
0 |
delete $options->{'ProcessAll'} || 0 |
496
|
0 |
0 |
delete $options->{'ReturnWhenEmpty'} || 0 |
497
|
0 |
0 |
delete $options->{'NoSigHandlers'} || 0 |
498
|
0 |
0 |
delete $options->{'WarnOnError'} || 0 |
701
|
0 |
0 |
$timeout ||= 10 |
line |
l |
!l&&r |
!l&&!r |
condition |
72
|
0 |
0 |
0 |
$self->{'redis_conn'} ||= 'Redis'->new(%{$$self{'redis_options'};}, 'encoding', undef, 'server', join(':', $self->server, $self->port)) |
483
|
0 |
0 |
0 |
$error_subs{$error_action} || croak("no handler for $error_action") |
532
|
0 |
0 |
0 |
$return_when_empty or $stop_time > 0 and time >= $stop_time |
568
|
0 |
0 |
0 |
$maxitems > 0 and --$maxitems == 0 or $stop_time > 0 and time >= $stop_time |
593
|
0 |
0 |
0 |
$return_when_empty or $stop_time > 0 and time >= $stop_time |
684
|
0 |
0 |
0 |
$maxitems > 0 and ($maxitems -= @done) <= 0 or $stop_time > 0 and time >= $stop_time |