| line |
true |
false |
branch |
|
303
|
0 |
0 |
if ($past_sort_options) { } |
|
309
|
0 |
0 |
unless $self->get_options(\@argv, 'help|?', sub {
pod2usage(1);
}
, 'man', sub {
pod2usage('-verbose', 2);
}
, 'autorun!', \$self->{'_autorun'}, 'close!', \$self->{'_close'}, 'd|debug+', \$self->{'_debug'}, 'endgame!', \$self->{'_endgame'}, 'i|input=s@', sub {
$self->parse_io_option('inputs', @_);
}
, 'inputs!', \$past_sort_options, 'j|parallelism=i', \$self->{'_max_parallelism'}, 'log!', \$self->{'_logprog'}, 'o|output=s', sub {
$self->parse_io_option('output', @_);
}
, 'removeinputs!', \$self->{'_remove_inputs'}, 'test=s', \$self->{'_test'}, 'T|tmpdir|tempdir=s', \$self->{'_tmpdir'}, 'xargs!', \$self->{'_xargs'}, 'n|numeric', sub {
$self->parse_sort_option(@_);
}
, 'N|lexical', sub {
$self->parse_sort_option(@_);
}
, 'r|descending', sub {
$self->parse_sort_option(@_);
}
, 'R|ascending', sub {
$self->parse_sort_option(@_);
}
, '<>', sub {
if ($past_sort_options) {
$self->parse_io_option('inputs', @_);
}
else {
$self->parse_sort_option('<>', @_);
} ;
}
) |
|
322
|
0 |
0 |
if ref $fn |
|
342
|
0 |
0 |
if ($output_type eq 'final') { } |
|
|
0 |
0 |
elsif ($output_type eq 'file') { } |
|
|
0 |
0 |
elsif ($output_type eq 'ipc') { } |
|
346
|
0 |
0 |
if $self->{'_debug'} |
|
382
|
0 |
0 |
if (ref $file) |
|
383
|
0 |
0 |
if (ref($file) =~ /^IO::/) { } |
|
|
0 |
0 |
elsif (ref $file eq 'Fsdb::BoundedQueue') { } |
|
384
|
0 |
0 |
if $self->{'_debug'} |
|
394
|
0 |
0 |
unless defined $file |
|
396
|
0 |
0 |
if (not defined $cleanup_type) { } |
|
|
0 |
0 |
elsif ($cleanup_type eq 'unlink') { } |
|
|
0 |
0 |
elsif ($cleanup_type eq 'NamedTmpfile') { } |
|
397
|
0 |
0 |
if $self->{'_debug'} |
|
400
|
0 |
0 |
if $self->{'_debug'} |
|
403
|
0 |
0 |
if $self->{'_debug'} |
|
439
|
0 |
0 |
if $is_final_output |
|
442
|
0 |
0 |
if ($self->{'_debug'}) |
|
443
|
0 |
0 |
$is_final_output ? : |
|
446
|
0 |
0 |
if $self->{'_debug'} |
|
453
|
0 |
0 |
if $self->{'_debug'} |
|
457
|
0 |
0 |
if (not $is_final_output) |
|
459
|
0 |
0 |
if $self->{'_debug'} |
|
493
|
0 |
0 |
if $#$work_depth_ref == -1 |
|
497
|
0 |
0 |
if $self->{'_debug'} |
|
510
|
0 |
0 |
$closed ? : |
|
511
|
0 |
0 |
if ($#{$work_depth_ref;} == 0) |
|
512
|
0 |
0 |
unless $closed |
|
514
|
0 |
0 |
if $self->{'_debug'} |
|
516
|
0 |
0 |
if $#{$work_depth_ref;} != -1 |
|
523
|
0 |
0 |
if ($work_ref->[0] == -1) { } |
|
|
0 |
0 |
elsif ($work_ref->[0] == 0) { } |
|
|
0 |
0 |
elsif ($work_ref->[0] == 1) { } |
|
|
0 |
0 |
elsif ($work_ref->[0] == 2) { } |
|
524
|
0 |
0 |
if $self->{'_debug'} |
|
528
|
0 |
0 |
if $self->{'_debug'} |
|
532
|
0 |
0 |
if $self->{'_debug'} |
|
541
|
0 |
0 |
if $waiting_on_inputs |
|
546
|
0 |
0 |
if ($closed and $#{$work_depth_ref;} == -1 and $depth == $#{$$self{'_work'};}) { } |
|
|
0 |
0 |
elsif ($self->{'_endgame'} and $closed and $self->{'_work_max_files'}[$depth] <= $self->{'_endgame_max_files'}) { } |
|
549
|
0 |
0 |
if $self->{'_debug'} |
|
553
|
0 |
0 |
if $self->{'_debug'} |
|
556
|
0 |
0 |
if ref($two_fn[$i][1]) =~ /^(Fsdb::BoundedQueue|IO::)/ or $two_fn[$i][1] eq '-' |
|
557
|
0 |
0 |
unless -f $two_fn[$i][1] |
|
561
|
0 |
0 |
if ($output_type eq 'final') |
|
570
|
0 |
0 |
ref $out_fn eq 'ARRAY' ? : |
|
571
|
0 |
0 |
ref $out_fn eq 'ARRAY' ? : |
|
578
|
0 |
0 |
$output_type eq 'ipc' ? : |
|
580
|
0 |
0 |
if $output_type eq 'ipc' |
|
581
|
0 |
0 |
if $self->{'_debug'} |
|
583
|
0 |
0 |
if defined $self->{'_test'} and $self->{'_test'} eq 'delay-finish' |
|
584
|
0 |
0 |
if $self->{'_debug'} |
|
589
|
0 |
0 |
if $self->{'_debug'} |
|
592
|
0 |
0 |
if $exit_code != 0 |
|
596
|
0 |
0 |
if $output_type eq 'ipc' |
|
603
|
0 |
0 |
if $output_type ne 'file' or $self->{'_parallelism_available'} > 0 |
|
604
|
0 |
0 |
if $self->{'_debug'} |
|
630
|
0 |
0 |
if ($#{$$self{'_inputs'};} == 0) |
|
638
|
0 |
0 |
if $self->{'_debug'} |
|
704
|
0 |
0 |
if ($self->{'_xargs'}) |
|
721
|
0 |
0 |
if $self->{'_work_closed'}[$deepest] and $#{$$self{'_work'}[$deepest];} <= 0 |
|
736
|
0 |
0 |
if ($#{$$self{'_work'}[$depth];} == -1 and $self->{'_work_closed'}[$depth]) |
|
739
|
0 |
0 |
unless ($self->{'_work_closed'}[$next_depth]) |
|
743
|
0 |
0 |
if $self->{'_debug'} |
|
753
|
0 |
0 |
if $self->{'_debug'} |
|
756
|
0 |
0 |
if ref $fred_or_code eq '' |
|
758
|
0 |
0 |
if $fred_or_code->exit_code != 0 |
|
760
|
0 |
0 |
if $self->{'_debug'} |
|
770
|
0 |
0 |
if (defined $work_ref and $work_ref->[0] == -1) |
|
776
|
0 |
0 |
if (++$i > $#{$$self{'_work'}[$depth];}) |
|
777
|
0 |
0 |
if ++$depth > $#{$$self{'_work'};} |
|
791
|
0 |
0 |
if ($self->{'_xargs_ipc_status'}) |
|
795
|
0 |
0 |
if (defined $fn) { } |
|
798
|
0 |
0 |
if $self->{'_remove_inputs'} |
|
800
|
0 |
0 |
if $self->{'_debug'} |
|
812
|
0 |
0 |
if (not $overall_progress) { } |
|
814
|
0 |
0 |
if $self->{'_debug'} |
|
817
|
0 |
0 |
if $progress_backoff > $PROGRESS_MAX |
|
827
|
0 |
0 |
if $zombie_work_ref->[0] == 2 |
|
828
|
0 |
0 |
if $self->{'_debug'} |
|
830
|
0 |
0 |
if $zombie_work_ref->[0] != 2 |
|
834
|
0 |
0 |
if ($self->{'_xargs_fred'}) |
|
835
|
0 |
0 |
if $self->{'_debug'} |
|
855
|
0 |
0 |
if $#{$$self{'_sort_argv'};} == -1 |
|
857
|
0 |
0 |
if (not $self->{'_xargs'} and $#{$$self{'_inputs'};} == -1) |
|
860
|
0 |
0 |
if (not $self->{'_xargs'} and $#{$$self{'_inputs'};} == 0) |
|
863
|
0 |
0 |
if ($self->{'_xargs'} and $#{$$self{'_inputs'};} > 0) |
|
868
|
0 |
0 |
if ref $_ ne '' |
|
869
|
0 |
0 |
if $_ eq '-' |
|
870
|
0 |
0 |
unless (-f $_) |
|
874
|
0 |
0 |
if ($self->{'_remove_inputs'}) |
|
876
|
0 |
0 |
if $_ ne '-' |
|
902
|
0 |
0 |
if (not $self->{'_xargs'}) { } |
|
910
|
0 |
0 |
unless pipe $xargs_ipc_reader, $xargs_ipc_writer |
|
943
|
0 |
0 |
if $self->{'_debug'} |
|
944
|
0 |
0 |
if $self->{'_debug'} |