| line |
l |
!l&&r |
!l&&!r |
condition |
|
700
|
0 |
0 |
0 |
$api_version //= $DEFAULT_APIVERSION |
|
883
|
0 |
0 |
98 |
$api_version //= $DEFAULT_APIVERSION |
|
1024
|
0 |
0 |
5021 |
$api_version //= $DEFAULT_APIVERSION |
|
1050
|
0 |
0 |
5021 |
$is_v1 or $is_v2 |
|
|
0 |
0 |
5021 |
$is_v1 or $is_v2 or $is_v3 |
|
1222
|
18 |
0 |
5 |
$api_version //= $DEFAULT_APIVERSION |
|
1743
|
18 |
0 |
10262 |
$request_ref->{'ApiVersion'} // $DEFAULT_APIVERSION |
|
1765
|
0 |
0 |
5021 |
$is_v1 or $is_v2 |
|
|
0 |
0 |
5021 |
$is_v1 or $is_v2 or $is_v3 |
|
1884
|
2 |
0 |
0 |
&Compress::Snappy::decompress($Message->{'Value'}) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to decompress snappy compressed data') |
|
1963
|
2 |
0 |
0 |
gzip($message_set) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to compress gzip data') |
|
1966
|
2 |
0 |
0 |
&Compress::Snappy::compress($message_set) // _error($Kafka::Protocol::ERROR_COMPRESSION, 'Unable to compress snappy data') |
|
2006
|
7 |
0 |
25147 |
$compression_codec // $Kafka::Protocol::COMPRESSION_NONE |