| line |
true |
false |
branch |
|
22
|
0 |
0 |
if $INC{'threads.pm'}
|
|
121
|
2 |
5 |
do {
|
|
|
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
|