| line |
true |
false |
branch |
|
43
|
1 |
2 |
if @_ > 1 |
|
52
|
0 |
0 |
if (@_ > 1) |
|
53
|
0 |
0 |
if (not $cb and $self->{'_on_message'}) |
|
62
|
0 |
0 |
if $cb |
|
72
|
0 |
0 |
if (@_ > 1) |
|
92
|
0 |
0 |
unless ($ok) |
|
106
|
0 |
0 |
if (my $cb = $self->{'_on_error'}) |
|
109
|
0 |
0 |
unless ($ok) |
|
167
|
0 |
0 |
if $self->{'_closed'} |
|
171
|
0 |
0 |
if ($self->{'_on_message'}) |
|
175
|
0 |
0 |
if (@{$self->{'_message_queue'};}) |
|
181
|
0 |
0 |
unless $frame |
|
186
|
0 |
0 |
if (@{$self->{'_message_queue'};}) |
|
212
|
1 |
0 |
unless ($ok) |
|
214
|
0 |
1 |
if ($redis->{'reconnect'} and $self->channel_count > 0) |
|
219
|
0 |
0 |
unless ($reconnect_ok) |
|
223
|
0 |
0 |
if ($self->{'_on_reconnect'}) |
|
246
|
0 |
0 |
unless $frame and ref $frame eq "ARRAY" |
|
251
|
0 |
0 |
if ($type eq 'message') { } |
|
|
0 |
0 |
elsif ($type eq 'pmessage') { } |
|
|
0 |
0 |
elsif ($type eq 'smessage') { } |
|
279
|
0 |
0 |
if (my $cb = $self->{'_on_message'}) |
|
296
|
0 |
3 |
if $self->{'_driver_step'} |
|
297
|
3 |
0 |
unless $self->{'_on_message'} |
|
298
|
0 |
0 |
if $self->{'_closed'} |
|
299
|
0 |
0 |
unless $self->channel_count > 0 |
|
306
|
0 |
0 |
unless $weak and not $weak->{'_closed'} |
|
311
|
0 |
0 |
if ($SYNC_DEPTH >= 32) |
|
313
|
0 |
0 |
if $weak_step and $weak and not $weak->{'_closed'} |
|
325
|
0 |
0 |
unless $weak and not $weak->{'_closed'} |
|
328
|
0 |
0 |
if (builtin::blessed($cb_result) and $cb_result->isa('Future')) { } |
|
333
|
0 |
0 |
unless $weak and not $weak->{'_closed'} |
|
335
|
0 |
0 |
if ($res->is_failed) |
|
341
|
0 |
0 |
if $weak_step and $weak and not $weak->{'_closed'} |
|
344
|
0 |
0 |
if $weak_step and $weak and not $weak->{'_closed'} |
|
349
|
0 |
0 |
unless $weak |
|
355
|
0 |
0 |
if $weak->{'_closed'} |
|
371
|
0 |
0 |
unless $msg |
|
386
|
0 |
0 |
if (@{$self->{'_waiters'};}) { } |
|
401
|
0 |
0 |
if $self->{'_closed'} |
|
405
|
0 |
0 |
if (@channels) { } |
|
419
|
0 |
0 |
if (@all_channels) |
|
431
|
0 |
0 |
if ($self->channel_count == 0) |
|
442
|
0 |
0 |
if $self->{'_closed'} |
|
446
|
0 |
0 |
if (@patterns) { } |
|
457
|
0 |
0 |
if (@all_patterns) |
|
467
|
0 |
0 |
if ($self->channel_count == 0) |
|
478
|
0 |
0 |
if $self->{'_closed'} |
|
482
|
0 |
0 |
if (@channels) { } |
|
493
|
0 |
0 |
if (@all) |
|
503
|
0 |
0 |
if ($self->channel_count == 0) |
|
519
|
0 |
0 |
unless $waiter->is_ready |
|
541
|
1 |
0 |
if @channels |
|
544
|
1 |
0 |
if @patterns |
|
547
|
0 |
1 |
if @sharded |