Branch Coverage

blib/lib/Fsdb/Filter/dbmapreduce.pm
Criterion Covered Total %
branch 0 134 0.0


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)