| line |
true |
false |
branch |
|
51
|
0 |
0 |
unless ref $self->collection eq 'Mango::Collection' |
|
59
|
0 |
0 |
if exists $self->plugins->{$name} |
|
63
|
0 |
0 |
unless ($name->can('new')) |
|
64
|
0 |
0 |
unless eval "require $name" |
|
68
|
0 |
0 |
unless eval {
do {
$self->plugins->{$name} = $name->new(%$options);
return 1
}
} |
|
73
|
0 |
0 |
unless eval {
do {
$self->plugins->{$name}->register($self);
return 1
}
} |
|
84
|
0 |
0 |
$self->capped ? : |
|
85
|
0 |
0 |
$self->capped ? : |
|
86
|
0 |
0 |
$self->capped ? : |
|
98
|
0 |
0 |
unless defined $new_status |
|
107
|
0 |
0 |
unless defined $new_status |
|
116
|
0 |
0 |
unless defined $new_status |
|
124
|
0 |
0 |
ref $$self{'_pending_status'} eq 'ARRAY' ? : |
|
166
|
0 |
0 |
if ($self->delay_compat) { } |
|
182
|
0 |
0 |
ref $args[-1] eq 'CODE' ? : |
|
185
|
0 |
0 |
if scalar @args |
|
197
|
0 |
0 |
if $args{'delay_until'} |
|
199
|
0 |
0 |
if ($callback) { } |
|
202
|
0 |
0 |
if ($error) |
|
208
|
0 |
0 |
if $self->has_subscribers('enqueued') |
|
209
|
0 |
0 |
unless eval {
do {
$self->run_callback($callback, $db_job, undef);
return 1
}
} |
|
215
|
0 |
0 |
unless eval {
do {
$$db_job{'_id'} = $self->collection->insert($db_job);
return 1
}
} |
|
219
|
0 |
0 |
if $self->has_subscribers('enqueued') |
|
227
|
0 |
0 |
ref $id_or_job ? : |
|
234
|
0 |
0 |
if ($callback) { } |
|
250
|
0 |
0 |
$doc ? : |
|
252
|
0 |
0 |
if ($doc and !ref($status) && $$doc{'status'} eq $status || ref $status eq 'ARRAY' && grep({$_ =~ /$$doc{'status'}/;} @$status)) { } |
|
265
|
0 |
0 |
$doc ? : |
|
267
|
0 |
0 |
if ($doc and !ref($status) && $$doc{'status'} eq $status || ref $status eq 'ARRAY' && grep({$_ =~ /$$doc{'status'}/;} @$status)) { } |
|
274
|
0 |
0 |
unless 'Mojo::IOLoop'->is_running |
|
286
|
0 |
0 |
ref $pending eq 'ARRAY' ? : |
|
295
|
0 |
0 |
ref $id_or_job ? : |
|
297
|
0 |
0 |
if ($callback) { } |
|
301
|
0 |
0 |
if ($error) |
|
302
|
0 |
0 |
if $self->has_subscribers('error') |
|
308
|
0 |
0 |
if $self->has_subscribers('dequeued') |
|
312
|
0 |
0 |
if $self->has_subscribers('dequeued') |
|
319
|
0 |
0 |
ref $id_or_job ? : |
|
321
|
0 |
0 |
if ($callback) { } |
|
325
|
0 |
0 |
if ($error) |
|
326
|
0 |
0 |
if $self->has_subscribers('error') |
|
341
|
0 |
0 |
if $self->no_binary_oid |
|
343
|
0 |
0 |
if ($callback) { } |
|
346
|
0 |
0 |
if ($error) |
|
347
|
0 |
0 |
if $self->has_subscribers('error') |
|
352
|
0 |
0 |
unless return $self->collection->update({'_id', $$job{'_id'}}, $job, {'upsert', 1}) |
|
361
|
0 |
0 |
ref $args[-1] eq 'CODE' ? : |
|
363
|
0 |
0 |
if scalar @args |
|
367
|
0 |
0 |
if ($callback) { } |
|
383
|
0 |
0 |
ref $args[-1] eq 'CODE' ? : |
|
385
|
0 |
0 |
if scalar @args |
|
389
|
0 |
0 |
if ($callback) { } |
|
417
|
0 |
0 |
if scalar keys %$args |
|
420
|
0 |
0 |
$doc ? : |
|
422
|
0 |
0 |
if ($doc and $$doc{'attempt'} > $self->retries) |
|
429
|
0 |
0 |
if ($doc) { } |
|
430
|
0 |
0 |
if $self->no_binary_oid |
|
431
|
0 |
0 |
if $self->has_subscribers('consumed') |
|
434
|
0 |
0 |
if $fetch |
|
443
|
0 |
0 |
$self->concurrent_job_limit < 0 ? : |
|
446
|
0 |
0 |
if ($self->concurrent_job_limit > -1 and $self->job_count >= $self->concurrent_job_limit) |
|
447
|
0 |
0 |
unless 'Mojo::IOLoop'->is_running |
|
448
|
0 |
0 |
if $fetch |
|
449
|
0 |
0 |
if $self->has_subscribers('concurrent_job_limit_reached') |
|
451
|
0 |
0 |
unless exists $self->consumers->{$consumer_id} |
|
454
|
0 |
0 |
unless exists $self->consumers->{$consumer_id} |
|
464
|
0 |
0 |
if scalar keys %$args |
|
468
|
0 |
0 |
$doc ? : |
|
470
|
0 |
0 |
if ($err) |
|
475
|
0 |
0 |
if ($doc and $$doc{'attempt'} > $self->retries) |
|
482
|
0 |
0 |
if ($doc) { } |
|
483
|
0 |
0 |
if $self->no_binary_oid |
|
495
|
0 |
0 |
if $self->has_subscribers('consumed') |
|
497
|
0 |
0 |
unless eval {
do {
$self->run_callback($callback, $job);
return 1
}
} |
|
501
|
0 |
0 |
unless 'Mojo::IOLoop'->is_running |
|
502
|
0 |
0 |
if $fetch |
|
503
|
0 |
0 |
unless exists $self->consumers->{$consumer_id} |
|
509
|
0 |
0 |
unless 'Mojo::IOLoop'->is_running |
|
510
|
0 |
0 |
if $fetch |
|
512
|
0 |
0 |
unless exists $self->consumers->{$consumer_id} |