File Coverage

blib/lib/XAS/Lib/Pipe/Unix.pm

Criterion	Covered	Total	%
statement	12	44	27.2
branch	0	10	0.0
condition			n/a
subroutine	4	9	44.4
pod	0	1	0.0
total	16	64	25.0

package XAS::Lib::Pipe::Unix;

our $VERSION = '0.01';

use POE;
use POE::Filter::Line;
use POE::Wheel::ReadWrite;

use XAS::Class
  debug   => 0,
  version => $VERSION,
  base    => 'XAS::Base',
  utils   => 'trim dotid',
  mixins  => 'init_pipe _pipe_connect _pipe_input _pipe_output _pipe_error'
;

#use Data::Dumper;

# ----------------------------------------------------------------------
# Public Methods
# ----------------------------------------------------------------------

# ----------------------------------------------------------------------
# Public Events
# ----------------------------------------------------------------------

# ----------------------------------------------------------------------
# Private Events
# ----------------------------------------------------------------------

sub _pipe_connect {
    my ($self) = $_[OBJECT];

    my $alias = $self->alias;

    $self->log->debug("$alias: _pipe_connect()");

    # Start listening on the pipe.

    $self->{'pipe'} = POE::Wheel::ReadWrite->new(
        Handle     => $self->fifo->open('r+'),
        Filter     => $self->filter,
        InputEvent => 'pipe_input',
        ErrorEvent => 'pipe_error'
    );

}

sub _pipe_input {
    my ($self, $input) = @_[OBJECT,ARG0];

    my $alias = $self->alias;

    $self->log->debug("$alias: _pipe_input()");

    $poe_kernel->post($alias, 'process_input', $input);

}

sub _pipe_output {
    my ($self, $output) = @_[OBJECT,ARG0];

    my @buffer;
    my $alias = $self->alias;

    $self->log->debug("$alias: _pipe_output()");

    if (my $wheel = $self->pipe) {

        push(@buffer, $output);
        $wheel->put(@buffer);

    } else {

        $self->log->error_msg('net_client_nowheel', $alias);

    }

}

sub _pipe_error {
    my ($self, $syscall, $errnum, $errstr) = @_[OBJECT,ARG0 .. ARG2];

    my $alias = $self->alias;

    $self->log->debug("$alias: _pipe_error()");
    $self->log->debug(sprintf("%s: syscall: %s, errnum: %s, errstr: %s", $alias, $syscall, $errnum, $errstr));

    if ($errnum == 0) {

        # EOF detected.

        $self->log->info_msg('net_client_disconnect', $alias, 'localhost', $self->fifo);

        $poe_kernel->post($alias, 'session_shutdown');

    } else {

        $poe_kernel->post($alias, 'process_error', $syscall, $errnum, $errstr);

    }

}

# ----------------------------------------------------------------------
# Private Methods
# ----------------------------------------------------------------------

sub init_pipe {
    my $self = shift;

    my $alias  = $self->alias;
    my $mkfifo = '/usr/bin/mkfifo -m 666 ';

    unless (-p $self->fifo->path) {

        system($mkfifo . $self->fifo) && $self->throw_msg(
            dotid($self->class) . '.nofifo',
            'net_client_nocreate_fifo',
            $self->fifo, $!
        );

        $self->log->info_msg('net_client_create_fifo', $alias, $self->fifo);

    }

    unless (defined($self->filter)) {

        $self->{'filter'} = POE::Filter::Line->new(
            InputLiteral  => $self->eol,
            OutputLiteral => $self->eol
        );

    }

}

1;

__END__