| blib/lib/Net/Async/CassandraCQL/Connection.pm | |||
|---|---|---|---|
| Criterion | Covered | Total | % |
| condition | 11 | 26 | 42.3 |
| line | l | !l | condition |
|---|---|---|---|
| 190 | 4 | 1 | defined $_ and return 1 |
| 324 | 0 | 21 | $id = $_ and last |
| line | !l | l&&!r | l&&r | condition |
|---|---|---|---|---|
| 210 | 1027 | 0 | 2 | $flags & 1 and my $decompress = $$self{'decompress'} |
| 220 | 1 | 0 | 0 | $streamid == 0 and $opcode == 0 |
| 0 | 0 | 1 | $streamid == 255 and $opcode == 12 | |
| 234 | 154 | 0 | 1 | my $close_f = $$self{'cassandra_close_future'} and not $self->_has_pending |
| line | l | !l | condition |
|---|---|---|---|
| 177 | 0 | 0 | $args{'socktype'} ||= 'stream' |
| 321 | 1028 | 0 | $$self{'streams'} ||= [] |
| line | l | !l&&r | !l&&!r | condition |
|---|---|---|---|---|
| 184 | 0 | 0 | 0 | $$self{'connect_f'} ||= $self->SUPER::connect(%args)->on_fail(sub { undef $$self{'connect_f'}; } ) |
| 613 | 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 } |