| line |
true |
false |
branch |
|
57
|
0 |
0 |
$options->{'anyevent'} ? : |
|
71
|
0 |
0 |
$options->{'tls'} ? : |
|
84
|
0 |
0 |
if $self->{'connected'} |
|
85
|
0 |
0 |
if $self->{'shutdown'} |
|
88
|
0 |
0 |
if (not $self->{'connecting'} and $self->{'throttler'}->should_fail) |
|
93
|
0 |
0 |
if ($self->{'connecting'}++) |
|
103
|
0 |
0 |
unless ($contact_point) |
|
130
|
0 |
0 |
if ($error) |
|
149
|
0 |
0 |
if $self->{'shutdown'} |
|
160
|
0 |
0 |
unless $self->{'connected'} |
|
172
|
0 |
0 |
if ($change eq 'NEW_NODE') { } |
|
|
0 |
0 |
elsif ($change eq 'REMOVED_NODE') { } |
|
194
|
0 |
0 |
if ($self->{'metadata'}->is_prepared(\$query)) |
|
237
|
0 |
0 |
if $self->{'active_queries'} >= $self->{'options'}{'max_concurrent_queries'} |
|
239
|
0 |
0 |
unless $self->{'connected'} |
|
242
|
0 |
0 |
unless $connection |
|
244
|
0 |
0 |
if $self->{'throttler'}->should_fail |
|
252
|
0 |
0 |
if $self->{'command_queue'}{'has_any'} |
|
254
|
0 |
0 |
if $error |
|
284
|
0 |
0 |
if ($self->{'throttler'}->should_fail) |
|
294
|
0 |
0 |
if $self->{'command_queue'}{'has_any'} |
|
296
|
0 |
0 |
if $error |
|
309
|
0 |
0 |
if ($self->{'active_queries'} >= $self->{'options'}{'max_concurrent_queries'}) { } |
|
320
|
0 |
0 |
unless XXX |
|
323
|
0 |
0 |
if ($error->do_retry) { } |
|
|
0 |
0 |
elsif ($error->is_request_error) { } |
|
|
0 |
0 |
elsif ($error->isa('Cassandra::Client::Error::WriteTimeoutException')) { } |
|
|
0 |
0 |
elsif ($error->isa('Cassandra::Client::Error::ReadTimeoutException')) { } |
|
|
0 |
0 |
elsif ($error->isa('Cassandra::Client::Error::UnavailableException')) { } |
|
337
|
0 |
0 |
if ($retry_decision and $retry_decision eq 'retry') |
|
346
|
0 |
0 |
if (my $error = $self->{'command_queue'}->enqueue([$command, $callback, $args, $command_info])) |
|
354
|
0 |
0 |
unless my $item = $self->{'command_queue'}->dequeue |
|
363
|
0 |
0 |
$params ? : |
|
364
|
0 |
0 |
$attribs ? : |
|
375
|
0 |
0 |
if $error |
|
380
|
0 |
0 |
if ($next_page_id) { } |
|
399
|
0 |
0 |
if &in_global_destruction() |
|
402
|
0 |
0 |
if ($self->{'connected'}) |
|
415
|
0 |
0 |
unless ($c, $file, $line) = caller 2 |
|
417
|
0 |
0 |
unless ($c, $file, $line) = caller 3 |
|
428
|
0 |
0 |
unless (eval {
do {
&$cb;
1
}
}) |
|
442
|
0 |
0 |
if ($err) |
|
465
|
0 |
0 |
if ($error) { } |
|
484
|
0 |
0 |
if ($error) |