File Coverage

blib/lib/Sys/Async/Virt/Connection/Process.pm

Criterion	Covered	Total	%
statement	32	66	48.4
branch	0	6	0.0
condition			n/a
subroutine	11	16	68.7
pod	1	3	33.3
total	44	91	48.3

####################################################################
#
#     This file was generated using XDR::Parse version v1.0.1
#                   and LibVirt version v12.5.0
#
#      Don't edit this file, use the source template instead
#
#                 ANY CHANGES HERE WILL BE LOST !
#
####################################################################


use v5.26;
use warnings;
use experimental 'signatures';
use Future::AsyncAwait;
use Object::Pad ':experimental(inherit_field)';

class Sys::Async::Virt::Connection::Process v0.6.5;

inherit Sys::Async::Virt::Connection '$_in', '$_out';

use Carp qw(croak);
use Future::IO;
use IO::Handle;
use IPC::Open2;
use Log::Any qw($log);

use Protocol::Sys::Virt::URI v12.5.0; # imports parse_url

field $_url :param :reader;
field $_pid;
field $_exit_f;

async method close() {
    unless ($_exit_f->is_ready) {
        kill 'TERM', $_pid;
    }
    ### TODO: log exit status
    await $_exit_f;
}

method _command( $url ) {
    my %c = parse_url( $url );
    my @rv;
    if (exists $c{query}->{argv}) {
        @rv = ( $c{query}->{command}, $c{query}->{argv}->@* );
    }
    else {
        @rv = ( $c{query}->{command} );
    }
    return @rv;
}

async method connect() {
    my @cmd = $self->_command( $_url );
    $log->trace('Connection process command: ' . join(' ', @cmd));

    $_pid = open2( $_in, $_out, @cmd )
        or die "Unable to open external command: $!";
    $_out->autoflush( 1 );
    $_out->blocking( 0 );
    $_in->autoflush( 1 );
    $_in->blocking( 0 );
    $_exit_f = Future::IO->waitpid( $_pid );
    $_exit_f->on_ready(sub { $self->_finalize_io });

    return;
}

1;


__END__