line |
l |
!l&&r |
!l&&!r |
condition |
705
|
0 |
0 |
0 |
$api_version //= $DEFAULT_APIVERSION
|
891
|
0 |
0 |
98 |
$api_version //= $DEFAULT_APIVERSION
|
1032
|
0 |
0 |
5021 |
$api_version //= $DEFAULT_APIVERSION
|
1058
|
0 |
0 |
5021 |
$is_v1 or $is_v2
|
|
0 |
0 |
5021 |
$is_v1 or $is_v2 or $is_v3
|
1230
|
18 |
0 |
5 |
$api_version //= $DEFAULT_APIVERSION
|
1845
|
19 |
0 |
10263 |
$request_ref->{'ApiVersion'} // $DEFAULT_APIVERSION
|
1867
|
0 |
0 |
5021 |
$is_v1 or $is_v2
|
|
0 |
0 |
5021 |
$is_v1 or $is_v2 or $is_v3
|
1965
|
1 |
3 |
0 |
$compressed_data //= pack('a[8]L>L>', $XERIAL_SNAPPY_MAGIC_HEADER, $XERIAL_SNAPPY_FILE_VERSION, $XERIAL_SNAPPY_FILE_VERSION)
|
1987
|
3 |
0 |
0 |
_snappy_xerial_decompress($data) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to decompress snappy compressed data')
|
1993
|
0 |
0 |
0 |
&Compress::LZ4Frame::decompress($data) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to decompress LZ4 compressed data')
|
2011
|
2 |
0 |
0 |
gzip($data) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to compress gzip data')
|
2014
|
2 |
0 |
0 |
_snappy_xerial_compress($data) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to compress snappy data')
|
2019
|
0 |
0 |
0 |
&Compress::LZ4Frame::compress_checksum($data) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to compress LZ4 data')
|
2111
|
25164 |
0 |
0 |
$Attributes //= $Kafka::Protocol::COMPRESSION_NONE
|
2205
|
7 |
0 |
25147 |
$compression_codec // $Kafka::Protocol::COMPRESSION_NONE
|