File Coverage

blib/lib/Data/PubSub/Shared.pm

Criterion	Covered	Total	%
statement	15	17	88.2
branch			n/a
condition			n/a
subroutine	6	8	75.0
pod			n/a
total	21	25	84.0

package Data::PubSub::Shared;
use strict;
use warnings;
our $VERSION = '0.07';

require XSLoader;
XSLoader::load('Data::PubSub::Shared', $VERSION);

# ithreads: blessed shared-memory handles must never be cloned into a
# child thread -- the clone would double-free the handle on thread exit.
{ no strict 'refs'; *{"${_}::CLONE_SKIP"} = sub { 1 } for qw(
  Data::PubSub::Shared::Int
  Data::PubSub::Shared::Int::Sub
  Data::PubSub::Shared::Int16
  Data::PubSub::Shared::Int16::Sub
  Data::PubSub::Shared::Int32
  Data::PubSub::Shared::Int32::Sub
  Data::PubSub::Shared::Str
  Data::PubSub::Shared::Str::Sub
); }

sub _enable_keywords {
    my ($pkg, @kws) = @_;
    $^H{"$pkg/$_"} = 1 for @kws;
}

for my $variant (qw(Int Int32 Int16 Str)) {
    my $lc = lc $variant;
    my $pkg = "Data::PubSub::Shared::$variant";
    my @kws = map { "ps_${lc}_$_" } qw(publish poll lag);
    no strict 'refs';
    *{"${pkg}::import"} = sub {
        _enable_keywords($pkg, @kws);
    };
    *{"${pkg}::unimport"} = sub {
        delete $^H{"$pkg/$_"} for @kws;
    };
}

1;

__END__