| line |
true |
false |
branch |
|
50
|
0 |
13 |
$method =~ s/^_// ? : |
|
52
|
0 |
13 |
unless $method =~ /[^A-Z]/ |
|
57
|
0 |
13 |
unless exists $COMMANDS{$method} |
|
59
|
1 |
12 |
$method eq 'shutdown' ? : |
|
60
|
0 |
13 |
if ($call) { } |
|
92
|
0 |
2 |
if (@_ & 1 and &_HASH($_[0])) { } |
|
96
|
0 |
2 |
if (@_ & 1) |
|
130
|
0 |
2 |
unless (exists $opt{'dsn'}) |
|
136
|
0 |
2 |
unless (exists $opt{'username'}) |
|
142
|
0 |
2 |
unless (exists $opt{'password'}) |
|
148
|
0 |
2 |
if (exists $opt{'reconnect_wait'} and $opt{'reconnect_wait'} < 1) { } |
|
|
2 |
0 |
elsif (not $opt{'reconnect_wait'}) { } |
|
156
|
0 |
2 |
unless (exists $opt{'alias'}) |
|
165
|
2 |
0 |
if (exists $opt{'connect_error'}) |
|
166
|
2 |
0 |
if (&_ARRAY($opt{'connect_error'})) { } |
|
167
|
0 |
2 |
unless ($#{$opt{"connect_error"};} > 0) |
|
180
|
2 |
0 |
if (exists $opt{'connected'}) |
|
181
|
2 |
0 |
if (&_ARRAY($opt{'connected'})) { } |
|
182
|
0 |
2 |
unless ($#{$opt{"connected"};} > 0) |
|
194
|
0 |
2 |
if (exists $opt{'options'}) |
|
195
|
0 |
0 |
unless (&_HASH($opt{'options'})) |
|
201
|
2 |
0 |
if ($opt{'stopwatch'}) |
|
203
|
0 |
2 |
if ($@) |
|
213
|
0 |
2 |
if (keys %opt) |
|
280
|
0 |
2 |
unless my $session = "POE::Session"->create("object_states", [$self, {"_start", "start", "_stop", "stop", "setup_wheel", "setup_wheel", "sig_child", "sig_child", "child_error", "child_error", "child_closed", "child_closed", "child_STDOUT", "child_STDOUT", "child_STDERR", "child_STDERR", map({$_, "db_handler", uc $_, "db_handler";} keys %COMMANDS), "combo", "combo_query", "COMBO", "combo_query", "shutdown", "shutdown_poco", "SHUTDOWN", "shutdown_poco", "send_query", "send_query", "check_queue", "check_queue", "print_queue", "print_queue"}], "heap", {"queue", [], "idcounter", 0, "wheel", undef, "retries", 0, "shutdown", 0, "opts", $keep, "alias", $keep->{'alias'}, "max_retries", $keep->{'max_retries'} || 5, "no_connect_failures", $keep->{'no_connect_failures'} || 0, "action_params", {"commit", [], "rollback", [], "begin_work", [], "func", ["args"], "method", ["function", "args"], "single", ["separator"], "insert", ["insert", "hash", "table", "last_insert_id"], "array", ["chunked", "separator"], "arrayarray", ["chunked"], "keyvalhash", ["primary_key", "chunked"], "hashhash", ["primary_key", "chunked"], "hasharray", ["primary_key", "chunked"], "arrayhash", ["chunked"]}}) |
|
304
|
1 |
1 |
wantarray ? : |
|
312
|
0 |
2 |
if ($heap->{'shutdown'}) |
|
314
|
0 |
0 |
if ($heap->{'shutdown'} == 1 and not defined $_[10]) { } |
|
|
0 |
0 |
elsif ($heap->{'shutdown'} == 2) { } |
|
326
|
0 |
2 |
if (defined $_[10] and uc $_[10] eq 'NOW') { } |
|
330
|
0 |
0 |
if ($heap->{'wheel'}) |
|
342
|
0 |
0 |
if ($queue->{'action'} and $queue->{'action'} eq "EXIT") |
|
374
|
0 |
2 |
unless (&_HASH($args)) |
|
380
|
2 |
0 |
unless (defined $args->{'session'}) |
|
387
|
0 |
2 |
if (not exists $args->{'event'}) { } |
|
394
|
0 |
0 |
unless (not ref $a or $a =~ /postback/i or $a =~ /callback/i) |
|
406
|
2 |
2 |
if delete $res[-1]{'__last'} |
|
414
|
4 |
12 |
if defined $arg->{$key} or $key eq "queries" |
|
432
|
27 |
0 |
if (&_HASH($_[10])) { } |
|
441
|
0 |
27 |
if ($args->{'seperator'}) |
|
447
|
23 |
4 |
unless (defined $args->{'session'}) |
|
454
|
0 |
27 |
if (not exists $args->{'event'}) { } |
|
461
|
0 |
0 |
unless (not ref $a or $a =~ /postback/i or $a =~ /callback/i) |
|
470
|
6 |
21 |
if (not defined $args->{'sql'}) { } |
|
471
|
0 |
6 |
unless ($args->{'action'} =~ /^(insert|func|method|commit|rollback|begin_work)$/i) |
|
478
|
0 |
21 |
if (ref $args->{'sql'}) |
|
480
|
0 |
0 |
if (&reftype($args->{'event'}) and &reftype($args->{'event'}) eq 'CODE') { } |
|
492
|
23 |
4 |
if (not defined $args->{'placeholders'}) { } |
|
496
|
0 |
4 |
unless (&_ARRAY($args->{'placeholders'})) |
|
498
|
0 |
0 |
if (&reftype($args->{'event'}) and &reftype($args->{'event'}) eq 'CODE') { } |
|
510
|
0 |
27 |
if ($args->{'action'} eq "HASHHASH" or $args->{'action'} eq "HASHARRAY") |
|
511
|
0 |
0 |
if (not defined $args->{'primary_key'}) { } |
|
514
|
0 |
0 |
if (&reftype($args->{'event'}) and &reftype($args->{'event'}) eq 'CODE') { } |
|
523
|
0 |
0 |
if (ref $args->{'sql'}) |
|
525
|
0 |
0 |
if (&reftype($args->{'event'}) and &reftype($args->{'event'}) eq 'CODE') { } |
|
537
|
0 |
27 |
if ($heap->{'shutdown'}) |
|
541
|
0 |
0 |
if (&reftype($args->{'event'}) and &reftype($args->{'event'}) eq 'CODE') { } |
|
553
|
4 |
23 |
if ($args->{'session'} ne $_[5]->ID) |
|
569
|
0 |
29 |
unless (defined $args and &_HASH($args)) |
|
590
|
2 |
56 |
if $heap->{'active'} |
|
593
|
27 |
29 |
unless scalar @{$heap->{'queue'};} > 0 |
|
596
|
0 |
29 |
unless $heap->{'shutdown'} != 2 |
|
598
|
29 |
0 |
if ($heap->{'opts'}{'stopwatch'}) |
|
608
|
144 |
122 |
unless defined $heap->{'queue'}[0]{$_} |
|
632
|
2 |
0 |
if $heap->{'alias'} ne "" |
|
645
|
0 |
2 |
if ($heap->{'shutdown'}) |
|
655
|
0 |
2 |
if ($heap->{'retries'} == $heap->{'max_retries'}) |
|
665
|
0 |
2 |
if ($heap->{'opts'}{'alt_fork'} and $^O ne "MSWin32") |
|
666
|
0 |
0 |
$heap->{'opts'}{'alt_fork'} ne '1' ? : |
|
677
|
0 |
2 |
$^O eq 'MSWin32' ? : |
|
707
|
2 |
0 |
if ($kernel->can('sig_child')) { } |
|
714
|
0 |
2 |
if (not defined $heap->{'wheel'}) { } |
|
723
|
0 |
2 |
if ($heap->{'opts'}{'alt_fork'}) |
|
745
|
0 |
0 |
unless (defined $id) |
|
752
|
0 |
0 |
if (defined $heap->{'queue'}[0]) |
|
753
|
0 |
0 |
if ($heap->{'queue'}[0]{'id'} eq $id) { } |
|
759
|
0 |
0 |
if ($heap->{'queue'}[$count]{'id'} eq $id) |
|
779
|
0 |
0 |
if ($heap->{'shutdown'}) |
|
808
|
2 |
0 |
if ($heap->{'shutdown'}) |
|
809
|
2 |
0 |
if ($heap->{'wheel'}) |
|
822
|
0 |
29 |
unless (&_HASH($data)) |
|
834
|
0 |
29 |
if ($data->{'id'} eq "DBI") |
|
836
|
0 |
0 |
if ($heap->{'no_connect_failures'}) |
|
838
|
0 |
0 |
if (defined $heap->{'queue'}[0]) |
|
842
|
0 |
0 |
if (&_ARRAY($heap->{'opts'}{'connect_error'})) { } |
|
|
0 |
0 |
elsif ($qc->{'session'} and $qc->{'event'}) { } |
|
844
|
0 |
0 |
if (&_HASH($heap->{'queue'}[0])) |
|
848
|
0 |
0 |
if (&reftype($qc->{'event'}) and &reftype($qc->{'event'}) eq 'CODE') { } |
|
869
|
2 |
27 |
if ($data->{'id'} eq "DBI-CONNECTED") |
|
870
|
2 |
0 |
if (&_ARRAY($heap->{'opts'}{'connected'})) |
|
872
|
0 |
2 |
if (defined $heap->{'queue'}[0]) |
|
883
|
0 |
27 |
if (exists $data->{'chunked'}) { } |
|
885
|
0 |
0 |
if (exists $data->{'last_chunk'}) { } |
|
894
|
0 |
27 |
if ($data->{'id'} ne $heap->{'queue'}[0]{'id'}) |
|
919
|
0 |
27 |
if $self->{'query_logger'} |
|
930
|
7 |
20 |
if (&reftype($query_copy->{'event'}) and &reftype($query_copy->{'event'}) eq 'CODE') { } |
|
940
|
27 |
0 |
if ($refcount_decrement) |
|
944
|
4 |
23 |
if (defined $query_copy->{'sendersession'} and $query_copy->{'sendersession'} ne $query_copy->{'session'}) |
|
960
|
0 |
0 |
if ($input eq "") |
|
962
|
0 |
0 |
if $_[3]{'opts'}{'no_warnings'} and Deparse error: Can't locate object method "object_2svref" via package "B::SPECIAL" at /usr/local/lib/perl5/5.26.1/B/Deparse.pm line 5018. |
|
973
|
2 |
0 |
if ($heap->{'shutdown'}) |
|
975
|
2 |
0 |
if $heap->{'alias'} ne "" |
|
992
|
1 |
0 |
if (ref $self and $self->ID) { } |