line |
!l |
l&&!r |
l&&r |
condition |
85
|
15 |
15 |
90 |
(!defined($options->{'queue'}) || $_->{'queue'} eq $options->{'queue'}) && (!defined($options->{'state'}) || $_->{'state'} eq $options->{'state'}) && (!defined($options->{'task'}) || $_->{'task'} eq $options->{'task'}) |
87
|
0 |
0 |
60 |
($_->{'children'} = $guard->_children($_->{'id'})) && $_ |
169
|
3 |
5 |
0 |
$_->{'notified'} < $after and delete $$workers{$_->{'id'}} |
174
|
88 |
53 |
31 |
$job->{'state'} eq 'finished' and $job->{'finished'} <= $after |
181
|
126 |
1 |
16 |
$_->{'state'} eq 'active' && !exists($$workers{$_->{'worker'}}) |
201
|
91 |
15 |
0 |
exists $options->{$_} and $job->{$_} = $options->{$_} |
216
|
226 |
5 |
18 |
$job->{'state'} eq 'active' and not $seen{$job->{'worker'}}++ |
218
|
194 |
53 |
2 |
$job->{'state'} eq 'inactive' and &Minion::Backend::Sereal::time() < $job->{'delayed'} || @{$job->{'parents'};} |
242
|
20 |
35 |
45 |
$i < $length and ($locks->[$i] // 0) <= $now |
271
|
20 |
10 |
263 |
$_->{'state'} eq 'inactive' && $queues{$_->{'queue'}} && $$tasks{$_->{'task'}} && $_->{'delayed'} <= $now |
280
|
2 |
7 |
6 |
exists $jobs->{$parent} and grep(($jobs->{$parent}{'state'} eq $_), ('active', 'failed', 'inactive')) |
303
|
99 |
53 |
5 |
$fail and $job->{'attempts'} > $retries + 1 |
311
|
10 |
5 |
85 |
$id and my $worker = $guard->_workers->{$id} |
314
|
170 |
0 |
15 |
$_->{'state'} eq 'active' && $_->{'worker'} eq $id |
line |
l |
!l |
condition |
20
|
5 |
2 |
shift() // [] |
|
4 |
3 |
shift() // [] |
28
|
9 |
1 |
$inboxes->{$_} //= [] |
42
|
106 |
69 |
shift() // [] |
|
32 |
143 |
shift() // {} |
55
|
6 |
169 |
$options->{'attempts'} // 1 |
|
5 |
170 |
$options->{'delay'} // 0 |
|
5 |
170 |
$options->{'notes'} // {} |
|
3 |
172 |
$options->{'parents'} // [] |
|
5 |
170 |
$options->{'priority'} // 0 |
|
8 |
167 |
$options->{'queue'} // 'default' |
99
|
45 |
30 |
shift() // {} |
100
|
45 |
30 |
$options->{'limit'} || 1 |
103
|
55 |
20 |
$guard->_locks->{$name} //= [] |
107
|
70 |
10 |
$_ // 0 |
116
|
15 |
25 |
$$locks[$#$locks] // 0 |
119
|
0 |
0 |
$a // 0 |
|
0 |
0 |
$b // 0 |
135
|
4 |
1 |
$inboxes->{$id} // [] |
141
|
152 |
0 |
shift() // {} |
148
|
152 |
0 |
$options->{'status'} // {} |
192
|
25 |
40 |
shift() // {} |
229
|
18 |
50 |
$states{'active'} // 0 |
|
13 |
55 |
$states{'failed'} // 0 |
|
30 |
38 |
$states{'finished'} // 0 |
|
42 |
26 |
$states{'inactive'} // 0 |
237
|
55 |
0 |
$guard->_locks->{$name} //= [] |
242
|
35 |
45 |
$locks->[$i] // 0 |
263
|
27 |
249 |
$options->{'queues'} // ['default'] |
277
|
208 |
0 |
$candidate->{'parents'} // [] |
346
|
4649 |
0 |
$job->{'parents'} // [] |
359
|
107 |
12 |
$_[0]->_data->{'inboxes'} //= {} |
367
|
58 |
10 |
$_[0]->_data->{'job_count'} //= 0 |
376
|
2150 |
12 |
$_[0]->_data->{'jobs'} //= {} |
391
|
125 |
10 |
(shift())->_data->{'locks'} //= {} |
400
|
1111 |
0 |
syswrite($file, $payload) // -1 |
405
|
590 |
12 |
$_[0]->_data->{'workers'} //= {} |