File Coverage

lib/Net/Signalet.pm

Criterion	Covered	Total	%
statement	29	46	63.0
branch	5	20	25.0
condition	0	3	0.0
subroutine	9	11	81.8
pod	0	5	0.0
total	43	85	50.5

package Net::Signalet;
use strict;
use warnings;
our $VERSION = 0.02;

use Carp ();
use IO::Socket::INET;
use Net::IP::Minimal qw(ip_is_ipv4);


sub _init {
    my ($class, %args) = @_;

    for (qw(saddr daddr)) {
        if (exists $args{$_}) {
            ip_is_ipv4 $args{$_}
                or Carp::croak "$_ is not ipv4: $args{$_}";
        }
    }
}

sub recv {
    my ($self) = @_;
    unless ($self->{sock}) {
        Carp::croak "recv: Not connect";
    }
    my $message = $self->{sock}->getline;
    chomp $message;
    return $message;
}

sub send {
    my ($self, $message) = @_;
    unless ($self->{sock}) {
        Carp::croak "send: Not connect";
    }
    $self->{sock}->print($message."\n");
}

sub run {
    my ($self, %params) = @_;

    if (!exists $params{command} && !exists $params{code}) {
        Carp::croak "Required command or code";
    }
    my $pid = fork;
    unless ($pid) {
        # child process
        if (my $command = $params{command}) {
            if (ref($params{command}) eq 'ARRAY') {
                exec @{$params{command}};
            }
            else {
                exec $command;
            }
        }
        elsif ($params{code}) {
            $params{code}->();
        }
    }
    $self->{worker_pid} = $pid if $pid > 0;
}

sub term_worker {
    my ($self) = @_;
    my $pgrp = getpgrp $self->{worker_pid};
    kill(-15, $pgrp); # send TERM signal to child processes
}

sub close {
    my ($self) = @_;
    close $self->{sock};
}

1;
__END__