Branch Coverage

lib/Redis/JobQueue.pm

Criterion	Covered	Total	%
branch	0	156	0.0

line	true	false	branch
710	0	0	unless $self->_redis
712	0	0	if ($self->_check_maxmemory)
714	0	0	unless defined &_NONNEGINT($max_datasize)
716	0	0	if $max_datasize
721	0	0	if ($major < 2 or $major == 2 and $minor <= 4)
906	0	0	unless ref $_[0] eq 'HASH' or &_INSTANCE($_[0], 'Redis::JobQueue::Job')
908	0	0	&_INSTANCE($_[0], 'Redis::JobQueue::Job') ? :
932	0	0	if ($expire)
939	0	0	$args{'LPUSH'} ? :
987	0	0	unless &_STRING($_)
991	0	0	if ($data_fields) { }
992	0	0	if (exists $right_names{'elapsed'})
994	0	0	unless exists $right_names{$field}
1013	0	0	unless $job_exists
1017	0	0	if ($field ne 'elapsed' and $field =~ /^(workload|result)$/ || !$job_fnames{$field})
1018	0	0	if $data[$i]
1023	0	0	if (not $data_fields) { }
1029	0	0	if (my $started = $result_data{'started'}) { }
1042	0	0	if ($right_keys[$i] eq 'elapsed')
1043	0	0	if (my $started = $data[&firstidx(sub { $_ eq 'started'; } , @all_fields)]) { }
1054	0	0	unless wantarray
1085	0	0	if not $job_fnames{$_}
1117	0	0	unless $job_exists
1123	0	0	if ($job_fnames{$key}) { }
1132	0	0	if $pre_job->{$field}
1134	0	0	if ($pre_job->{'meta_data'})
1138	0	0	if $meta_data->{$field}
1189	0	0	if scalar(@_) % 2
1196	0	0	unless ref $queues
1200	0	0	unless defined &_STRING($arg)
1207	0	0	if (@keys)
1211	0	0	if ($blocking) { }
1217	0	0	unless $full_id
1220	0	0	if $ret
1225	0	0	unless $self->_call_redis('EXISTS', $key)
1230	0	0	unless $full_id
1233	0	0	if $ret
1260	0	0	if ($self->_call_redis('EXISTS', $key)) { }
1261	0	0	if ($only_id) { }
1265	0	0	if (my $expire = $job->expire)
1271	0	0	if (not $expire_time or time < $expire_time)
1304	0	0	unless &_INSTANCE($job, 'Redis::JobQueue::Job')
1308	0	0	unless @modified
1313	0	0	unless ($self->_call_redis('EXISTS', $key))
1322	0	0	if ($expire) { }
1330	0	0	if (not $job_fnames{$field}) { }
	0	0	elsif ($field ne 'expire' and $field ne 'id') { }
1375	0	0	unless defined &_STRING($id_source) or &_INSTANCE($id_source, 'Redis::JobQueue::Job')
1380	0	0	ref $id_source ? :
1434	0	0	if scalar(@_) % 2
1441	0	0	if exists $args{$field} and ref $args{$field} ne 'ARRAY'
1452	0	0	$args{'queued'} ? :
	0	0	scalar @queues ? :
	0	0	scalar @statuses ? :
1510	0	0	($ret // '') eq 'PONG' ? :
1530	0	0	if $] >= 5.14 and ${^GLOBAL_PHASE} eq 'DESTRUCT'
1534	0	0	unless ($self->_use_external_connection)
1597	0	0	unless defined &_STRING($maybe_queue) or &_INSTANCE($maybe_queue, 'Redis::JobQueue::Job')
1600	0	0	if ref $maybe_queue
1621	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+] ERR command not allowed when used memory > 'maxmemory'/ or $error =~ /[\S+] OOM command not allowed when used memory > 'maxmemory'/) { }
1639	0	0	if ($self->_transaction)
1681	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])) { }
1695	0	0	if (length $$data_ref > $self->max_datasize)
1696	0	0	if ($self->_transaction)
1750	0	0	if $error
1753	0	0	if $method eq 'MULTI'
1755	0	0	if ($method eq 'EXEC')
1760	0	0	if ($method eq 'HGET' and $_[1] =~ /^(workload|result)$/)
1761	0	0	if ($result[0])
1763	0	0	if ref $result[0] eq 'SCALAR'
1767	0	0	wantarray ? :
1787	0	0	unless defined &_STRING($id_source) or &_INSTANCE($id_source, 'Redis::JobQueue::Job')
1790	0	0	ref $id_source ? :
1797	0	0	unless ($sha1)
1799	0	0	unless (($self->_call_redis('SCRIPT', 'EXISTS', $sha1))[0])