Branch Coverage

blib/lib/Net/OpenSSH/Parallel.pm

Criterion	Covered	Total	%
branch	0	328	0.0

line	true	false	branch
25	0	0	if ($max_conns)
26	0	0	if ($max_workers) { }
27	0	0	if $max_conns < $max_workers
35	0	0	if %opts
71	0	0	unless my $bit = $debug_channel{$channel}
73	0	0	if ($debug & $debug_channel{$channel})
74	0	0	defined $_ ? :
82	0	0	if $label =~ m[([,*!()<>/{}])]
83	0	0	@_ & 1 ? :
84	0	0	unless defined $opts{'host'}
85	0	0	unless defined $opts{'batch_mode'}
101	0	0	if $debug
103	0	0	if $debug
110	0	0	unless delete $$self{'in_state'}{$old}{$label}
112	0	0	if $old eq 'suspended' or $old eq 'waiting' or $old eq 'join_failed'
117	0	0	if $debug
119	0	0	if ($$host{'ssh'} and $state eq 'suspended' || $state eq 'waiting' || $state eq 'join_failed')
123	0	0	if $debug
147	0	0	if $debug
178	0	0	if (ref $action eq 'CODE')
184	0	0	if defined $alias
186	0	0	unless $action =~ /^(?:command|(?:(?:rsync|scp)_(?:get|put))|join|sub|parsub|here|stop|goto|_notify)$/
189	0	0	$action ne 'sub' && ref $_[0] eq 'HASH' ? :
190	0	0	if %opts and grep(($action eq $_), ('join', 'here'))
196	0	0	if defined $max and $max < @_
200	0	0	if defined $min and $min > @_
203	0	0	if ($action eq 'join') { }
209	0	0	unless (my(@depends) = $self->push($notify_selector, '_notify', {}, $join))
218	0	0	if $debug
219	0	0	if $$in_state{'done'}{$label}
227	0	0	if $debug
228	0	0	if $$in_state{'done'}{$label}
240	0	0	if $debug
241	0	0	unless $num == $$self{'num_conns'}
255	0	0	if (defined $_)
257	0	0	if defined $v
269	0	0	if $debug
272	0	0	if $task
275	0	0	if ($error == 1)
276	0	0	if ($$host{'state'} eq 'connecting')
278	0	0	if $task
279	0	0	if @$queue
283	0	0	if $debug
284	0	0	if ($reconnections < $max_reconnections)
285	0	0	if $debug
291	0	0	if (ref $on_error eq 'CODE')
292	0	0	if ($error == 100) { }
300	0	0	if not defined $on_error or $error == 101
303	0	0	if $debug
305	0	0	if ($on_error == 205)
306	0	0	if ($error == 1) { }
	0	0	elsif ($error == 102) { }
325	0	0	if ($on_error == 201) { }
326	0	0	if ($error == 1) { }
330	0	0	unless $task
341	0	0	unless ($on_error == 202 or $on_error == 203 or $on_error == 204)
349	0	0	if $debug
352	0	0	if $debug
353	0	0	if $action eq '_notify'
357	0	0	if $on_error == 204
369	0	0	if $debug
370	0	0	if $$host{'ssh'}
380	0	0	if ($ssh->error)
388	0	0	if $debug
390	0	0	if ($ssh->wait_for_master(1)) { }
	0	0	elsif ($ssh->error) { }
391	0	0	if $debug
403	0	0	unless delete $$join{'depends'}{$label}
405	0	0	if $debug
406	0	0	if $failed
407	0	0	if (not %{$$join{'depends'};})
408	0	0	if $debug
412	0	0	if $debug
413	0	0	$failed ? :
430	0	0	unless $state =~ /^(?:waiting|suspended|done|connecting)$/
432	0	0	if ($$host{'ssh'})
433	0	0	if $debug
435	0	0	if defined $master_pid
446	0	0	if $debug
452	0	0	if $debug
455	0	0	if defined $label
457	0	0	if $debug
458	0	0	unless defined $label
466	0	0	if (my $max_workers = $$self{'max_workers'})
469	0	0	if $debug
470	0	0	if ($num_workers > $max_workers)
471	0	0	if $debug
478	0	0	if $debug
482	0	0	if ($$self{'abort_all'})
489	0	0	if $debug
490	0	0	if ($action eq 'join') { }
	0	0	elsif ($action eq 'here') { }
	0	0	elsif ($action eq 'stop') { }
	0	0	elsif ($action eq 'goto') { }
	0	0	elsif ($action eq '_notify') { }
	0	0	elsif ($action eq 'sub') { }
492	0	0	if ($$join{'done'})
493	0	0	if $debug
494	0	0	if ($$join{'failed'})
498	0	0	if $debug
527	0	0	if $debug
533	0	0	unless ($action eq 'parsub' and $$task[0]{'no_ssh'})
534	0	0	unless ($ssh)
538	0	0	if (my $max_conns = $$self{'max_conns'})
539	0	0	if $$self{'num_conns'} >= $max_conns
541	0	0	if $debug
546	0	0	if (my $error = $ssh->error)
555	0	0	unless my $method = $self->can("_start_$action")
558	0	0	if $debug
559	0	0	unless (defined $pid)
572	0	0	if $debug
583	0	0	if $debug
585	0	0	unless ($pid)
586	0	0	unless defined $pid
588	0	0	if $@ and $debug
589	0	0	$@ ? :
599	0	0	if $debug
608	0	0	if $debug
618	0	0	if $debug
628	0	0	if $debug
638	0	0	if $debug
652	0	0	if $debug
657	0	0	if $$task[0] eq 'here' and $$task[2] eq $target
659	0	0	if ($task or $target eq 'END')
662	0	0	if $$task[0] eq '_notify'
667	0	0	if $debug
675	0	0	if (defined $label) { }
676	0	0	if $debug
679	0	0	if ($?)
682	0	0	unless my $ssh = $$host{'ssh'}
684	0	0	unless $error or $rc == 255
685	0	0	if (defined $or_goto) { }
686	0	0	if $debug
696	0	0	if defined $or_goto
702	0	0	unless defined $label
704	0	0	if $debug
706	0	0	unless my $ssh = $$host{'ssh'}
718	0	0	if $debug
723	0	0	if (%{$$self{'in_state'}{'running'};})
724	0	0	if $debug
727	0	0	if $pid <= 0
728	0	0	if $debug
733	0	0	if $dontwait
734	0	0	if $debug
763	0	0	if $debug
765	0	0	if $debug
768	0	0	if $debug
774	0	0	if $debug
777	0	0	if ($max_workers)
778	0	0	if $debug
779	0	0	if (%$suspended)
784	0	0	unless my($label) = each %$hash
789	0	0	if $debug
797	0	0	if $debug
798	0	0	if $debug
799	0	0	if $debug
801	0	0	if keys %$hosts == keys %$done
803	0	0	%$connecting ? :
	0	0	%$ready ? :
813	0	0	if $$hosts{$label}{'error'}
814	0	0	if $debug
821	0	0	unless my $host = $$self{'hosts'}{$label}
828	0	0	if (wantarray) { }
831	0	0	defined $error ? :