| line |
true |
false |
branch |
|
149
|
2 |
4 |
ref $_[0] ? : |
|
152
|
3 |
3 |
if (exists $self->{'data'}) |
|
157
|
1 |
5 |
if @missing |
|
161
|
1 |
4 |
if @invalid |
|
170
|
3 |
1 |
unless exists $self->{'prefix'} |
|
171
|
3 |
1 |
unless exists $self->{'expire'} |
|
172
|
3 |
1 |
unless exists $self->{'usleep'} |
|
173
|
3 |
1 |
unless exists $self->{'redis_read'} |
|
174
|
2 |
2 |
unless exists $self->{'redis_write'} |
|
175
|
3 |
1 |
unless exists $self->{'retry'} |
|
205
|
0 |
0 |
unless $self->{'read_conn'} |
|
213
|
1 |
0 |
unless $self->{'write_conn'} |
|
220
|
0 |
0 |
unless $self->{'daemon_conn'} |
|
234
|
0 |
0 |
if ($self->_write->setnx($self->_unique, 1)) |
|
276
|
0 |
0 |
if not $last_job or $last_worker and $last_job <= $last_worker |
|
282
|
0 |
0 |
if $payload = $self->_read->get($self->_job_load($next)) |
|
285
|
0 |
0 |
unless $payload |
|
298
|
0 |
0 |
if $self->_read->ttl($self->_unique) <= 0 |
|
319
|
0 |
0 |
if ($count == 0) |