| line |
!l |
l&&!r |
l&&r |
condition |
|
265
|
659 |
594 |
0 |
exists $p{$_} and $self->{$_} = $p{$_} |
|
272
|
7 |
1 |
151 |
$self->{'ClientId'} eq '' || defined &_STRING($self->{'ClientId'}) and not utf8::is_utf8($self->{'ClientId'}) |
|
274
|
1 |
9 |
141 |
defined $self->{'MaxWaitTime'} and defined &_NUMBER($self->{'MaxWaitTime'}) |
|
|
10 |
2 |
139 |
defined $self->{'MaxWaitTime'} and defined &_NUMBER($self->{'MaxWaitTime'}) and int $self->{'MaxWaitTime'} * 1000 >= 1 |
|
|
11 |
0 |
139 |
defined $self->{'MaxWaitTime'} and defined &_NUMBER($self->{'MaxWaitTime'}) and int $self->{'MaxWaitTime'} * 1000 >= 1 and int $self->{'MaxWaitTime'} * 1000 <= $Kafka::Consumer::MAX_INT32 |
|
276
|
13 |
0 |
126 |
_isbig($self->{'MinBytes'}) ? $self->{'MinBytes'} >= 0 : defined &_NONNEGINT($self->{'MinBytes'}) and $self->{'MinBytes'} <= $Kafka::Consumer::MAX_INT32 |
|
278
|
15 |
1 |
110 |
_isbig($self->{'MaxBytes'}) ? $self->{'MaxBytes'} > 0 : &_POSINT($self->{'MaxBytes'}) and $self->{'MaxBytes'} >= $Kafka::Consumer::MESSAGE_SIZE_OVERHEAD |
|
|
16 |
0 |
110 |
_isbig($self->{'MaxBytes'}) ? $self->{'MaxBytes'} > 0 : &_POSINT($self->{'MaxBytes'}) and $self->{'MaxBytes'} >= $Kafka::Consumer::MESSAGE_SIZE_OVERHEAD and $self->{'MaxBytes'} <= $Kafka::Consumer::MAX_INT32 |
|
280
|
15 |
0 |
95 |
defined &_POSINT($self->{'MaxNumberOfOffsets'}) and $self->{'MaxNumberOfOffsets'} <= $Kafka::Consumer::MAX_INT32 |
|
335
|
0 |
7 |
5048 |
defined $topic and $topic eq '' || defined &_STRING($topic) |
|
|
7 |
1 |
5047 |
defined $topic and $topic eq '' || defined &_STRING($topic) and not utf8::is_utf8($topic) |
|
337
|
0 |
10 |
5037 |
defined $partition and &isint($partition) |
|
|
10 |
0 |
5037 |
defined $partition and &isint($partition) and $partition >= 0 |
|
339
|
1 |
12 |
5024 |
defined $start_offset and _isbig($start_offset) && $start_offset >= 0 || defined &_NONNEGINT($start_offset) |
|
341
|
12 |
1 |
5009 |
_isbig($max_size) || &_POSINT($max_size) and $max_size >= $Kafka::Consumer::MESSAGE_SIZE_OVERHEAD |
|
|
13 |
0 |
5009 |
_isbig($max_size) || &_POSINT($max_size) and $max_size >= $Kafka::Consumer::MESSAGE_SIZE_OVERHEAD and $max_size <= $Kafka::Consumer::MAX_INT32 |
|
387
|
15018 |
0 |
0 |
$offset < $start_offset and not $_return_all |
|
474
|
0 |
0 |
0 |
defined $time and _isbig($time) || &isint($time) |
|
|
0 |
0 |
0 |
defined $time and _isbig($time) || &isint($time) and $time >= 0 |
|
520
|
0 |
0 |
0 |
defined $time and _isbig($time) || &isint($time) |
|
|
0 |
0 |
0 |
defined $time and _isbig($time) || &isint($time) and $time >= 0 |
|
621
|
0 |
10 |
53 |
defined $time and _isbig($time) || &isint($time) |
|
|
10 |
1 |
52 |
defined $time and _isbig($time) || &isint($time) and $time >= $Kafka::Consumer::RECEIVE_EARLIEST_OFFSET |
|
623
|
14 |
0 |
36 |
&_POSINT($max_number) and $max_number <= $Kafka::Consumer::MAX_INT32 |
|
632
|
0 |
7 |
31 |
defined $topic and $topic eq '' || defined &_STRING($topic) |
|
|
7 |
1 |
30 |
defined $topic and $topic eq '' || defined &_STRING($topic) and not utf8::is_utf8($topic) |
|
634
|
0 |
10 |
20 |
defined $partition and &isint($partition) |
|
|
10 |
0 |
20 |
defined $partition and &isint($partition) and $partition >= 0 |
|
723
|
0 |
0 |
0 |
defined $topic and $topic eq '' || defined &_STRING($topic) |
|
|
0 |
0 |
0 |
defined $topic and $topic eq '' || defined &_STRING($topic) and not utf8::is_utf8($topic) |
|
725
|
0 |
0 |
0 |
defined $partition and &isint($partition) |
|
|
0 |
0 |
0 |
defined $partition and &isint($partition) and $partition >= 0 |
|
727
|
0 |
0 |
0 |
defined $offset and _isbig($offset) && $offset >= 0 || defined &_NONNEGINT($offset) |
|
729
|
0 |
0 |
0 |
defined $group and $group eq '' || defined &_STRING($group) |
|
|
0 |
0 |
0 |
defined $group and $group eq '' || defined &_STRING($group) and not utf8::is_utf8($group) |
|
787
|
0 |
0 |
0 |
defined $topic and $topic eq '' || defined &_STRING($topic) |
|
|
0 |
0 |
0 |
defined $topic and $topic eq '' || defined &_STRING($topic) and not utf8::is_utf8($topic) |
|
789
|
0 |
0 |
0 |
defined $partition and &isint($partition) |
|
|
0 |
0 |
0 |
defined $partition and &isint($partition) and $partition >= 0 |
|
791
|
0 |
0 |
0 |
defined $group and $group eq '' || defined &_STRING($group) |
|
|
0 |
0 |
0 |
defined $group and $group eq '' || defined &_STRING($group) and not utf8::is_utf8($group) |
| line |
l |
!l&&r |
!l&&!r |
condition |
|
272
|
0 |
152 |
7 |
$self->{'ClientId'} eq '' || defined &_STRING($self->{'ClientId'}) |
|
335
|
0 |
5048 |
7 |
$topic eq '' || defined &_STRING($topic) |
|
339
|
0 |
5024 |
12 |
_isbig($start_offset) && $start_offset >= 0 || defined &_NONNEGINT($start_offset) |
|
341
|
0 |
5010 |
12 |
_isbig($max_size) || &_POSINT($max_size) |
|
|
2 |
5022 |
0 |
not defined $max_size or _isbig($max_size) || &_POSINT($max_size) and $max_size >= $Kafka::Consumer::MESSAGE_SIZE_OVERHEAD and $max_size <= $Kafka::Consumer::MAX_INT32 |
|
361
|
0 |
0 |
5011 |
$api_version // $self->{'ApiVersion'} |
|
|
5009 |
2 |
0 |
$max_size // $self->{'MaxBytes'} |
|
|
5009 |
2 |
0 |
$max_size // $self->{'MaxBytes'} |
|
403
|
0 |
0 |
0 |
$compression_codec == 1 or $compression_codec == 2 |
|
474
|
0 |
0 |
0 |
_isbig($time) || &isint($time) |
|
520
|
0 |
0 |
0 |
_isbig($time) || &isint($time) |
|
621
|
0 |
53 |
10 |
_isbig($time) || &isint($time) |
|
623
|
2 |
50 |
0 |
not defined $max_number or &_POSINT($max_number) and $max_number <= $Kafka::Consumer::MAX_INT32 |
|
632
|
0 |
31 |
7 |
$topic eq '' || defined &_STRING($topic) |
|
653
|
18 |
2 |
0 |
$max_number // $self->{'MaxNumberOfOffsets'} |
|
723
|
0 |
0 |
0 |
$topic eq '' || defined &_STRING($topic) |
|
727
|
0 |
0 |
0 |
_isbig($offset) && $offset >= 0 || defined &_NONNEGINT($offset) |
|
729
|
0 |
0 |
0 |
$group eq '' || defined &_STRING($group) |
|
787
|
0 |
0 |
0 |
$topic eq '' || defined &_STRING($topic) |
|
791
|
0 |
0 |
0 |
$group eq '' || defined &_STRING($group) |