Alvis-Saa
view release on metacpan - search on metacpan
view release on metacpan or search on metacpan
lib/Alvis/Saa.pm view on Meta::CPAN
$this->{'conn_sel'}->remove($conn);
delete($this->{'conns'}->{"${host}_$port"});
shutdown($conn, 2);
close($conn);
return 1;
}
sub unlisten
{
my $this = shift;
my $port = shift;
if(!exists($this->{'servs'}->{$port}))
{
$this->{'err'} = "Not connected";
return 0;
}
my $serv = $this->{'servs'}->{$port};
$this->{'serv_sel'}->remove($serv->{'unix_sock'});
$this->{'serv_sel'}->remove($serv->{'inet_sock'});
shutdown($serv->{'unix_sock'}, 2);
shutdown($serv->{'inet_sock'}, 2);
close($serv->{'unix_sock'});
close($serv->{'inet_sock'});
unlink("$LOCALADDR_PREFIX$port");
delete($this->{'servs'}->{$port});
return 1;
}
sub connect
{
my $this = shift;
my $host = shift;
my $port = shift;
if(exists($this->{'conns'}->{"${host}_$port"}))
{
$this->{'err'} = "Already connected";
return 0;
}
my $cn =
{
'host' => $host,
'port' => $port,
'auto_arb' => 1,
};
my $addr = gethostbyname($host);
my $conn = undef;
# local socket handling is fundamentally broken, a saa-redesign is needed
# if($this->{'my_addr'} eq $addr) # try domain socket first
# {
# $conn = IO::Socket::UNIX->new(Peer => "$LOCALADDR_PREFIX$port",
# Type => SOCK_STREAM,
# Timeout => 10);
# }
if(!defined($conn))
{
# $debug && print STDERR "Saa::connect(): domain socket $LOCALADDR_PREFIX$port failed with $!, trying inet\n";
if(!($conn = IO::Socket::INET->new(PeerAddr => $host,
PeerPort => $port,
Proto => "tcp",
Type => SOCK_STREAM)))
{
$debug && print STDERR "Saa::connect(): tcp connect failed with $@\n";
$this->{'err'} = "$@";
return 0;
}
}
else
{
$debug && print STDERR "Saa::connect(): Successfully opened localsoc!\n";
}
binmode($conn, ":raw");
$cn->{'conn'} = $conn;
$this->{'conn_sel'}->add($conn);
$this->{'conns'}->{"${host}_$port"} = $cn;
return 1;
}
# 'auto_arb' => bool
sub conn_set
{
my $this = shift;
my $host = shift;
my $port = shift;
my %par = @_;
my $c = "${host}_$port";
if(!exists($this->{'conns'}->{$c}))
{
$this->{'err'} = "No such connection.";
return 0;
}
for(keys(%par))
{
$this->{'conns'}->{$c}->{$_} = $par{$_};
}
return 1;
}
# 'tag' => client name for the msg
# 'arb' => scalar data or func(tag) that returs scalar or undef on end-of-data
# 'arb_name' => scalar
sub queue
{
my $this = shift;
my $host = shift;
view all matches for this distributionview release on metacpan - search on metacpan
( run in 1.170 second using v1.00-cache-2.02-grep-82fe00e-cpan-cec75d87357c )