| line |
true |
false |
branch |
|
45
|
0 |
0 |
if $_arg eq "await" |
|
46
|
0 |
0 |
if $_arg eq "porder" |
|
47
|
0 |
0 |
if $_arg eq "type" |
|
52
|
2 |
37 |
if $_imported++ |
|
57
|
35 |
2 |
if ($INC{'MCE.pm'} and "MCE"->wid == 0) |
|
121
|
0 |
0 |
if $INC{'threads.pm'} |
|
126
|
0 |
23 |
$_tid ? : |
|
128
|
23 |
0 |
if exists $_Q->{'_id'} |
|
131
|
16 |
7 |
if (exists $_Q->{'_init_pid'} and $_Q->{'_init_pid'} eq $_pid) |
|
154
|
0 |
45 |
unless exists $_valid_fields_new{$_p} |
|
163
|
6 |
45 |
defined $_argv{'await'} ? : |
|
166
|
7 |
44 |
defined $_argv{'porder'} ? : |
|
169
|
25 |
26 |
defined $_argv{'type'} ? : |
|
173
|
7 |
44 |
if (exists $_argv{'queue'}) { } |
|
175
|
0 |
7 |
unless ref $_argv{'queue'} eq "ARRAY" |
|
183
|
0 |
51 |
if (exists $_argv{'gather'}) |
|
185
|
0 |
0 |
unless ref $_argv{'gather'} eq "CODE" |
|
193
|
0 |
51 |
$_tid ? : |
|
198
|
6 |
45 |
if $_Q->{'_await'} |
|
210
|
0 |
0 |
if ($INC{'MCE.pm'}) { } |
|
223
|
65 |
18 |
if (not exists $_Q->{'_datp'}{$_p} or @{$_Q->{'_datp'}{$_p};} == 0) |
|
225
|
9 |
6 |
do {
$_Q->{'_porder'}
} ? : |
|
|
15 |
50 |
scalar @{$_Q->{'_heap'};} ? : |
|
248
|
800 |
94 |
unless (scalar @{$_Q->{'_heap'};}) |
|
250
|
786 |
14 |
$_Q->{'_type'} ? : |
|
256
|
47 |
47 |
if @{$_Q->{'_datp'}{$_p};} == 1 |
|
260
|
70 |
24 |
$_Q->{'_type'} ? : |
|
269
|
0 |
50 |
if $INC{'MCE.pm'} and not defined $MCE::MCE->{'_wid'} |
|
270
|
0 |
38 |
if defined $MCE::MCE and $MCE::MCE->{'_wid'} |
|
272
|
45 |
5 |
if (defined $_p) |
|
273
|
0 |
45 |
if not &looks_like_number($_p) or int $_p != $_p |
|
276
|
9 |
36 |
unless exists $_Q->{'_datp'}{$_p} |
|
289
|
0 |
6 |
if ($_p < $_Q->{'_heap'}[0]) { } |
|
|
4 |
2 |
elsif ($_p > $_Q->{'_heap'}[-1]) { } |
|
304
|
2 |
2 |
if ($_p > $_Q->{'_heap'}[$_midpoint]) { } |
|
324
|
6 |
3 |
if ($_p > $_Q->{'_heap'}[0]) { } |
|
|
0 |
3 |
elsif ($_p < $_Q->{'_heap'}[-1]) { } |
|
339
|
3 |
3 |
if ($_p < $_Q->{'_heap'}[$_midpoint]) { } |
|
739
|
0 |
0 |
unless (exists $_Q->{'_ended'}) |
|
752
|
0 |
569 |
unless scalar @_ |
|
754
|
0 |
569 |
if (exists $_Q->{'_ended'}) |
|
759
|
146 |
423 |
if ($_Q->{'_dsem'}) |
|
762
|
75 |
75 |
unless $_Q->{'_dsem'} |
|
777
|
0 |
74 |
if not &looks_like_number($_p) or int $_p != $_p |
|
780
|
0 |
74 |
unless scalar @_ |
|
782
|
0 |
74 |
if (exists $_Q->{'_ended'}) |
|
787
|
0 |
74 |
if ($_Q->{'_dsem'}) |
|
790
|
0 |
0 |
unless $_Q->{'_dsem'} |
|
806
|
6 |
10 |
if (defined $_cnt and $_cnt ne '1') { } |
|
807
|
0 |
6 |
if not &looks_like_number($_cnt) or int $_cnt != $_cnt or $_cnt < 1 |
|
812
|
4 |
0 |
if ($_pending < $_cnt and scalar @{$_Q->{'_heap'};}) |
|
817
|
0 |
6 |
if $_pending < $_cnt |
|
822
|
10 |
0 |
@{$_Q->{'_datq'};} || @{$_Q->{'_heap'};} ? : |
|
826
|
6 |
10 |
if scalar @_items |
|
827
|
10 |
0 |
if $_has_data |
|
828
|
0 |
0 |
if exists $_Q->{'_ended'} |
|
841
|
0 |
4 |
if (defined $_cnt and $_cnt ne 1) |
|
842
|
0 |
0 |
if not &looks_like_number($_cnt) or int $_cnt != $_cnt or $_cnt < 1 |
|
847
|
0 |
0 |
if ($_pending < $_cnt and scalar @{$_Q->{'_heap'};}) |
|
853
|
0 |
0 |
if $_pending < $_cnt |
|
860
|
4 |
0 |
defined $_buf ? : |
|
869
|
0 |
4 |
if (defined $_timeout) |
|
870
|
0 |
0 |
unless &looks_like_number($_timeout) |
|
874
|
0 |
4 |
if (defined $_cnt and $_cnt ne 1) |
|
875
|
0 |
0 |
if not &looks_like_number($_cnt) or int $_cnt != $_cnt or $_cnt < 1 |
|
880
|
0 |
0 |
if ($_pending < $_cnt and scalar @{$_Q->{'_heap'};}) |
|
886
|
0 |
0 |
if $_pending < $_cnt |
|
893
|
4 |
0 |
defined $_buf ? : |
|
902
|
9 |
5 |
if (scalar @{$_Q->{'_heap'};}) |
|
909
|
0 |
0 |
$_pending ? : |
|
|
0 |
14 |
exists $_Q->{'_ended'} ? : |
|
918
|
0 |
50 |
if not &looks_like_number($_i) or int $_i != $_i |
|
921
|
0 |
50 |
unless scalar @_ |
|
923
|
0 |
50 |
if (exists $_Q->{'_ended'}) |
|
928
|
0 |
50 |
if ($_Q->{'_dsem'}) |
|
931
|
0 |
0 |
unless $_Q->{'_dsem'} |
|
935
|
10 |
40 |
if (abs $_i > scalar @{$_Q->{'_datq'};}) { } |
|
936
|
5 |
5 |
if ($_i >= 0) { } |
|
937
|
3 |
2 |
if ($_Q->{'_type'}) { } |
|
944
|
3 |
2 |
if ($_Q->{'_type'}) { } |
|
952
|
16 |
24 |
unless ($_Q->{'_type'}) |
|
954
|
10 |
6 |
$_i >= 0 ? : |
|
968
|
0 |
90 |
if not &looks_like_number($_p) or int $_p != $_p |
|
970
|
0 |
90 |
if not &looks_like_number($_i) or int $_i != $_i |
|
973
|
0 |
90 |
unless scalar @_ |
|
975
|
0 |
90 |
if (exists $_Q->{'_ended'}) |
|
980
|
0 |
90 |
if ($_Q->{'_dsem'}) |
|
983
|
0 |
0 |
unless $_Q->{'_dsem'} |
|
987
|
81 |
9 |
if (exists $_Q->{'_datp'}{$_p} and scalar @{$_Q->{'_datp'}{$_p};}) { } |
|
989
|
18 |
63 |
if (abs $_i > scalar @{$_Q->{'_datp'}{$_p};}) { } |
|
990
|
9 |
9 |
if ($_i >= 0) { } |
|
991
|
5 |
4 |
if ($_Q->{'_type'}) { } |
|
998
|
5 |
4 |
if ($_Q->{'_type'}) { } |
|
1006
|
28 |
35 |
unless ($_Q->{'_type'}) |
|
1008
|
16 |
12 |
$_i >= 0 ? : |
|
1027
|
40 |
15 |
if ($_i) { } |
|
1028
|
0 |
40 |
if not &looks_like_number($_i) or int $_i != $_i |
|
1033
|
15 |
40 |
if abs $_i > scalar @{$_Q->{'_datq'};} |
|
1035
|
16 |
24 |
unless ($_Q->{'_type'}) |
|
1037
|
10 |
6 |
$_i >= 0 ? : |
|
1050
|
72 |
27 |
if ($_i) { } |
|
1051
|
0 |
72 |
if not &looks_like_number($_i) or int $_i != $_i |
|
1056
|
0 |
99 |
if not &looks_like_number($_p) or int $_p != $_p |
|
1059
|
0 |
99 |
unless exists $_Q->{'_datp'}{$_p} |
|
1060
|
27 |
72 |
if abs $_i > scalar @{$_Q->{'_datp'}{$_p};} |
|
1062
|
32 |
40 |
unless ($_Q->{'_type'}) |
|
1064
|
20 |
12 |
$_i >= 0 ? : |
|
1077
|
5 |
5 |
if ($_i) { } |
|
1078
|
0 |
5 |
if not &looks_like_number($_i) or int $_i != $_i |
|
1083
|
0 |
10 |
if abs $_i > scalar @{$_Q->{'_heap'};} |
|
1158
|
0 |
28 |
if ($_lock_chn) |
|
1161
|
0 |
0 |
$_tid ? : |
|
1163
|
0 |
0 |
if $_is_MSWin32 |
|
1165
|
0 |
0 |
unless $_DAT_LOCK->{$_pid} |
|
1168
|
0 |
0 |
$_tid ? : |
|
1170
|
0 |
0 |
if $_DAT_LOCK->{$_pid} |
|
1202
|
0 |
0 |
if exists $$_all{$_Q->{'_id'}} |
|
1205
|
0 |
0 |
unless $_Q->{'_await'} |
|
1206
|
0 |
0 |
if not &looks_like_number($_t) or int $_t != $_t |
|
1209
|
0 |
0 |
if $_t < 0 |
|
1212
|
0 |
0 |
if $_is_MSWin32 |
|
1221
|
0 |
8 |
if exists $$_all{$_Q->{'_id'}} |
|
1231
|
0 |
0 |
if exists $$_all{$_Q->{'_id'}} |
|
1243
|
0 |
56 |
if exists $$_all{$_Q->{'_id'}} |
|
1245
|
56 |
0 |
if (scalar @_) |
|
1257
|
0 |
20 |
if exists $$_all{$_Q->{'_id'}} |
|
1259
|
0 |
20 |
if not &looks_like_number($_p) or int $_p != $_p |
|
1262
|
20 |
0 |
if (scalar @_) |
|
1276
|
0 |
229 |
if exists $$_all{$_Q->{'_id'}} |
|
1278
|
6 |
223 |
if (defined $_cnt and $_cnt ne '1') { } |
|
1279
|
0 |
6 |
if not &looks_like_number($_cnt) or int $_cnt != $_cnt or $_cnt < 1 |
|
1286
|
0 |
229 |
if defined $\ |
|
1287
|
0 |
229 |
if $/ ne $MCE::Queue::LF |
|
1289
|
0 |
229 |
if $_lock_chn |
|
1295
|
183 |
46 |
if $_len >= 0 |
|
1297
|
0 |
229 |
if $_lock_chn |
|
1300
|
177 |
52 |
if $_len > 0 and $_cnt == 1 |
|
1301
|
6 |
46 |
if $_len > 0 |
|
1302
|
0 |
46 |
if $_len == -2 |
|
1304
|
0 |
46 |
if $_is_MSWin32 |
|
1313
|
0 |
4 |
if exists $$_all{$_Q->{'_id'}} |
|
1315
|
0 |
4 |
if (defined $_cnt and $_cnt ne '1') { } |
|
1316
|
0 |
0 |
if not &looks_like_number($_cnt) or int $_cnt != $_cnt or $_cnt < 1 |
|
1330
|
0 |
4 |
if exists $$_all{$_Q->{'_id'}} |
|
1332
|
0 |
4 |
if (defined $_timeout) |
|
1333
|
0 |
0 |
unless &looks_like_number($_timeout) |
|
1338
|
0 |
4 |
if (defined $_cnt and $_cnt ne '1') { } |
|
1339
|
0 |
0 |
if not &looks_like_number($_cnt) or int $_cnt != $_cnt or $_cnt < 1 |
|
1345
|
4 |
0 |
if (not $_timeout or $_timeout < 0) |
|
1350
|
0 |
0 |
if defined $\ |
|
1351
|
0 |
0 |
if $/ ne $MCE::Queue::LF |
|
1353
|
0 |
0 |
if $_lock_chn |
|
1359
|
0 |
0 |
if $_len >= 0 |
|
1361
|
0 |
0 |
if $_lock_chn |
|
1364
|
0 |
0 |
if $_len > 0 and $_cnt == 1 |
|
1365
|
0 |
0 |
if $_len > 0 |
|
1366
|
0 |
0 |
if $_len == -2 |
|
1370
|
0 |
0 |
if $_timeout < "0.045" |
|
1373
|
0 |
0 |
if (select($_r, undef, undef, $_timeout) > 0) |
|
1391
|
0 |
4 |
if exists $$_all{$_Q->{'_id'}} |
|
1393
|
0 |
4 |
if defined $\ |
|
1394
|
0 |
4 |
if $/ ne $MCE::Queue::LF |
|
1396
|
0 |
4 |
if $_lock_chn |
|
1401
|
0 |
4 |
if $_lock_chn |
|
1403
|
4 |
0 |
length $_pending ? : |
|
1409
|
0 |
20 |
if exists $$_all{$_Q->{'_id'}} |
|
1411
|
0 |
20 |
if not &looks_like_number($_i) or int $_i != $_i |
|
1414
|
0 |
20 |
unless scalar @_ |
|
1427
|
0 |
20 |
if exists $$_all{$_Q->{'_id'}} |
|
1429
|
0 |
20 |
if not &looks_like_number($_p) or int $_p != $_p |
|
1431
|
0 |
20 |
if not &looks_like_number($_i) or int $_i != $_i |
|
1434
|
0 |
20 |
unless scalar @_ |
|
1449
|
0 |
22 |
if exists $$_all{$_Q->{'_id'}} |
|
1451
|
0 |
22 |
if not &looks_like_number($_i) or int $_i != $_i |
|
1460
|
0 |
22 |
if exists $$_all{$_Q->{'_id'}} |
|
1462
|
0 |
22 |
if not &looks_like_number($_p) or int $_p != $_p |
|
1464
|
0 |
22 |
if not &looks_like_number($_i) or int $_i != $_i |
|
1473
|
0 |
4 |
if exists $$_all{$_Q->{'_id'}} |
|
1475
|
0 |
4 |
if not &looks_like_number($_i) or int $_i != $_i |
|
1480
|
4 |
0 |
length $_ret ? : |
|
1486
|
0 |
2 |
if exists $$_all{$_Q->{'_id'}} |