File Coverage

blib/lib/Test/Stream/IPC.pm

Criterion	Covered	Total	%
statement	51	51	100.0
branch	10	10	100.0
condition	2	2	100.0
subroutine	16	16	100.0
pod	5	7	71.4
total	84	86	97.6

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

use Config qw/%Config/;
use Carp qw/confess carp longmess/;

use Test::Stream::HashBase(
    accessors => [qw/no_fatal/],
);

sub import {
    my $class = shift;
    return if $class eq __PACKAGE__;
    $class->register_drivers($class);
}

my @DRIVERS;
*register_driver = \®ister_drivers;
sub register_drivers {
    my $class = shift;
    my %seen = map {($_ => 1)} @DRIVERS;
    push @DRIVERS => grep { !$seen{$_} } @_;
}

sub drivers {
    unless(@DRIVERS) {
        # Fallback to files
        require Test::Stream::IPC::Files;
        push @DRIVERS => 'Test::Stream::IPC::Files';
    }

    return @DRIVERS;
}

sub init {
    my $class = shift;

    for my $driver ($class->drivers) {
        next unless $driver->is_viable;
        my $ipc = $driver->new || next;
        return $ipc;
    }

    die "Could not find a viable IPC driver! Aborting...\n";
}

my $POLLING = 0;
sub polling_enabled { $POLLING }
sub enable_polling {
    return if $POLLING++;
    require Test::Stream::Context;
    Test::Stream::Context->ON_INIT(sub { $_[0]->hub->cull });
}

for my $meth (qw/send cull add_hub drop_hub waiting is_viable/) {
    no strict 'refs';
    *$meth = sub {
        my $thing = shift;
        confess "'$thing' did not define the required method '$meth'."
    };
}

# Print the error and call exit. We are not using 'die' cause this is a
# catastophic error that should never be caught. If we get here it
# means some serious shit has happened in a child process, the only way
# to inform the parent may be to exit false.

sub abort {
    my $self = shift;
    chomp(my ($msg) = @_);
    print STDERR "IPC Fatal Error: $msg\n";
    print STDOUT "not ok - IPC Fatal Error\n";

    CORE::exit(255) unless $self->no_fatal;
}

sub abort_trace {
    my $self = shift;
    my ($msg) = @_;
    $self->abort(longmess($msg));
}


1;

__END__