| line |
true |
false |
branch |
|
759
|
0 |
0 |
unless $self->_redis |
|
765
|
0 |
0 |
if exists $self->_redis->{'no_auto_connect_on_new'} and $self->_redis->{'no_auto_connect_on_new'} and not $self->_redis->{'sock'} |
|
767
|
0 |
0 |
if ($self->_check_maxmemory) |
|
769
|
0 |
0 |
unless defined &_NONNEGINT($max_datasize) |
|
771
|
0 |
0 |
if $max_datasize |
|
779
|
0 |
0 |
if ($major < 2 or $major == 2 and $minor < 8) |
|
846
|
0 |
0 |
if scalar @_ == 2 and not defined $timeout || defined $old_timeout |
|
848
|
0 |
0 |
if (my $redis = $self->_redis) |
|
849
|
0 |
0 |
unless my $socket = &_INSTANCE($redis->{'sock'}, 'IO::Socket') |
|
876
|
0 |
0 |
if scalar @_ == 2 and not defined $timeout || defined $old_timeout |
|
878
|
0 |
0 |
if (my $redis = $self->_redis) |
|
879
|
0 |
0 |
unless my $socket = &_INSTANCE($redis->{'sock'}, 'IO::Socket') |
|
883
|
0 |
0 |
if (defined $timeout) { } |
|
1051
|
0 |
0 |
unless ref $_[0] eq 'HASH' or &_INSTANCE($_[0], 'Redis::JobQueue::Job') |
|
1053
|
0 |
0 |
&_INSTANCE($_[0], 'Redis::JobQueue::Job') ? : |
|
1077
|
0 |
0 |
if ($expire) |
|
1084
|
0 |
0 |
$args{'LPUSH'} ? : |
|
1132
|
0 |
0 |
unless &_STRING($_) |
|
1136
|
0 |
0 |
if ($data_fields) { } |
|
1137
|
0 |
0 |
if (exists $right_names{'elapsed'}) |
|
1139
|
0 |
0 |
unless exists $right_names{$field} |
|
1158
|
0 |
0 |
unless $job_exists |
|
1162
|
0 |
0 |
if ($field ne 'elapsed' and $field =~ /^(workload|result)$/ || !$job_fnames{$field}) |
|
1163
|
0 |
0 |
if $data[$i] |
|
1168
|
0 |
0 |
if (not $data_fields) { } |
|
1174
|
0 |
0 |
if (my $started = $result_data{'started'}) { } |
|
1187
|
0 |
0 |
if ($right_keys[$i] eq 'elapsed') |
|
1188
|
0 |
0 |
if (my $started = $data[&firstidx(sub {
$_ eq 'started';
}
, @all_fields)]) { } |
|
1199
|
0 |
0 |
unless wantarray |
|
1232
|
0 |
0 |
if not $job_fnames{$_} |
|
1264
|
0 |
0 |
unless $job_exists |
|
1270
|
0 |
0 |
if ($job_fnames{$key}) { } |
|
1279
|
0 |
0 |
if $pre_job->{$field} |
|
1281
|
0 |
0 |
if ($pre_job->{'meta_data'}) |
|
1285
|
0 |
0 |
if $meta_data->{$field} |
|
1336
|
0 |
0 |
if scalar(@_) % 2 |
|
1343
|
0 |
0 |
unless ref $queues |
|
1347
|
0 |
0 |
unless defined &_STRING($arg) |
|
1356
|
0 |
0 |
if (@keys) |
|
1360
|
0 |
0 |
if ($blocking) { } |
|
1366
|
0 |
0 |
unless $full_id |
|
1369
|
0 |
0 |
if $ret |
|
1374
|
0 |
0 |
unless $self->_call_redis('EXISTS', $key) |
|
1379
|
0 |
0 |
unless $full_id |
|
1382
|
0 |
0 |
if $ret |
|
1409
|
0 |
0 |
if ($self->_call_redis('EXISTS', $key)) { } |
|
1410
|
0 |
0 |
if ($only_id) { } |
|
1414
|
0 |
0 |
if (my $expire = $job->expire) |
|
1420
|
0 |
0 |
if (not $expire_time or time < $expire_time) |
|
1455
|
0 |
0 |
unless &_INSTANCE($job, 'Redis::JobQueue::Job') |
|
1459
|
0 |
0 |
unless @modified |
|
1466
|
0 |
0 |
unless ($self->_call_redis('EXISTS', $key)) |
|
1475
|
0 |
0 |
if ($expire) { } |
|
1483
|
0 |
0 |
if (not $job_fnames{$field}) { } |
|
|
0 |
0 |
elsif ($field ne 'expire' and $field ne 'id') { } |
|
1528
|
0 |
0 |
unless defined &_STRING($id_source) or &_INSTANCE($id_source, 'Redis::JobQueue::Job') |
|
1533
|
0 |
0 |
ref $id_source ? : |
|
1587
|
0 |
0 |
if scalar(@_) % 2 |
|
1594
|
0 |
0 |
if exists $args{$field} and ref $args{$field} ne 'ARRAY' |
|
1605
|
0 |
0 |
$args{'queued'} ? : |
|
|
0 |
0 |
scalar @queues ? : |
|
|
0 |
0 |
scalar @statuses ? : |
|
1658
|
0 |
0 |
($ret // '') eq 'PONG' ? : |
|
1680
|
0 |
0 |
if $] >= 5.14 and ${^GLOBAL_PHASE} eq 'DESTRUCT' |
|
1683
|
0 |
0 |
unless $self->_use_external_connection |
|
1740
|
0 |
0 |
unless defined &_STRING($maybe_queue) or &_INSTANCE($maybe_queue, 'Redis::JobQueue::Job') |
|
1743
|
0 |
0 |
if ref $maybe_queue |
|
1776
|
0 |
0 |
unless defined &_STRING($maybe_queue) or &_INSTANCE($maybe_queue, 'Redis::JobQueue::Job') |
|
1779
|
0 |
0 |
if ref $maybe_queue |
|
1797
|
0 |
0 |
if ($error =~ /Could not connect to Redis server at / or $error =~ /^Can't close socket: / or $error =~ /^Not connected to any server/ or $error =~ /^Error while reading from Redis server: / or $error =~ /^Redis server closed connection/) { } |
|
|
0 |
0 |
elsif ($error =~ /^\[[^]]+\]\s+NOSCRIPT No matching script. Please use EVAL./) { } |
|
|
0 |
0 |
elsif ($error =~ /[\S+] ERR command not allowed when used memory > 'maxmemory'/ or $error =~ /[\S+] OOM command not allowed when used memory > 'maxmemory'/) { } |
|
1806
|
0 |
0 |
if not $self->_transaction and $self->reconnect_on_error |
|
1819
|
0 |
0 |
if not $self->_transaction and $self->reconnect_on_error |
|
1822
|
0 |
0 |
if ($self->_transaction) |
|
1861
|
0 |
0 |
if $self and $method =~ /^EVAL/i |
|
1869
|
0 |
0 |
if ($method eq 'HSET' and $_[1] eq $_ID_IN_QUEUE_FIELD) { } |
|
|
0 |
0 |
elsif ($method eq 'HSET' and $_[1] =~ /^(workload|result)$/ || !$job_fnames{$_[1]}) { } |
|
|
0 |
0 |
elsif ($method eq 'HSET' and utf8::is_utf8($_[2])) { } |
|
1883
|
0 |
0 |
if (length $$data_ref > $self->max_datasize) |
|
1884
|
0 |
0 |
if ($self->_transaction) |
|
1940
|
0 |
0 |
if ($try_again and $method eq 'EVALSHA') |
|
1949
|
0 |
0 |
if $error |
|
1952
|
0 |
0 |
if $method eq 'MULTI' |
|
1954
|
0 |
0 |
if ($method eq 'EXEC') |
|
1959
|
0 |
0 |
if ($method eq 'HGET' and $_[1] =~ /^(workload|result)$/) |
|
1960
|
0 |
0 |
if ($result[0]) |
|
1962
|
0 |
0 |
if ref $result[0] eq 'SCALAR' |
|
1966
|
0 |
0 |
wantarray ? : |
|
1970
|
0 |
0 |
unless $WAIT_USED_MEMORY |
|
1976
|
0 |
0 |
if ($maxmemory) |
|
1982
|
0 |
0 |
if ($used_memory < $maxmemory or $sleepped > $max_timeout) |
|
1999
|
0 |
0 |
if (not $self->_transaction and $self->reconnect_on_error and not $self->ping) |
|
2001
|
0 |
0 |
if $err_msg |
|
2012
|
0 |
0 |
if (not $err or $err != 1 and $err != 2 and $err != 4 and $err != 5) |
|
2030
|
0 |
0 |
if ($err_msg) |
|
2031
|
0 |
0 |
$msg ? : |
|
|
0 |
0 |
defined $msg ? : |
|
2056
|
0 |
0 |
unless defined &_STRING($id_source) or &_INSTANCE($id_source, 'Redis::JobQueue::Job') |
|
2059
|
0 |
0 |
ref $id_source ? : |
|
2069
|
0 |
0 |
unless ($sha1) |
|
2071
|
0 |
0 |
unless (($self->_call_redis('SCRIPT', 'EXISTS', $sha1))[0]) |