line |
!l |
l&&!r |
l&&r |
condition |
79
|
15 |
15 |
90 |
(!exists $options->{'queue'} || $_->{'queue'} eq $options->{'queue'}) && (!exists $options->{'state'} || $_->{'state'} eq $options->{'state'}) && (!exists $options->{'task'} || $_->{'task'} eq $options->{'task'}) |
81
|
0 |
0 |
60 |
($_->{'children'} = $guard->_children($_->{'id'})) && $_ |
132
|
4 |
5 |
0 |
$_->{'notified'} < $after and delete $$workers{$_->{'id'}} |
136
|
0 |
182 |
1 |
$job->{'parents'} and $job->{'state'} eq 'inactive' |
147
|
99 |
53 |
31 |
$job->{'state'} eq 'finished' and $job->{'finished'} <= $after |
155
|
137 |
1 |
16 |
$_->{'state'} eq 'active' && !exists($$workers{$_->{'worker'}}) |
175
|
91 |
15 |
0 |
exists $options->{$_} and $job->{$_} = $options->{$_} |
190
|
200 |
5 |
17 |
$job->{'state'} eq 'active' and not $seen{$job->{'worker'}}++ |
192
|
169 |
52 |
1 |
$job->{'state'} eq 'inactive' and &Minion::Backend::Storable::time() < $job->{'delayed'} || @{$job->{'parents'};} |
230
|
20 |
10 |
260 |
$_->{'state'} eq 'inactive' && $queues{$_->{'queue'}} && $$tasks{$_->{'task'}} && $_->{'delayed'} < $now |
257
|
96 |
53 |
5 |
$fail and $job->{'attempts'} > $retries + 1 |
265
|
10 |
5 |
85 |
$id and my $worker = $guard->_workers->{$id} |
268
|
170 |
0 |
15 |
$_->{'state'} eq 'active' && $_->{'worker'} eq $id |
line |
l |
!l |
condition |
16
|
5 |
2 |
shift() || [] |
|
4 |
3 |
shift() || [] |
24
|
9 |
1 |
$inboxes->{$_} ||= [] |
36
|
105 |
67 |
shift() || [] |
|
26 |
146 |
shift() || {} |
48
|
6 |
166 |
$options->{'attempts'} // 1 |
|
5 |
167 |
$options->{'delay'} // 0 |
|
2 |
170 |
$options->{'parents'} || [] |
|
5 |
167 |
$options->{'priority'} // 0 |
|
8 |
164 |
$options->{'queue'} // 'default' |
98
|
4 |
1 |
$inboxes->{$id} || [] |
104
|
151 |
0 |
shift() || {} |
111
|
151 |
0 |
$options->{'status'} || {} |
166
|
25 |
40 |
shift() || {} |
203
|
17 |
49 |
$states{'active'} // 0 |
|
11 |
55 |
$states{'failed'} // 0 |
|
28 |
38 |
$states{'finished'} // 0 |
|
41 |
25 |
$states{'inactive'} // 0 |
236
|
12 |
2 |
$jobs->{$_}{'state'} // '' |
312
|
106 |
12 |
(shift())->_data->{'inboxes'} ||= {} |
328
|
56 |
10 |
(shift())->_data->{'job_count'} //= 0 |
330
|
2119 |
12 |
(shift())->_data->{'jobs'} ||= {} |
334
|
586 |
12 |
(shift())->_data->{'workers'} ||= {} |