line |
true |
false |
branch |
205
|
0 |
0 |
if defined $error
|
232
|
0 |
0 |
unless defined &_STRING($message)
|
236
|
0 |
0 |
unless $length <= $Kafka::IO::Async::MAX_SOCKET_REQUEST_BYTES
|
239
|
0 |
0 |
unless defined $timeout
|
240
|
0 |
0 |
unless $timeout > 0
|
245
|
0 |
0 |
if not $socket or $socket->destroyed
|
281
|
0 |
0 |
unless $length > 0
|
284
|
0 |
0 |
unless defined $timeout
|
285
|
0 |
0 |
unless $timeout > 0
|
289
|
0 |
0 |
if not $socket or $socket->destroyed
|
310
|
0 |
0 |
if $fatal
|
327
|
0 |
0 |
if $error
|
345
|
0 |
0 |
unless $length > 0
|
348
|
0 |
0 |
unless defined $timeout
|
349
|
0 |
0 |
unless $timeout > 0
|
353
|
0 |
0 |
if not $socket or $socket->destroyed
|
387
|
0 |
0 |
if $error
|
402
|
0 |
0 |
if ($self->{'socket'})
|
443
|
0 |
0 |
if $fatal
|
457
|
0 |
0 |
$timeout ? :
|
461
|
0 |
0 |
if $error
|
472
|
0 |
0 |
if ($header) { }
|
473
|
0 |
0 |
unless ($_hdr)
|
519
|
0 |
0 |
if $self->debug_level
|