line |
l |
!l&&r |
!l&&!r |
condition |
703
|
0 |
0 |
0 |
$api_version //= $DEFAULT_APIVERSION |
889
|
0 |
0 |
98 |
$api_version //= $DEFAULT_APIVERSION |
1030
|
0 |
0 |
5021 |
$api_version //= $DEFAULT_APIVERSION |
1056
|
0 |
0 |
5021 |
$is_v1 or $is_v2 |
|
0 |
0 |
5021 |
$is_v1 or $is_v2 or $is_v3 |
1228
|
18 |
0 |
5 |
$api_version //= $DEFAULT_APIVERSION |
1749
|
18 |
0 |
10262 |
$request_ref->{'ApiVersion'} // $DEFAULT_APIVERSION |
1771
|
0 |
0 |
5021 |
$is_v1 or $is_v2 |
|
0 |
0 |
5021 |
$is_v1 or $is_v2 or $is_v3 |
1869
|
1 |
3 |
0 |
$compressed_data //= pack('a[8]L>L>', $XERIAL_SNAPPY_MAGIC_HEADER, $XERIAL_SNAPPY_FILE_VERSION, $XERIAL_SNAPPY_FILE_VERSION) |
1891
|
3 |
0 |
0 |
_snappy_xerial_decompress($data) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to decompress snappy compressed data') |
1897
|
0 |
0 |
0 |
&Compress::LZ4Frame::decompress($data) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to decompress LZ4 compressed data') |
1915
|
2 |
0 |
0 |
gzip($data) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to compress gzip data') |
1918
|
2 |
0 |
0 |
_snappy_xerial_compress($data) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to compress snappy data') |
1923
|
0 |
0 |
0 |
&Compress::LZ4Frame::compress_checksum($data) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to compress LZ4 data') |
2015
|
25164 |
0 |
0 |
$Attributes //= $Kafka::Protocol::COMPRESSION_NONE |
2109
|
7 |
0 |
25147 |
$compression_codec // $Kafka::Protocol::COMPRESSION_NONE |