| blib/lib/Net/Async/CassandraCQL/Connection.pm | |||
|---|---|---|---|
| Criterion | Covered | Total | % |
| condition | 14 | 29 | 48.2 |
| line | l | !l | condition |
|---|---|---|---|
| 194 | 4 | 1 | defined $_ and return 1 |
| 339 | 0 | 21 | $id = $_ and last |
| line | !l | l&&!r | l&&r | condition |
|---|---|---|---|---|
| 214 | 1027 | 0 | 2 | $flags & 1 and my $decompress = $$self{'decompress'} |
| 224 | 1 | 0 | 0 | $streamid == 0 and $opcode == 0 |
| 0 | 0 | 1 | $streamid == 255 and $opcode == 12 | |
| 249 | 1 | 154 | 873 | not $$self{'streams'}[$streamid] and my $next = shift @{$$self{'pending'};} |
| 154 | 0 | 1 | my $close_f = $$self{'cassandra_close_future'} and not $self->_has_pending |
| line | l | !l | condition |
|---|---|---|---|
| 181 | 0 | 0 | $args{'socktype'} ||= 'stream' |
| 336 | 1028 | 0 | $$self{'streams'} ||= [] |
| line | l | !l&&r | !l&&!r | condition |
|---|---|---|---|---|
| 188 | 0 | 0 | 0 | $$self{'connect_f'} ||= $self->SUPER::connect(%args)->on_fail(sub { undef $$self{'connect_f'}; } ) |
| 628 | 0 | 3 | 0 | $$self{'cassandra_close_future'} ||= do { my $f = $self->loop->new_future; $f->on_done(sub { $_[0]->close; } ); $f->done($self) unless $self->_has_pending; $f } |