| line |
true |
false |
branch |
|
25
|
0 |
38 |
if ($opts{'join'} and not $opts{'db_file'}) |
|
28
|
0 |
38 |
if ($opts{'file'} and not $opts{'db_file'}) |
|
38
|
2 |
36 |
if (not $opts{'join'} and -f $opts{'db_file'}) |
|
49
|
36 |
2 |
if (not $exists) { } |
|
53
|
2 |
34 |
unless (eval {
do {
$self->_init
}
}) |
|
60
|
5 |
31 |
if (defined $list) |
|
61
|
5 |
0 |
if (ref $list eq 'ARRAY') { } |
|
77
|
24751 |
0 |
if $] >= 5.014 |
|
81
|
0 |
0 |
if --$count <= 0 |
|
84
|
0 |
0 |
if $DEBUG |
|
98
|
2 |
34 |
unless ($z1) |
|
104
|
0 |
34 |
unless ($z2) |
|
111
|
0 |
34 |
unless ($z3) |
|
117
|
0 |
34 |
unless ($z4) |
|
130
|
0 |
28724 |
$INC{'threads.pm'} ? : |
|
135
|
28511 |
12 |
if ($self->{'_dbh'} and $$ == $self->{'_pid'}[0] and $tid == $self->{'_pid'}[1]) |
|
143
|
12 |
2 |
unless ($self->{'_DESTROY'}) |
|
160
|
34 |
0 |
$self->{'_pid'} ? : |
|
182
|
34 |
0 |
if $dbh |
|
183
|
22 |
12 |
if ($t and $t->[0] and $t->[0][0] == 0) { } |
|
184
|
0 |
22 |
if $_DEBUG |
|
185
|
20 |
2 |
if (not $self->{'persist'}) |
|
197
|
0 |
0 |
if not $dbh and $self->{'_DESTROY'} |
|
198
|
22590 |
198 |
if (@_ == 1) { } |
|
|
198 |
0 |
elsif (@_ == 2) { } |
|
200
|
0 |
0 |
if (not $sth and $self->{'_DESTROY'}) |
|
208
|
0 |
22590 |
unless ($z) |
|
213
|
22519 |
71 |
if (@$t == 0) |
|
237
|
0 |
8 |
if ($end) |
|
242
|
8 |
0 |
unless ($end) |
|
267
|
0 |
82 |
if $XDEBUG |
|
273
|
0 |
4 |
if $XDEBUG |
|
287
|
4 |
32 |
unless ($self->{'_limit_magic'}) |
|
289
|
0 |
4 |
if $XDEBUG |
|
291
|
10 |
26 |
if (@_) { } |
|
293
|
0 |
10 |
if $XDEBUG |
|
295
|
6 |
4 |
if (@_) |
|
296
|
0 |
6 |
if $XDEBUG |
|
302
|
0 |
26 |
if $XDEBUG |
|
326
|
0 |
3747 |
unless $dbh |
|
328
|
0 |
3747 |
unless $sth |
|
351
|
0 |
2 |
if ($self->_end) |
|
358
|
0 |
2 |
if $self->{'limit'} <= 0 |
|
366
|
2 |
0 |
if (@items and $self->_avail < $limit) |
|
374
|
0 |
2 |
if (@items > 0) |
|
378
|
2 |
0 |
if $pushed |
|
380
|
0 |
2 |
if ($failed_items) |
|
381
|
0 |
0 |
if ($self->{'on_limit'} eq 'fail') { } |
|
385
|
0 |
0 |
if $_DEBUG |
|
388
|
0 |
0 |
if $_DEBUG |
|
418
|
2 |
146 |
if ($self->_end) |
|
425
|
109 |
37 |
if $self->{'limit'} <= 0 |
|
439
|
21 |
125 |
if (@items > 0) |
|
443
|
143 |
3 |
if $pushed |
|
445
|
21 |
125 |
if ($failed_items) |
|
446
|
13 |
8 |
if ($self->{'on_limit'} eq 'fail') { } |
|
450
|
0 |
8 |
if $_DEBUG |
|
453
|
0 |
8 |
if $_DEBUG |
|
465
|
2215 |
7 |
unless $ready |
|
472
|
0 |
8 |
if ($self->{'limit'} <= 0) |
|
476
|
0 |
8 |
@_ ? : |
|
478
|
8 |
8 |
if $self->_avail + $count <= $self->{'limit'} |
|
479
|
0 |
8 |
if $self->_end |
|
491
|
0 |
148 |
if (@$tt == 0) { } |
|
500
|
8 |
0 |
if @_ |
|
502
|
0 |
3 |
if ($self->limit > 0 and $count > $self->limit) |
|
505
|
3 |
0 |
if ($self->{'style'} ne 'lifo') { } |
|
506
|
3 |
0 |
@_ ? : |
|
509
|
0 |
0 |
@_ ? : |
|
517
|
21 |
16 |
@_ ? : |
|
522
|
4 |
5 |
if @_ |
|
525
|
4 |
5 |
@_ ? : |
|
531
|
0 |
1 |
@_ ? : |
|
537
|
0 |
2 |
@_ ? : |
|
539
|
0 |
2 |
@_ ? : |
|
545
|
24 |
2 |
if @_ |
|
547
|
13 |
10 |
if @_ |
|
552
|
9 |
9 |
if ($self->{'style'} eq 'lifo') |
|
556
|
0 |
18 |
if ($count <= 0) |
|
560
|
8 |
10 |
if ($index < 0) |
|
561
|
0 |
8 |
if ($index + $count > 0) |
|
572
|
9 |
9 |
if ($reverse) |
|
575
|
8 |
10 |
@_ ? : |
|
584
|
0 |
10 |
if ($self->_end) |
|
591
|
0 |
10 |
if $self->{'limit'} <= 0 |
|
593
|
2 |
8 |
if ($pos >= $self->_avail) |
|
594
|
0 |
2 |
if ($self->{'on_limit'} eq 'tq-compat') { } |
|
604
|
2 |
6 |
if ($pos <= -$self->_avail) |
|
608
|
2 |
6 |
if ($pos < 0) |
|
624
|
8 |
0 |
if (@$tt > 0) { } |
|
631
|
0 |
8 |
if (@$tt == $pos) { } |
|
|
2 |
6 |
elsif ($pos == 0) { } |
|
635
|
0 |
0 |
if ($t2 < 0) { } |
|
649
|
6 |
2 |
if ($t1 == $t2) { } |
|
658
|
0 |
2 |
if ($t3 == $t1) |
|
662
|
0 |
8 |
if ($self->{'on_limit'} eq 'tq-compat') { } |
|
678
|
2 |
6 |
if (@items > 0) |
|
681
|
2 |
6 |
if (@deferred_items) |
|
682
|
2 |
0 |
if ($self->{'on_limit'} eq 'fail') { } |
|
686
|
0 |
0 |
if $_DEBUG |
|
689
|
0 |
0 |
if $_DEBUG |
|
693
|
8 |
0 |
if $inserted |
|
710
|
51 |
66 |
@_ ? : |
|
711
|
0 |
117 |
if $hi <= $lo |
|
720
|
0 |
117 |
if ($lo > 0 and $block) |
|
725
|
42 |
75 |
$tfactor > 0 ? : |
|
734
|
0 |
117 |
unless ($sths) |
|
739
|
0 |
20228 |
$lo < 0 ? : |
|
743
|
0 |
20228 |
if ($lo < 0 and -$lo > @$tt) |
|
747
|
14 |
20214 |
if (not $tt or @$tt == 0) { } |
|
|
20104 |
110 |
elsif ($block > 1 and $lo == 0 and @$tt < $hi) { } |
|
|
6 |
104 |
elsif (@$tt <= $lo) { } |
|
749
|
7 |
7 |
if ($block) { } |
|
764
|
12 |
92 |
if $hi > @$tt |
|
767
|
0 |
443 |
unless (defined $tt->[$itt]) |
|
772
|
399 |
44 |
if ($purge) |
|
775
|
0 |
399 |
unless ($zd) |
|
783
|
20156 |
59 |
if ($block) |
|
784
|
29 |
20127 |
if ($self->_end or $self->_expired) |
|
789
|
45 |
59 |
@_ ? : |
|
804
|
0 |
0 |
if ($tfactor > 0) |
|
817
|
0 |
0 |
if (@$tt == 0) |
|
818
|
0 |
0 |
if ($block and $self->_wait_for_item) { } |
|
827
|
0 |
0 |
if ($purge) |
|
830
|
0 |
0 |
unless ($zd) |
|
837
|
0 |
0 |
$wantarray ? : |
|
852
|
10 |
25 |
if ($index < 0) |
|
863
|
5 |
22 |
if ($index < 0) |
|
871
|
0 |
161 |
unless $Forks::Queue::NOTIFY_OK |
|
879
|
76 |
85 |
if (@pids) |
|
880
|
0 |
76 |
if $self->{'debug'} // $DEBUG |
|
883
|
161 |
91 |
if $_->[0] == $$ |
|
884
|
0 |
161 |
if (@tids) |
|
887
|
0 |
0 |
if $thr |
|
899
|
0 |
17 |
if ($^O eq 'MSWin32') { } |
|
908
|
17 |
0 |
if (defined $candidate and $candidate ne '' and -d $candidate and -w _ and -x _) |