1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
package NDB::Net::ServerINET;
use strict;
use Carp;
use Socket;
require NDB::Net::Server;
use vars qw(@ISA);
@ISA = qw(NDB::Net::Server);
# constructors
my $log;
sub initmodule {
$log = NDB::Util::Log->instance;
}
NDB::Net::ServerINET->attributes(
host => sub { s/^\s+|\s+$//g; /^\S+$/ },
port => sub { s/^\s+|\s+$//g; /^\d+$/ },
canon => sub { s/^\s+|\s+$//g; /^\S+$/ },
aliases => sub { ref($_) eq 'ARRAY' },
);
sub desc {
my $server = shift;
my $id = $server->getid;
my $host = $server->gethost;
return "server $id at $host";
}
sub new {
my $class = shift;
@_ % 2 == 0 or confess 0+@_;
my(%attr) = @_;
my $server = $class->SUPER::new(%attr);
$server->setid($attr{id})
or $log->push, return undef;
$server->setdomain(PF_INET)
or $log->push, return undef;
$server->sethost($attr{host})
or $log->push, return undef;
$server->setport($attr{port})
or $log->push, return undef;
my($canon, $aliases) = gethostbyname($server->gethost);
if (! defined($canon)) {
$log->put("%s: unknown host", $server->gethost);
return undef;
}
$server->setcanon($canon)
or $log->push, return undef;
$server->setaliases([ split(' ', $aliases) ])
or $log->push, return undef;
$server->add or
$log->push, return undef;
$log->put("added")->push($server)->debug;
return $server;
}
# find matching servers
sub match {
my $class = shift;
@_ == 3 or confess 0+@_;
my($host, $port, $servers) = @_;
if (! defined($port) && $host =~ /:/) {
($host, $port) = split(/:/, $host, 2);
}
$host =~ s/^\s+|\s+$//g;
my($canon) = gethostbyname($host);
unless (defined($canon)) {
$log->put("$host: unknown host");
return undef;
}
my $hostport = $host;
if (defined($port)) {
$port =~ s/^\s+|\s+$//g;
$port =~ /\d+$/
or $log->put("$port: non-numeric port"), return undef;
$hostport .= ":$port";
}
my @server = ();
for my $s (@$servers) {
($s->getdomain == PF_INET) || next;
($s->getcanon eq $canon) || next;
($port && $s->getport != $port) && next;
push(@server, $s);
}
if (! @server) {
$log->put("$hostport: no server found");
}
if (@server > 1) {
$log->put("$hostport: multiple servers at ports ",
join(' ', map($_->getport, @server)));
}
return \@server;
}
# client side
sub connect {
my $server = shift;
@_ == 0 or confess 0+@_;
my $socket;
$socket = NDB::Util::SocketINET->new or
$log->push, return undef;
$socket->connect($server->gethost, $server->getport) or
$log->push, return undef;
return $socket;
}
1;
# vim:set sw=4:
|
