File Coverage

blib/lib/POSIX/RT/Semaphore.pm

Criterion	Covered	Total	%
statement	31	50	62.0
branch	1	6	16.6
condition			n/a
subroutine	11	11	100.0
pod	2	2	100.0
total	45	69	65.2

package POSIX::RT::Semaphore;
#============================================================================#

use 5.008;
use strict;
our ($VERSION, @EXPORT_OK);

BEGIN {
$VERSION = '0.05_02';
require XSLoader;
XSLoader::load(__PACKAGE__, $VERSION);

# -- awkwardness to support threaded
#    operation
if ($INC{'threads.pm'}) {
  require threads::shared;
  no warnings 'redefine';

  for ('Unnamed::init', 'Named::open') {
    no strict 'refs';

    my $sym = __PACKAGE__ . "::$_";
    my $ctor = \&{$sym};
    *{$sym} = sub {
      my $psem = &$ctor;
      &threads::shared::share($psem) if defined $psem;
      $psem;
    }
  }

  for ('Unnamed', 'Named') {
    no strict 'refs';

    my $sym = __PACKAGE__ . "::${_}::DESTROY";
    my $dtor = \&{$sym};
    *{$sym} = sub {
      lock($_[0]);
      return unless threads::shared::_refcnt($_[0]) == 1;
      &$dtor;
    }
  }
} # -- if ($INC{'threads.pm'})

}

use strict;
use warnings;

#
# -- Internal methods
#

sub import {
  require Exporter;
  goto &Exporter::import;
}

#
# -- Public methods
#

sub init {
  shift @_;
  return POSIX::RT::Semaphore::Unnamed->init(@_);
}

sub open {
  shift @_;
  return POSIX::RT::Semaphore::Named->open(@_);
}

1;

__END__