| 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 {
|
|
|
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 {
|
|
|
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 {
|
|
|
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 {
|
|
|
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
|