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
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
|
package NTP::Util;
use strict;
use warnings;
use Exporter 'import';
use Carp;
use version 0.77;
our @EXPORT_OK = qw(ntp_read_vars do_dns ntp_peers ntp_sntp_line);
my $ntpq_path = 'ntpq';
my $sntp_path = 'sntp';
our $IP_AGNOSTIC;
BEGIN {
require Socket;
if (version->parse($Socket::VERSION) >= version->parse(1.94)) {
Socket->import(qw(getaddrinfo getnameinfo SOCK_RAW AF_INET));
$IP_AGNOSTIC = 1;
}
else {
Socket->import(qw(inet_aton SOCK_RAW AF_INET));
}
}
my %obsolete_vars = (
phase => 'offset',
rootdispersion => 'rootdisp',
);
sub ntp_read_vars {
my ($peer, $vars, $host) = @_;
my $do_all = !@$vars;
my %out_vars = map {; $_ => undef } @$vars;
$out_vars{status_line} = {} if $do_all;
my $cmd = "$ntpq_path -n -c 'rv $peer ".(join ',', @$vars)."'";
$cmd .= " $host" if defined $host;
$cmd .= " |";
open my $fh, $cmd or croak "Could not start ntpq: $!";
while (<$fh>) {
return undef if /Connection refused/;
if (/^asso?c?id=0 status=(\S{4}) (\S+), (\S+),/gi) {
$out_vars{status_line}{status} = $1;
$out_vars{status_line}{leap} = $2;
$out_vars{status_line}{sync} = $3;
}
while (/(\w+)=([^,]+),?\s/g) {
my ($var, $val) = ($1, $2);
$val =~ s/^"([^"]+)"$/$1/;
$var = $obsolete_vars{$var} if exists $obsolete_vars{$var};
if ($do_all) {
$out_vars{$var} = $val
}
else {
$out_vars{$var} = $val if exists $out_vars{$var};
}
}
}
close $fh or croak "running ntpq failed: $! (exit status $?)";
return \%out_vars;
}
sub do_dns {
my ($host) = @_;
if ($IP_AGNOSTIC) {
my ($err, $res);
($err, $res) = getaddrinfo($host, '', {socktype => SOCK_RAW});
die "getaddrinfo failed: $err\n" if $err;
($err, $res) = getnameinfo($res->{addr}, 0);
die "getnameinfo failed: $err\n" if $err;
return $res;
}
# Too old perl, do only ipv4
elsif ($host =~ /^(\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3})$/) {
return gethostbyaddr inet_aton($host), AF_INET;
}
else {
return;
}
}
sub ntp_peers {
my ($host) = @_;
$host ||= '';
my $cmd = "$ntpq_path -npw $host |";
open my $fh, $cmd or croak "Could not start ntpq: $!";
<$fh> for 1 .. 2;
my @columns = qw(tally host refid st t when poll reach delay offset jitter);
my @peers;
while (<$fh>) {
if (/^([ x+#*o-])((?:[\w.*:-]+\s+){10}|([\w.*:-]+\s+))$/) {
my $col = 0;
my @line = ($1, split /\s+/, $2);
if( @line == 2 ) {
defined ($_ = <$fh>) or last;
s/^\s+//;
push @line, split /\s+/;
}
my $r = { map {; $columns[ $col++ ] => $_ } @line };
$r->{remote} = $r->{tally} . $r->{host};
push @peers, $r;
}
else {
#TODO return error (but not needed anywhere now)
warn "ERROR: $_";
}
}
close $fh or croak "running ntpq failed: $! (exit status $?)";
return \@peers;
}
# TODO: we don't need this but it would be nice to have all the line parsed
sub ntp_sntp_line {
my ($host) = @_;
my $cmd = "$sntp_path $host |";
open my $fh, $cmd or croak "Could not start sntp: $!";
my ($offset, $stratum);
while (<$fh>) {
next if !/^\d{4}-\d\d-\d\d/;
chomp;
my @output = split / /;
$offset = $output[3];
($stratum = pop @output) =~ s/s(\d{1,2})/$1/;
}
close $fh or croak "running sntp failed: $! (exit status $?)";
return ($offset, $stratum);
}
1;
|
