Condition Coverage

blib/lib/EV/Kafka.pm
Criterion Covered Total %
condition 26 349 7.4


and 3 conditions

line !l l&&!r l&&r condition
87 1 0 0 $conn && $conn->connected
123 0 0 0 $weak_cfg and $weak_cfg->{'on_error'}
204 0 0 0 $cfg->{'bootstrap_conn'} and $meta->{'brokers'}
0 0 0 $cfg->{'bootstrap_conn'} and $meta->{'brokers'} and @{$meta->{'brokers'};}
209 0 0 0 $cfg->{'idempotent'} || $cfg->{'transactional_id'} and $cfg->{'producer_id'} < 0
247 0 0 0 $t->{'name'} eq $topic and not $t->{'error_code'}
0 0 0 $t->{'name'} eq $topic and not $t->{'error_code'} and @{$t->{'partitions'} // [];}
273 0 0 0 not $err and $res
0 0 0 not $err and $res and not $res->{'error_code'}
291 0 0 0 $res->{'error_code'} and $res->{'error_code'} != 0
300 0 0 0 $txn_conn and $txn_conn->connected
327 0 0 0 defined $op->{'node_id'} and $op->{'node_id'} == $node_id
344 0 0 0 $conn and $conn->connected
378 0 0 0 defined $key and length $key
421 0 0 0 $conn and $conn->connected
460 0 0 0 $batch and @$batch
469 0 0 0 defined $cfg->{'producer_id'} and $cfg->{'producer_id'} >= 0
486 0 0 0 not $err and $result
0 0 0 not $err and $result and ref $result->{'topics'} eq "ARRAY"
495 0 0 0 $retriable and ($cfg->{'_batch_retries'}{$bkey} // 0) > 0
527 0 0 0 $conn and $conn->connected
531 0 0 0 $skipped and keys %{$$cfg{"batches"};}
544 0 0 0 $cb and not $remaining
556 0 0 0 --$remaining <= 0 and $cb
562 0 0 0 $cb and $acks0
578 0 0 0 $conn and $conn->connected
582 0 0 0 $cfg->{'bootstrap_conn'} and $cfg->{'bootstrap_conn'}->connected
0 0 0 $cfg->{'bootstrap_conn'} and $cfg->{'bootstrap_conn'}->connected and not $seen{${$cfg->{'bootstrap_conn'};}}
595 0 0 0 $c and $c->connected
601 0 0 0 $cfg->{'bootstrap_conn'} and $cfg->{'bootstrap_conn'}->connected
0 0 0 $cfg->{'bootstrap_conn'} and $cfg->{'bootstrap_conn'}->connected and not $s{${$cfg->{'bootstrap_conn'};}}
622 0 0 0 $a->{'topic'} eq $topic and $a->{'partition'} == $partition
630 0 0 0 $conn and $conn->connected
633 0 0 0 not $err and $res
677 0 0 0 $conn and $conn->connected
697 0 0 0 not $err and $result
0 0 0 not $err and $result and ref $result->{'topics'} eq "ARRAY"
718 0 0 0 $cb and $dispatched <= 0
721 0 0 0 $cb and not $dispatched
729 0 0 0 $cb and not $np
737 0 0 0 $conn and $conn->connected
739 0 0 0 $cb and --$remaining <= 0
747 0 0 0 not $err and $res
0 0 0 not $err and $res and ref $res->{'topics'} eq "ARRAY"
754 0 0 0 $cb and --$remaining <= 0
765 0 0 0 $cb and not @assignments
773 0 0 0 $conn and $conn->connected
777 0 0 0 not $err and $res
0 0 0 not $err and $res and ref $res->{'topics'} eq "ARRAY"
785 0 0 0 $cb and --$remaining <= 0
789 0 0 0 $cb and --$remaining <= 0
930 0 0 0 $is_leader and $res->{'members'}
0 0 0 $is_leader and $res->{'members'} and @{$res->{'members'};}
1101 0 0 0 $coord and $coord->connected
0 0 0 $coord and $coord->connected and @$assignments
1115 0 0 0 not $err and $res
0 0 0 not $err and $res and ref $res->{'topics'} eq "ARRAY"
1121 0 0 0 $a->{'topic'} eq $t->{'topic'} and $a->{'partition'} == $p->{'partition'}
1136 0 0 0 $lconn and $lconn->connected
1139 0 0 0 not $lerr and $lres
0 0 0 not $lerr and $lres and ref $lres->{'topics'} eq "ARRAY"
1169 0 0 0 $coord and $coord->connected
1174 0 0 0 $res and $res->{'error_code'} == 27
1217 0 0 0 $coord and $coord->connected
1251 0 0 0 $g and $g->{'coordinator'}
0 0 0 $g and $g->{'coordinator'} and $g->{'coordinator'}->connected
0 0 0 $g and $g->{'coordinator'} and $g->{'coordinator'}->connected and $g->{'member_id'}
1264 0 0 0 $g and $g->{'auto_commit'}
1277 0 0 0 defined $cfg->{'producer_id'} and $cfg->{'producer_id'} >= 0
1286 0 0 0 $conn and $conn->connected
1401 0 0 0 $conn and $conn->connected
1414 0 0 4 $self and $self->{'cfg'}

or 2 conditions

line l !l condition
19 2 3 delete $opts{'brokers'} // "127.0.0.1:9092"
24 6 1 $p //= 9092
49 0 5 delete $opts{'client_id'} // "ev-kafka"
0 5 delete $opts{'tls'} // 0
0 5 delete $opts{'tls_skip_verify'} // 0
1 4 delete $opts{'acks'} // -1
0 5 delete $opts{'linger_ms'} // 5
0 5 delete $opts{'batch_size'} // 16384
0 5 delete $opts{'idempotent'} // 0
0 5 delete $opts{'fetch_max_wait_ms'} // 500
0 5 delete $opts{'fetch_max_bytes'} // 1048576
0 5 delete $opts{'fetch_min_bytes'} // 1
0 5 delete $opts{'metadata_refresh'} // 300
170 0 0 $meta->{'brokers'} // []
175 0 0 $meta->{'topics'} // []
177 0 0 $t->{'partitions'} // []
246 0 0 $meta->{'topics'} // []
247 0 0 $t->{'partitions'} // []
363 0 0 $meta->{'topics'} // []
433 0 0 $cfg->{'batches'}{$bkey} //= []
439 0 0 $b->{'rec'}{'value'} // ""
0 0 $b->{'rec'}{'key'} // ""
472 0 0 $cfg->{'next_sequence'}{$bkey} // 0
480 0 0 $cfg->{'_batch_retries'}{$bkey} //= 3
488 0 0 $t->{'partitions'} // []
489 0 0 $p->{'error_code'} // 0
495 0 0 $cfg->{'_batch_retries'}{$bkey} // 0
577 0 0 $cfg->{'conns'} // {}
594 0 0 $cfg->{'conns'} // {}
699 0 0 $t->{'partitions'} // []
700 0 0 $p->{'records'} // []
764 0 0 $cfg->{'assignments'} // []
778 0 0 $res->{'topics'}[0]{'partitions'}[0]{'offset'} // 0
832 0 0 $opts{'session_timeout'} // 30000
0 0 $opts{'rebalance_timeout'} // 60000
0 0 $opts{'heartbeat_interval'} // 3
0 0 $opts{'auto_commit'} // 1
0 0 $opts{'auto_offset_reset'} // "earliest"
947 7 0 $meta->{'topics'} // []
950 11 0 $t->{'partitions'} // []
960 5 2 $cfg->{'_prev_assignments'} // {}
969 4 10 $prev->{$mid} // []
1050 0 0 $res->{'assignment'} // ""
1066 0 0 $g->{'auto_offset_reset'} // "earliest"
1117 0 0 $t->{'partitions'} // []
1141 0 0 $lt->{'partitions'} // []
1221 0 0 $cfg->{'assignments'} // []
1336 0 0 $cfg->{'assignments'} // []
1358 0 0 $g->{'member_id'} // ""
1400 4 0 $cfg->{'conns'} // {}

or 3 conditions

line l !l&&r !l&&!r condition
49 5 0 0 delete $opts{'on_error'} // sub { die "EV::Kafka: @_\n"; }
206 0 0 0 $cfg->{'conns'}{$binfo->{'node_id'}} //= $cfg->{'bootstrap_conn'}
209 0 0 0 $cfg->{'idempotent'} || $cfg->{'transactional_id'}
277 0 0 0 $err || 'InitProducerId error: ' . ($res->{'error_code'} // '?')
291 0 0 0 $err or $res->{'error_code'} and $res->{'error_code'} != 0
308 0 0 0 $cfg->{'_txn_coordinator'} || $conn
490 0 0 0 $ec == 6 or $ec == 15
0 0 0 $ec == 6 or $ec == 15 or $ec == 16
860 0 0 0 $err or $res->{'error_code'}
861 0 0 0 $err || "FindCoordinator error: $res->{'error_code'}"
903 0 0 0 $res->{'error_code'} == 15 or $res->{'error_code'} == 16