| line |
true |
false |
branch |
|
27
|
0 |
85 |
if ($^O eq 'MSWin32' and not $INC{'threads.pm'}) { } |
|
|
0 |
170 |
elsif ($INC{'threads.pm'} and not $INC{'threads/shared.pm'}) { } |
|
34
|
0 |
85 |
$INC{'threads.pm'} ? : |
|
35
|
0 |
85 |
$_has_threads ? : |
|
38
|
85 |
0 |
if ($] ge "5.008008" and not $INC{'PDL.pm'}) |
|
40
|
85 |
0 |
unless ($@) |
|
43
|
85 |
0 |
if ($_encoder_ver - $_decoder_ver == 0) |
|
50
|
0 |
85 |
if (not defined $_freeze) |
|
112
|
0 |
85 |
$^O eq 'MSWin32' ? : |
|
113
|
0 |
85 |
$^O =~ /mswin|mingw|msys|cygwin/i ? : |
|
120
|
3 |
96 |
unless ref $self |
|
126
|
62 |
1 |
unless ref $self |
|
132
|
166 |
42 |
unless ref $self |
|
163
|
0 |
0 |
if $_arg eq "max_workers" |
|
164
|
0 |
0 |
if $_arg eq "chunk_size" |
|
165
|
0 |
0 |
if $_arg eq "tmp_dir" |
|
166
|
0 |
0 |
if $_arg eq "freeze" |
|
167
|
0 |
0 |
if $_arg eq "thaw" |
|
168
|
0 |
0 |
if $_arg eq "init_relay" |
|
169
|
0 |
0 |
if $_arg eq "use_threads" |
|
171
|
0 |
0 |
if ($_arg eq "export_const" or $_arg eq "const") |
|
172
|
0 |
0 |
if (shift() eq 1) |
|
182
|
0 |
0 |
if ($_arg eq "sereal") |
|
183
|
0 |
0 |
if (shift() eq 0) |
|
194
|
13 |
85 |
if $_imported++ |
|
265
|
0 |
0 |
if $INC{'threads.pm'} |
|
269
|
0 |
0 |
if $_is_MSWin32 and $MCE::Signal::KILLED |
|
273
|
0 |
0 |
if $_[0] and $_[0]{'_spawned'} and $_[0]{'_init_pid'} eq "$$.$_tid" and not $MCE::Signal::KILLED |
|
280
|
65 |
20 |
unless defined $MCE |
|
282
|
0 |
20 |
$MCE::MCE->{'_is_thread'} ? : |
|
283
|
0 |
20 |
if exists $MCE::MCE->{'_wuf'} and $MCE::MCE->{'_pid'} eq $_pid |
|
289
|
37 |
48 |
if $INC{'MCE/Flow.pm'} |
|
290
|
4 |
81 |
if $INC{'MCE/Grep.pm'} |
|
291
|
5 |
80 |
if $INC{'MCE/Loop.pm'} |
|
292
|
4 |
81 |
if $INC{'MCE/Map.pm'} |
|
293
|
12 |
73 |
if $INC{'MCE/Step.pm'} |
|
294
|
10 |
75 |
if $INC{'MCE/Stream.pm'} |
|
311
|
45 |
0 |
unless (exists $_plugin_list{$_ext_module}) |
|
319
|
45 |
0 |
if (ref $_ext_output_function eq "HASH") |
|
322
|
545 |
0 |
unless exists $_plugin_function{$_p} |
|
326
|
45 |
0 |
if ref $_ext_output_loop_begin eq "CODE" |
|
328
|
45 |
0 |
if ref $_ext_output_loop_end eq "CODE" |
|
330
|
35 |
10 |
if ref $_ext_worker_init eq "CODE" |
|
359
|
0 |
0 |
if ("MCE"->wid == 0 or not $^S) |
|
376
|
103 |
216 |
exists $self{'pkg'} ? : |
|
390
|
0 |
319 |
if exists $_def->{$_pkg}{'INIT_RELAY'} |
|
393
|
0 |
319 |
if exists $_def->{$_pkg}{'USE_THREADS'} |
|
395
|
85 |
234 |
if (exists $self{'_module_instance'}) |
|
408
|
0 |
1637 |
unless exists $_valid_fields_new{$_p} |
|
413
|
0 |
234 |
if (defined $self{'use_threads'}) { } |
|
414
|
0 |
0 |
if (not $_has_threads and $self{'use_threads'}) |
|
424
|
0 |
234 |
$_has_threads ? : |
|
427
|
234 |
0 |
unless (exists $self{'posix_exit'}) |
|
433
|
0 |
234 |
if $^S or $_tid or $INC{'Mojo/IOLoop.pm'} or $INC{'Coro.pm'} or $INC{'LWP/UserAgent.pm'} or $INC{'stfl.pm'} or $INC{'Curses.pm'} or $INC{'CGI.pm'} or $INC{'FCGI.pm'} or $INC{'Tk.pm'} or $INC{'Wx.pm'} or $INC{'Win32/GUI.pm'} or $INC{'Gearman/Util.pm'} or $INC{'Gearman/XS.pm'} |
|
440
|
42 |
192 |
if (defined $self{'tmp_dir'}) |
|
442
|
0 |
42 |
unless -d $self{'tmp_dir'} |
|
444
|
0 |
42 |
unless -w $self{'tmp_dir'} |
|
447
|
103 |
131 |
if (defined $self{'user_tasks'}) |
|
449
|
0 |
103 |
unless ref $self{'user_tasks'} eq "ARRAY" |
|
453
|
0 |
103 |
if $self{'user_tasks'}[0]{'init_relay'} |
|
458
|
0 |
528 |
unless exists $_valid_fields_task{$_p} |
|
460
|
0 |
159 |
unless scalar keys %{$_task;} |
|
463
|
59 |
100 |
unless defined $_task->{'max_workers'} |
|
465
|
159 |
0 |
unless defined $_task->{'use_threads'} |
|
486
|
0 |
234 |
if $_is_MSWin32 |
|
489
|
0 |
234 |
ref $self{'input_data'} eq 'SCALAR' ? : |
|
492
|
0 |
234 |
$INC{'MCE/Channel.pm'} ? : |
|
|
234 |
0 |
"$$.$_tid" eq $_oid ? : |
|
497
|
103 |
131 |
if (defined $self{'user_tasks'}) { } |
|
505
|
186 |
48 |
$_total_workers < $_data_channels ? : |
|
508
|
42 |
192 |
$_total_workers > $self{'_data_channels'} ? : |
|
509
|
0 |
234 |
if $INC{'MCE/Child.pm'} or $INC{'MCE/Hobo.pm'} |
|
511
|
234 |
0 |
if $MCE::MCE->{'_wid'} == 0 |
|
523
|
0 |
126 |
unless ref $self |
|
528
|
0 |
126 |
if $self->{'_wid'} |
|
531
|
0 |
126 |
if $self->{'_spawned'} or exists $self->{'_module_instance'} |
|
533
|
0 |
126 |
if $_is_MSWin32 |
|
534
|
0 |
126 |
if $_has_threads and $_is_winenv |
|
536
|
0 |
0 |
if $_tid and $MCE::_GMUTEX |
|
537
|
0 |
126 |
if $_tid |
|
541
|
0 |
126 |
if ($INC{'PDL.pm'}) |
|
543
|
0 |
0 |
unless $INC{'PDL/IO/Storable.pm'} |
|
549
|
0 |
126 |
if ($INC{'LWP/UserAgent.pm'} and not $INC{'Net/HTTP.pm'}) |
|
554
|
0 |
126 |
if $INC{'MCE/Shared.pm'} |
|
557
|
0 |
126 |
if (defined $self->{'sequence'}) { } |
|
|
45 |
81 |
elsif (defined $self->{'input_data'}) { } |
|
559
|
0 |
0 |
unless $INC{'MCE/Core/Input/Sequence.pm'} |
|
563
|
45 |
0 |
if ($_ref =~ /^(?:ARRAY|HASH|GLOB|FileHandle|IO::)/) { } |
|
|
0 |
0 |
elsif ($_ref eq 'CODE') { } |
|
565
|
34 |
11 |
unless $INC{'MCE/Core/Input/Request.pm'} |
|
569
|
0 |
0 |
unless $INC{'MCE/Core/Input/Iterator.pm'} |
|
573
|
0 |
0 |
unless $INC{'MCE/Core/Input/Handle.pm'} |
|
583
|
126 |
0 |
if (not defined $TOP_HDLR && ($TOP_HDLR->{'_mgr_live'} || $TOP_HDLR->{'_wid'})) { } |
|
|
0 |
0 |
elsif (&refaddr($self) != &refaddr($TOP_HDLR)) { } |
|
585
|
0 |
0 |
if ($_is_MSWin32 and defined $TOP_HDLR and $TOP_HDLR->{'_spawned'}) |
|
592
|
0 |
0 |
if $self->{'_data_channels'} > 4 |
|
593
|
0 |
0 |
if $self->{'_init_total_workers'} > 4 |
|
596
|
0 |
0 |
if ($_is_MSWin32 and $ENV{'PERL_MCE_IPC'} ne "win32") |
|
615
|
0 |
126 |
if ($self->{'_lock_chn'}) |
|
632
|
0 |
126 |
if $^O ne "aix" and $^O ne "linux" |
|
635
|
24 |
102 |
if (defined $self->{'init_relay'}) |
|
636
|
9 |
15 |
unless ($INC{'MCE/Relay.pm'}) |
|
651
|
0 |
126 |
if ($self->{'loop_timeout'} and not $_is_MSWin32) |
|
655
|
126 |
0 |
unless $_is_MSWin32 |
|
657
|
35 |
91 |
if (not defined $self->{'user_tasks'}) { } |
|
660
|
0 |
35 |
if (defined $_use_threads and $_use_threads == 1) { } |
|
687
|
0 |
114 |
if (defined $_tsk_use_threads and $_tsk_use_threads == 1) { } |
|
703
|
0 |
56 |
if (defined $_tsk_use_threads and $_tsk_use_threads == 1) { } |
|
739
|
61 |
0 |
if $MCE::MCE->{'_wid'} == 0 |
|
741
|
0 |
0 |
if $_tid and $MCE::_GMUTEX |
|
753
|
0 |
106 |
unless ref $self |
|
759
|
6 |
100 |
if (ref $_[0] eq 'HASH' and ref $_[1] eq 'HASH') { } |
|
|
95 |
5 |
elsif (ref $_[0] eq 'HASH') { } |
|
770
|
106 |
0 |
if (defined $_input_data) { } |
|
|
0 |
0 |
elsif (not defined $_params_ref->{'input_data'} || defined $_params_ref->{'sequence'}) { } |
|
786
|
0 |
0 |
unless defined $MCE::MCE->{'init_relay'} |
|
798
|
0 |
0 |
unless ref $self |
|
802
|
0 |
0 |
if ($_fcn eq 'forchunk') { } |
|
|
0 |
0 |
elsif ($_fcn eq 'foreach') { } |
|
|
0 |
0 |
elsif ($_fcn eq 'forseq') { } |
|
803
|
0 |
0 |
unless $INC{'MCE/Candy.pm'} |
|
807
|
0 |
0 |
unless $INC{'MCE/Candy.pm'} |
|
811
|
0 |
0 |
unless $INC{'MCE/Candy.pm'} |
|
817
|
0 |
0 |
if ($_fcn eq 'relay_lock' or $_fcn eq 'relay_recv') { } |
|
|
0 |
0 |
elsif ($_fcn eq 'relay_final') { } |
|
819
|
0 |
0 |
unless defined $MCE::MCE->{'init_relay'} |
|
827
|
0 |
0 |
if ($_fcn eq 'last') { } |
|
|
0 |
0 |
elsif ($_fcn eq 'next') { } |
|
|
0 |
0 |
elsif ($_fcn eq 'pid') { } |
|
|
0 |
0 |
elsif ($_fcn eq 'status') { } |
|
829
|
0 |
0 |
unless $self->{'_wid'} |
|
831
|
0 |
0 |
if defined $self->{'_last_jmp'} |
|
840
|
0 |
0 |
unless $self->{'_wid'} |
|
842
|
0 |
0 |
if defined $self->{'_next_jmp'} |
|
850
|
0 |
0 |
if (defined $self->{'_pid'}) { } |
|
|
0 |
0 |
elsif ($_has_threads and $self->{'use_threads'}) { } |
|
863
|
0 |
0 |
if $self->{'_wid'} |
|
865
|
0 |
0 |
defined $self->{'_wrk_status'} ? : |
|
878
|
0 |
0 |
unless ref $self |
|
883
|
0 |
0 |
if $self->{'_wid'} |
|
896
|
0 |
0 |
defined $_task_id ? : |
|
898
|
0 |
0 |
if defined $_task_id |
|
899
|
0 |
0 |
if defined $_task_id |
|
904
|
0 |
0 |
if (defined $_use_threads and $_use_threads == 1) { } |
|
912
|
0 |
0 |
if (defined $self->{'spawn_delay'} and $self->{'spawn_delay'} > 0) { } |
|
|
0 |
0 |
elsif ($_tid or $_is_MSWin32) { } |
|
928
|
0 |
207 |
unless ref $self |
|
931
|
0 |
207 |
if $self->{'_wid'} |
|
935
|
81 |
126 |
if (ref $_[0] eq 'HASH') { } |
|
936
|
81 |
0 |
defined $_[1] ? : |
|
939
|
106 |
20 |
defined $_[0] ? : |
|
945
|
154 |
53 |
defined $self->{'user_tasks'} ? : |
|
951
|
0 |
207 |
if $self->{'_send_cnt'} |
|
953
|
91 |
0 |
unless (defined $self->{'user_func'} or defined $_params_ref->{'user_func'}) |
|
962
|
187 |
20 |
if (defined $_params_ref and ref $_params_ref eq "HASH") |
|
966
|
154 |
53 |
if ($_has_user_tasks) |
|
968
|
0 |
154 |
if $self->{'user_tasks'}[0]{'input_data'} |
|
970
|
0 |
154 |
if $self->{'user_tasks'}[0]{'use_slurpio'} |
|
972
|
0 |
154 |
if $self->{'user_tasks'}[0]{'parallel_io'} |
|
974
|
0 |
154 |
if $self->{'user_tasks'}[0]{'RS'} |
|
976
|
0 |
207 |
if (ref $self->{'input_data'} eq "SCALAR") |
|
977
|
0 |
0 |
if (&refaddr($self->{'input_data'}) != $self->{'_last_sref'}) |
|
983
|
0 |
207 |
if $_requires_shutdown |
|
990
|
126 |
81 |
unless $self->{'_spawned'} |
|
991
|
0 |
142 |
unless $self->{'_total_workers'} |
|
996
|
142 |
0 |
if $MCE::MCE->{'_wid'} == 0 |
|
1004
|
0 |
142 |
$_has_user_tasks && $self->{'user_tasks'}[0]{'sequence'} ? : |
|
1007
|
18 |
124 |
if (defined $_seq) { } |
|
|
79 |
45 |
elsif (defined $self->{'input_data'}) { } |
|
1009
|
18 |
0 |
ref $_seq eq 'ARRAY' ? : |
|
1012
|
0 |
14 |
if $_has_user_tasks and $self->{'user_tasks'}[0]{'chunk_size'} |
|
1024
|
18 |
0 |
if ($_step > 0) { } |
|
1025
|
18 |
0 |
if $_abort_msg * $_chunk_size * abs($_step) + $_begin <= $_end |
|
1028
|
0 |
0 |
if $_abort_msg * $_chunk_size * abs($_step) + $_end <= $_begin |
|
1037
|
18 |
61 |
if ($_ref eq '') { } |
|
|
40 |
21 |
elsif ($_ref eq 'ARRAY') { } |
|
|
3 |
18 |
elsif ($_ref eq 'HASH') { } |
|
|
18 |
0 |
elsif ($_ref =~ /^(?:GLOB|FileHandle|IO::)/) { } |
|
|
0 |
0 |
elsif ($_ref eq 'CODE') { } |
|
|
0 |
0 |
elsif ($_ref eq 'SCALAR') { } |
|
1044
|
0 |
18 |
if (-s $_input_file == 0) |
|
1045
|
0 |
0 |
if $_auto_shutdown == 1 |
|
1053
|
40 |
0 |
if ref $_input_data->[0] eq "" |
|
1057
|
0 |
40 |
if (@{$_input_data;} == 0) |
|
1058
|
0 |
0 |
if $_auto_shutdown == 1 |
|
1069
|
0 |
3 |
if (scalar keys %{$_input_data;} == 0) |
|
1070
|
0 |
0 |
if $_auto_shutdown == 1 |
|
1094
|
0 |
0 |
if (length ${$self->{'input_data'};} == 0) |
|
1095
|
0 |
0 |
if $_auto_shutdown == 1 |
|
1111
|
0 |
142 |
if ($_send_cnt) { } |
|
1133
|
0 |
142 |
$self->{'progress'} ? : |
|
1138
|
108 |
34 |
if ($_has_user_tasks) |
|
1149
|
201 |
146 |
unless $self->{'_state'}[$_i]{'_task_id'} |
|
1156
|
97 |
45 |
if (defined $_first_msg) |
|
1164
|
282 |
146 |
if (not $_has_user_tasks or exists $_task0_wids{$_wid}) { } |
|
1172
|
0 |
428 |
if defined $_submit_delay and $_submit_delay > 0 |
|
1182
|
142 |
0 |
if ($self->{'_total_running'} > 0) |
|
1187
|
0 |
142 |
if $_is_MSWin32 |
|
1189
|
142 |
0 |
unless ($_send_cnt) |
|
1191
|
0 |
142 |
if ($_is_MSWin32) { } |
|
1210
|
97 |
45 |
if (not $_send_cnt and $_run_mode ne "nodata") |
|
1212
|
97 |
0 |
if defined $self->{'_que_r_sock'} |
|
1218
|
10 |
132 |
if ($_auto_shutdown or $self->{'_total_exited'}) { } |
|
|
0 |
132 |
elsif ($INC{'MCE/Simple.pm'}) { } |
|
|
0 |
132 |
elsif ($^S or $ENV{'PERL_IPERL_RUNNING'}) { } |
|
1225
|
0 |
0 |
unless ($INC{'Mojo/IOLoop.pm'} or $INC{'Win32/GUI.pm'} or $INC{'Gearman/XS.pm'} or $INC{'Gearman/Util.pm'} or $INC{'Tk.pm'} or $INC{'Wx.pm'}) |
|
1233
|
0 |
0 |
if ($_t =~ /^(?:[^\n]+\n){1,7}\teval / or $_t =~ /\n\teval [^\n]+\n\t(?:eval|Try)/ or $_t =~ /\n\tMCE::_dispatch\(\) [^\n]+ thread \d+\n$/ or $_tid and not $self->{'use_threads'}) |
|
1253
|
0 |
0 |
unless ref $self |
|
1256
|
0 |
0 |
if $self->{'_wid'} |
|
1258
|
0 |
0 |
if $self->{'_total_running'} |
|
1261
|
0 |
0 |
if defined $self->{'input_data'} or defined $self->{'sequence'} |
|
1263
|
0 |
0 |
if defined $self->{'user_tasks'} |
|
1267
|
0 |
0 |
if (ref $_[0] eq 'ARRAY' or ref $_[0] eq 'HASH' or ref $_[0] eq 'PDL') { } |
|
1275
|
0 |
0 |
unless defined $self->{'_send_cnt'} |
|
1280
|
0 |
0 |
unless $self->{'_spawned'} |
|
1283
|
0 |
0 |
if $self->{'_send_cnt'} >= $self->{'_task'}[0]{'_total_workers'} |
|
1302
|
0 |
0 |
if defined $_submit_delay and $_submit_delay > 0 |
|
1315
|
0 |
61 |
unless ref $self |
|
1321
|
0 |
61 |
unless $self->{'_spawned'} |
|
1324
|
0 |
61 |
if ($MCE::Signal::KILLED) |
|
1325
|
0 |
0 |
if (defined $self->{'_sess_dir'}) |
|
1327
|
0 |
0 |
if -d $_sess_dir |
|
1335
|
0 |
61 |
if $self->{'_send_cnt'} |
|
1345
|
61 |
0 |
if (defined $TOP_HDLR and &refaddr($self) == &refaddr($TOP_HDLR)) |
|
1351
|
0 |
0 |
if $_has_threads and $_is_winenv and not $_no_lock |
|
1361
|
61 |
0 |
if (@{$self->{'_pids'};} > 0) |
|
1364
|
146 |
61 |
if $_list->[$i] |
|
1367
|
0 |
61 |
if (@{$self->{'_thrs'};} > 0) |
|
1370
|
0 |
0 |
if $_list->[$i] |
|
1389
|
0 |
61 |
if defined $_sess_dir and -d $_sess_dir |
|
1400
|
0 |
61 |
if ($self->{'loop_timeout'}) |
|
1415
|
0 |
0 |
unless ref $self |
|
1417
|
0 |
0 |
unless $self->{'_wid'} |
|
1422
|
0 |
0 |
if $self->{'_task_id'} > 0 |
|
1430
|
0 |
0 |
if defined $\ |
|
1436
|
0 |
0 |
if $_is_MSWin32 |
|
1443
|
0 |
0 |
if $_is_MSWin32 |
|
1450
|
0 |
0 |
unless ref $self |
|
1452
|
0 |
0 |
unless $self->{'_wid'} |
|
1461
|
0 |
0 |
if defined $\ |
|
1462
|
0 |
0 |
if not $/ or $/ ne $MCE::LF |
|
1464
|
0 |
0 |
if $_lock_chn |
|
1468
|
0 |
0 |
if $_lock_chn |
|
1482
|
0 |
0 |
unless ref $self |
|
1488
|
0 |
0 |
if (defined $_abort_msg) |
|
1491
|
0 |
0 |
if ($_abort_msg > 0) |
|
1496
|
0 |
0 |
if ($self->{'_wid'} > 0) |
|
1503
|
0 |
0 |
if $_lock_chn |
|
1505
|
0 |
0 |
if $_lock_chn |
|
1515
|
0 |
0 |
unless ref $self |
|
1517
|
0 |
0 |
defined $_[0] ? : |
|
1518
|
0 |
0 |
defined $_[1] ? : |
|
1519
|
0 |
0 |
defined $_[2] ? : |
|
1524
|
0 |
0 |
unless $self->{'_wid'} |
|
1533
|
0 |
0 |
unless ($self->{'_exiting'}) |
|
1536
|
0 |
0 |
$self->{'_is_thread'} ? : |
|
1540
|
0 |
0 |
if (defined $self->{'init_relay'} and not $self->{'_relayed'} and not $_task_id and exists $self->{'_wuf'} and $self->{'_pid'} eq $_pid) |
|
1543
|
0 |
0 |
unless defined $self->{'_retry_cnt'} |
|
1545
|
0 |
0 |
if (not $_max_retries or ++$self->{'_retry_cnt'} == $_max_retries) |
|
1546
|
0 |
0 |
if $_chunk_id |
|
1551
|
0 |
0 |
if $INC{'MCE/Child.pm'} |
|
1554
|
0 |
0 |
if $INC{'MCE/Hobo.pm'} and "MCE::Hobo"->can("_clear") |
|
1556
|
0 |
0 |
if defined $\ |
|
1560
|
0 |
0 |
if $_lock_chn |
|
1562
|
0 |
0 |
if ($self->{'_retry'} and $self->{'_retry'}[2]--) { } |
|
1580
|
0 |
0 |
if $_lock_chn |
|
1589
|
0 |
0 |
unless ref $self |
|
1590
|
0 |
0 |
if defined $self->{'_sess_dir'} |
|
1592
|
0 |
0 |
if ($self->{'_wid'} == 0) { } |
|
1594
|
0 |
0 |
$self->{'_spawned'} ? : |
|
1604
|
0 |
0 |
if defined $\ |
|
1605
|
0 |
0 |
if not $/ or $/ ne $MCE::LF |
|
1607
|
0 |
0 |
if $_lock_chn |
|
1610
|
0 |
0 |
if $_lock_chn |
|
1619
|
31 |
0 |
unless ref $self |
|
1620
|
0 |
31 |
if defined $self->{'tmp_dir'} |
|
1622
|
31 |
0 |
if ($self->{'_wid'} == 0) { } |
|
1633
|
0 |
0 |
if defined $\ |
|
1634
|
0 |
0 |
if not $/ or $/ ne $MCE::LF |
|
1636
|
0 |
0 |
if $_lock_chn |
|
1639
|
0 |
0 |
if $_lock_chn |
|
1654
|
130 |
3 |
unless ref $self |
|
1655
|
0 |
133 |
caller() eq 'MCE' ? : |
|
1657
|
0 |
133 |
if ref $_[0] eq "CODE" |
|
1659
|
0 |
133 |
unless defined(my $_func = shift()) |
|
1662
|
133 |
0 |
if index($_func, ":") < 0 |
|
1664
|
133 |
0 |
if ($self->{'_wid'}) { } |
|
1676
|
357 |
0 |
unless ref $self |
|
1679
|
0 |
357 |
unless $self->{'_wid'} |
|
1697
|
0 |
0 |
unless ref $self |
|
1701
|
0 |
0 |
unless $self->{'_wid'} |
|
1703
|
0 |
0 |
unless defined $_[0] |
|
1706
|
0 |
0 |
exists $_sendto_lkup{lc $_to} ? : |
|
1709
|
0 |
0 |
unless (defined $_dest) |
|
1712
|
0 |
0 |
if (ref $_to and defined($_fd = fileno $_to) || defined($_fd = eval {
do {
$_to->fileno
}
})) { } |
|
|
0 |
0 |
elsif (&reftype($_to) eq 'GLOB') { } |
|
1715
|
0 |
0 |
if (my $_ob = tied *{$_to;}) |
|
1716
|
0 |
0 |
if (ref $_ob eq "IO::TieCombine::Handle") |
|
1717
|
0 |
0 |
if lc $_ob->{'slot_name'} eq "stdout" |
|
1718
|
0 |
0 |
if lc $_ob->{'slot_name'} eq "stderr" |
|
1722
|
0 |
0 |
scalar @_ == 1 ? : |
|
1729
|
0 |
0 |
if (defined $_to and $_to =~ /$_v2_regx/o) |
|
1731
|
0 |
0 |
exists $_sendto_lkup{lc $1} ? : |
|
1735
|
0 |
0 |
if (not defined $_dest or not defined $_value and $_dest == 1 || $_dest == 4) |
|
1752
|
0 |
0 |
if ($_dest == 0) |
|
1753
|
0 |
0 |
if not defined $_[1] or @_ > 2 |
|
1769
|
0 |
0 |
unless ref $self |
|
1772
|
0 |
0 |
if (ref $_[0] and defined($_fd = fileno $_[0]) || defined($_fd = eval {
do {
$_[0]->fileno
}
})) { } |
|
|
0 |
0 |
elsif (&reftype($_[0]) eq 'GLOB') { } |
|
1775
|
0 |
0 |
if (my $_ob = tied *{$_[0];}) |
|
1776
|
0 |
0 |
if (ref $_ob eq "IO::TieCombine::Handle") |
|
1777
|
0 |
0 |
if lc $_ob->{'slot_name'} eq "stdout" |
|
1778
|
0 |
0 |
if lc $_ob->{'slot_name'} eq "stderr" |
|
1788
|
0 |
0 |
scalar @_ ? : |
|
1790
|
0 |
0 |
if $_fd |
|
1791
|
0 |
0 |
if $self->{'_wid'} |
|
1796
|
0 |
0 |
unless ref $self |
|
1799
|
0 |
0 |
if (ref $_[0] and defined($_fd = fileno $_[0]) || defined($_fd = eval {
do {
$_[0]->fileno
}
})) { } |
|
|
0 |
0 |
elsif (&reftype($_[0]) eq 'GLOB') { } |
|
1802
|
0 |
0 |
if (my $_ob = tied *{$_[0];}) |
|
1803
|
0 |
0 |
if (ref $_ob eq "IO::TieCombine::Handle") |
|
1804
|
0 |
0 |
if lc $_ob->{'slot_name'} eq "stdout" |
|
1805
|
0 |
0 |
if lc $_ob->{'slot_name'} eq "stderr" |
|
1816
|
0 |
0 |
scalar @_ ? : |
|
1818
|
0 |
0 |
if $_fd |
|
1819
|
0 |
0 |
if $self->{'_wid'} |
|
1824
|
0 |
0 |
unless ref $self |
|
1827
|
0 |
0 |
if (ref $_[0] and defined($_fd = fileno $_[0]) || defined($_fd = eval {
do {
$_[0]->fileno
}
})) { } |
|
|
0 |
0 |
elsif (&reftype($_[0]) eq 'GLOB') { } |
|
1830
|
0 |
0 |
if (my $_ob = tied *{$_[0];}) |
|
1831
|
0 |
0 |
if (ref $_ob eq "IO::TieCombine::Handle") |
|
1832
|
0 |
0 |
if lc $_ob->{'slot_name'} eq "stdout" |
|
1833
|
0 |
0 |
if lc $_ob->{'slot_name'} eq "stderr" |
|
1843
|
0 |
0 |
scalar @_ ? : |
|
1845
|
0 |
0 |
if $_fd |
|
1846
|
0 |
0 |
if $self->{'_wid'} |
|
1858
|
0 |
65 |
exists $self->{'_guard'} && $self->{'_guard'}[0] ? : |
|
1860
|
0 |
65 |
if $_has_guard |
|
1864
|
65 |
0 |
unless $_tid |
|
1867
|
0 |
65 |
if $self->{'use_threads'} |
|
1869
|
65 |
0 |
unless ($_tid) |
|
1873
|
0 |
0 |
if $_[0] eq 'INT' || $_[0] eq 'TERM' and $^O ne "MSWin32" |
|
1880
|
0 |
0 |
if ($self->{'posix_exit'} and not $_has_guard and not $_is_MSWin32) |
|
1882
|
0 |
0 |
if $INC{'POSIX.pm'} |
|
1890
|
0 |
126 |
unless ref $self |
|
1892
|
91 |
35 |
if (defined $self->{'user_tasks'}) |
|
1893
|
91 |
0 |
if (defined $self->{'user_tasks'}[0]{'max_workers'}) |
|
1902
|
0 |
0 |
unless ref $self |
|
1906
|
0 |
0 |
unless (defined $_sess_dir) |
|
1908
|
0 |
0 |
unless defined $self->{'tmp_dir'} |
|
1910
|
0 |
0 |
$INC{'threads.pm'} ? : |
|
1911
|
0 |
0 |
unless defined $self->{'_mce_tid'} |
|
1916
|
0 |
0 |
if not defined $_tmp_dir or $_tmp_dir eq "" |
|
1918
|
0 |
0 |
unless -d $_tmp_dir |
|
1920
|
0 |
0 |
unless -w $_tmp_dir |
|
1948
|
0 |
5 |
if (length $_chop_str) { } |
|
1969
|
0 |
187 |
if (defined $_params_ref->{'init_relay'} and not defined $self->{'init_relay'}) |
|
1973
|
0 |
561 |
if (defined $_params_ref->{$_p}) |
|
1980
|
0 |
311 |
unless exists $_params_allowed_args{$_p} |
|
1985
|
81 |
106 |
$self->{'_spawned'} ? : |
|
2004
|
0 |
0 |
if $_is_MSWin32 and defined $self->{'max_retries'} || $INC{'MCE/Child.pm'} || $INC{'MCE/Hobo.pm'} |
|
2010
|
0 |
65 |
$_is_thread ? : |
|
2022
|
65 |
0 |
unless ($self->{'use_threads'}) |
|
2024
|
0 |
65 |
if $INC{'Math/Prime/Util.pm'} |
|
2027
|
0 |
65 |
if $INC{'MCE/Hobo.pm'} and "MCE::Hobo"->can("_clear") |
|
2029
|
0 |
65 |
if $INC{'MCE/Child.pm'} |
|
2033
|
0 |
65 |
if (not $self->{'use_threads'} and $INC{'Math/Random.pm'}) |
|
2036
|
0 |
0 |
$_cur_seed < 1073741781 ? : |
|
2043
|
0 |
65 |
if (not $self->{'use_threads'} and $INC{'Math/Random/MT/Auto.pm'}) |
|
2047
|
0 |
0 |
$_cur_seed < 1073741781 ? : |
|
2070
|
0 |
0 |
unless defined $_thr |
|
2074
|
0 |
0 |
if (defined $_params) |
|
2075
|
0 |
0 |
unless (defined $self->{'_tids'}[$_i]) |
|
2086
|
0 |
0 |
if defined $self->{'spawn_delay'} and $self->{'spawn_delay'} > 0 |
|
2097
|
0 |
277 |
unless defined $_pid |
|
2100
|
65 |
212 |
if $_pid == 0 |
|
2104
|
0 |
212 |
if (defined $_params) |
|
2105
|
0 |
0 |
unless (defined $self->{'_pids'}[$_i]) |
|
2113
|
0 |
212 |
if ($self->{'loop_timeout'} and not $_is_MSWin32) |
|
2119
|
0 |
212 |
if defined $self->{'spawn_delay'} and $self->{'spawn_delay'} > 0 |