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) |