line |
true |
false |
branch |
35
|
0 |
0 |
unless ref $client |
38
|
0 |
0 |
unless not exists $args{'databases'} or ref $args{'databases'} eq "ARRAY" |
52
|
0 |
0 |
if $floor |
54
|
0 |
0 |
if keys %args |
67
|
0 |
0 |
unless $client->{'verbose'} |
77
|
0 |
0 |
if ($ref->{'driver'}) { } |
79
|
0 |
0 |
if (my $getter = $ref->{'driver'}->get_dbh) { } |
91
|
0 |
0 |
unless $ref->{$_} |
104
|
0 |
0 |
if ($cache_duration and $client->{'cached_drivers'}{$hashdsn}{'create_ts'} and $client->{'cached_drivers'}{$hashdsn}{'create_ts'} + $cache_duration > $t) { } |
112
|
0 |
0 |
unless my $db = $client->{'databases'}{$hashdsn} |
115
|
0 |
0 |
if ($db->{'driver'}) { } |
125
|
0 |
0 |
if exists $db->{'prefix'} |
127
|
0 |
0 |
if ($cache_duration) |
148
|
0 |
0 |
if ($client->{'dead_dsns'}{$hashdsn}) |
149
|
0 |
0 |
if ($client->{'retry_at'}{$hashdsn} < time) { } |
167
|
0 |
0 |
unless my $job = $driver->lookup("TheSchwartz::Job", $handle->jobid) |
184
|
0 |
0 |
if exists $arg->{'run_after'} |
187
|
0 |
0 |
if exists $arg->{'grabbed_until'} |
190
|
0 |
0 |
if exists $arg->{'jobid'} |
192
|
0 |
0 |
unless exists $arg->{'funcname'} |
194
|
0 |
0 |
unless defined $arg->{'want_handle'} |
198
|
0 |
0 |
if ($arg->{'coalesce'}) |
203
|
0 |
0 |
if ($client->prioritize) { } |
213
|
0 |
0 |
if ($client->floor) |
220
|
0 |
0 |
if $client->is_database_dead($hashdsn) |
222
|
0 |
0 |
if (ref $arg->{'funcname'}) { } |
232
|
0 |
0 |
if ($arg->{'want_handle'}) { } |
270
|
0 |
0 |
if $client->is_database_dead($hashdsn) |
276
|
0 |
0 |
if ($client->prioritize) { } |
303
|
0 |
0 |
if ($client->floor) |
312
|
0 |
0 |
if ($@) |
313
|
0 |
0 |
unless ({"1" => 1}->{$driver->last_error or 0}) |
319
|
0 |
0 |
if $job |
329
|
0 |
0 |
if ($client->prioritize) { } |
341
|
0 |
0 |
if $client->is_database_dead($hashdsn) |
362
|
0 |
0 |
if ($client->floor) |
371
|
0 |
0 |
if ($@) |
372
|
0 |
0 |
unless ({"1" => 1}->{$driver->last_error or 0}) |
378
|
0 |
0 |
if $T_AFTER_GRAB_SELECT_BEFORE_UPDATE |
382
|
0 |
0 |
if $job |
392
|
0 |
0 |
if $driver->dbd->isa("Data::ObjectDriver::Driver::DBD::Oracle") |
404
|
0 |
0 |
$RANDOMIZE_JOBS ? : |
417
|
0 |
0 |
unless my $server_time = $client->get_server_time($driver) |
428
|
0 |
0 |
if ($driver->update($job, {"grabbed_until", ["-and", {"op", "=", "value", $old_grabbed_until}, \" <= $unixtime"]}) < 1) |
437
|
0 |
0 |
if $T_LOST_RACE |
480
|
0 |
0 |
if ($@) { } |
|
0 |
0 |
elsif ($job->jobid) { } |
481
|
0 |
0 |
unless ({"1" => 1}->{$driver->last_error or 0}) |
510
|
0 |
0 |
if $client->is_database_dead($hashdsn) |
516
|
0 |
0 |
if ($h) { } |
525
|
0 |
0 |
if eval {
do {
$driver->commit
}
} |
530
|
0 |
0 |
wantarray ? : |
536
|
0 |
0 |
if (ref $_[0] eq "TheSchwartz::Job") |
539
|
0 |
0 |
unless (ref $job eq "TheSchwartz::Job") |
547
|
0 |
0 |
if $client->is_database_dead($hashdsn) |
554
|
0 |
0 |
if $handle |
591
|
0 |
0 |
if (not @{$client->{'current_abilities'};}) |
599
|
0 |
0 |
unless my $job = $client->lookup_job($hstr) |
607
|
0 |
0 |
unless my $job = $client->lookup_job($hstr) |
614
|
0 |
0 |
if $current_time < $job->grabbed_until |
617
|
0 |
0 |
unless $job = $client->_grab_a_job($hashdsn, $job) |
628
|
0 |
0 |
unless $client->work_once |
635
|
0 |
0 |
unless $client->work_once |
651
|
0 |
0 |
if (not $job || $client->{'strict_remove_ability'} and @{$client->{'current_abilities'};} < @{$client->{'all_abilities'};}) |
659
|
0 |
0 |
$job ? : |
660
|
0 |
0 |
if ($job) { } |
661
|
0 |
0 |
$job->priority ? : |
670
|
0 |
0 |
unless $job |
677
|
0 |
0 |
unless $client->{'strict_remove_ability'} |
697
|
0 |
0 |
unless (exists $cache->{'funcname2id'}{$funcname}) |
708
|
0 |
0 |
unless (exists $client->{'funcmap_cache'}{$hashdsn}) |
731
|
0 |
0 |
if ($logger and ref $logger ne "CODE") |
751
|
0 |
0 |
unless $dir |
754
|
0 |
0 |
if ($dir eq 1 or $dir eq "on") |
759
|
0 |
0 |
if -e $dir |
764
|
0 |
0 |
unless (-e $dir) |
765
|
0 |
0 |
unless mkdir $dir, 493 |
777
|
0 |
0 |
unless $scoreboard |
781
|
0 |
0 |
unless $job |
785
|
0 |
0 |
unless open my $SB, ">", $scoreboard |
806
|
0 |
0 |
if (ref $args) { } |
807
|
0 |
0 |
if (ref $args eq 'HASH') { } |
|
0 |
0 |
elsif (ref $args eq 'ARRAY') { } |
827
|
0 |
0 |
unless $scoreboard |
831
|
0 |
0 |
unless open my $SB, ">>", $scoreboard |
844
|
0 |
0 |
unless $scoreboard |
866
|
0 |
0 |
unless $client->prioritize |
906
|
0 |
0 |
if (ref $arg and $arg->isa("TheSchwartz")) |