| line |
true |
false |
branch |
|
28
|
0 |
0 |
if $INC{'threads.pm'} |
|
50
|
37 |
0 |
unless ($_pkg =~ /^MCE::/) |
|
61
|
0 |
0 |
if $_arg eq "max_workers" |
|
62
|
0 |
0 |
if $_arg eq "chunk_size" |
|
63
|
0 |
0 |
if $_arg eq "tmp_dir" |
|
64
|
0 |
0 |
if $_arg eq "freeze" |
|
65
|
0 |
0 |
if $_arg eq "thaw" |
|
66
|
0 |
0 |
if $_arg eq "init_relay" |
|
67
|
0 |
0 |
if $_arg eq "use_threads" |
|
70
|
0 |
0 |
if ($_arg eq "sereal") |
|
71
|
0 |
0 |
if (shift() eq 0) |
|
86
|
0 |
37 |
unless $_p->{'CHUNK_SIZE'} eq "auto" |
|
99
|
23 |
6 |
if defined $_[0] and $_[0] eq "MCE::Flow" |
|
102
|
0 |
29 |
ref $_[0] eq 'HASH' ? : |
|
111
|
101 |
0 |
if defined $_[0] and $_[0] eq "MCE::Flow" |
|
112
|
66 |
35 |
defined $_[0] ? : |
|
114
|
37 |
64 |
if ($_pkg eq 'MCE') { } |
|
|
35 |
29 |
elsif ($_MCE->{$_pkg} and $_MCE->{$_pkg}{'_init_pid'} eq "$$.$_tid") { } |
|
118
|
35 |
0 |
if $_MCE->{$_pkg}{'_spawned'} |
|
141
|
0 |
4 |
if defined $_[0] and $_[0] eq "MCE::Flow" |
|
143
|
4 |
0 |
ref $_[0] eq 'HASH' ? : |
|
146
|
4 |
0 |
if (defined(my $_p = $_params->{$_pid})) { } |
|
147
|
0 |
4 |
if exists $_p->{'input_data'} |
|
148
|
0 |
4 |
if exists $_p->{'sequence'} |
|
156
|
2 |
4 |
if ($_r eq "" or $_r eq "SCALAR" or $_r =~ /^(?:GLOB|FileHandle|IO::)/) |
|
162
|
2 |
2 |
if (defined $_file and ref $_file eq '' and $_file ne '') { } |
|
|
2 |
0 |
elsif (ref $_file eq 'SCALAR' or ref($_file) =~ /^(?:GLOB|FileHandle|IO::)/) { } |
|
163
|
0 |
2 |
unless -e $_file |
|
164
|
0 |
2 |
unless -r $_file |
|
165
|
0 |
2 |
unless -f $_file |
|
175
|
4 |
0 |
if (defined $_pos) |
|
190
|
0 |
2 |
if defined $_[0] and $_[0] eq "MCE::Flow" |
|
192
|
2 |
0 |
ref $_[0] eq 'HASH' ? : |
|
195
|
2 |
0 |
if (defined(my $_p = $_params->{$_pid})) { } |
|
196
|
0 |
2 |
if exists $_p->{'sequence'} |
|
197
|
0 |
2 |
if exists $_p->{'input_data'} |
|
198
|
0 |
2 |
if exists $_p->{'_file'} |
|
207
|
0 |
2 |
if ($_r eq "" or $_r =~ /^Math::/ or $_r eq "HASH" or $_r eq "ARRAY") |
|
210
|
2 |
0 |
if ($_r eq '' or $_r =~ /^Math::/) { } |
|
|
0 |
0 |
elsif ($_r eq 'HASH') { } |
|
|
0 |
0 |
elsif ($_r eq 'ARRAY') { } |
|
230
|
0 |
2 |
unless exists $_params->{$_pid}{'sequence'} |
|
231
|
0 |
2 |
unless defined $_begin |
|
233
|
0 |
2 |
unless defined $_end |
|
238
|
2 |
0 |
if (defined $_pos) |
|
253
|
0 |
74 |
if defined $_[0] and $_[0] eq "MCE::Flow" |
|
255
|
6 |
68 |
caller() eq 'MCE::Flow' ? : |
|
258
|
48 |
26 |
if (ref $_[0] eq "HASH") |
|
259
|
9 |
39 |
unless defined $_params->{$_pid} |
|
274
|
94 |
0 |
if (defined(my $_p = $_params->{$_pid})) |
|
276
|
28 |
66 |
ref $_p->{'task_name'} eq 'ARRAY' ? : |
|
278
|
0 |
94 |
ref $_p->{'use_threads'} eq 'ARRAY' ? : |
|
280
|
40 |
54 |
ref $_p->{'max_workers'} eq 'ARRAY' ? : |
|
285
|
76 |
18 |
if not defined $_prev_c->{$_pid}[$_pos] or $_prev_c->{$_pid}[$_pos] != $_code[$_pos] |
|
288
|
12 |
82 |
if $_prev_n->{$_pid}[$_pos] ne $_name[$_pos] |
|
289
|
0 |
94 |
if $_prev_t->{$_pid}[$_pos] ne $_thrs[$_pos] |
|
290
|
24 |
70 |
if $_prev_w->{$_pid}[$_pos] ne $_wrks[$_pos] |
|
300
|
0 |
74 |
if (defined $_prev_c->{$_pid}[$_pos]) |
|
309
|
0 |
74 |
unless scalar @_code |
|
316
|
4 |
70 |
if (@_ == 1 and $_r =~ /^(?:ARRAY|HASH|SCALAR|GLOB|FileHandle|IO::)/) |
|
320
|
74 |
0 |
if (defined(my $_p = $_params->{$_pid})) |
|
322
|
54 |
20 |
if exists $_p->{'max_workers'} and ref $_p->{'max_workers'} ne "ARRAY" |
|
324
|
10 |
64 |
if defined $_input_data or scalar @_ |
|
325
|
0 |
74 |
if exists $_p->{'user_func'} |
|
326
|
0 |
74 |
if exists $_p->{'user_tasks'} |
|
329
|
20 |
54 |
if (@_code > 1 and $_max_workers > 1) |
|
338
|
74 |
0 |
if (defined(my $_p = $_params->{$_pid})) |
|
339
|
4 |
70 |
if (exists $_p->{'_file'}) { } |
|
342
|
0 |
70 |
if exists $_p->{'input_data'} |
|
350
|
64 |
10 |
if ($_init_mce) { } |
|
351
|
0 |
64 |
if defined $_MCE->{$_pid} |
|
363
|
64 |
0 |
if (defined(my $_p = $_params->{$_pid})) |
|
367
|
12 |
102 |
if $_ eq "max_workers" and ref $_p->{'max_workers'} eq "ARRAY" |
|
368
|
6 |
96 |
if $_ eq "task_name" and ref $_p->{'task_name'} eq "ARRAY" |
|
369
|
0 |
96 |
if $_ eq "use_threads" and ref $_p->{'use_threads'} eq "ARRAY" |
|
371
|
0 |
96 |
if $_ eq "chunk_size" |
|
372
|
0 |
96 |
if $_ eq "input_data" |
|
373
|
0 |
96 |
if $_ eq "sequence_run" |
|
376
|
0 |
96 |
unless exists $MCE::_valid_fields_new{$_} |
|
384
|
0 |
320 |
if exists $_def->{$_pkg}{uc $_k} and not exists $_opts{$_k} |
|
392
|
10 |
0 |
if (defined(my $_p = $_params->{$_pid})) |
|
398
|
10 |
150 |
if exists $_p->{$_k} |
|
405
|
31 |
43 |
if defined $_wa |
|
407
|
8 |
66 |
if (defined $_input_data) { } |
|
|
6 |
60 |
elsif (scalar @_) { } |
|
417
|
2 |
58 |
if (defined $_params->{$_pid} and exists $_params->{$_pid}{'sequence'}) { } |
|
422
|
2 |
0 |
if (exists $_params->{$_pid}{'sequence_run'}) |
|
435
|
18 |
27 |
if defined $_wa |
|
437
|
18 |
27 |
defined $_wa ? : |