1: #! @PATH_PERL@ -w
2: #
3: # $Id: ntpsweep.in,v 1.1.1.1 2012/05/29 12:08:38 misho Exp $
4: #
5: # DISCLAIMER
6: #
7: # Copyright (C) 1999,2000 Hans Lambermont and Origin B.V.
8: #
9: # Permission to use, copy, modify and distribute this software and its
10: # documentation for any purpose and without fee is hereby granted,
11: # provided that the above copyright notice appears in all copies and
12: # that both the copyright notice and this permission notice appear in
13: # supporting documentation. This software is supported as is and without
14: # any express or implied warranties, including, without limitation, the
15: # implied warranties of merchantability and fitness for a particular
16: # purpose. The name Origin B.V. must not be used to endorse or promote
17: # products derived from this software without prior written permission.
18: #
19: # Hans Lambermont <ntpsweep@lambermont.dyndns.org>
20:
21: require 5.0; # But actually tested on 5.004 ;)
22: use Getopt::Long; # GetOptions()
23: use strict;
24:
25: my $version = 1.3;
26: (my $program = $0) =~ s%.*/(.+?)(.pl)?$%$1%;
27:
28: # Hardcoded paths/program names
29: my $ntpdate = "ntpdate";
30: my $ntpq = "ntpq";
31:
32: # no STDOUT buffering
33: $| = 1;
34:
35: my ($help, $single_host, $showpeers, $maxlevel, $strip, $askversion);
36: my $res = GetOptions("help!" => \$help,
37: "host=s" => \$single_host,
38: "peers!" => \$showpeers,
39: "maxlevel=s" => \$maxlevel,
40: "strip=s" => \$strip,
41: "version!" => \$askversion);
42:
43: if ($askversion) {
44: print("$version\n");
45: exit 0;
46: }
47:
48: if ($help || ((@ARGV != 1) && !$single_host)) {
49: warn <<EOF;
50: This is $program, version $version
51: Copyright (C) 1999,2000 Hans Lambermont and Origin B.V. Disclaimer inside.
52:
53: Usage:
54: $program [--help|--peers|--strip <string>|--maxlevel <level>|--version] \\
55: <file>|[--host <hostname>]
56:
57: Description:
58: $program prints per host given in <file> the NTP stratum level, the
59: clock offset in seconds, the daemon version, the operating system and
60: the processor. Optionally recursing through all peers.
61:
62: Options:
63: --help
64: Print this short help text and exit.
65: --version
66: Print version ($version) and exit.
67: <file>
68: Specify hosts file. File format is one hostname or ip number per line.
69: Lines beginning with # are considered as comment.
70: --host <hostname>
71: Speficy a single host, bypassing the need for a hosts file.
72: --peers
73: Recursively list all peers a host synchronizes to.
74: An '= ' before a peer means a loop. Recursion stops here.
75: --maxlevel <level>
76: Traverse peers up to this level (4 is a reasonable number).
77: --strip <string>
78: Strip <string> from hostnames.
79:
80: Examples:
81: $program myhosts.txt --strip .foo.com
82: $program --host some.host --peers --maxlevel 4
83: EOF
84: exit 1;
85: }
86:
87: my $hostsfile = shift;
88: my (@hosts, @known_hosts);
89: my (%known_host_info, %known_host_peers);
90:
91: sub read_hosts()
92: {
93: local *HOSTS;
94: open (HOSTS, $hostsfile) ||
95: die "$program: FATAL: unable to read $hostsfile: $!\n";
96: while (<HOSTS>) {
97: next if /^\s*(#|$)/; # comment/empty
98: chomp;
99: push(@hosts, $_);
100: }
101: close(HOSTS);
102: }
103:
104: # translate IP to hostname if possible
105: sub ip2name {
106: my($ip) = @_;
107: my($addr, $name, $aliases, $addrtype, $length, @addrs);
108: $addr = pack('C4', split(/\./, $ip));
109: ($name, $aliases, $addrtype, $length, @addrs) = gethostbyaddr($addr, 2);
110: if ($name) {
111: # return lower case name
112: return("\L$name");
113: } else {
114: return($ip);
115: }
116: }
117:
118: # item_in_list($item, @list): returns 1 if $item is in @list, 0 if not
119: sub item_in_list {
120: my($item, @list) = @_;
121: my($i);
122: foreach $i (@list) {
123: return 1 if ($item eq $i);
124: }
125: return 0;
126: }
127:
128: sub scan_host($;$;$) {
129: my($host, $level, @trace) = @_;
130: my $stratum = 0;
131: my $offset = 0;
132: my $daemonversion = "";
133: my $system = "";
134: my $processor = "";
135: my @peers;
136: my $known_host = 0;
137:
138: if (&item_in_list($host, @known_hosts)) {
139: $known_host = 1;
140: } else {
141: # ntpdate part
142: open(NTPDATE, "$ntpdate -bd $host 2>/dev/null |") ||
143: die "Cannot open ntpdate pipe: $!\n";
144: while (<NTPDATE>) {
145: /^stratum\s+(\d+).*$/ && do {
146: $stratum = $1;
147: };
148: /^offset\s+([0-9.-]+)$/ && do {
149: $offset = $1;
150: };
151: }
152: close(NTPDATE);
153:
154: # got answers ? If so, go on.
155: if ($stratum) {
156: # ntpq part
157: my $ntpqparams = "-c 'rv 0 processor,system,daemon_version'";
158: open(NTPQ, "$ntpq $ntpqparams $host 2>/dev/null |") ||
159: die "Cannot open ntpq pipe: $!\n";
160: while (<NTPQ>) {
161: /daemon_version="(.*)"/ && do {
162: $daemonversion = $1;
163: };
164: /system="([^"]*)"/ && do {
165: $system = $1;
166: };
167: /processor="([^"]*)"/ && do {
168: $processor = $1;
169: };
170: }
171: close(NTPQ);
172:
173: # Shorten daemon_version string.
174: $daemonversion =~ s/(;|Mon|Tue|Wed|Thu|Fri|Sat|Sun).*$//;
175: $daemonversion =~ s/version=//;
176: $daemonversion =~ s/(x|)ntpd //;
177: $daemonversion =~ s/(\(|\))//g;
178: $daemonversion =~ s/beta/b/;
179: $daemonversion =~ s/multicast/mc/;
180:
181: # Shorten system string
182: $system =~ s/UNIX\///;
183: $system =~ s/RELEASE/r/;
184: $system =~ s/CURRENT/c/;
185:
186: # Shorten processor string
187: $processor =~ s/unknown//;
188: }
189:
190: # got answers ? If so, go on.
191: if ($daemonversion) {
192: # ntpq again, find out the peers this time
193: if ($showpeers) {
194: my $ntpqparams = "-pn";
195: open(NTPQ, "$ntpq $ntpqparams $host 2>/dev/null |") ||
196: die "Cannot open ntpq pipe: $!\n";
197: while (<NTPQ>) {
198: /^No association ID's returned$/ && do {
199: last;
200: };
201: /^ remote/ && do {
202: next;
203: };
204: /^==/ && do {
205: next;
206: };
207: /^( |x|\.|-|\+|#|\*|o)([^ ]+)/ && do {
208: push(@peers, ip2name($2));
209: next;
210: };
211: print "ERROR: $_";
212: }
213: close(NTPQ);
214: }
215: }
216:
217: # Add scanned host to known_hosts array
218: push(@known_hosts, $host);
219: if ($stratum) {
220: $known_host_info{$host} = sprintf("%2d %9.3f %-11s %-12s %s",
221: $stratum, $offset, substr($daemonversion,0,11),
222: substr($system,0,12), substr($processor,0,9));
223: } else {
224: # Stratum level 0 is consider invalid
225: $known_host_info{$host} = sprintf(" ?");
226: }
227: $known_host_peers{$host} = [@peers];
228: }
229:
230: if ($stratum || $known_host) { # Valid or known host
231: my $printhost = ' ' x $level . $host;
232: # Shorten host string
233: if ($strip) {
234: $printhost =~ s/$strip//;
235: }
236: # append number of peers in brackets if requested and valid
237: if ($showpeers && ($known_host_info{$host} ne " ?")) {
238: $printhost .= " (" . @{$known_host_peers{$host}} . ")";
239: }
240: # Finally print complete host line
241: printf("%-32s %s\n",
242: substr($printhost,0,32), $known_host_info{$host});
243: if ($showpeers && (eval($maxlevel ? $level < $maxlevel : 1))) {
244: my $peer;
245: push(@trace, $host);
246: # Loop through peers
247: foreach $peer (@{$known_host_peers{$host}}) {
248: if (&item_in_list($peer, @trace)) {
249: # we've detected a loop !
250: $printhost = ' ' x ($level + 1) . "= " . $peer;
251: # Shorten host string
252: if ($strip) {
253: $printhost =~ s/$strip//;
254: }
255: printf("%-32s %s\n",
256: substr($printhost,0,32));
257: } else {
258: if (substr($peer,0,3) ne "127") {
259: &scan_host($peer, $level + 1, @trace);
260: }
261: }
262: }
263: }
264: } else { # We did not get answers from this host
265: my $printhost = ' ' x $level . $host;
266: # Shorten host string
267: if ($strip) {
268: $printhost =~ s/$strip//;
269: }
270: printf("%-32s ?\n", substr($printhost,0,32));
271: }
272: }
273:
274: sub scan_hosts()
275: {
276: my $host;
277: for $host (@hosts) {
278: my @trace;
279: push(@trace, $host);
280: scan_host($host, 0, @trace);
281: }
282: }
283:
284: # Main program
285:
286: if ($single_host) {
287: push(@hosts, $single_host);
288: } else {
289: &read_hosts($hostsfile);
290: }
291:
292: # Print header
293: print <<EOF;
294: Host st offset(s) version system processor
295: --------------------------------+--+---------+-----------+------------+---------
296: EOF
297:
298: &scan_hosts();
299:
300: exit 0;
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to ntpsweep.in CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / ntp / scripts