| line |
true |
false |
branch |
|
154
|
0 |
0 |
if ($error) |
|
178
|
0 |
0 |
unless (my $prepared = $self->{'prepare_cache'}{$$queryref}) |
|
184
|
0 |
0 |
if ($parameters) |
|
188
|
0 |
0 |
unless (eval {
do {
$row = $prepared->{'encoder'}->encode($parameters);
1
}
}) |
|
195
|
0 |
0 |
unless (defined $consistency) |
|
207
|
0 |
0 |
if ($err) |
|
208
|
0 |
0 |
if (XXX and $err->code == 9472) |
|
214
|
0 |
0 |
if ($code != 8) |
|
233
|
0 |
0 |
if ($exec_info->{'_prepared_and_tried_again'}++) |
|
243
|
0 |
0 |
if $_[0] |
|
245
|
0 |
0 |
unless ($self->{'prepare_cache'}{$$queryref}) |
|
259
|
0 |
0 |
unless (XXX) |
|
265
|
0 |
0 |
unless (XXX) |
|
268
|
0 |
0 |
unless ($query->[0]) |
|
271
|
0 |
0 |
if ($query->[1] and not XXX) |
|
275
|
0 |
0 |
if (my $prep = $self->{'prepare_cache'}{$query->[0]}) { } |
|
284
|
0 |
0 |
if ($attribs->{'batch_type'}) |
|
286
|
0 |
0 |
unless (defined $batch_type) |
|
292
|
0 |
0 |
unless (defined $consistency) |
|
306
|
0 |
0 |
if ($err) |
|
307
|
0 |
0 |
if (XXX and $err->code == 9472) |
|
313
|
0 |
0 |
if ($code != 8) |
|
332
|
0 |
0 |
if ($exec_info->{'_prepared_and_tried_again'}++) |
|
345
|
0 |
0 |
if $_[0] |
|
355
|
0 |
0 |
if (exists $self->{'in_prepare'}{$query}) |
|
370
|
0 |
0 |
if ($code != 8) |
|
375
|
0 |
0 |
if ($result_type != 4) |
|
382
|
0 |
0 |
unless eval {
do {
($encoder) = unpack_metadata($body);
1
}
} |
|
386
|
0 |
0 |
unless eval {
do {
($decoder) = unpack_metadata($body);
1
}
} |
|
396
|
0 |
0 |
unless my $in_prepare = delete $self->{'in_prepare'}{$query} |
|
407
|
0 |
0 |
if ($result_type == 2) { } |
|
|
0 |
0 |
elsif ($result_type == 1) { } |
|
|
0 |
0 |
elsif ($result_type == 3) { } |
|
|
0 |
0 |
elsif ($result_type == 5) { } |
|
409
|
0 |
0 |
unless eval {
do {
($decoder, $paging_state) = unpack_metadata($_[3]);
1
}
} |
|
464
|
0 |
0 |
if $error |
|
468
|
0 |
0 |
if (keys %versions > 1) { } |
|
469
|
0 |
0 |
if ($waited >= $max_wait) |
|
496
|
0 |
0 |
if ($response_code != 6) |
|
502
|
0 |
0 |
unless ($map->{'CQL_VERSION'} and $map->{'COMPRESSION'}) |
|
507
|
0 |
0 |
unless ($selected_cql_version) |
|
513
|
0 |
0 |
unless ($selected_compression) |
|
515
|
0 |
0 |
if ($ss_compression{$_} and $available_compression{$_}) |
|
521
|
0 |
0 |
if $selected_compression and $selected_compression eq 'none' |
|
523
|
0 |
0 |
if ($selected_compression) |
|
524
|
0 |
0 |
unless ($ss_compression{$selected_compression}) |
|
527
|
0 |
0 |
unless ($available_compression{$selected_compression}) |
|
532
|
0 |
0 |
$selected_compression ? : |
|
544
|
0 |
0 |
if ($response_code == 2) |
|
548
|
0 |
0 |
if ($response_code == 3) |
|
556
|
0 |
0 |
if ($self->{'options'}{'keyspace'}) |
|
563
|
0 |
0 |
unless ($self->{'ipaddress'}) |
|
570
|
0 |
0 |
if ($status) |
|
575
|
0 |
0 |
unless ($self->{'ipaddress'}) |
|
590
|
0 |
0 |
if utf8::is_utf8($user) |
|
591
|
0 |
0 |
if utf8::is_utf8($pass) |
|
593
|
0 |
0 |
unless ($user and $pass) |
|
605
|
0 |
0 |
if ($code == 16) { } |
|
619
|
0 |
0 |
if ($type eq 'TOPOLOGY_CHANGE') { } |
|
|
0 |
0 |
elsif ($type eq 'STATUS_CHANGE') { } |
|
649
|
0 |
0 |
if $self->{'connected'} |
|
651
|
0 |
0 |
if ($self->{'connecting'}++) |
|
657
|
0 |
0 |
if ($self->{'options'}{'tls'}) |
|
661
|
0 |
0 |
unless (eval {
do {
$self->{'tls'} = $self->{'client'}{'tls'}->new_conn;
1
}
}) |
|
670
|
0 |
0 |
if ($self->{'host'} =~ /:/) { } |
|
688
|
0 |
0 |
unless ($socket) |
|
706
|
0 |
0 |
if ($self->{'options'}{'tls'}) |
|
714
|
0 |
0 |
if ($error) |
|
729
|
0 |
0 |
if $self->{'shutdown'} |
|
737
|
0 |
0 |
if ++$attempts >= 32768 |
|
748
|
0 |
0 |
if (length $_[3] > 500 and my $compress_func = $self->{'compress_func'}) |
|
755
|
0 |
0 |
if (defined $self->{'pending_write'}) |
|
760
|
0 |
0 |
if ($self->{'tls'}) { } |
|
763
|
0 |
0 |
if ($rv == $length) { } |
|
|
0 |
0 |
elsif ($rv > 0) { } |
|
772
|
0 |
0 |
if ($rv == ERROR_WANT_WRITE() or $rv == ERROR_WANT_READ() or $rv == ERROR_NONE()) { } |
|
775
|
0 |
0 |
if ($rv == ERROR_WANT_READ()) { } |
|
804
|
0 |
0 |
if ($result and $result == $length) { } |
|
|
0 |
0 |
elsif (defined $result or $! == 11) { } |
|
807
|
0 |
0 |
if $result |
|
845
|
0 |
0 |
if ($self->{'tls'}) { } |
|
847
|
0 |
0 |
if (length $bytes) |
|
853
|
0 |
0 |
if ($rv <= 0) |
|
855
|
0 |
0 |
if ($rv == ERROR_WANT_WRITE()) { } |
|
|
0 |
0 |
elsif ($rv == ERROR_WANT_READ()) { } |
|
|
0 |
0 |
elsif ($rv == ERROR_NONE()) { } |
|
861
|
0 |
0 |
if (delete $self->{'tls_want_write'}) |
|
875
|
0 |
0 |
if ($read_cnt) { } |
|
|
0 |
0 |
elsif (not defined $read_cnt) { } |
|
|
0 |
0 |
elsif ($read_cnt == 0) { } |
|
877
|
0 |
0 |
if $read_cnt >= 16384 |
|
880
|
0 |
0 |
if ($! != 11) |
|
889
|
0 |
0 |
if $bufsize < 9 |
|
892
|
0 |
0 |
if ($bufsize < $bodylen + 9) |
|
901
|
0 |
0 |
if ($flags & 1 and $body) |
|
905
|
0 |
0 |
if ($stream_id != -1) { } |
|
907
|
0 |
0 |
if (not $stream_cb) { } |
|
|
0 |
0 |
elsif ($opcode == 0) { } |
|
929
|
0 |
0 |
unless $should_read_more |
|
933
|
0 |
0 |
if ($shutdown_when_done) |
|
943
|
0 |
0 |
if ($self->{'tls'}) { } |
|
945
|
0 |
0 |
if ($rv > 0) { } |
|
947
|
0 |
0 |
unless (length $self->{'pending_write'}) |
|
955
|
0 |
0 |
if ($rv == ERROR_WANT_WRITE()) { } |
|
|
0 |
0 |
elsif ($rv == ERROR_WANT_READ()) { } |
|
|
0 |
0 |
elsif ($rv == ERROR_NONE()) { } |
|
974
|
0 |
0 |
unless (defined $result) |
|
975
|
0 |
0 |
if ($! == 11) |
|
982
|
0 |
0 |
if ($result == 0) |
|
985
|
0 |
0 |
unless (length $self->{'pending_write'}) |
|
1009
|
0 |
0 |
if $self->{'shutdown'} |
|
1019
|
0 |
0 |
if (defined delete $self->{'pending_write'}) |
|
1051
|
0 |
0 |
unless $type |
|
1052
|
0 |
0 |
if ($type eq 'snappy') { } |
|
|
0 |
0 |
elsif ($type eq 'lz4') { } |
|
1071
|
0 |
0 |
if ($_[0] ne "\000") { } |
|
1086
|
0 |
0 |
if ($len) { } |