| line |
true |
false |
branch |
|
34
|
28 |
0 |
unless $self->bufsize |
|
35
|
0 |
28 |
unless defined $self->connect_delay |
|
36
|
27 |
1 |
unless defined $self->reconnect_on_fork |
|
37
|
27 |
1 |
unless defined $self->reconnect_attempts |
|
38
|
26 |
2 |
unless defined $self->initial_reconnect_attempts |
|
39
|
28 |
0 |
unless defined $self->socket_options |
|
41
|
28 |
0 |
unless $self->logger |
|
54
|
6 |
22 |
if ($self->failover) { } |
|
|
19 |
3 |
elsif ($self->hosts) { } |
|
57
|
1 |
5 |
unless $uris |
|
61
|
0 |
5 |
if $self->ssl |
|
62
|
0 |
5 |
if $self->ssl_options |
|
64
|
1 |
6 |
unless $host =~ m[^\w+://([a-zA-Z0-9\-./]+):([0-9]+)$] |
|
74
|
23 |
3 |
if @hosts |
|
88
|
5 |
24 |
if ($self->_should_stop_trying($initial, $tries)) |
|
100
|
11 |
18 |
$initial ? : |
|
104
|
12 |
17 |
unless $max_tries > 0 |
|
106
|
14 |
3 |
if (defined $self->hosts) |
|
115
|
48 |
4 |
if (my $hosts = $self->hosts) |
|
116
|
13 |
35 |
if (defined $self->current_host and $self->current_host < $#{$hosts;}) { } |
|
128
|
29 |
23 |
unless $socket |
|
143
|
0 |
0 |
unless defined $timeout |
|
154
|
0 |
0 |
if ($self->ssl) { } |
|
156
|
0 |
0 |
if $@ |
|
159
|
0 |
0 |
unless $self->ssl_options |
|
167
|
0 |
0 |
if $socket |
|
169
|
0 |
0 |
if ($socket and $keep_alive) |
|
171
|
0 |
0 |
if ('Socket'->can('SO_KEEPALIVE')) { } |
|
191
|
11 |
0 |
if ($frame and $frame->command eq 'CONNECTED') { } |
|
207
|
0 |
14 |
unless $self->socket |
|
244
|
0 |
0 |
if ($self->{'_framebuf_changed'} and length $self->{'_framebuf'}) |
|
250
|
0 |
0 |
exists $conf->{'timeout'} ? : |
|
274
|
4 |
5 |
exists $conf->{'timeout'} ? : |
|
279
|
4 |
5 |
defined $receipt_timeout ? : |
|
285
|
4 |
5 |
if (@_ > 2) |
|
289
|
2 |
7 |
if ($receipt_frame and $receipt_frame->command eq 'RECEIPT' and $receipt_frame->headers->{'receipt-id'} eq $receipt_id) { } |
|
296
|
3 |
4 |
unless $receipt_frame |
|
318
|
0 |
4 |
if (@_ > 2) |
|
322
|
1 |
3 |
if ($ret) { } |
|
347
|
2 |
11 |
if ($conf->{'id'}) |
|
400
|
5 |
43 |
unless ($self->_connected) |
|
402
|
0 |
4 |
unless ($self->_connected) |
|
413
|
1 |
57 |
unless defined $written |
|
416
|
1 |
46 |
unless (defined $written) |
|
419
|
2 |
45 |
unless (defined $written and $self->_connected) |
|
429
|
32 |
106 |
unless $self->select->can_read($timeout) |
|
434
|
103 |
3 |
if (defined $len and $len > 0) { } |
|
438
|
2 |
1 |
unless (defined $len) |
|
455
|
10 |
133 |
if $self->{'_headers'} |
|
456
|
31 |
102 |
if ($self->{'_framebuf'} =~ s/^\n*([^\n].*?)\n\n//s) |
|
459
|
31 |
0 |
if ($raw_headers =~ s/^(.+)\n//) |
|
465
|
36 |
0 |
unless defined $self->{'_headers'}{$key} |
|
476
|
37 |
30 |
if ($h->{'content-length'}) { } |
|
|
26 |
4 |
elsif ($self->{'_framebuf'} =~ s/^(.*?)\000\n*//s) { } |
|
477
|
5 |
32 |
if (length $self->{'_framebuf'} > $h->{'content-length'}) |
|
516
|
1 |
163 |
if $self->{'_pid'} != $$ and $self->reconnect_on_fork |
|
530
|
5 |
61 |
exists $conf->{'timeout'} ? : |
|
532
|
3 |
63 |
unless ($self->_connected) |
|
538
|
25 |
77 |
unless $self->_read_data($timeout) |
|
541
|
10 |
26 |
unless $self->_read_data($timeout) |