Branch Coverage

blib/lib/MCE/Core/Manager.pm
Criterion Covered Total %
branch 89 286 31.1


line true false branch
33 0 85 $^O eq 'solaris' ? :
0 85 $INC{'POSIX.pm'} ? :
49 180 34 if (defined $self->{'user_tasks'}) { }
0 34 elsif (defined $self->{'task_end'}) { }
52 0 180 exists $self->{'user_tasks'}[$_task_id]{'task_end'} ? :
54 144 36 if (defined $_task_end)
57 144 0 exists $self->{'user_tasks'}[$_task_id]{'task_name'} ? :
90 0 0 unless ($_sendto_fhs{$_fd})
93 0 0 unless $_sendto_fhs{$_fd}->fdopen($_fd, "w")
98 0 0 if (not exists $self->{'flush_file'} or $self->{'flush_file'})
130 0 285 if $_O_FLG
131 0 285 if $_I_FLG
135 274 11 if ($_wa == 0) { }
2 9 elsif ($_wa == 1) { }
166 347 81 if ($_has_user_tasks and $_task_id >= 0)
172 347 81 $_has_user_tasks ? :
174 0 282 if ($_task_id == 0 and defined $_syn_flag and $_sync_cnt)
175 0 0 if ($_sync_cnt == $_total_running)
183 214 214 unless $_total_running
197 0 0 if ($_has_user_tasks and $_task_id >= 0)
204 0 0 $_has_user_tasks ? :
206 0 0 if ($_task_id == 0 and defined $_syn_flag and $_sync_cnt)
207 0 0 if ($_sync_cnt == $_total_running)
223 0 0 if $_len
227 0 0 if $_len
229 0 0 if (abs $_exit_status > abs $self->{'_wrk_status'})
237 0 0 if ($_exit_pid =~ /^PID_(-?\d+)/) { }
0 0 elsif ($_exit_pid =~ /^TID_(\d+)/) { }
240 0 0 if ($_list->[$i] and $_list->[$i] == $_pid)
250 0 0 if ($_list->[$i] and $_list->[$i] == $_tid)
262 0 0 if (defined $_on_post_exit) { }
0 0 elsif (defined $_on_post_run) { }
265 0 0 if (length $_retry_buf) { }
292 0 0 unless $_total_running
302 80 296 if ($_offset_pos >= $_input_size or $_aborted)
303 0 80 if defined $\
309 229 67 if ($_single_dim and $_cs_one_flag) { }
313 54 13 if ($_offset_pos + $_chunk_size - 1 < $_input_size) { }
325 0 296 if defined $\
339 36 18 if ($_eof_flag or $_aborted)
340 0 36 if defined $\
347 0 18 if $_RS_FLG
349 0 18 if ($_chunk_size <= 8192) { }
350 0 0 if ($_chunk_size == 1) { }
351 0 0 $_input_glob->can('getline') ? :
353 0 0 unless length $_buf
358 0 0 $_input_glob->can('getline') ? :
361 0 0 if ($_len == $_last_len)
370 18 0 if ($_input_glob->can('getline') and $_input_glob->can('read')) { }
371 0 18 if ($_input_glob->read($_buf, $_chunk_size) == $_chunk_size) { }
373 0 0 if length $_buf == $_chunk_size
379 0 0 if (read($_input_glob, $_buf, $_chunk_size) == $_chunk_size) { }
381 0 0 if length $_buf == $_chunk_size
389 0 18 if defined $\
391 18 0 if ($_len) { }
405 3 15 if ($_offset_pos >= $_input_size or $_aborted)
406 0 3 if defined $\
412 12 3 if ($_offset_pos + $_chunk_size - 1 < $_input_size) { }
425 0 15 if defined $\
435 0 0 if ($_aborted)
436 0 0 if defined $\
444 0 0 if (@_ret_a > 1 or defined $_ret_a[0])
446 0 0 if defined $\
452 0 0 if defined $\
487 579 529 if ($_is_c_ref[$_task_id]) { }
0 529 elsif ($_is_h_ref[$_task_id]) { }
379 150 elsif ($_is_q_ref[$_task_id]) { }
496 0 0 unless @{$_;}
517 0 0 if (defined $_user_output) { }
534 0 0 if (defined $_user_error) { }
554 0 0 unless (exists $_sendto_fhs{$_file})
555 0 0 unless open $_sendto_fhs{$_file}, ">>", "$_file"
560 0 0 if (not exists $self->{'flush_file'} or $self->{'flush_file'})
595 0 0 if (not defined $_sync_cnt or $_sync_cnt == 0)
601 0 0 $_has_user_tasks ? :
603 0 0 if (++$_sync_cnt == $_total_running)
614 0 0 if (--$_sync_cnt == 0)
617 0 0 $_has_user_tasks ? :
630 0 0 unless $_win32_ipc
665 0 0 $_has_user_tasks ? :
671 0 0 $_tasks && exists $_tasks->[$_task_id]{'interval'} ? :
673 0 0 if (not $_interval) { }
0 0 elsif ($_interval->{'max_nodes'} == 1) { }
681 0 0 if (not $_delay && defined $_lapse) { }
0 0 elsif ($_lapse + $_delay - $_time < 0) { }
694 0 0 $_tasks ? :
696 0 0 if (++$_delay_wid[$_task_id] > $_max_workers)
710 0 0 if ($_delay < 0 and $_app_tb)
713 0 0 if $_count > "2000000000"
718 0 0 $_delay > 0 ? :
731 108 34 defined $self->{'user_tasks'} ? :
732 60 82 $self->{'chunk_size'} == 1 ? :
743 0 142 if (defined $_max_retries and not $_on_post_exit)
747 0 0 if ($_e->{'id'})
751 0 0 if (defined $self->{'init_relay'}) { }
752 0 0 if $_retry_cnt < $_max_retries
758 0 0 $_retry_cnt < $_max_retries ? :
766 0 108 if ($_has_user_tasks and $self->{'user_tasks'}[0]{'chunk_size'})
770 108 34 if ($_has_user_tasks)
773 102 78 defined $self->{'user_tasks'}[$_i]{'gather'} ? :
775 91 89 ref $_gather[$_i] eq 'CODE' ? :
776 0 180 ref $_gather[$_i] eq 'HASH' ? :
778 51 129 ref $_gather[$_i] eq 'MCE::Queue' || ref $_gather[$_i] eq 'Thread::Queue' ? :
784 62 80 if (defined $self->{'gather'})
787 40 22 ref $_gather[0] eq 'CODE' ? :
788 0 62 ref $_gather[0] eq 'HASH' ? :
790 0 62 ref $_gather[0] eq 'MCE::Queue' || ref $_gather[0] eq 'Thread::Queue' ? :
795 40 102 if (defined $_input_data and ref $_input_data eq 'ARRAY') { }
3 99 elsif (defined $_input_data and ref $_input_data eq 'HASH') { }
809 0 142 if (defined $self->{'stdout_file'}) { }
811 0 0 unless open $_MCE_STDOUT, ">>", $self->{'stdout_file'}
818 0 142 if (defined $self->{'stderr_file'}) { }
820 0 0 unless open $_MCE_STDERR, ">>", $self->{'stderr_file'}
833 142 0 if not exists $self->{'flush_stderr'} or $self->{'flush_stderr'}
836 142 0 if not exists $self->{'flush_stdout'} or $self->{'flush_stdout'}
861 0 142 !$_RS || $_RS ne $MCE::LF ? :
862 0 142 defined $_O_SEP ? :
863 0 142 !$_I_SEP || $_I_SEP ne $MCE::LF ? :
876 0 142 if ($self->{'loop_timeout'} and @{$self->{'_tids'};} == 0 and $^O ne 'MSWin32') { }
0 142 elsif ($^O eq 'MSWin32') { }
882 0 0 if $_timeout < 5
888 0 0 if ($_pid = $_list->[$i])
889 0 0 if (waitpid $_pid, 1)
893 0 0 if ($? > abs $self->{'_wrk_status'})
904 0 0 if ($_has_user_tasks and $_task_id >= 0)
911 0 0 $_has_user_tasks ? :
913 0 0 if ($_task_id == 0 and defined $_syn_flag and $_sync_cnt)
914 0 0 if ($_sync_cnt == $_total_running)
922 0 0 unless $_total_running
924 0 0 if (my $_cid = $self->{'_pids_c'}{$_pid})
928 0 0 if ($_cid > $self->{'_relayed'})
932 0 0 if (defined $_pid and $_pid == 0)
961 0 0 if (exists $_core_output_function{$_func}) { }
0 0 elsif (exists $_plugin_function->{$_func}) { }
974 0 0 if $_win32_ipc
978 0 0 unless length $_func == 8
981 0 0 if (exists $_core_output_function{$_func}) { }
0 0 elsif (exists $_plugin_function->{$_func}) { }
988 0 0 if $_win32_ipc
993 0 3760 unless length $_func == 6
996 2269 1491 if (exists $_core_output_function{$_func}) { }
1491 0 elsif (exists $_plugin_function->{$_func}) { }
1012 0 142 if defined $_on_post_run