| line |
true |
false |
branch |
|
248
|
4 |
9 |
if defined $error
|
|
275
|
0 |
1 |
unless defined &_STRING($message)
|
|
279
|
0 |
1 |
unless $length <= $Kafka::IO::MAX_SOCKET_REQUEST_BYTES
|
|
282
|
1 |
0 |
unless defined $timeout
|
|
283
|
0 |
1 |
unless $timeout > 0
|
|
287
|
0 |
1 |
unless $select
|
|
289
|
0 |
1 |
if $self->debug_level >= 2
|
|
303
|
0 |
1 |
if $remaining_time <= 0
|
|
308
|
0 |
1 |
if ($errno)
|
|
309
|
0 |
0 |
if ($errno == 4)
|
|
321
|
1 |
0 |
if ($can_write)
|
|
323
|
0 |
1 |
if ($retries == 1 and $self->_is_close_wait)
|
|
333
|
1 |
0 |
if (defined $wrote and $wrote > 0)
|
|
335
|
0 |
1 |
if ($sent < $length)
|
|
341
|
0 |
1 |
if ($errno)
|
|
342
|
0 |
0 |
if ($errno == 4) { }
|
|
|
0 |
0 |
elsif ($errno != 11 and $errno != 11 and not $errno == 104 && $^O eq 'freebsd') { }
|
|
358
|
0 |
1 |
unless defined $wrote
|
|
362
|
0 |
1 |
unless (not $errno and defined $sent and $sent == $length)
|
|
396
|
0 |
1 |
unless $length > 0
|
|
399
|
1 |
0 |
unless defined $timeout
|
|
400
|
0 |
1 |
unless $timeout > 0
|
|
404
|
0 |
1 |
unless $select
|
|
418
|
0 |
1 |
if $remaining_time <= 0
|
|
423
|
0 |
1 |
if ($errno)
|
|
424
|
0 |
0 |
if ($errno == 4)
|
|
436
|
1 |
0 |
if ($can_read)
|
|
442
|
1 |
0 |
if (defined $from_recv and length $buf)
|
|
447
|
0 |
1 |
if ($errno)
|
|
448
|
0 |
0 |
if ($errno == 4) { }
|
|
|
0 |
0 |
elsif ($errno != 11 and $errno != 11 and not $errno == 104 && $^O eq 'freebsd') { }
|
|
464
|
0 |
1 |
if (length $buf == 0)
|
|
465
|
0 |
0 |
if (defined $from_recv and not $errno)
|
|
467
|
0 |
0 |
if $self->debug_level
|
|
471
|
0 |
0 |
if (length $message == 0)
|
|
479
|
0 |
0 |
if (my $remaining_attempts = $MAX_RETRIES - $retries)
|
|
482
|
0 |
0 |
if ($micro_seconds > 0)
|
|
483
|
0 |
0 |
if $micro_seconds > 250000
|
|
484
|
0 |
0 |
if $self->debug_level
|
|
493
|
0 |
1 |
unless (not $errno and length $message >= $length)
|
|
510
|
0 |
1 |
if $self->debug_level >= 2
|
|
540
|
1 |
0 |
if ($self->{'socket'})
|
|
551
|
0 |
1 |
unless $self->{'socket'} and $self->{'_io_select'}
|
|
554
|
1 |
0 |
unless $self->{'_io_select'}->can_read(0)
|
|
568
|
1 |
2 |
unless $socket
|
|
594
|
2 |
10 |
if ($self->_get_family($name)) { }
|
|
597
|
10 |
0 |
if (defined $timeout) { }
|
|
601
|
0 |
10 |
if $self->debug_level
|
|
621
|
0 |
10 |
if $self->debug_level
|
|
624
|
0 |
10 |
if $error
|
|
625
|
2 |
8 |
unless $ip
|
|
630
|
0 |
8 |
if $self->debug_level
|
|
632
|
2 |
6 |
if ($remaining)
|
|
633
|
1 |
1 |
if ($remaining - $elapsed > 0) { }
|
|
634
|
0 |
1 |
if $self->debug_level
|
|
638
|
0 |
1 |
if $self->debug_level
|
|
643
|
0 |
2 |
if $self->debug_level
|
|
648
|
0 |
0 |
unless $ip
|
|
653
|
0 |
10 |
unless socket my $connection, $self->{'pf'}, 1, scalar getprotobyname 'tcp'
|
|
659
|
0 |
10 |
unless my $flags = fcntl($connection, 3, 0)
|
|
660
|
0 |
10 |
unless fcntl $connection, 4, $flags | 1
|
|
662
|
0 |
10 |
unless $flags = fcntl($connection, 3, 0)
|
|
663
|
0 |
10 |
unless fcntl $connection, 4, $flags | 2048
|
|
668
|
9 |
1 |
$self->{'af'} eq 2 ? :
|
|
670
|
1 |
9 |
unless connect $connection, $sockaddr or $!{'EINPROGRESS'}
|
|
673
|
0 |
9 |
unless $flags = fcntl($connection, 3, 0)
|
|
674
|
0 |
9 |
unless fcntl $connection, 4, $flags & 18446744073709549567
|
|
680
|
0 |
9 |
unless (vec $vec, fileno $connection, 1)
|
|
688
|
0 |
9 |
if $!
|
|
720
|
0 |
9 |
if ($Kafka::IO::Config{'osname'} eq 'netbsd' and _major_osvers() >= 6 and $Kafka::IO::Config{'longsize'} == 4) { }
|
|
721
|
0 |
0 |
if (defined $Kafka::IO::Config{'use64bitint'}) { }
|
|
727
|
0 |
0 |
$Kafka::IO::Config{'byteorder'} eq '1234' ? :
|
|
755
|
1 |
7 |
if (defined $ip_version and $ip_version == $Kafka::IO::IP_V6)
|
|
765
|
0 |
1 |
if $err
|
|
770
|
0 |
1 |
if $err
|
|
779
|
7 |
0 |
if ($is_v4_fqdn and !defined($ip_version) || $ip_version == $Kafka::IO::IP_V4)
|
|
780
|
5 |
2 |
if (my $ipaddr = gethostbyname $name)
|
|
793
|
2 |
11 |
if ($is_ip = is_ipv6($name) and not $ip_version or $ip_version == $Kafka::IO::IP_V6) { }
|
|
|
3 |
8 |
elsif ($is_ip = is_ipv4($name) and not $ip_version or $ip_version == $Kafka::IO::IP_V4) { }
|
|
|
8 |
0 |
elsif (not $ip_version) { }
|
|
794
|
1 |
1 |
if $ip_version and !$is_ip && is_ipv4($name) || $is_ip && $ip_version == $Kafka::IO::IP_V4
|
|
806
|
0 |
2 |
if $ip_version and !$is_ip && is_ipv6($name) || $is_ip && $ip_version == $Kafka::IO::IP_V6
|
|
829
|
0 |
0 |
if ($header) { }
|
|
830
|
0 |
0 |
unless ($_hdr)
|
|
876
|
0 |
88 |
if $self->debug_level
|