| line |
true |
false |
branch |
|
70
|
0 |
0 |
unless (defined &$func) |
|
73
|
0 |
0 |
unless $pkg =~ s/::[^:]+$// |
|
546
|
11 |
6 |
if ($self->{'fh'}) { } |
|
|
6 |
0 |
elsif ($self->{'connect'}) { } |
|
548
|
0 |
11 |
unless $self->{'fh'} |
|
554
|
6 |
0 |
unless exists $self->{'peername'} |
|
570
|
6 |
0 |
if ($fh) { } |
|
581
|
5 |
1 |
if $self->{'on_connect'} |
|
584
|
0 |
0 |
if ($self->{'on_connect_error'}) { } |
|
586
|
0 |
0 |
if $self |
|
596
|
0 |
6 |
$self->{'on_prepare'} ? : |
|
615
|
0 |
17 |
if 1 != unpack('I', $type) and defined $type |
|
626
|
0 |
17 |
if $self->{'read_size'} > ($self->{'max_read_size'} || 131072) |
|
628
|
10 |
7 |
if $self->{'timeout'} |
|
629
|
0 |
17 |
if $self->{'rtimeout'} |
|
630
|
0 |
17 |
if $self->{'wtimeout'} |
|
632
|
0 |
0 |
if exists $self->{'no_delay'} and $self->{'no_delay'} |
|
633
|
0 |
0 |
if exists $self->{'keepalive'} and $self->{'keepalive'} |
|
635
|
0 |
17 |
exists $self->{'oobinline'} ? : |
|
638
|
10 |
7 |
if $self->{'tls'} |
|
640
|
1 |
16 |
if $self->{'on_drain'} |
|
643
|
6 |
11 |
if $self->{'on_read'} or @{$self->{'_queue'};} |
|
654
|
1 |
0 |
if ($self->{'on_error'}) { } |
|
|
0 |
0 |
elsif ($self->{'fh'} or $self->{'connect'}) { } |
|
656
|
1 |
0 |
if $fatal |
|
727
|
0 |
0 |
if $_[0]{'fh'} |
|
743
|
0 |
0 |
if $_[0]{'fh'} |
|
760
|
17 |
0 |
if $_[0]{'fh'} |
|
841
|
0 |
10 |
unless $new_value >= 0 |
|
927
|
6 |
7 |
if $cb and $self->{'low_water_mark'} >= length($self->{'wbuf'}) + length($self->{'_tls_wbuf'}) |
|
944
|
344 |
17 |
if (not $self->{'_ww'} and length $self->{'wbuf'}) |
|
951
|
344 |
0 |
if (defined $len) { } |
|
|
0 |
0 |
elsif ($! != 11 and $! != 4 and $! != 11 and $! != -1e+99) { } |
|
958
|
2 |
333 |
if $self->{'low_water_mark'} >= length($self->{'wbuf'}) + length($self->{'_tls_wbuf'}) and $self->{'on_drain'} |
|
960
|
343 |
1 |
unless length $self->{'wbuf'} |
|
967
|
344 |
0 |
unless $self->{'autocork'} |
|
971
|
1 |
343 |
if length $self->{'wbuf'} |
|
973
|
0 |
344 |
if (defined $self->{'wbuf_max'} and $self->{'wbuf_max'} < length $self->{'wbuf'}) |
|
992
|
132 |
142 |
if (@_ > 1) |
|
1003
|
262 |
12 |
if ($self->{'tls'}) { } |
|
1005
|
258 |
4 |
if $self->{'fh'} |
|
1008
|
11 |
1 |
if $self->{'fh'} |
|
1112
|
0 |
0 |
unless (eval {
do {
require JSON::XS;
'JSON::XS'->new->utf8
}
}) |
|
1303
|
306 |
402 |
if $self->{'_skip_drain_rbuf'} |
|
1310
|
365 |
421 |
if exists $self->{'_tls_rbuf'} |
|
1314
|
635 |
151 |
if (my $cb = shift @{$$self{'_queue'};}) { } |
|
|
137 |
14 |
elsif ($self->{'on_read'}) { } |
|
1315
|
320 |
315 |
unless (&$cb($self)) |
|
1319
|
1 |
319 |
if $self->{'_eof'} |
|
1325
|
68 |
69 |
unless $len |
|
1329
|
0 |
0 |
if ($len == length $self->{'rbuf'} and not @{$self->{'_queue'};} and $self->{'on_read'}) |
|
1337
|
0 |
0 |
if $self->{'_eof'} |
|
1343
|
3 |
11 |
unless $self->{'tls'} |
|
1348
|
6 |
395 |
if ($self->{'_eof'}) |
|
1350
|
6 |
0 |
$self->{'on_eof'} ? : |
|
1356
|
0 |
395 |
if (defined $self->{'rbuf_max'} and $self->{'rbuf_max'} < length $self->{'rbuf'}) |
|
1364
|
6 |
389 |
unless ($self->{'_rw'}) |
|
1366
|
3 |
3 |
if $self->{'on_read'} or @{$self->{'_queue'};} |
|
1385
|
1 |
0 |
if $cb |
|
1443
|
217 |
0 |
if (@_) |
|
1459
|
99 |
0 |
if (@_) |
|
2000
|
15 |
0 |
unless ($self->{'_rw'} or $self->{'_eof'} or not $self->{'fh'}) |
|
2004
|
296 |
21 |
$self->{'tls'} ? : |
|
2007
|
310 |
7 |
if ($len > 0) { } |
|
|
7 |
0 |
elsif (defined $len) { } |
|
|
0 |
0 |
elsif ($! != 11 and $! != 4 and $! != 11 and $! != -1e+99) { } |
|
2010
|
291 |
19 |
if ($self->{'tls'}) { } |
|
2018
|
22 |
288 |
if ($len == $self->{'read_size'}) |
|
2021
|
2 |
20 |
if $self->{'read_size'} > ($self->{'max_read_size'} || 131072) |
|
2042
|
0 |
0 |
if $err == Net::SSLeay::ERROR_SYSCALL() |
|
2050
|
0 |
0 |
if ($self->{'_on_starttls'}) { } |
|
2070
|
10 |
365 |
if (($tmp = Net::SSLeay::write($self->{'tls'}, $self->{'_tls_wbuf'})) <= 0) |
|
2073
|
0 |
0 |
if $tmp != $ERROR_WANT_READ and $tmp != $ERROR_SYSCALL || $! |
|
2084
|
0 |
365 |
unless (length $tmp) |
|
2086
|
0 |
0 |
if $self->{'_on_starttls'} |
|
2089
|
0 |
0 |
if ($self->{'on_stoptls'}) { } |
|
2101
|
0 |
365 |
unless $self->{'tls'} |
|
2105
|
0 |
0 |
if $tmp != $ERROR_WANT_READ and $tmp != $ERROR_SYSCALL || $! |
|
2112
|
0 |
333 |
unless $self->{'tls'} |
|
2117
|
0 |
559 |
if $self->{'_on_starttls'} and Net::SSLeay::state($self->{'tls'}) == Net::SSLeay::ST_OK() |
|
2160
|
0 |
10 |
if $self->{'tls'} |
|
2162
|
0 |
10 |
unless (defined $AnyEvent::TLS::VERSION) |
|
2163
|
0 |
0 |
unless eval {
do {
require Net::SSLeay;
require AnyEvent::TLS;
1
}
} |
|
2171
|
10 |
0 |
if @_ > 2 |
|
2173
|
0 |
10 |
unless $self->{'fh'} |
|
2183
|
0 |
10 |
if ('HASH' eq ref $ctx) |
|
2184
|
0 |
0 |
if ($ctx->{'cache'}) { } |
|
2221
|
0 |
10 |
if $self->{'on_starttls'} |
|
2242
|
0 |
0 |
if ($self->{'tls'} and $self->{'fh'}) |
|
2256
|
6 |
10 |
unless $self->{'tls'} |
|
2259
|
10 |
0 |
if $self->{'tls'} > 0 |
|
2282
|
0 |
16 |
exists $self->{'linger'} ? : |
|
2284
|
1 |
0 |
if ($linger and length $self->{'wbuf'} and $self->{'fh'}) |
|
2293
|
3 |
1 |
if ($len > 0) { } |
|
|
1 |
0 |
elsif (defined $len or $! != 11 and $! != 4 and $! != 11 and $! != -1e+99) { } |