| line |
true |
false |
branch |
|
480
|
0 |
0 |
unless $self->get_options(\@argv, 'help|?', sub {
pod2usage(1);
}
, 'man', sub {
pod2usage('-verbose', 2);
}
, 'autorun!', \$self->{'_autorun'}, 'C|filter-code|code=s', \$self->{'_filter_generator_code'}, 'close!', \$self->{'_close'}, 'copy-fs|copy-fieldseparator!', \$self->{'_copy_fscode'}, 'd|debug+', \$self->{'_debug'}, 'f|code-files=s@', $self->{'_code_files'}, 'header=s', \$self->{'_header'}, 'i|input=s', sub {
$self->parse_io_option('input', @_);
}
, 'j|parallelism=i', \$self->{'_max_parallelism'}, 'k|key=s', \$self->{'_key_column'}, 'K|pass-current-key!', \$self->{'_pass_current_key'}, 'prepend-key', sub {
$self->{'_prepend_key'} = 1;
}
, 'no-prepend-key', sub {
$self->{'_prepend_key'} = 0;
}
, 'log!', \$self->{'_logprog'}, 'M|multiple-ok!', \$self->{'_reducer_is_multikey_aware'}, 'o|output=s', sub {
$self->parse_io_option('output', @_);
}
, 'S|pre-sorted+', \$self->{'_pre_sorted'}, 'test-parallelism!', \$self->{'_test_parallelism'}, 'T|tmpdir|tempdir=s', \$self->{'_tmpdir'}, 'saveoutput=s', \$self->{'_save_output'}, 'w|warnings!', \$self->{'_warnings'}) |
|
497
|
0 |
0 |
unless defined $self->{'_prepend_key'} |
|
499
|
0 |
0 |
if $self->{'_prepend_key'} and $self->{'_reducer_is_multikey_aware'} |
|
506
|
0 |
0 |
unless open IN, "< $code_file" |
|
515
|
0 |
0 |
if $self->{'_max_parallelism'} < 1 |
|
526
|
0 |
0 |
if ($#{$$self{'_external_command_argv'};} >= 0) { } |
|
|
0 |
0 |
elsif (defined $self->{'_filter_generator_code'}) { } |
|
529
|
0 |
0 |
if $argv[0] eq '--' |
|
532
|
0 |
0 |
$self->{'_warnings'} ? : |
|
535
|
0 |
0 |
if ($self->{'_pass_current_key'}) { } |
|
545
|
0 |
0 |
if $self->{'_debug'} > 2 |
|
548
|
0 |
0 |
if (ref $self->{'_filter_generator_code'} eq 'CODE') { } |
|
549
|
0 |
0 |
if $self->{'_debug'} |
|
559
|
0 |
0 |
if $self->{'_debug'} |
|
561
|
0 |
0 |
if $@ |
|
573
|
0 |
0 |
if ($raw_to_raw) { } |
|
580
|
0 |
0 |
if defined $self->{'_header'} |
|
581
|
0 |
0 |
if ($self->{'_pre_sorted'}) { } |
|
585
|
0 |
0 |
defined $self->{'_key_column'} ? : |
|
587
|
0 |
0 |
if defined $self->{'_header'} |
|
604
|
0 |
0 |
if ($raw_to_raw) { } |
|
|
0 |
0 |
elsif (defined $self->{'_key_column'}) { } |
|
610
|
0 |
0 |
unless defined $self->{'_key_coli'} |
|
645
|
0 |
0 |
if ($self->{'_reducer_is_multikey_aware'}) { } |
|
674
|
0 |
0 |
defined $key ? : |
|
691
|
0 |
0 |
if $self->{'_debug'} >= 2 |
|
696
|
0 |
0 |
if $self->{'_reducer_is_multikey_aware'} |
|
704
|
0 |
0 |
if ($self->{'_copy_fscode'}) |
|
707
|
0 |
0 |
if ($self->{'_prepend_key'}) |
|
711
|
0 |
0 |
if $self->{'_debug'} |
|
722
|
0 |
0 |
if $debug |
|
723
|
0 |
0 |
if -z $output_file |
|
743
|
0 |
0 |
if $self->{'_debug'} >= 2 |
|
745
|
0 |
0 |
unless (defined $key) |
|
746
|
0 |
0 |
unless $final |
|
749
|
0 |
0 |
if $self->{'_reducer_is_multikey_aware'} |
|
752
|
0 |
0 |
if defined $key and $self->{'_current_key'} ne $key |
|
754
|
0 |
0 |
if $self->{'_debug'} >= 2 |
|
773
|
0 |
0 |
$force ? : |
|
775
|
0 |
0 |
if $self->{'_test_parallelism'} |
|
776
|
0 |
0 |
if ($backlog >= $self->{'_max_parallelism'}) |
|
781
|
0 |
0 |
if $self->{'_debug'} |
|
784
|
0 |
0 |
if ref $fred_or_code eq '' |
|
785
|
0 |
0 |
if $fred_or_code->exit_code != 0 |
|
787
|
0 |
0 |
if $self->{'_debug'} |
|
796
|
0 |
0 |
if ($force) |
|
798
|
0 |
0 |
if $self->{'_debug'} |
|
800
|
0 |
0 |
if $exit_code != 0 |
|
802
|
0 |
0 |
if $work_queue_href->{'status'} ne 'done' |
|
804
|
0 |
0 |
if ($work_queue_href->{'status'} ne 'done') |
|
805
|
0 |
0 |
if $force |
|
810
|
0 |
0 |
if $self->{'_debug'} |
|
836
|
0 |
0 |
if $self->{'_debug'} |
|
842
|
0 |
0 |
if $cat_writer->error |
|
858
|
0 |
0 |
if (not defined $last_key or $key ne $last_key) |
|
861
|
0 |
0 |
if ($self->{'_pre_sorted'} == 1) |
|
863
|
0 |
0 |
if defined $self->{'_key_counts'}{$key} |
|
867
|
0 |
0 |
if (defined $last_key) |
|
874
|
0 |
0 |
unless defined $reducer_fastpath_sub |
|
880
|
0 |
0 |
unless (defined $last_key) |
|
903
|
0 |
0 |
if ($self->{'_reducer_is_multikey_aware'}) { } |
|
924
|
0 |
0 |
if ($self->{'_sorter_fred'}) |
|
926
|
0 |
0 |
if $self->{'_debug'} |
|
929
|
0 |
0 |
if $self->{'_sorter_fred'}->error |
|
932
|
0 |
0 |
if ($self->{'_reducer_is_multikey_aware'}) { } |
|
942
|
0 |
0 |
if $self->{'_debug'} |
|
944
|
0 |
0 |
if (my $error = $self->{'_cat_fred'}->error) |