line |
!l |
l&&!r |
l&&r |
condition |
233
|
52 |
39 |
0 |
exists $p{$_} and $self->{$_} = $p{$_}
|
301
|
1 |
0 |
1 |
$sent < $length and $retries++ < $MAX_RETRIES
|
323
|
0 |
1 |
0 |
$retries == 1 and $self->_is_close_wait
|
333
|
0 |
0 |
1 |
defined $wrote and $wrote > 0
|
342
|
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'
|
362
|
0 |
0 |
1 |
not $errno and defined $sent
|
|
0 |
0 |
1 |
not $errno and defined $sent and $sent == $length
|
416
|
1 |
0 |
1 |
$len_to_read > 0 and $retries++ < $MAX_RETRIES
|
442
|
0 |
0 |
1 |
defined $from_recv and length $buf
|
448
|
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'
|
465
|
0 |
0 |
0 |
defined $from_recv and not $errno
|
493
|
0 |
0 |
1 |
not $errno and length $message >= $length
|
551
|
0 |
0 |
1 |
$self->{'socket'} and $self->{'_io_select'}
|
559
|
0 |
0 |
0 |
!$! && defined $status && length $buf == 0
|
720
|
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
|
755
|
6 |
1 |
1 |
defined $ip_version and $ip_version == $Kafka::IO::IP_V6
|
779
|
1 |
0 |
7 |
$is_v4_fqdn and !defined($ip_version) || $ip_version == $Kafka::IO::IP_V4
|
793
|
13 |
0 |
0 |
$is_ip = is_ipv6($name) and not $ip_version
|
|
9 |
1 |
1 |
$is_ip = is_ipv4($name) and not $ip_version
|
794
|
0 |
2 |
0 |
$ip_version and !$is_ip && is_ipv4($name) || $is_ip && $ip_version == $Kafka::IO::IP_V4
|
806
|
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 |
282
|
1 |
0 |
0 |
$self->{'timeout'} // $Kafka::IO::REQUEST_TIMEOUT
|
368
|
0 |
0 |
0 |
$error_code // $Kafka::IO::ERROR_CANNOT_SEND
|
399
|
1 |
0 |
0 |
$self->{'timeout'} // $Kafka::IO::REQUEST_TIMEOUT
|
499
|
0 |
0 |
0 |
$error_code // $Kafka::IO::ERROR_CANNOT_RECV
|
670
|
0 |
9 |
1 |
connect $connection, $sockaddr or $!{'EINPROGRESS'}
|
679
|
9 |
0 |
0 |
$timeout // $Kafka::IO::REQUEST_TIMEOUT
|
701
|
9 |
0 |
0 |
$timeout // $Kafka::IO::REQUEST_TIMEOUT
|
779
|
6 |
1 |
0 |
!defined($ip_version) || $ip_version == $Kafka::IO::IP_V4
|
793
|
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
|
794
|
1 |
0 |
1 |
!$is_ip && is_ipv4($name) || $is_ip && $ip_version == $Kafka::IO::IP_V4
|
806
|
0 |
0 |
2 |
!$is_ip && is_ipv6($name) || $is_ip && $ip_version == $Kafka::IO::IP_V6
|