|  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'} //= {}  |