File Coverage

blib/lib/KinoSearch1/Index/TermInfosWriter.pm

Criterion	Covered	Total	%
statement	34	34	100.0
branch	8	10	80.0
condition			n/a
subroutine	7	7	100.0
pod	1	2	50.0
total	50	53	94.3

package KinoSearch1::Index::TermInfosWriter;
use strict;
use warnings;
use KinoSearch1::Util::ToolSet;
use base qw( KinoSearch1::Util::Class );

BEGIN {
    __PACKAGE__->init_instance_vars(
        # constructor params
        invindex       => undef,
        seg_name       => undef,
        is_index       => 0,
        index_interval => 1024,
        skip_interval  => 16,
    );
}
our %instance_vars;

sub new {
    my $class = shift;
    confess kerror() unless verify_args( \%instance_vars, @_ );
    my %args = ( %instance_vars, @_ );
    my $invindex = $args{invindex};

    # open an outstream
    my $suffix = $args{is_index} ? 'tii' : 'tis';
    my $filename = "$args{seg_name}.$suffix";
    $invindex->delete_file($filename) if $invindex->file_exists($filename);
    my $outstream = $args{invindex}->open_outstream($filename);

    my $self = _new( $outstream,
        @args{qw( is_index index_interval skip_interval )} );

    # create the tii doppelganger
    if ( !$args{is_index} ) {
        my $other = __PACKAGE__->new(
            invindex => $invindex,
            seg_name => $args{seg_name},
            is_index => 1,
        );
        $self->_set_other($other);
        $other->_set_other($self);
    }

    return $self;
}

sub finish {
    my $self      = shift;
    my $outstream = $self->_get_outstream;

    # seek to near the head and write the number of terms processed
    $outstream->seek(4);
    $outstream->lu_write( 'Q', $self->_get_size );

    # cue the doppelganger's exit
    if ( !$self->_get_is_index ) {
        $self->_get_other()->finish;
    }

    $outstream->close;
}

1;

__END__