| line |
true |
false |
branch |
|
656
|
0 |
0 |
if ($api_version >= 1)
|
|
708
|
0 |
0 |
$is_v1 ? :
|
|
715
|
0 |
0 |
if ($is_v1)
|
|
719
|
0 |
0 |
if ($is_v1)
|
|
895
|
0 |
98 |
$is_v2 ? :
|
|
|
0 |
98 |
$is_v1 ? :
|
|
914
|
0 |
98 |
$is_v2 ? :
|
|
927
|
0 |
98 |
if defined $data[$i]
|
|
976
|
0 |
5015 |
$is_v3 ? :
|
|
979
|
0 |
5015 |
if ($is_v3) { }
|
|
1058
|
0 |
5021 |
if ($is_v1 or $is_v2 or $is_v3)
|
|
1139
|
0 |
27 |
$is_v1 ? :
|
|
1140
|
0 |
27 |
$is_v1 ? :
|
|
1155
|
0 |
27 |
$is_v1 ? :
|
|
1232
|
0 |
23 |
$is_v1 ? :
|
|
1256
|
0 |
23 |
if ($is_v1) { }
|
|
1488
|
0 |
0 |
if ($is_v1)
|
|
1524
|
0 |
0 |
if ($is_v1)
|
|
1867
|
0 |
5021 |
if ($is_v1 or $is_v2 or $is_v3) { }
|
|
1932
|
4 |
0 |
if (length $data > 16)
|
|
1934
|
3 |
1 |
if ($header eq $XERIAL_SNAPPY_MAGIC_HEADER)
|
|
1936
|
0 |
3 |
unless $x_compatversion == $XERIAL_SNAPPY_FILE_VERSION
|
|
1937
|
0 |
3 |
unless $x_version == $XERIAL_SNAPPY_FILE_VERSION
|
|
1941
|
0 |
4 |
if length $data < 4
|
|
1944
|
0 |
4 |
if length $data < $compressed_frame_length
|
|
1947
|
0 |
4 |
unless defined $uncompressed_frame
|
|
1952
|
1 |
3 |
if ($raw_format_suspected)
|
|
1964
|
0 |
4 |
unless defined $compressed_block
|
|
1973
|
0 |
7 |
if 'Kafka::Protocol'->debug_level // !1
|
|
1980
|
3 |
4 |
if ($compression_codec == $Kafka::Protocol::COMPRESSION_GZIP) { }
|
|
|
3 |
1 |
elsif ($compression_codec == $Kafka::Protocol::COMPRESSION_SNAPPY) { }
|
|
|
1 |
0 |
elsif ($compression_codec == $Kafka::Protocol::COMPRESSION_LZ4) { }
|
|
1992
|
0 |
1 |
if (&Compress::LZ4Frame::looks_like_lz4frame($data)) { }
|
|
2001
|
0 |
5 |
unless defined $decompressed
|
|
2010
|
2 |
2 |
if ($compression_codec == $Kafka::Protocol::COMPRESSION_GZIP) { }
|
|
|
2 |
0 |
elsif ($compression_codec == $Kafka::Protocol::COMPRESSION_SNAPPY) { }
|
|
|
0 |
0 |
elsif ($compression_codec == $Kafka::Protocol::COMPRESSION_LZ4) { }
|
|
2043
|
12 |
25072 |
if (defined $_override_offset)
|
|
2061
|
0 |
25084 |
if ($is_v1_msg_format)
|
|
2066
|
25084 |
0 |
$Key_length == $NULL_BYTES_LENGTH ? :
|
|
2068
|
0 |
25084 |
$Value_length == $NULL_BYTES_LENGTH ? :
|
|
2070
|
7 |
25077 |
if (my $compression_codec = $Message->{'Attributes'} & $COMPRESSION_CODEC_MASK) { }
|
|
2109
|
0 |
25164 |
$v1_format ? :
|
|
2119
|
0 |
25164 |
$v1_format ? :
|
|
|
0 |
25164 |
$key_length ? :
|
|
|
25164 |
0 |
$value_length ? :
|
|
|
0 |
25164 |
$v1_format ? :
|
|
|
0 |
25164 |
$key_length ? :
|
|
|
25164 |
0 |
$value_length ? :
|
|
2154
|
0 |
25160 |
if ($MessageSet->{'Timestamp'})
|
|
2160
|
4 |
10123 |
if ($compression_codec)
|
|
2242
|
2 |
25088 |
if $MessageSetSize < 22
|
|
2267
|
0 |
25088 |
if ($is_v1_msg_format and $MessageSetSize < 30)
|
|
2272
|
0 |
25088 |
$is_v1_msg_format ? :
|
|
2274
|
0 |
25088 |
$is_v1_msg_format ? :
|
|
2284
|
0 |
25088 |
if $Key_length != $NULL_BYTES_LENGTH
|
|
2286
|
25086 |
2 |
if ($bin_stream_length >= $response->{'stream_offset'} + 4) { }
|
|
2287
|
0 |
25086 |
if $Key_length != $NULL_BYTES_LENGTH
|
|
2304
|
25086 |
0 |
if $Value_length != $NULL_BYTES_LENGTH
|
|
2306
|
25084 |
2 |
if ($bin_stream_length >= $response->{'stream_offset'}) { }
|
|
2307
|
25084 |
0 |
if $Value_length != $NULL_BYTES_LENGTH
|
|
2316
|
25084 |
4 |
if ($local_template) { }
|
|
2335
|
131 |
30662 |
if ($string eq '') { }
|