line |
true |
false |
branch |
28
|
0 |
0 |
if $INC{'threads.pm'} |
48
|
4 |
0 |
unless ($_pkg =~ /^MCE::/) |
59
|
0 |
0 |
if $_arg eq "max_workers" |
60
|
0 |
0 |
if $_arg eq "chunk_size" |
61
|
0 |
0 |
if $_arg eq "tmp_dir" |
62
|
0 |
0 |
if $_arg eq "freeze" |
63
|
0 |
0 |
if $_arg eq "thaw" |
64
|
0 |
0 |
if $_arg eq "init_relay" |
65
|
0 |
0 |
if $_arg eq "use_threads" |
68
|
0 |
0 |
if ($_arg eq "sereal") |
69
|
0 |
0 |
if (shift() eq 0) |
84
|
0 |
4 |
unless $_p->{'CHUNK_SIZE'} eq "auto" |
115
|
3 |
0 |
if defined $_[0] and $_[0] eq "MCE::Map" |
118
|
0 |
3 |
ref $_[0] eq 'HASH' ? : |
121
|
0 |
3 |
if ref $_params->{$_pkg}{'input_data'} eq "HASH" |
130
|
7 |
0 |
if defined $_[0] and $_[0] eq "MCE::Map" |
131
|
6 |
1 |
defined $_[0] ? : |
133
|
4 |
3 |
if ($_pkg eq 'MCE') { } |
|
1 |
2 |
elsif ($_MCE->{$_pkg} and $_MCE->{$_pkg}{'_init_pid'} eq "$$.$_tid") { } |
137
|
1 |
0 |
if $_MCE->{$_pkg}{'_spawned'} |
157
|
0 |
2 |
if defined $_[0] and $_[0] eq "MCE::Map" |
162
|
2 |
0 |
if (defined(my $_p = $_params->{$_pid})) { } |
163
|
0 |
2 |
if exists $_p->{'input_data'} |
164
|
0 |
2 |
if exists $_p->{'sequence'} |
170
|
1 |
1 |
if (defined $_file and ref $_file eq '' and $_file ne '') { } |
|
1 |
0 |
elsif (ref $_file eq 'SCALAR' or ref($_file) =~ /^(?:GLOB|FileHandle|IO::)/) { } |
171
|
0 |
1 |
unless -e $_file |
172
|
0 |
1 |
unless -r $_file |
173
|
0 |
1 |
unless -f $_file |
196
|
0 |
1 |
if defined $_[0] and $_[0] eq "MCE::Map" |
201
|
1 |
0 |
if (defined(my $_p = $_params->{$_pid})) { } |
202
|
0 |
1 |
if exists $_p->{'input_data'} |
203
|
0 |
1 |
if exists $_p->{'_file'} |
211
|
0 |
1 |
if (ref $_[0] eq 'HASH') { } |
|
0 |
1 |
elsif (ref $_[0] eq 'ARRAY') { } |
|
1 |
0 |
elsif (ref $_[0] eq '' or ref($_[0]) =~ /^Math::/) { } |
216
|
0 |
0 |
if (@{$_[0];} > 3 and $_[0][3] =~ /\d$/) { } |
226
|
0 |
1 |
if (@_ > 3 and $_[3] =~ /\d$/) { } |
239
|
0 |
1 |
unless defined $_begin |
241
|
0 |
1 |
unless defined $_end |
259
|
0 |
7 |
if defined $_[0] and $_[0] eq "MCE::Map" |
262
|
3 |
4 |
caller() eq 'MCE::Map' ? : |
268
|
1 |
6 |
if (@_ == 1 and $_r =~ /^(?:ARRAY|HASH|SCALAR|CODE|GLOB|FileHandle|IO::)/) |
269
|
0 |
1 |
if $_r eq "HASH" |
274
|
7 |
0 |
if (defined(my $_p = $_params->{$_pid})) |
276
|
7 |
0 |
if exists $_p->{'max_workers'} |
278
|
4 |
3 |
if defined $_input_data or scalar @_ |
279
|
0 |
7 |
if exists $_p->{'user_func'} |
280
|
0 |
7 |
if exists $_p->{'user_tasks'} |
281
|
0 |
7 |
if exists $_p->{'use_slurpio'} |
282
|
0 |
7 |
if exists $_p->{'bounds_only'} |
283
|
0 |
7 |
if exists $_p->{'gather'} |
290
|
0 |
7 |
defined $_p->{'init_relay'} || defined $_def->{$_pkg}{'INIT_RELAY'} ? : |
295
|
7 |
0 |
if (defined(my $_p = $_params->{$_pid})) |
296
|
2 |
5 |
if (exists $_p->{'_file'}) { } |
299
|
0 |
5 |
if exists $_p->{'input_data'} |
307
|
3 |
4 |
if (not defined $_prev_c->{$_pid} or $_prev_c->{$_pid} != $_code) |
308
|
0 |
3 |
if defined $_MCE->{$_pid} |
318
|
37 |
0 |
if ($_wantarray) { } |
321
|
1 |
36 |
if (ref $_chunk_ref eq 'SCALAR') { } |
322
|
0 |
1 |
if defined $_mce->{'RS'} |
330
|
27 |
9 |
if (ref $_chunk_ref) { } |
342
|
0 |
0 |
if (ref $_chunk_ref eq 'SCALAR') { } |
343
|
0 |
0 |
if defined $_mce->{'RS'} |
351
|
0 |
0 |
if (ref $_chunk_ref) { } |
358
|
0 |
0 |
if defined $_wantarray |
363
|
3 |
0 |
if (defined(my $_p = $_params->{$_pid})) |
365
|
0 |
3 |
if $_k eq "sequence_run" |
366
|
0 |
3 |
if $_k eq "input_data" |
367
|
0 |
3 |
if $_k eq "chunk_size" |
370
|
0 |
3 |
unless exists $MCE::_valid_fields_new{$_k} |
378
|
0 |
15 |
if exists $_def->{$_pkg}{uc $_k} and not exists $_opts{$_k} |
388
|
1 |
6 |
$_chunk_size > &MCE::MAX_RECS_SIZE ? : |
392
|
7 |
0 |
$_wantarray ? : |
394
|
3 |
4 |
if (defined $_input_data) { } |
|
3 |
1 |
elsif (scalar @_) { } |
404
|
1 |
0 |
if (defined $_params->{$_pid} and exists $_params->{$_pid}{'sequence'}) |
409
|
1 |
0 |
if (exists $_params->{$_pid}{'sequence_run'}) |
419
|
5 |
0 |
if ($_wantarray) { } |
|
0 |
0 |
elsif (defined $_wantarray) { } |