Branch Coverage

blib/lib/Cassandra/Client/Connection.pm

Criterion	Covered	Total	%
branch	0	252	0.0

line	true	false	branch
160	0	0	if ($error)
184	0	0	unless (my $prepared = $self->{'prepare_cache'}{$$queryref})
190	0	0	if ($parameters)
194	0	0	unless (eval { do { $row = $prepared->{'encoder'}->encode($parameters); 1 } })
201	0	0	unless (defined $consistency)
213	0	0	if ($err)
214	0	0	if (is_blessed_ref($err) and $err->code == 9472)
220	0	0	if ($code != 8)
231	0	0	if $attr->{'_synthetic_error'}
241	0	0	if ($exec_info->{'_prepared_and_tried_again'}++)
251	0	0	if $_[0]
253	0	0	unless ($self->{'prepare_cache'}{$$queryref})
267	0	0	unless (is_plain_arrayref($queries))
273	0	0	unless (is_plain_arrayref($query))
276	0	0	unless ($query->[0])
279	0	0	if ($query->[1] and not is_plain_arrayref($query->[1]))
283	0	0	if (my $prep = $self->{'prepare_cache'}{$query->[0]}) { }
292	0	0	if ($attribs->{'batch_type'})
294	0	0	unless (defined $batch_type)
300	0	0	unless (defined $consistency)
314	0	0	if ($err)
315	0	0	if (is_blessed_ref($err) and $err->code == 9472)
321	0	0	if ($code != 8)
340	0	0	if ($exec_info->{'_prepared_and_tried_again'}++)
353	0	0	if $_[0]
363	0	0	if (exists $self->{'in_prepare'}{$query})
378	0	0	if ($code != 8)
383	0	0	if ($result_type != 4)
390	0	0	unless eval { do { ($encoder) = unpack_metadata($self->{'protocol_version'}, 0, $body); 1 } }
394	0	0	unless eval { do { ($decoder) = unpack_metadata($self->{'protocol_version'}, 1, $body); 1 } }
404	0	0	unless my $in_prepare = delete $self->{'in_prepare'}{$query}
415	0	0	if ($result_type == 2) { }
	0	0	elsif ($result_type == 1) { }
	0	0	elsif ($result_type == 3) { }
	0	0	elsif ($result_type == 5) { }
420	0	0	unless (eval { do { ($decoder, $paging_state) = unpack_metadata($self->{'protocol_version'}, 1, $_[3]); 1 } })
467	0	0	if $error
471	0	0	if (keys %versions > 1) { }
472	0	0	if ($waited >= $max_wait)
502	0	0	if ($response_code != 6)
508	0	0	unless ($map->{'CQL_VERSION'} and $map->{'COMPRESSION'})
513	0	0	unless ($selected_cql_version)
519	0	0	unless ($selected_compression)
521	0	0	if ($ss_compression{$_} and $available_compression{$_})
527	0	0	if $selected_compression and $selected_compression eq "none"
529	0	0	if ($selected_compression)
530	0	0	unless ($ss_compression{$selected_compression})
533	0	0	unless ($available_compression{$selected_compression})
538	0	0	$selected_compression ? :
550	0	0	if ($response_code == 2)
554	0	0	if ($response_code == 3)
562	0	0	if ($self->{'options'}{'keyspace'})
569	0	0	unless ($self->{'ipaddress'})
576	0	0	if ($status)
581	0	0	unless ($self->{'ipaddress'})
595	0	0	unless ($self->{'options'}{'authentication'})
603	0	0	unless (eval { do { $auth = $self->{'options'}{'authentication'}->begin($authenticator); 1 } })
621	0	0	unless (eval { do { $auth->evaluate($next, $next_challenge); 1 } })
631	0	0	if ($opcode == 14)
635	0	0	if ($opcode == 16)
640	0	0	unless (eval { do { $auth->success(unpack_bytes($body)); 1 } })
658	0	0	if ($type eq 'TOPOLOGY_CHANGE') { }
	0	0	elsif ($type eq 'STATUS_CHANGE') { }
688	0	0	if $self->{'connected'}
690	0	0	if ($self->{'connecting'}++)
696	0	0	if ($self->{'options'}{'tls'})
700	0	0	unless (eval { do { $self->{'tls'} = $self->{'client'}{'tls'}->new_conn; 1 } })
709	0	0	if ($self->{'host'} =~ /:/) { }
727	0	0	unless ($socket)
745	0	0	if ($self->{'options'}{'tls'})
753	0	0	if ($error)
768	0	0	if $self->{'shutdown'}
776	0	0	if ++$attempts >= 32768
787	0	0	if (length $_[3] > 500 and my $compress_func = $self->{'compress_func'})
794	0	0	if (defined $self->{'pending_write'})
799	0	0	if ($self->{'tls'}) { }
802	0	0	if ($rv == $length) { }
	0	0	elsif ($rv > 0) { }
813	0	0	if ($rv == ERROR_WANT_WRITE() or $rv == ERROR_WANT_READ() or $rv == ERROR_NONE()) { }
816	0	0	if ($rv == ERROR_WANT_READ()) { }
845	0	0	if ($result and $result == $length) { }
	0	0	elsif (defined $result or $! == 11) { }
849	0	0	if $result
888	0	0	if ($self->{'tls'}) { }
890	0	0	if (length $bytes)
897	0	0	if ($rv <= 0)
899	0	0	if ($rv == ERROR_WANT_WRITE()) { }
	0	0	elsif ($rv == ERROR_WANT_READ()) { }
	0	0	elsif ($rv == ERROR_NONE()) { }
905	0	0	if (delete $self->{'tls_want_write'})
919	0	0	if ($read_cnt) { }
	0	0	elsif (not defined $read_cnt) { }
	0	0	elsif ($read_cnt == 0) { }
921	0	0	if $read_cnt >= 16384
925	0	0	if ($! != 11)
936	0	0	if $bufsize < 9
938	0	0	if ($bufsize < $bodylen + 9)
946	0	0	if ($flags & 1 and $body)
950	0	0	if ($flags & 4)
954	0	0	if ($flags & 8)
962	0	0	if ($stream_id != -1) { }
964	0	0	if (not $stream_cb) { }
	0	0	elsif ($opcode == 0) { }
985	0	0	unless $should_read_more
988	0	0	if ($shutdown_when_done)
998	0	0	if ($self->{'tls'}) { }
1000	0	0	if ($rv > 0) { }
1003	0	0	unless (length $self->{'pending_write'})
1011	0	0	if ($rv == ERROR_WANT_WRITE()) { }
	0	0	elsif ($rv == ERROR_WANT_READ()) { }
	0	0	elsif ($rv == ERROR_NONE()) { }
1030	0	0	unless (defined $result)
1031	0	0	if ($! == 11)
1038	0	0	if ($result == 0)
1042	0	0	unless (length $self->{'pending_write'})
1066	0	0	if $self->{'healthcheck'}
1080	0	0	if ($self->{'bytes_read'} > $check->{'bytes_read'}) { }
	0	0	elsif (not $error) { }
	0	0	elsif (is_blessed_ref($error) and $error->is_request_error and $error->is_timeout) { }
1096	0	0	if $self->{'shutdown'}
1106	0	0	if (defined delete $self->{'pending_write'})
1138	0	0	unless $type
1139	0	0	if ($type eq 'snappy') { }
	0	0	elsif ($type eq 'lz4') { }
1158	0	0	if ($_[0] ne "\000") { }
1173	0	0	if ($len) { }