| 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"
|
|
116
|
0 |
0 |
if (defined $_pkg and $_id eq "${$}.$_tid")
|
|
126
|
3 |
0 |
if defined $_[0] and $_[0] eq "MCE::Map"
|
|
129
|
0 |
3 |
ref $_[0] eq 'HASH' ? :
|
|
132
|
0 |
3 |
if ref $_params->{$_pkg}{'input_data'} eq "HASH"
|
|
137
|
0 |
3 |
defined wantarray ? :
|
|
143
|
7 |
0 |
if defined $_[0] and $_[0] eq "MCE::Map"
|
|
144
|
6 |
1 |
defined $_[0] ? :
|
|
146
|
4 |
3 |
if ($_pkg eq 'MCE') { }
|
|
|
1 |
2 |
elsif ($_MCE->{$_pkg} and $_MCE->{$_pkg}{'_init_pid'} eq "${$}.$_tid") { }
|
|
150
|
1 |
0 |
if $_MCE->{$_pkg}{'_spawned'}
|
|
170
|
0 |
2 |
if defined $_[0] and $_[0] eq "MCE::Map"
|
|
175
|
2 |
0 |
if (defined(my $_p = $_params->{$_pid})) { }
|
|
176
|
0 |
2 |
if exists $_p->{'input_data'}
|
|
177
|
0 |
2 |
if exists $_p->{'sequence'}
|
|
183
|
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::)/) { }
|
|
184
|
0 |
1 |
unless -e $_file
|
|
185
|
0 |
1 |
unless -r $_file
|
|
186
|
0 |
1 |
unless -f $_file
|
|
209
|
0 |
1 |
if defined $_[0] and $_[0] eq "MCE::Map"
|
|
214
|
1 |
0 |
if (defined(my $_p = $_params->{$_pid})) { }
|
|
215
|
0 |
1 |
if exists $_p->{'input_data'}
|
|
216
|
0 |
1 |
if exists $_p->{'_file'}
|
|
224
|
0 |
1 |
if (ref $_[0] eq 'HASH') { }
|
|
|
0 |
1 |
elsif (ref $_[0] eq 'ARRAY') { }
|
|
|
1 |
0 |
elsif (ref $_[0] eq '' or ref($_[0]) =~ /^Math::/) { }
|
|
229
|
0 |
0 |
if (@{$_[0];} > 3 and $_[0][3] =~ /\d$/) { }
|
|
239
|
0 |
1 |
if (@_ > 3 and $_[3] =~ /\d$/) { }
|
|
252
|
0 |
1 |
unless defined $_begin
|
|
254
|
0 |
1 |
unless defined $_end
|
|
272
|
0 |
7 |
if defined $_[0] and $_[0] eq "MCE::Map"
|
|
275
|
3 |
4 |
caller() eq 'MCE::Map' ? :
|
|
281
|
1 |
6 |
if (@_ == 1 and $_r =~ /^(?:ARRAY|HASH|SCALAR|CODE|GLOB|FileHandle|IO::|Iterator::)/)
|
|
282
|
0 |
1 |
if $_r eq "HASH"
|
|
287
|
7 |
0 |
if (defined(my $_p = $_params->{$_pid}))
|
|
289
|
7 |
0 |
if exists $_p->{'max_workers'}
|
|
291
|
4 |
3 |
if defined $_input_data or scalar @_
|
|
292
|
0 |
7 |
if exists $_p->{'user_func'}
|
|
293
|
0 |
7 |
if exists $_p->{'user_tasks'}
|
|
294
|
0 |
7 |
if exists $_p->{'use_slurpio'}
|
|
295
|
0 |
7 |
if exists $_p->{'bounds_only'}
|
|
296
|
0 |
7 |
if exists $_p->{'gather'}
|
|
303
|
0 |
7 |
defined $_p->{'init_relay'} || defined $_def->{$_pkg}{'INIT_RELAY'} ? :
|
|
308
|
7 |
0 |
if (defined(my $_p = $_params->{$_pid}))
|
|
309
|
2 |
5 |
if (exists $_p->{'_file'}) { }
|
|
312
|
0 |
5 |
if exists $_p->{'input_data'}
|
|
320
|
3 |
4 |
if (not defined $_prev_c->{$_pid} or $_prev_c->{$_pid} != $_code)
|
|
321
|
0 |
3 |
if defined $_MCE->{$_pid}
|
|
331
|
37 |
0 |
if ($_wantarray) { }
|
|
334
|
1 |
36 |
if (ref $_chunk_ref eq 'SCALAR') { }
|
|
335
|
0 |
1 |
if defined $_mce->{'RS'}
|
|
343
|
27 |
9 |
if (ref $_chunk_ref) { }
|
|
355
|
0 |
0 |
if (ref $_chunk_ref eq 'SCALAR') { }
|
|
356
|
0 |
0 |
if defined $_mce->{'RS'}
|
|
364
|
0 |
0 |
if (ref $_chunk_ref) { }
|
|
371
|
0 |
0 |
if defined $_wantarray
|
|
376
|
3 |
0 |
if (defined(my $_p = $_params->{$_pid}))
|
|
378
|
0 |
3 |
if $_k eq "sequence_run"
|
|
379
|
0 |
3 |
if $_k eq "input_data"
|
|
380
|
0 |
3 |
if $_k eq "chunk_size"
|
|
383
|
0 |
3 |
unless exists $MCE::_valid_fields_new{$_k}
|
|
391
|
0 |
15 |
if exists $_def->{$_pkg}{uc $_k} and not exists $_opts{$_k}
|
|
401
|
1 |
6 |
$_chunk_size > &MCE::MAX_RECS_SIZE ? :
|
|
405
|
7 |
0 |
$_wantarray ? :
|
|
407
|
3 |
4 |
if (defined $_input_data) { }
|
|
|
3 |
1 |
elsif (scalar @_) { }
|
|
417
|
1 |
0 |
if (defined $_params->{$_pid} and exists $_params->{$_pid}{'sequence'})
|
|
422
|
1 |
0 |
if (exists $_params->{$_pid}{'sequence_run'})
|
|
432
|
5 |
0 |
if ($_wantarray) { }
|
|
|
0 |
0 |
elsif (defined $_wantarray) { }
|