| line |
true |
false |
branch |
|
30
|
1 |
2 |
if @_ > 1 |
|
82
|
0 |
0 |
if $self->{'_closed'} |
|
85
|
0 |
0 |
if (@{$self->{'_message_queue'};}) |
|
98
|
0 |
0 |
if (my $error = $@) |
|
100
|
0 |
0 |
if ($redis->{'reconnect'} and $self->channel_count > 0) |
|
104
|
0 |
0 |
if ($@) |
|
110
|
0 |
0 |
if ($self->{'_on_reconnect'}) |
|
123
|
0 |
0 |
unless $frame and ref $frame eq "ARRAY" |
|
127
|
0 |
0 |
if ($type eq 'message') { } |
|
|
0 |
0 |
elsif ($type eq 'pmessage') { } |
|
|
0 |
0 |
elsif ($type eq 'smessage') { } |
|
|
0 |
0 |
elsif ($type =~ /^(un)?p?s?subscribe$/u) { } |
|
166
|
0 |
0 |
unless $msg |
|
181
|
0 |
0 |
if (@{$self->{'_waiters'};}) { } |
|
196
|
0 |
0 |
if $self->{'_closed'} |
|
200
|
0 |
0 |
if (@channels) { } |
|
214
|
0 |
0 |
if (@all_channels) |
|
226
|
0 |
0 |
if ($self->channel_count == 0) |
|
237
|
0 |
0 |
if $self->{'_closed'} |
|
241
|
0 |
0 |
if (@patterns) { } |
|
252
|
0 |
0 |
if (@all_patterns) |
|
262
|
0 |
0 |
if ($self->channel_count == 0) |
|
273
|
0 |
0 |
if $self->{'_closed'} |
|
277
|
0 |
0 |
if (@channels) { } |
|
288
|
0 |
0 |
if (@all) |
|
298
|
0 |
0 |
if ($self->channel_count == 0) |
|
314
|
0 |
0 |
unless $waiter->is_ready |
|
328
|
1 |
0 |
if @channels |
|
331
|
1 |
0 |
if @patterns |
|
334
|
0 |
1 |
if @sharded |