| line |
true |
false |
branch |
|
153
|
2 |
4 |
ref $_[0] ? : |
|
156
|
3 |
3 |
if (exists $self->{'data'}) |
|
161
|
1 |
5 |
if @missing |
|
165
|
1 |
4 |
if @invalid |
|
174
|
3 |
1 |
unless exists $self->{'prefix'} |
|
175
|
3 |
1 |
unless exists $self->{'expire'} |
|
176
|
3 |
1 |
unless exists $self->{'usleep'} |
|
177
|
3 |
1 |
unless exists $self->{'redis_read'} |
|
178
|
2 |
2 |
unless exists $self->{'redis_write'} |
|
179
|
3 |
1 |
unless exists $self->{'retry'} |
|
208
|
0 |
0 |
unless $self->{'read_conn'} |
|
216
|
1 |
0 |
unless $self->{'write_conn'} |
|
223
|
0 |
0 |
unless $self->{'daemon_conn'} |
|
237
|
0 |
0 |
if ($self->_write->setnx($self->_unique, 1)) |
|
277
|
0 |
0 |
if not $last_job or $last_worker and $last_job <= $last_worker |
|
283
|
0 |
0 |
if $payload = $self->_read->get($self->_job_load($next)) |
|
286
|
0 |
0 |
unless $payload |
|
299
|
0 |
0 |
if $self->_read->ttl($self->_unique) <= 0 |
|
320
|
0 |
0 |
if ($count == 0) |