Condition Coverage

blib/lib/EV/ClickHouse.pm
Criterion Covered Total %
condition 0 334 0.0


and 3 conditions

line !l l&&!r l&&r condition
39 0 0 0 defined $qs and length $qs
42 0 0 0 defined $k and length $k
57 0 0 0 defined $u and $u ne ""
61 0 0 0 defined $db and $db ne ""
77 0 0 0 ref $h eq "ARRAY" and @$h
138 0 0 0 defined $qlc and length $qlc
141 0 0 0 !ref($qlc) && "$qlc" ne '1'
169 0 0 0 not $host =~ /^[\d.]+$|^\[?[0-9a-fA-F:]+\]?$/ and eval { do { require EV::cares; 1 } }
192 0 0 0 $weak2 and $weak2->_take_dns_pending
273 0 0 0 defined $table and ref $producer eq "CODE"
0 0 0 defined $table and ref $producer eq "CODE" and ref $cb eq "CODE"
291 0 0 0 $hi and $s->buffered_count >= $hi
317 0 0 0 defined $table and defined $data
0 0 0 defined $table and defined $data and ref $cb eq "CODE"
410 0 0 0 defined $query_id and ref $cb eq "CODE"
461 0 0 0 defined $dur and $dur >= 0
516 0 0 0 defined $query_id and length $query_id
518 0 0 0 defined $cur and $cur eq $query_id
579 0 0 0 defined $table and ref $cb eq "CODE"
605 0 0 0 defined $table and defined $column
0 0 0 defined $table and defined $column and ref $cb eq "CODE"
677 0 0 0 defined $threshold and ref $cb eq "CODE"
683 0 0 0 defined $dur and $dur >= $threshold
694 0 0 0 defined $name and ref $cb eq "CODE"
704 0 0 0 $rows && @$rows
716 0 0 0 defined $table and ref $cb eq "CODE"
721 0 0 0 defined $where and length $where
725 0 0 0 $rows && @$rows
733 0 0 0 defined $table and ref $cb eq "CODE"
750 0 0 0 $rows && @$rows
762 0 0 0 defined $name and ref $cb eq "CODE"
772 0 0 0 defined $name and ref $cb eq "CODE"
788 0 0 0 defined $table and ref $cb eq "CODE"
819 0 0 0 $rows && @$rows
824 0 0 0 defined $fail and length $fail
836 0 0 0 defined $timeout and &EV::time() - $started >= $timeout
874 0 0 0 defined $user and $user ne ""
877 0 0 0 defined $db and $db ne ""
919 0 0 0 defined $name and length $name
963 0 0 0 defined $columns and ref $columns ne 'ARRAY' || !@$columns
1011 0 0 0 $self->{'high_water_active'} and @{$self->{'buffer'};} < $self->{'high_water'}
1017 0 0 0 not $self->{'in_flight'} and @{$self->{'drain_waiters'};}
0 0 0 not $self->{'in_flight'} and @{$self->{'drain_waiters'};} and @{$self->{'buffer'};} <= ($low || 0)
1025 0 0 0 $self->{'pending_finish'} and not $self->{'in_flight'}
0 0 0 $self->{'pending_finish'} and not $self->{'in_flight'} and not @{$self->{'buffer'};}
1065 0 0 0 not $self->{'in_flight'} and @{$self->{'buffer'};} <= $low
1166 0 0 0 $self->{'cb_thresh'} and ref $user_cb eq "CODE"
1335 0 0 0 $self->{'cb_thresh'} and $self->{'cb_state'}[$i]{'dead_until'} > $now
1433 0 0 0 $grace and $grace > 0
1519 0 0 0 defined $err and length $err

or 2 conditions

line l !l condition
98 0 0 delete $args{'host'} // "127.0.0.1"
100 0 0 delete $args{'protocol'} // "http"
101 0 0 delete $args{'user'} // "default"
102 0 0 delete $args{'password'} // ""
103 0 0 (delete $args{'database'} // delete $args{'db'}) // "default"
141 0 0 $ENV{'USER'} // "na"
275 0 0 $opts{'high_water'} //= 50000
320 0 0 delete $opts{'settings'} // {}
335 0 0 delete $opts{'cb'} // die("insert_aggregated: cb required")
336 0 0 delete $opts{'rows'} // die("insert_aggregated: rows required")
340 0 0 delete $opts{'key_cols'} || []
354 0 0 $spec->{'func'} // die("insert_aggregated: $ac.func required")
355 0 0 $spec->{'args'} // die("insert_aggregated: $ac.args required")
437 0 0 $size //= 1024
534 0 0 delete $opts{'cb'} // die("retry: cb required")
535 0 0 delete $opts{'retries'} // 3
536 0 0 delete $opts{'backoff'} // "0.25"
537 0 0 delete $opts{'jitter'} // 0
566 0 0 $@ || 'unknown error'
595 0 0 $rows // []
628 0 0 $rows // []
639 0 0 $timeout //= 5
751 0 0 $r->[0] // 0
0 0 $r->[1] // 0
0 0 $r->[2] // 0
791 0 0 $opts{'poll'} // 1
846 0 0 $@ || 'unknown error'
881 0 0 $out{'protocol'} //= "http"
980 0 0 $opts{'batch_size'} || 10000
0 0 $opts{'high_water'} || 0
0 0 $opts{'high_water'} || 0
1017 0 0 $low || 0
1061 0 0 $self->{'low_water'} || 0
1123 0 0 delete $args{'size'} || 4
1128 0 0 delete $args{'circuit_threshold'} || 0
1129 0 0 delete $args{'circuit_cooldown'} || 30
1165 0 0 $observe_failures //= 1
1232 0 0 delete $opts{'hedge'} // 2
1353 0 0 "$@" || 'fan_out: dispatch failed'
1370 0 0 $self->{'_pinned'}{$r} // 0
1511 0 0 $args{'message'} // ""
0 0 $args{'code'} // 0
1522 0 0 eval { do { $ch->last_error_code } } || 0
1532 0 0 $_[1] // 0

or 3 conditions

line l !l&&r !l&&!r condition
43 0 0 0 $h->{$k} //= defined $v ? _uri_unescape($v) : 1
56 0 0 0 $args{'protocol'} //= $proto
57 0 0 0 $args{'user'} //= _uri_unescape($u)
58 0 0 0 $args{'password'} //= _uri_unescape($pw)
59 0 0 0 $args{'host'} //= $h
60 0 0 0 $args{'port'} //= $p
61 0 0 0 $args{'database'} //= _uri_unescape($db)
68 0 0 0 delete $args{'loop'} || &EV::default_loop()
83 0 0 0 $args{'port'} //= $p0
103 0 0 0 delete $args{'database'} // delete $args{'db'}
105 0 0 0 $protocol eq "http" or $protocol eq "native"
108 0 0 0 $port //= $protocol eq "native" ? 9000 : 8123
193 0 0 0 $status != 0 or not @addrs
204 0 0 0 $v4 // $addrs[0]
216 0 0 0 $2 // $default_port
338 0 0 0 ref $rows ne "ARRAY" or not @$rows
548 0 0 0 not $err or $attempt > $tries
0 0 0 not $err or $attempt > $tries or not "EV::ClickHouse"->is_retryable_error($self->last_error_code)
963 0 0 0 ref $columns ne 'ARRAY' || !@$columns
980 0 0 0 $opts{'on_batch_error'} || sub { }
0 0 0 $opts{'on_high_water'} || sub { }
995 0 0 0 $self->{'in_flight'} or not @{$self->{'buffer'};}
1003 0 0 0 $self->{'sticky_err'} //= $err
1040 0 0 0 $self->{'in_flight'} || @{$self->{'buffer'};}
1175 0 0 0 $observe_failures or not $_[1]
1204 0 0 0 $idx < 0 or $idx >= @{$self->{'conns'};}
1217 0 0 0 $idx < 0 or $idx >= @{$self->{'conns'};}
1270 0 0 0 $first_err //= $err
1391 0 0 0 $err //= $_[0]
1415 0 0 0 $cb //= sub { }
1429 0 0 0 $err //= $_[0]
1435 0 0 0 $err //= "Pool::shutdown timed out after ${grace}s"