|
Packit |
8bbd3c |
#!/usr/bin/perl
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
use strict;
|
|
Packit |
8bbd3c |
use warnings;
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
use Errno qw( EINPROGRESS );
|
|
Packit |
8bbd3c |
use IO::Poll;
|
|
Packit |
8bbd3c |
use IO::Socket::IP;
|
|
Packit |
8bbd3c |
use Net::LibAsyncNS;
|
|
Packit |
8bbd3c |
use Socket qw( SOCK_STREAM );
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
my $host = shift @ARGV or die "Need HOST\n";
|
|
Packit |
8bbd3c |
my $service = shift @ARGV or die "Need SERVICE\n";
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
my $poll = IO::Poll->new;
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
my $asyncns = Net::LibAsyncNS->new( 1 );
|
|
Packit |
8bbd3c |
my $asyncns_fh = $asyncns->new_handle_for_fd;
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
my $q = $asyncns->getaddrinfo( $host, $service, { socktype => SOCK_STREAM } );
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
$poll->mask( $asyncns_fh => POLLIN );
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
while( !$q->isdone ) {
|
|
Packit |
8bbd3c |
$poll->poll( undef );
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
if( $poll->events( $asyncns_fh ) ) {
|
|
Packit |
8bbd3c |
$asyncns->wait( 0 );
|
|
Packit |
8bbd3c |
}
|
|
Packit |
8bbd3c |
}
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
$poll->mask( $asyncns_fh => 0 );
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
my ( $err, @peeraddrinfo ) = $asyncns->getaddrinfo_done( $q );
|
|
Packit |
8bbd3c |
$err and die "getaddrinfo() - $!";
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
my $socket = IO::Socket::IP->new(
|
|
Packit |
8bbd3c |
PeerAddrInfo => \@peeraddrinfo,
|
|
Packit |
8bbd3c |
Blocking => 0,
|
|
Packit |
8bbd3c |
) or die "Cannot construct socket - $@";
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
$poll->mask( $socket => POLLOUT );
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
while(1) {
|
|
Packit |
8bbd3c |
$poll->poll( undef );
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
if( $poll->events( $socket ) & POLLOUT ) {
|
|
Packit |
8bbd3c |
last if $socket->connect;
|
|
Packit |
8bbd3c |
die "Cannot connect - $!" unless $! == EINPROGRESS;
|
|
Packit |
8bbd3c |
}
|
|
Packit |
8bbd3c |
}
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
printf STDERR "Connected to %s:%s\n", $socket->peerhost_service;
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
$poll->mask( \*STDIN => POLLIN );
|
|
Packit |
8bbd3c |
$poll->mask( $socket => POLLIN );
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
while(1) {
|
|
Packit |
8bbd3c |
$poll->poll( undef );
|
|
Packit |
8bbd3c |
|
|
Packit |
8bbd3c |
if( $poll->events( \*STDIN ) ) {
|
|
Packit |
8bbd3c |
my $ret = STDIN->sysread( my $buffer, 8192 );
|
|
Packit |
8bbd3c |
defined $ret or die "Cannot read STDIN - $!\n";
|
|
Packit |
8bbd3c |
$ret or last;
|
|
Packit |
8bbd3c |
$socket->syswrite( $buffer );
|
|
Packit |
8bbd3c |
}
|
|
Packit |
8bbd3c |
if( $poll->events( $socket ) ) {
|
|
Packit |
8bbd3c |
my $ret = $socket->sysread( my $buffer, 8192 );
|
|
Packit |
8bbd3c |
defined $ret or die "Cannot read socket - $!\n";
|
|
Packit |
8bbd3c |
$ret or last;
|
|
Packit |
8bbd3c |
STDOUT->syswrite( $buffer );
|
|
Packit |
8bbd3c |
}
|
|
Packit |
8bbd3c |
}
|