| line |
!l |
l&&!r |
l&&r |
condition |
|
53
|
0 |
0 |
0 |
not $cb and $self->{'_on_message'} |
|
180
|
0 |
0 |
0 |
$exit_on_pause and $self->{'_paused'} |
|
187
|
0 |
0 |
0 |
$self->{'_closed'} and not @{$self->{'_pending_messages'};} |
|
189
|
0 |
0 |
0 |
$exit_on_pause and $self->{'_paused'} |
|
|
0 |
0 |
0 |
$exit_on_pause and $self->{'_paused'} and not @{$self->{'_pending_messages'};} |
|
235
|
1 |
0 |
1 |
$redis->{'reconnect'} and $self->channel_count > 0 |
|
269
|
0 |
0 |
0 |
$frame and ref $frame eq "ARRAY" |
|
311
|
0 |
0 |
0 |
$redis && $redis->{'message_queue_depth'} |
|
313
|
0 |
0 |
0 |
$depth and scalar @{$self->{'_pending_messages'};} >= $depth |
|
370
|
0 |
0 |
0 |
builtin::blessed($result) and $result->isa("Future") |
|
398
|
4 |
0 |
0 |
$self->{'_driver_step'} and not $self->{'_driver_step'}->is_ready |
|
448
|
0 |
0 |
0 |
$redis and defined $redis->{'_subscription'} |
|
|
0 |
0 |
0 |
$redis and defined $redis->{'_subscription'} and builtin::refaddr($redis->{'_subscription'}) == builtin::refaddr($self) |
|
482
|
0 |
0 |
0 |
$redis and defined $redis->{'_subscription'} |
|
|
0 |
0 |
0 |
$redis and defined $redis->{'_subscription'} and builtin::refaddr($redis->{'_subscription'}) == builtin::refaddr($self) |