| line |
true |
false |
branch |
|
24
|
7 |
21 |
if exists $params{$key} |
|
65
|
0 |
1 |
if $self->{'_connected'} |
|
88
|
0 |
0 |
unless $self->{'_connect_future'}->is_ready |
|
98
|
0 |
0 |
unless $self->{'_connected'} |
|
99
|
0 |
0 |
unless defined $subject and length $subject |
|
105
|
0 |
0 |
defined $reply ? : |
|
117
|
0 |
0 |
unless $self->{'_connected'} |
|
118
|
0 |
0 |
unless defined $subject and length $subject |
|
119
|
0 |
0 |
unless ref $callback eq "CODE" |
|
132
|
0 |
0 |
defined $queue ? : |
|
144
|
0 |
0 |
unless $self->{'_connected'} |
|
146
|
0 |
0 |
ref $sub ? : |
|
149
|
0 |
0 |
defined $max ? : |
|
154
|
0 |
0 |
unless defined $max |
|
162
|
0 |
0 |
unless $self->{'_connected'} |
|
170
|
0 |
0 |
unless $f->is_ready |
|
189
|
0 |
0 |
unless $self->{'_connected'} |
|
199
|
0 |
1 |
unless $self->{'_connected'} |
|
205
|
1 |
0 |
if (my $stream = $self->{'_stream'}) |
|
220
|
5 |
6 |
if ($line =~ /\AMSG\s+(\S+)\s+(\S+)\s+(?:(\S+)\s+)?(\d+)\z/i) |
|
224
|
0 |
5 |
if (length $$buffref < $bytes + 2) |
|
226
|
0 |
0 |
defined $reply_to ? : |
|
240
|
0 |
6 |
if ($line =~ /\AHMSG\s+(\S+)\s+(\S+)\s+(?:(\S+)\s+)?(\d+)\s+(\d+)\z/i) |
|
243
|
0 |
0 |
if (length $$buffref < $total_bytes + 2) |
|
244
|
0 |
0 |
defined $reply_to ? : |
|
254
|
0 |
0 |
$payload_bytes > 0 ? : |
|
264
|
2 |
4 |
if ($line =~ /\AINFO\s+(\{.*\})\s*\z/i) |
|
272
|
1 |
3 |
if ($line =~ /\APING\z/i) |
|
278
|
1 |
2 |
if ($line =~ /\APONG\z/i) |
|
279
|
1 |
0 |
if (my $f = delete $self->{'_ping_future'}) |
|
280
|
1 |
0 |
unless $f->is_ready |
|
286
|
1 |
1 |
if $line =~ /\A\+OK\z/i |
|
289
|
1 |
0 |
if ($line =~ /\A-ERR\s+'?(.+?)'?\z/i) |
|
302
|
0 |
2 |
if $self->{'_connected'} |
|
311
|
0 |
2 |
$self->{'verbose'} ? : |
|
|
0 |
2 |
$self->{'pedantic'} ? : |
|
317
|
0 |
2 |
if (defined $self->{'auth_token'}) |
|
320
|
0 |
2 |
if (defined $self->{'user'}) |
|
334
|
1 |
1 |
if (my $f = delete $self->{'_connect_future'}) |
|
335
|
1 |
0 |
unless $f->is_ready |
|
338
|
0 |
2 |
if (my $cb = $self->{'on_connect'}) |
|
347
|
0 |
5 |
unless $sub |
|
351
|
0 |
5 |
if (defined $sub->max_msgs) |
|
353
|
0 |
0 |
if ($sub->{'_received'} >= $sub->max_msgs) |
|
361
|
2 |
2 |
if (my $stream = $self->{'_stream'}) |
|
370
|
0 |
0 |
if (my $cb = $self->{'on_disconnect'}) |
|
374
|
0 |
0 |
if ($self->{'reconnect'}) |
|
381
|
1 |
0 |
if (my $cb = $self->{'on_error'}) |
|
395
|
0 |
0 |
unless my $self = $weak_self |
|
396
|
0 |
0 |
if $self->{'_connected'} |
|
397
|
0 |
0 |
if ++$attempts > $max |
|
400
|
0 |
0 |
unless my $self = $weak_self |
|
401
|
0 |
0 |
if $self->{'_connected'} |
|
404
|
0 |
0 |
if (my $old = delete $self->{'_stream'}) |
|
405
|
0 |
0 |
if $old->parent |
|
414
|
0 |
0 |
unless my $self = $weak_self |
|
417
|
0 |
0 |
defined $sub->queue ? : |
|
434
|
2 |
0 |
if (open my $fh, '<:raw', '/dev/urandom') { } |