File Coverage

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

Criterion	Covered	Total	%
statement	32	55	58.1
branch	0	2	0.0
condition	0	3	0.0
subroutine	11	15	73.3
pod	2	4	50.0
total	45	79	56.9

####################################################################
#
#     This file was generated using XDR::Parse version v1.0.1
#                   and LibVirt version v12.1.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::Local v0.6.1;

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

use Carp qw(croak);
use Future::IO;
use IO::Socket;
use IO::Socket::UNIX;
use Log::Any qw($log);

field $_url :param :reader;
field $_readonly :param = undef;
field $_socket :param = undef;

async method close() {
    # Work around for Future::IO which doesn't
    # like handles being closed when there are
    # outstanding read/write requests (causing
    # warnings of undefined values)
    $self->_finalize_io();
    # When Future::IO and/or IO::Async are changed
    # (ready_for_input() is where this happens),
    # the handle *can* be closed.
    # $_in->close;
    return;
}

async method connect() {
    # disect URL
    $_socket //=
        '/run/libvirt/libvirt-sock' . ($_readonly ? '-ro' : '');

    my $sock = IO::Socket->new(
        Domain => AF_UNIX,
        Type => SOCK_STREAM,
        );
    binmode $sock, ':bytes';
    $sock->blocking( 0 );

    $_in = $_out = $sock;
    my $addr = sockaddr_un( $_socket );
    await Future::IO->connect( $sock, $addr );
}

method is_secure() {
    return 1;
}

1;


__END__