File Coverage

blib/lib/KinoSearch1/Store/InvIndex.pm

Criterion	Covered	Total	%
statement	22	31	70.9
branch	2	4	50.0
condition			n/a
subroutine	6	15	40.0
pod	0	10	0.0
total	30	60	50.0

package KinoSearch1::Store::InvIndex;
use strict;
use warnings;
use KinoSearch1::Util::ToolSet;
use base qw( KinoSearch1::Util::Class );

BEGIN {
    __PACKAGE__->init_instance_vars(
        create => 0,
        path   => undef,
    );
}

__PACKAGE__->ready_get(qw( create path ));

=begin comment

    my $outstream = $invindex->open_outstream($filename);

Given a filename, return an OutStream object.

=end comment
=cut

sub open_outstream { shift->abstract_death }

=begin comment

    my $instream = $invindex->open_instream($filename);

Given a filename, return an InStream object.

=end comment
=cut

sub open_instream { shift->abstract_death }

=begin comment

    my @files = $invindex->list;

Return a list of all the files in the InvIndex

=end comment
=cut

sub list { shift->abstract_death }

=begin comment

    my $truth = $invindex->file_exists($filename);

Indicate whether the invindex contains a file with the given filename.

=end comment
=cut

sub file_exists { shift->abstract_death }

=begin comment

    $invindex->rename_file( $from, $to );

Rename a file.

=end comment
=cut

sub rename_file { shift->abstract_death }

=begin comment

   $invindex->delete_file($filename);

Delete a file from the invindex.

=end comment
=cut

sub delete_file { shift->abstract_death }

=begin comment

    my $file_contents = $invindex->slurp_file($filename);

Return a scalar with the file's contents.  Only for small files, obviously.

=end comment
=cut

sub slurp_file { shift->abstract_death }

=begin comment

   my $lock = $invindex->make_lock(
       lock_name => $name,
       timeout   => $timeout,  # milliseconds
   );

Factory method for creating a KinoSearch1::Store::Lock subclassed object.

=end comment
=cut

sub make_lock { shift->abstract_death }

=begin comment

    $invindex->run_while_locked(
        lock_name => $name,
        timeout   => $timeout,  # milliseconds
        do_body   => \&do_some_stuff,
    );

Create a Lock object and obtain a lock, run the subroutine specified by
the do_body parameter, then release the lock and discard the Lock object.
The hash-style argument labels include all the arguments to make_lock, plus
do_body.

=end comment
=cut

sub run_while_locked {
    my ( $self, %args ) = @_;
    my $do_body = delete $args{do_body};
    my $lock = $self->make_lock( %args, invindex => $self, );
    my $locked;
    eval {
        $locked = $lock->obtain;
        $do_body->();
    };
    $lock->release if $lock->is_locked;
    confess $@ if $@;
}

=begin comment

    $invindex->close()

Release any reserved resources.

=end comment
=cut

sub close { shift->abstract_death }

1;

__END__