File Coverage

blib/lib/Test/Stream/Plugin/IPC.pm

Criterion	Covered	Total	%
statement	51	51	100.0
branch	13	14	92.8
condition			n/a
subroutine	10	10	100.0
pod	0	2	0.0
total	74	77	96.1

package Test::Stream::Plugin::IPC;
use strict;
use warnings;

use Test::Stream::IPC;

use Test::Stream::Context qw/context/;
use Test::Stream::Util qw/pkg_to_file/;
use Carp qw/croak confess/;

use Test::Stream::Plugin;

sub load_ts_plugin {
    my $class = shift;
    my $caller = shift;

    my @drivers;
    my %params;

    for my $arg (@_) {
        if ($arg =~ m/^-(.*)$/) {
            $params{$1}++;
        }
        elsif ($arg =~ m/^\+(.+)$/) {
            push @drivers => $1;
        }
        else {
            push @drivers => "Test::Stream::IPC::$arg";
        }
    }

    for my $driver (@drivers) {
        my $file = pkg_to_file($driver);
        unless(eval { require $file; 1 }) {
            my $error = $@;
            die $error unless $error =~ m/^Can't locate/;
            next;
        }
        Test::Stream::IPC->register_driver($driver);
    }

    Test::Stream::IPC->enable_polling if delete $params{poll};

    if (delete $params{cull}) {
        no strict 'refs';
        *{"$caller->[0]\::cull"} = \&cull
    }

    if (my @bad = keys %params) {
        confess "Invalid parameters: " . join ', ', map { "'-$_'" } @bad;
    }
}

sub cull {
    my $ctx = context();
    $ctx->hub->cull;
    $ctx->release;
}

1;

__END__