| line |
true |
false |
branch |
|
22
|
0 |
0 |
if $INC{'threads.pm'} |
|
121
|
2 |
5 |
do {
wantarray
} ? : |
|
|
7 |
126 |
defined wantarray ? : |
|
129
|
0 |
133 |
if defined $\ |
|
133
|
2 |
131 |
if (not @{$_aref;}) { } |
|
134
|
0 |
2 |
if $_lock_chn |
|
142
|
0 |
131 |
if $_lock_chn |
|
149
|
7 |
126 |
if ($_wa) |
|
150
|
0 |
7 |
if $/ ne $MCE::LF |
|
154
|
0 |
7 |
if $_lock_chn |
|
158
|
5 |
2 |
$_wa != 1 ? : |
|
161
|
0 |
126 |
if $_lock_chn |
|
170
|
0 |
357 |
unless scalar @{$_aref;} |
|
176
|
0 |
357 |
if defined $\ |
|
178
|
0 |
357 |
if $_lock_chn |
|
181
|
0 |
357 |
if $_lock_chn |
|
194
|
0 |
0 |
if (scalar @_ > 1) { } |
|
|
0 |
0 |
elsif (my $_ref = ref $_[0]) { } |
|
198
|
0 |
0 |
if ($_ref eq 'SCALAR') { } |
|
|
0 |
0 |
elsif ($_ref eq 'ARRAY') { } |
|
|
0 |
0 |
elsif ($_ref eq 'HASH') { } |
|
224
|
0 |
0 |
if ($self->{'_wid'} > 0) { } |
|
225
|
0 |
0 |
if ($_fd == 1) { } |
|
|
0 |
0 |
elsif ($_fd == 2) { } |
|
238
|
0 |
0 |
if defined $\ |
|
259
|
0 |
65 |
if ($_lock_chn) |
|
262
|
0 |
0 |
$_tid ? : |
|
264
|
0 |
0 |
if $_is_MSWin32 |
|
266
|
0 |
0 |
unless $_DAT_LOCK->{$_pid} |
|
269
|
0 |
0 |
$_tid ? : |
|
271
|
0 |
0 |
if $_DAT_LOCK->{$_pid} |
|
277
|
65 |
0 |
if defined fileno STDERR |
|
278
|
65 |
0 |
if defined fileno STDOUT |
|
305
|
0 |
246 |
if ($self->{'progress'} and $self->{'_task_id'} == 0) |
|
307
|
0 |
0 |
if (ref $_chunk eq 'SCALAR') { } |
|
|
0 |
0 |
elsif ($self->{'sequence'} and $self->{'bounds_only'}) { } |
|
|
0 |
0 |
elsif ($self->{'input_data'}) { } |
|
313
|
0 |
0 |
ref $_seq eq 'ARRAY' ? : |
|
323
|
0 |
0 |
ref $_chunk eq 'ARRAY' ? : |
|
327
|
0 |
246 |
if ($self->{'max_retries'}) |
|
331
|
0 |
0 |
if ($self->{'loop_timeout'} and $self->{'_task_id'} == 0 and defined $self->{'init_relay'} and not $self->{'_is_thread'} and not $_is_MSWin32) |
|
334
|
0 |
0 |
if defined $\ |
|
336
|
0 |
0 |
if $_lock_chn |
|
339
|
0 |
0 |
if $_lock_chn |
|
344
|
0 |
246 |
if ($self->{'progress'} and $self->{'_task_id'} == 0) |
|
345
|
0 |
0 |
if defined $\ |
|
347
|
0 |
0 |
if $_lock_chn |
|
350
|
0 |
0 |
if $_lock_chn |
|
376
|
0 |
163 |
if (defined $mce and $id eq "$$.$_tid") |
|
414
|
208 |
444 |
if (defined $$_params_ref{"_$_p"}) |
|
416
|
208 |
0 |
unless defined $self->{'_task'}{$_p} |
|
428
|
0 |
163 |
if (defined $self->{'user_begin'}) |
|
431
|
0 |
0 |
if ($_task_id == 0 and defined $self->{'init_relay'} and not $self->{'_retry'}) |
|
437
|
0 |
163 |
if ($self->{'_retry'}) |
|
444
|
14 |
149 |
if ($_run_mode eq 'sequence') { } |
|
|
0 |
149 |
elsif (defined $self->{'_task'}{'sequence'}) { } |
|
|
36 |
113 |
elsif ($_run_mode eq 'array') { } |
|
|
14 |
99 |
elsif ($_run_mode eq 'glob') { } |
|
|
3 |
96 |
elsif ($_run_mode eq 'hash') { } |
|
|
0 |
96 |
elsif ($_run_mode eq 'iterator') { } |
|
|
14 |
82 |
elsif ($_run_mode eq 'file') { } |
|
|
0 |
82 |
elsif ($_run_mode eq 'memory') { } |
|
|
82 |
0 |
elsif (defined $self->{'user_func'}) { } |
|
446
|
12 |
2 |
unless $INC{'MCE/Core/Input/Sequence.pm'} |
|
451
|
0 |
0 |
unless $INC{'MCE/Core/Input/Generator.pm'} |
|
456
|
0 |
36 |
unless $INC{'MCE/Core/Input/Request.pm'} |
|
461
|
0 |
14 |
unless $INC{'MCE/Core/Input/Request.pm'} |
|
466
|
0 |
3 |
unless $INC{'MCE/Core/Input/Request.pm'} |
|
471
|
0 |
0 |
unless $INC{'MCE/Core/Input/Iterator.pm'} |
|
476
|
12 |
2 |
unless $INC{'MCE/Core/Input/Handle.pm'} |
|
481
|
0 |
0 |
unless $INC{'MCE/Core/Input/Handle.pm'} |
|
485
|
0 |
82 |
if ($self->{'max_retries'}) |
|
492
|
91 |
72 |
if defined $self->{'_next_jmp'} |
|
493
|
91 |
72 |
if defined $self->{'_last_jmp'} |
|
494
|
0 |
163 |
if defined $self->{'user_data'} |
|
497
|
0 |
163 |
if (defined $self->{'user_end'}) |
|
499
|
0 |
0 |
if $_task_id == 0 and defined $self->{'init_relay'} |
|
509
|
0 |
163 |
if $INC{'MCE/Child.pm'} |
|
510
|
0 |
163 |
if $INC{'MCE/Hobo.pm'} |
|
513
|
0 |
163 |
if defined $\ |
|
515
|
0 |
163 |
if $_lock_chn |
|
520
|
0 |
163 |
if $_lock_chn |
|
522
|
0 |
163 |
if ($^O eq "MSWin32") |
|
547
|
0 |
65 |
if ($^O eq "MSWin32") |
|
558
|
65 |
163 |
if $_response eq "_exit\n" |
|
561
|
0 |
163 |
if ($_response eq "_data\n") { } |
|
|
163 |
0 |
elsif ($_response =~ /\d+/) { } |
|
567
|
0 |
0 |
if defined $_job_delay and $_job_delay > 0 |
|
584
|
0 |
163 |
if $_response eq "_data\n" |
|
591
|
0 |
163 |
if defined $_job_delay and $_job_delay > 0 |
|
617
|
27 |
38 |
if (exists $self->{'input_data'}) |
|
619
|
27 |
0 |
if $_ref and $_ref ne "SCALAR" |
|
622
|
46 |
19 |
defined $_task_id ? : |
|
623
|
46 |
19 |
defined $_task_wid ? : |
|
629
|
46 |
19 |
defined $_task->{'use_threads'} ? : |
|
631
|
0 |
65 |
if ($INC{'threads.pm'} and $_use_threads) { } |
|
642
|
0 |
0 |
if (not defined $^S or $^S) |
|
643
|
0 |
0 |
if ($INC{'threads.pm'} and $_tid != 0 or $ENV{'PERL_IPERL_RUNNING'} or $_running_inside_eval) { } |
|
649
|
0 |
0 |
if ($_t =~ /^(?:[^\n]+\n){1,7}\teval / or $_t =~ /\n\teval [^\n]+\n\t(?:eval|Try)/) |
|
662
|
0 |
0 |
defined $_[0] ? : |
|
670
|
46 |
19 |
if $_task->{'max_workers'} |
|
671
|
0 |
65 |
if $_task->{'chunk_size'} |
|
672
|
8 |
57 |
if $_task->{'gather'} |
|
673
|
0 |
65 |
if $_task->{'sequence'} |
|
674
|
0 |
65 |
if $_task->{'bounds_only'} |
|
675
|
16 |
49 |
if $_task->{'task_name'} |
|
676
|
0 |
65 |
if $_task->{'user_args'} |
|
677
|
0 |
65 |
if $_task->{'user_begin'} |
|
678
|
46 |
19 |
if $_task->{'user_func'} |
|
679
|
0 |
65 |
if $_task->{'user_end'} |
|
684
|
0 |
65 |
if (defined $_params and exists $_params->{'_chn'}) { } |
|
692
|
0 |
65 |
if $self->{'_lock_chn'} |
|
703
|
0 |
65 |
if not $_use_threads and $INC{'MCE/Shared.pm'} |
|
711
|
0 |
65 |
if defined $_params |