| line |
!l |
l&&!r |
l&&r |
condition |
|
237
|
52 |
39 |
0 |
exists $p{$_} and $self->{$_} = $p{$_} |
|
305
|
1 |
0 |
1 |
$sent < $length and $retries++ < $MAX_RETRIES |
|
327
|
0 |
1 |
0 |
$retries == 1 and $self->_is_close_wait |
|
337
|
0 |
0 |
1 |
defined $wrote and $wrote > 0 |
|
346
|
0 |
0 |
0 |
$errno != 11 and $errno != 11 |
|
|
0 |
0 |
0 |
$errno == 104 && $^O eq 'freebsd' |
|
|
0 |
0 |
0 |
$errno != 11 and $errno != 11 and not $errno == 104 && $^O eq 'freebsd' |
|
366
|
0 |
0 |
1 |
not $errno and defined $sent |
|
|
0 |
0 |
1 |
not $errno and defined $sent and $sent == $length |
|
420
|
1 |
0 |
1 |
$len_to_read > 0 and $retries++ < $MAX_RETRIES |
|
446
|
0 |
0 |
1 |
defined $from_recv and length $buf |
|
452
|
0 |
0 |
0 |
$errno != 11 and $errno != 11 |
|
|
0 |
0 |
0 |
$errno == 104 && $^O eq 'freebsd' |
|
|
0 |
0 |
0 |
$errno != 11 and $errno != 11 and not $errno == 104 && $^O eq 'freebsd' |
|
469
|
0 |
0 |
0 |
defined $from_recv and not $errno |
|
497
|
0 |
0 |
1 |
not $errno and length $message >= $length |
|
542
|
0 |
0 |
1 |
$self->{'socket'} and $self->{'_io_select'} |
|
550
|
0 |
0 |
0 |
!$! && defined $status && length $buf == 0 |
|
711
|
9 |
0 |
0 |
$Kafka::IO::Config{'osname'} eq 'netbsd' and _major_osvers() >= 6 |
|
|
9 |
0 |
0 |
$Kafka::IO::Config{'osname'} eq 'netbsd' and _major_osvers() >= 6 and $Kafka::IO::Config{'longsize'} == 4 |
|
746
|
6 |
1 |
1 |
defined $ip_version and $ip_version == $Kafka::IO::IP_V6 |
|
770
|
1 |
0 |
7 |
$is_v4_fqdn and !defined($ip_version) || $ip_version == $Kafka::IO::IP_V4 |
|
784
|
13 |
0 |
0 |
$is_ip = is_ipv6($name) and not $ip_version |
|
|
9 |
1 |
1 |
$is_ip = is_ipv4($name) and not $ip_version |
|
785
|
0 |
2 |
0 |
$ip_version and !$is_ip && is_ipv4($name) || $is_ip && $ip_version == $Kafka::IO::IP_V4 |
|
797
|
1 |
2 |
0 |
$ip_version and !$is_ip && is_ipv6($name) || $is_ip && $ip_version == $Kafka::IO::IP_V6 |
| line |
l |
!l&&r |
!l&&!r |
condition |
|
286
|
1 |
0 |
0 |
$self->{'timeout'} // $Kafka::IO::REQUEST_TIMEOUT |
|
372
|
0 |
0 |
0 |
$error_code // $Kafka::IO::ERROR_CANNOT_SEND |
|
403
|
1 |
0 |
0 |
$self->{'timeout'} // $Kafka::IO::REQUEST_TIMEOUT |
|
503
|
0 |
0 |
0 |
$error_code // $Kafka::IO::ERROR_CANNOT_RECV |
|
661
|
0 |
9 |
1 |
connect $connection, $sockaddr or $!{'EINPROGRESS'} |
|
670
|
9 |
0 |
0 |
$timeout // $Kafka::IO::REQUEST_TIMEOUT |
|
692
|
9 |
0 |
0 |
$timeout // $Kafka::IO::REQUEST_TIMEOUT |
|
770
|
6 |
1 |
0 |
!defined($ip_version) || $ip_version == $Kafka::IO::IP_V4 |
|
784
|
0 |
2 |
11 |
$is_ip = is_ipv6($name) and not $ip_version or $ip_version == $Kafka::IO::IP_V6 |
|
|
1 |
2 |
8 |
$is_ip = is_ipv4($name) and not $ip_version or $ip_version == $Kafka::IO::IP_V4 |
|
785
|
1 |
0 |
1 |
!$is_ip && is_ipv4($name) || $is_ip && $ip_version == $Kafka::IO::IP_V4 |
|
797
|
0 |
0 |
2 |
!$is_ip && is_ipv6($name) || $is_ip && $ip_version == $Kafka::IO::IP_V6 |