File Coverage

lib/IPC/SRLock/Utils.pm

Criterion	Covered	Total	%
statement	39	40	100.0
branch	13	14	100.0
condition	5	5	100.0
subroutine	12	12	100.0
pod	5	5	100.0
total	74	76	100.0

package IPC::SRLock::Utils;

use strict;
use warnings;
use parent 'Exporter::Tiny';

use IPC::SRLock::Constants qw( EXCEPTION_CLASS );
use Scalar::Util           qw( blessed );

our @EXPORT_OK = qw( Unspecified hash_from loop_until merge_attributes throw );

sub Unspecified () {
   return sub { 'Unspecified' };
}

sub hash_from  (;@) {
   my (@args) = @_; $args[ 0 ] or return {};

   return ref $args[ 0 ] ? $args[ 0 ] : { @args };
}

sub loop_until ($) {
   my $f = shift;

   return sub {
      my $self = shift; my $args = $self->_get_args( @_ ); my $start = time;

      while (1) {
         my $now = time;
         my $r   = $f->( $self, $args, $now ); $r and return $r;

         # uncoverable branch false
         $args->{async} and return 0;
         # uncoverable statement
         $self->_sleep_or_timeout( $start, $now, $self->lockfile );
      }
   };
}

sub merge_attributes ($$;$) {
   my ($dest, $src, $keys) = @_; my $class = blessed $src;

   for (grep { not exists $dest->{ $_ } or not defined $dest->{ $_ } }
            @{ $keys // [] }) {
      my $v = $class ? ($src->can( $_ ) ? $src->$_() : undef) : $src->{ $_ };

      defined $v and $dest->{ $_ } = $v;
   }

   return $dest;
}

sub throw (;@) {
   EXCEPTION_CLASS->throw( @_ );
}

1;

__END__