File Coverage

blib/lib/POSIX/RT/Semaphore.pm

Criterion	Covered	Total	%
statement	15	33	45.4
branch	0	6	0.0
condition			n/a
subroutine	5	5	100.0
pod			n/a
total	20	44	45.4

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

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

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

	# -- Set up exports at BEGIN time
	@EXPORT_OK =
		('SIZEOF_SEM_T', grep {/^(_SC_)?SEM_[A-Z_]+/} keys %POSIX::RT::Semaphore::);

	# -- 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;
			}
		}

		my $dtor = \&POSIX::RT::Semaphore::_base::DESTROY;
		*POSIX::RT::Semaphore::_base::DESTROY = 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__