| line |
true |
false |
branch |
|
228
|
0 |
0 |
unless $self->_db_type |
|
232
|
0 |
0 |
if ($self->_db_type eq 'SQLite') |
|
237
|
0 |
0 |
unless $self->skip_table_check |
|
285
|
0 |
0 |
unless $self->{'debug'} |
|
296
|
0 |
0 |
$p ? : |
|
298
|
0 |
0 |
unless $query =~ /;$/ |
|
308
|
0 |
0 |
if (defined $params[$i]) |
|
309
|
0 |
0 |
$params[$i] =~ /^\d+$/ ? : |
|
315
|
0 |
0 |
if @params and scalar @params |
|
326
|
0 |
0 |
$p ? : |
|
330
|
0 |
0 |
unless $query =~ /;$/ |
|
332
|
0 |
0 |
if ($self->{'debug'}) |
|
345
|
0 |
0 |
if ($sth_map->{$key}) { } |
|
357
|
0 |
0 |
if (not $no_results) { } |
|
368
|
0 |
0 |
if ($rv) |
|
405
|
0 |
0 |
$p ? : |
|
411
|
0 |
0 |
if ($sth_map->{$key}) { } |
|
546
|
0 |
0 |
if ($self->_db_type eq 'SQLite') { } |
|
|
0 |
0 |
elsif ($self->_db_type eq 'Pg') { } |
|
|
0 |
0 |
elsif ($self->_db_type eq 'mysql') { } |
|
581
|
0 |
0 |
@_ % 2 ? : |
|
583
|
0 |
0 |
if (ref $params ne 'HASH') |
|
594
|
0 |
0 |
if (ref $data ne 'HASH') |
|
600
|
0 |
0 |
unless ($qname and $data) |
|
606
|
0 |
0 |
if ($qname =~ /\*/) |
|
629
|
0 |
0 |
if not $resp->{'error'} |
|
670
|
0 |
0 |
@_ % 2 ? : |
|
672
|
0 |
0 |
if (ref $params ne 'HASH') |
|
693
|
0 |
0 |
$qname =~ /\*/ ? : |
|
697
|
0 |
0 |
if ($wild and $q =~ /$qname/ or $self->{'_queue_list'}{$qname}) |
|
745
|
0 |
0 |
@_ % 2 ? : |
|
747
|
0 |
0 |
if (ref $params ne 'HASH') |
|
756
|
0 |
0 |
unless $self->_valid_qname($qname) |
|
763
|
0 |
0 |
if not $params->{'callback'} or ref $params->{'callback'} ne 'CODE' |
|
765
|
0 |
0 |
if ($params->{'count'} > 100) |
|
792
|
0 |
0 |
unless scalar @t |
|
800
|
0 |
0 |
unless $resp->{'row_count'} |
|
835
|
0 |
0 |
if ($invalid) { } |
|
|
0 |
0 |
elsif ($state) { } |
|
914
|
0 |
0 |
@_ % 2 ? : |
|
916
|
0 |
0 |
if (ref $params ne 'HASH') |
|
928
|
0 |
0 |
unless $self->_valid_qname($qname) |
|
932
|
0 |
0 |
if not $params->{'callback'} or ref $params->{'callback'} ne 'CODE' |
|
934
|
0 |
0 |
if ($params->{'count'} > 100) |
|
958
|
0 |
0 |
unless scalar @t |
|
966
|
0 |
0 |
unless $resp->{'row_count'} |
|
1019
|
0 |
0 |
@_ % 2 ? : |
|
1021
|
0 |
0 |
if (ref $params ne 'HASH') |
|
1039
|
0 |
0 |
$resp->{'row_count'} ? : |
|
1064
|
0 |
0 |
unless ($result->{'error'}) |
|
1095
|
0 |
0 |
@_ % 2 ? : |
|
1097
|
0 |
0 |
if (ref $params ne 'HASH') |
|
1112
|
0 |
0 |
unless $self->_valid_qname($q) |
|
1113
|
0 |
0 |
if $qname =~ /\*/ and not $qname =~ /$q/ or $qname ne $q |
|
1160
|
0 |
0 |
if ($k =~ /_added/) { } |
|
1295
|
0 |
0 |
@_ % 2 ? : |
|
1297
|
0 |
0 |
if (ref $params ne 'HASH') |
|
1315
|
0 |
0 |
@_ % 2 ? : |
|
1317
|
0 |
0 |
if (ref $params ne 'HASH') |
|
1325
|
0 |
0 |
unless $self->_valid_qname($qname) |
|
1364
|
0 |
0 |
@_ % 2 ? : |
|
1366
|
0 |
0 |
if (ref $params ne 'HASH') |
|
1375
|
0 |
0 |
unless $self->_valid_qname($qname) |
|
1383
|
0 |
0 |
if ($params->{'counter'}) { } |
|
1447
|
0 |
0 |
@_ % 2 ? : |
|
1449
|
0 |
0 |
if (ref $params ne 'HASH') |
|
1454
|
0 |
0 |
unless ($params->{'queue'}) |
|
1459
|
0 |
0 |
if (ref $params->{'callback'} ne 'CODE') |
|
1466
|
0 |
0 |
if ($params->{'after'}) |
|
1472
|
0 |
0 |
if (not defined $params->{'after'}) { } |
|
|
0 |
0 |
elsif ($params->{'after'} =~ /^\d+$/) { } |
|
|
0 |
0 |
elsif (not $params->{'after'} =~ /^\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}$/) { } |
|
1521
|
0 |
0 |
@_ % 2 ? : |
|
1523
|
0 |
0 |
if (ref $params ne 'HASH') |
|
1528
|
0 |
0 |
unless (keys %{$$self{'subscriptions'};}) |
|
1550
|
0 |
0 |
unless $started or $subs->{'persist'} |
|
1553
|
0 |
0 |
if (not $started) { } |
|
1572
|
0 |
0 |
if ($row->{'added'} gt $subs->{'after'}) |
|
1575
|
0 |
0 |
if ($row->{'counter'} > $subs->{'counter'}) |
|
1587
|
0 |
0 |
if $params->{'events'} and $self->{'ev_count'} > $params->{'events'} |
|
1590
|
0 |
0 |
if $params->{'datetime'} and time > $params->{'datetime'} |
|
1627
|
0 |
0 |
@_ % 2 ? : |
|
1629
|
0 |
0 |
if (ref $params ne 'HASH') |
|
1634
|
0 |
0 |
if ($params->{'queue'}) |
|
1661
|
0 |
0 |
@_ % 2 ? : |
|
1663
|
0 |
0 |
if (ref $params ne 'HASH') |
|
1673
|
0 |
0 |
if (not defined $params->{'before'}) { } |
|
|
0 |
0 |
elsif ($params->{'before'} =~ /^\d+$/) { } |
|
|
0 |
0 |
elsif (not $params->{'before'} =~ /^\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}$/) { } |
|
1717
|
0 |
0 |
@_ % 2 ? : |
|
1719
|
0 |
0 |
if (ref $params ne 'HASH') |
|
1736
|
0 |
0 |
if (defined $params->{'counter'}) { } |
|
1746
|
0 |
0 |
if (not defined $params->{'before'}) { } |
|
|
0 |
0 |
elsif ($params->{'before'} =~ /^\d+$/) { } |
|
|
0 |
0 |
elsif (not $params->{'before'} =~ /^\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}$/) { } |
|
1787
|
0 |
0 |
@_ % 2 ? : |
|
1789
|
0 |
0 |
if (ref $params ne 'HASH') |
|
1820
|
0 |
0 |
@_ % 2 ? : |
|
1822
|
0 |
0 |
if (ref $params ne 'HASH') |
|
1839
|
0 |
0 |
$resp->{'row_count'} ? : |
|
1856
|
0 |
0 |
@_ % 2 ? : |
|
1858
|
0 |
0 |
if (ref $params ne 'HASH') |