File Coverage

blib/lib/HPC/Runner/Command/execute_job/Logger/Lock.pm

Criterion	Covered	Total	%
statement	18	35	51.4
branch	0	4	0.0
condition			n/a
subroutine	6	10	60.0
pod	1	2	50.0
total	25	51	49.0

package HPC::Runner::Command::execute_job::Logger::Lock;

use Moose::Role;
use namespace::autoclean;

use Try::Tiny;
use Time::HiRes;
use File::Spec;
use MooseX::Types::Path::Tiny qw/Path Paths AbsPath AbsFile/;

has 'lock_file' => (
    is       => 'rw',
    isa      => Path,
    lazy     => 1,
    coerce   => 1,
    required => 1,
    default  => sub {
        my $self = shift;
        my $file = File::Spec->catdir( $self->data_dir, '.lock' );
        return $file;
    },
);

has 'logger' => (
    is      => 'rw',
    isa     => 'Str',
    default => 'command_log',
);

=head3 check_lock

Check to see if the lock exists

Have a max retry count to avoid infinite loops

=cut

sub check_lock {
    my $self = shift;

    my $max_retries = 500;
    my $x           = 0;

    my $ret = 1;
    while ( $self->lock_file->exists ) {
        Time::HiRes::sleep(0.2);
        $x++;
        if($x >= $max_retries){
          $ret = 0;
          last;
        }
    }
    if ( $x >= $max_retries ) {
        $self->{$self->logger}->warn('Logger::JSON Error: We exited the lock!');
    }

    return $ret;
}

sub write_lock {
    my $self = shift;

    try {
        $self->lock_file->touchpath;
    }
    catch {
        $self->{$self->logger}->warn(
            'Logger::JSON Error: We were not able to write '
              . $self->lock_file->stringify );
    };
}

1;