| 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
|
1 |
6 |
unless $host =~ m[^\w+://([a-zA-Z0-9\-./]+):([0-9]+)$] |
|
71
|
23 |
3 |
if @hosts |
|
85
|
5 |
24 |
if ($self->_should_stop_trying($initial, $tries)) |
|
97
|
11 |
18 |
$initial ? : |
|
101
|
12 |
17 |
unless $max_tries > 0 |
|
103
|
14 |
3 |
if (defined $self->hosts) |
|
112
|
48 |
4 |
if (my $hosts = $self->hosts) |
|
113
|
13 |
35 |
if (defined $self->current_host and $self->current_host < $#{$hosts;}) { } |
|
125
|
29 |
23 |
unless $socket |
|
140
|
0 |
0 |
unless defined $timeout |
|
151
|
0 |
0 |
if ($self->ssl) { } |
|
153
|
0 |
0 |
if $@ |
|
156
|
0 |
0 |
unless $self->ssl_options |
|
164
|
0 |
0 |
if $socket |
|
166
|
0 |
0 |
if ($keep_alive) |
|
168
|
0 |
0 |
if ('Socket'->can('SO_KEEPALIVE')) { } |
|
188
|
11 |
0 |
if ($frame and $frame->command eq 'CONNECTED') { } |
|
204
|
0 |
14 |
unless $self->socket |
|
241
|
0 |
0 |
if ($self->{'_framebuf_changed'} and length $self->{'_framebuf'}) |
|
247
|
0 |
0 |
exists $conf->{'timeout'} ? : |
|
271
|
4 |
5 |
exists $conf->{'timeout'} ? : |
|
276
|
4 |
5 |
defined $receipt_timeout ? : |
|
282
|
4 |
5 |
if (@_ > 2) |
|
286
|
2 |
7 |
if ($receipt_frame and $receipt_frame->command eq 'RECEIPT' and $receipt_frame->headers->{'receipt-id'} eq $receipt_id) { } |
|
293
|
3 |
4 |
unless $receipt_frame |
|
315
|
0 |
4 |
if (@_ > 2) |
|
319
|
1 |
3 |
if ($ret) { } |
|
344
|
2 |
11 |
if ($conf->{'id'}) |
|
397
|
5 |
43 |
unless ($self->_connected) |
|
399
|
0 |
4 |
unless ($self->_connected) |
|
410
|
1 |
57 |
unless defined $written |
|
413
|
1 |
46 |
unless (defined $written) |
|
416
|
2 |
45 |
unless (defined $written and $self->_connected) |
|
426
|
32 |
106 |
unless $self->select->can_read($timeout) |
|
431
|
103 |
3 |
if (defined $len and $len > 0) { } |
|
435
|
2 |
1 |
unless (defined $len) |
|
452
|
10 |
133 |
if $self->{'_headers'} |
|
453
|
31 |
102 |
if ($self->{'_framebuf'} =~ s/^\n*([^\n].*?)\n\n//s) |
|
456
|
31 |
0 |
if ($raw_headers =~ s/^(.+)\n//) |
|
462
|
36 |
0 |
unless defined $self->{'_headers'}{$key} |
|
473
|
37 |
30 |
if ($h->{'content-length'}) { } |
|
|
26 |
4 |
elsif ($self->{'_framebuf'} =~ s/^(.*?)\000\n*//s) { } |
|
474
|
5 |
32 |
if (length $self->{'_framebuf'} > $h->{'content-length'}) |
|
513
|
1 |
163 |
if $self->{'_pid'} != $$ and $self->reconnect_on_fork |
|
527
|
5 |
61 |
exists $conf->{'timeout'} ? : |
|
529
|
3 |
63 |
unless ($self->_connected) |
|
535
|
25 |
77 |
unless $self->_read_data($timeout) |
|
538
|
10 |
26 |
unless $self->_read_data($timeout) |