| line |
true |
false |
branch |
|
112
|
25 |
213 |
if exists $params{$_} |
|
148
|
1005 |
5 |
if ($type == 1) { } |
|
152
|
3 |
2 |
if ($type == 2) { } |
|
|
1 |
1 |
elsif ($type == 3) { } |
|
|
1 |
0 |
elsif ($type == 5) { } |
|
203
|
0 |
1029 |
unless my($version, $flags, $streamid, $opcode, $body) = parse_frame($$buffref) |
|
205
|
0 |
1029 |
unless $version & 128 |
|
211
|
0 |
1029 |
unless $version <= $self->_version |
|
214
|
2 |
1027 |
if ($flags & 1 and my $decompress = $$self{'decompress'}) |
|
219
|
0 |
1029 |
unless $flags == 0 |
|
224
|
1028 |
1 |
if (my $f = $$self{'streams'}[$streamid]) { } |
|
|
0 |
1 |
elsif ($streamid == 0 and $opcode == 0) { } |
|
|
1 |
0 |
elsif ($streamid == 255 and $opcode == 12) { } |
|
226
|
1 |
1027 |
if ($opcode == 3) |
|
231
|
1 |
1027 |
if ($opcode == 0) { } |
|
236
|
0 |
1027 |
unless $version == $self->_version |
|
244
|
1027 |
1 |
unless ($opcode == 3) |
|
249
|
873 |
155 |
if (not $$self{'streams'}[$streamid] and my $next = shift @{$$self{'pending'};}) { } |
|
|
1 |
308 |
elsif (my $close_f = $$self{'cassandra_close_future'} and not $self->_has_pending) { } |
|
278
|
0 |
1 |
unless $self->maybe_invoke_event('on_' . lc($name), @args) |
|
294
|
0 |
0 |
if $_ |
|
332
|
0 |
1028 |
if $$self{'cassandra_close_future'} |
|
339
|
21 |
118873 |
unless defined $$streams[$_] |
|
342
|
1007 |
21 |
unless (defined $id) |
|
343
|
873 |
134 |
if ($#$streams == 127) |
|
348
|
7 |
127 |
unless $id |
|
364
|
12 |
1016 |
if (my $compress = $$self{'compress'}) |
|
366
|
2 |
10 |
if (length $body_compressed < length $body) |
|
392
|
1 |
3 |
if ($self->_version > 1) { } |
|
415
|
3 |
1 |
if ($op == 2) { } |
|
|
1 |
0 |
elsif ($op == 3) { } |
|
424
|
4 |
0 |
$compression ? : |
|
437
|
1 |
0 |
if ($authenticator eq 'org.apache.cassandra.auth.PasswordAuthenticator') { } |
|
439
|
0 |
2 |
unless defined $$self{$_} |
|
449
|
0 |
1 |
unless $op == 2 |
|
475
|
0 |
1 |
unless $op == 6 |
|
517
|
0 |
1005 |
unless $op == 8 |
|
539
|
0 |
3 |
unless $op == 8 |
|
542
|
0 |
3 |
unless $type == 4 |
|
584
|
0 |
5 |
unless $op == 8 |
|
607
|
0 |
1 |
unless $op == 2 |
|
632
|
2 |
1 |
unless $self->_has_pending |