xref: /freebsd/contrib/ntp/scripts/monitoring/ntploopstat (revision c0b746e5e8d9479f05b3749cbf1f73b8928719bd)
1c0b746e5SOllivier Robert#!/local/bin/perl -w--*-perl-*-
2c0b746e5SOllivier Robert;#
3c0b746e5SOllivier Robert;# ntploopstat,v 3.1 1993/07/06 01:09:11 jbj Exp
4c0b746e5SOllivier Robert;#
5c0b746e5SOllivier Robert;# Poll NTP server using NTP mode 7 loopinfo request.
6c0b746e5SOllivier Robert;# Log info and timestamp to file for processing by ntploopwatch.
7c0b746e5SOllivier Robert;#
8c0b746e5SOllivier Robert;#
9c0b746e5SOllivier Robert;# Copyright (c) 1992
10c0b746e5SOllivier Robert;# Rainer Pruy Friedrich-Alexander Universitaet Erlangen-Nuernberg
11c0b746e5SOllivier Robert;#
12c0b746e5SOllivier Robert;#################################################################
13c0b746e5SOllivier Robert;#
14c0b746e5SOllivier Robert;# The format written to the logfile is the same as used by xntpd
15c0b746e5SOllivier Robert;# for the loopstats file.
16c0b746e5SOllivier Robert;# This script however allows to gather loop filter statistics from
17c0b746e5SOllivier Robert;# remote servers where you do not have access to the loopstats logfile.
18c0b746e5SOllivier Robert;#
19c0b746e5SOllivier Robert;# Please note: Communication delays affect the accuracy of the
20c0b746e5SOllivier Robert;#              timestamps recorded. Effects from these delays will probably
21c0b746e5SOllivier Robert;#              not show up, as timestamps are recorded to the second only.
22c0b746e5SOllivier Robert;#              (Should have implemented &gettimeofday()..)
23c0b746e5SOllivier Robert;#
24c0b746e5SOllivier Robert
25c0b746e5SOllivier Robert$0 =~ s!^.*/([^/]+)$!\1!;		# beautify script name
26c0b746e5SOllivier Robert
27c0b746e5SOllivier Robert$ntpserver = 'localhost';		# default host to poll
28c0b746e5SOllivier Robert$delay = 60;				# default sampling rate
29c0b746e5SOllivier Robert				       ;# keep it shorter than minpoll (=64)
30c0b746e5SOllivier Robert				       ;# to get all values
31c0b746e5SOllivier Robert
32c0b746e5SOllivier Robertrequire "ctime.pl";
33c0b746e5SOllivier Robert;# handle bug in early ctime distributions
34c0b746e5SOllivier Robert$ENV{'TZ'} = 'MET' unless defined($ENV{'TZ'}) || $] > 4.010;
35c0b746e5SOllivier Robert
36c0b746e5SOllivier Robertif (defined(@ctime'MoY))
37c0b746e5SOllivier Robert{
38c0b746e5SOllivier Robert    *MonthName = *ctime'MoY;
39c0b746e5SOllivier Robert}
40c0b746e5SOllivier Robertelse
41c0b746e5SOllivier Robert{
42c0b746e5SOllivier Robert    @MonthName = ('Jan','Feb','Mar','Apr','May','Jun',
43c0b746e5SOllivier Robert		  'Jul','Aug','Sep','Oct','Nov','Dec');
44c0b746e5SOllivier Robert}
45c0b746e5SOllivier Robert
46c0b746e5SOllivier Robert;# this routine can be redefined to point to syslog if necessary
47c0b746e5SOllivier Robertsub msg
48c0b746e5SOllivier Robert{
49c0b746e5SOllivier Robert    return unless $verbose;
50c0b746e5SOllivier Robert
51c0b746e5SOllivier Robert    print  STDERR "$0: ";
52c0b746e5SOllivier Robert    printf STDERR @_;
53c0b746e5SOllivier Robert}
54c0b746e5SOllivier Robert
55c0b746e5SOllivier Robert;#############################################################
56c0b746e5SOllivier Robert;#
57c0b746e5SOllivier Robert;# process command line
58c0b746e5SOllivier Robert$usage = <<"E-O-S";
59c0b746e5SOllivier Robert
60c0b746e5SOllivier Robertusage:
61c0b746e5SOllivier Robert  $0 [-d<delay>] [-t<timeout>] [-l <logfile>] [-v] [ntpserver]
62c0b746e5SOllivier RobertE-O-S
63c0b746e5SOllivier Robert
64c0b746e5SOllivier Robertwhile($_ = shift)
65c0b746e5SOllivier Robert{
66c0b746e5SOllivier Robert    /^-v(\d*)$/ && ($verbose=($1 eq '') ? 1 : $1,1) && next;
67c0b746e5SOllivier Robert    /^-d(\d*)$/ &&
68c0b746e5SOllivier Robert	do {
69c0b746e5SOllivier Robert	    ($1 ne '') && ($delay = $1,1) && next;
70c0b746e5SOllivier Robert	    @ARGV || die("$0: delay value missing after -d\n$usage");
71c0b746e5SOllivier Robert	    $delay = shift;
72c0b746e5SOllivier Robert	    ($delay  >= 0) || die("$0: bad delay value \"$delay\"\n$usage");
73c0b746e5SOllivier Robert	    next;
74c0b746e5SOllivier Robert	};
75c0b746e5SOllivier Robert    /^-l$/ &&
76c0b746e5SOllivier Robert	do {
77c0b746e5SOllivier Robert	    @ARGV || die("$0: logfile missing after -l\n$usage");
78c0b746e5SOllivier Robert	    $logfile = shift;
79c0b746e5SOllivier Robert	    next;
80c0b746e5SOllivier Robert	};
81c0b746e5SOllivier Robert    /^-t(\d*(\.\d*)?)$/ &&
82c0b746e5SOllivier Robert	do {
83c0b746e5SOllivier Robert	    ($1 ne '') && ($timeout = $1,1) && next;
84c0b746e5SOllivier Robert	    @ARGV || die("$0: timeout value missing after -t\n$usage\n");
85c0b746e5SOllivier Robert	    $timeout = shift;
86c0b746e5SOllivier Robert	    ($timeout > 0) ||
87c0b746e5SOllivier Robert		die("$0: bad timeout value \"$timeout\"\n$usage");
88c0b746e5SOllivier Robert	    next;
89c0b746e5SOllivier Robert	};
90c0b746e5SOllivier Robert
91c0b746e5SOllivier Robert    /^-/ && die("$0: unknown option \"$_\"\n$usage");
92c0b746e5SOllivier Robert
93c0b746e5SOllivier Robert    ;# any other argument is server to poll
94c0b746e5SOllivier Robert    $ntpserver = $_;
95c0b746e5SOllivier Robert    last;
96c0b746e5SOllivier Robert}
97c0b746e5SOllivier Robert
98c0b746e5SOllivier Robertif (@ARGV)
99c0b746e5SOllivier Robert{
100c0b746e5SOllivier Robert    warn("unexpected arguments: ".join(" ",@ARGV).".\n");
101c0b746e5SOllivier Robert    die("$0: too many servers specified\n$usage");
102c0b746e5SOllivier Robert}
103c0b746e5SOllivier Robert
104c0b746e5SOllivier Robert;# logfile defaults to include server name
105c0b746e5SOllivier Robert;# The name of the current month is appended and
106c0b746e5SOllivier Robert;# the file is opened and closed for each sample.
107c0b746e5SOllivier Robert;#
108c0b746e5SOllivier Robert$logfile = "loopstats:$ntpserver." unless defined($logfile);
109c0b746e5SOllivier Robert$timeout = 12.0 unless defined($timeout); # wait $timeout seconds for reply
110c0b746e5SOllivier Robert
111c0b746e5SOllivier Robert$MAX_FAIL = 60;				# give up after $MAX_FAIL failed polls
112c0b746e5SOllivier Robert
113c0b746e5SOllivier Robert
114c0b746e5SOllivier Robert$MJD_1970 = 40587;
115c0b746e5SOllivier Robert
116c0b746e5SOllivier Robertif (eval 'require "syscall.ph";')
117c0b746e5SOllivier Robert{
118c0b746e5SOllivier Robert    if (defined(&SYS_gettimeofday))
119c0b746e5SOllivier Robert    {
120c0b746e5SOllivier Robert	;# assume standard
121c0b746e5SOllivier Robert 	;# gettimeofday(struct timeval *tp,struct timezone *tzp)
122c0b746e5SOllivier Robert	;# syntax for gettimeofday syscall
123c0b746e5SOllivier Robert 	;# tzp = NULL -> undef
124c0b746e5SOllivier Robert	;# tp = (long,long)
125c0b746e5SOllivier Robert	eval 'sub time { local($tz) = pack("LL",0,0);
126c0b746e5SOllivier Robert              (&msg("gettimeofday failed: $!\n"),
127c0b746e5SOllivier Robert	      return (time))
128c0b746e5SOllivier Robert	      unless syscall(&SYS_gettimeofday,$tz,undef) == 0;
129c0b746e5SOllivier Robert              local($s,$us) = unpack("LL",$tz);
130c0b746e5SOllivier Robert              return $s + $us/1000000; }';
131c0b746e5SOllivier Robert	local($t1,$t2,$t3);
132c0b746e5SOllivier Robert	$t1 = time;
133c0b746e5SOllivier Robert	eval '$t2 = &time;';
134c0b746e5SOllivier Robert	$t3 = time;
135c0b746e5SOllivier Robert	die("$0: gettimeofday failed: $@.\n") if defined($@) && $@;
136c0b746e5SOllivier Robert	die("$0: gettimeofday inconsistency time=$t1,gettimeofday=$t2,time=$t2\n")
137c0b746e5SOllivier Robert	    if (int($t1) != int($t2) && int($t3) != int($t2));
138c0b746e5SOllivier Robert	&msg("Using gettimeofday for timestamps\n");
139c0b746e5SOllivier Robert    }
140c0b746e5SOllivier Robert    else
141c0b746e5SOllivier Robert    {
142c0b746e5SOllivier Robert	warn("No gettimeofday syscall found - using time builtin for timestamps\n");
143c0b746e5SOllivier Robert        eval 'sub time { return time; }';
144c0b746e5SOllivier Robert    }
145c0b746e5SOllivier Robert}
146c0b746e5SOllivier Robertelse
147c0b746e5SOllivier Robert{
148c0b746e5SOllivier Robert    warn("No syscall.ph file found - using time builtin for timestamps\n");
149c0b746e5SOllivier Robert    eval 'sub time { return time; }';
150c0b746e5SOllivier Robert}
151c0b746e5SOllivier Robert
152c0b746e5SOllivier Robert
153c0b746e5SOllivier Robert;#------------------+
154c0b746e5SOllivier Robert;# from ntp_request.h
155c0b746e5SOllivier Robert;#------------------+
156c0b746e5SOllivier Robert
157c0b746e5SOllivier Robert;# NTP mode 7 packet format:
158c0b746e5SOllivier Robert;#	Byte 1:     ResponseBit MoreBit Version(3bit) Mode(3bit)==7
159c0b746e5SOllivier Robert;#      Byte 2:     AuthBit Sequence #   - 0 - 127 see MoreBit
160c0b746e5SOllivier Robert;#      Byte 3:     Implementation #
161c0b746e5SOllivier Robert;#      Byte 4:     Request Code
162c0b746e5SOllivier Robert;#
163c0b746e5SOllivier Robert;#      Short 1:    Err(3bit) NumItems(12bit)
164c0b746e5SOllivier Robert;#      Short 2:    MBZ(3bit)=0 DataItemSize(12bit)
165c0b746e5SOllivier Robert;#      0 - 500 byte Data
166c0b746e5SOllivier Robert;#  if AuthBit is set:
167c0b746e5SOllivier Robert;#      Long:       KeyId
168c0b746e5SOllivier Robert;#      2xLong:     AuthCode
169c0b746e5SOllivier Robert
170c0b746e5SOllivier Robert;#
171c0b746e5SOllivier Robert$IMPL_XNTPD  = 2;
172c0b746e5SOllivier Robert$REQ_LOOP_INFO = 8;
173c0b746e5SOllivier Robert
174c0b746e5SOllivier Robert
175c0b746e5SOllivier Robert;# request packet for REQ_LOOP_INFO:
176c0b746e5SOllivier Robert;#     B1:  RB=0 MB=0 V=2 M=7
177c0b746e5SOllivier Robert;#     B2:  S# = 0
178c0b746e5SOllivier Robert;#     B3:  I# = IMPL_XNTPD
179c0b746e5SOllivier Robert;#     B4:  RC = REQ_LOOP_INFO
180c0b746e5SOllivier Robert;#     S1:  E=0 NI=0
181c0b746e5SOllivier Robert;#     S2:  MBZ=0 DIS=0
182c0b746e5SOllivier Robert;#     data:  32 byte 0 padding
183c0b746e5SOllivier Robert;#            8byte timestamp if encryption, 0 padding otherwise
184c0b746e5SOllivier Robert$loopinfo_reqpkt =
185c0b746e5SOllivier Robert    pack("CCCC nn x32 x8", 0x17, 0, $IMPL_XNTPD, $REQ_LOOP_INFO, 0, 0);
186c0b746e5SOllivier Robert
187c0b746e5SOllivier Robert;# ignore any auth data in packets
188c0b746e5SOllivier Robert$loopinfo_response_size =
189c0b746e5SOllivier Robert    1+1+1+1+2+2			# header size like request pkt
190c0b746e5SOllivier Robert    + 8				# l_fp last_offset
191c0b746e5SOllivier Robert    + 8				# l_fp drift_comp
192c0b746e5SOllivier Robert    + 4				# u_long compliance
193c0b746e5SOllivier Robert    + 4				# u_long watchdog_timer
194c0b746e5SOllivier Robert    ;
195c0b746e5SOllivier Robert$loopinfo_response_fmt    = "C4n2N2N2NN";
196c0b746e5SOllivier Robert$loopinfo_response_fmt_v2 = "C4n2N2N2N2N";
197c0b746e5SOllivier Robert
198c0b746e5SOllivier Robert;#
199c0b746e5SOllivier Robert;# prepare connection to server
200c0b746e5SOllivier Robert;#
201c0b746e5SOllivier Robert
202c0b746e5SOllivier Robert;# workaround for broken socket.ph on dynix_ptx
203c0b746e5SOllivier Roberteval 'sub INTEL {1;}' unless defined(&INTEL);
204c0b746e5SOllivier Roberteval 'sub ATT {1;}'  unless defined(&ATT);
205c0b746e5SOllivier Robert
206c0b746e5SOllivier Robertrequire "sys/socket.ph";
207c0b746e5SOllivier Robert
208c0b746e5SOllivier Robertrequire 'netinet/in.ph';
209c0b746e5SOllivier Robert
210c0b746e5SOllivier Robert;# if you do not have netinet/in.ph enable the following lines
211c0b746e5SOllivier Robert;#eval 'sub INADDR_ANY { 0x00000000; }' unless defined(&INADDR_ANY);
212c0b746e5SOllivier Robert;#eval 'sub IPPRORO_UDP { 17; }' unless defined(&IPPROTO_UDP);
213c0b746e5SOllivier Robert
214c0b746e5SOllivier Robertif ($ntpserver =~ /^((0x?)?\w+)\.((0x?)?\w+)\.((0x?)?\w+)\.((0x?)?\w+)$/)
215c0b746e5SOllivier Robert{
216c0b746e5SOllivier Robert    local($a,$b,$c,$d) = ($1,$3,$5,$7);
217c0b746e5SOllivier Robert    $a = oct($a) if defined($2);
218c0b746e5SOllivier Robert    $b = oct($b) if defined($4);
219c0b746e5SOllivier Robert    $c = oct($c) if defined($6);
220c0b746e5SOllivier Robert    $d = oct($d) if defined($8);
221c0b746e5SOllivier Robert    $server_addr = pack("C4", $a,$b,$c,$d);
222c0b746e5SOllivier Robert
223c0b746e5SOllivier Robert    $server_mainname
224c0b746e5SOllivier Robert	= (gethostbyaddr($server_addr,&AF_INET))[$[] || $ntpserver;
225c0b746e5SOllivier Robert}
226c0b746e5SOllivier Robertelse
227c0b746e5SOllivier Robert{
228c0b746e5SOllivier Robert    ($server_mainname,$server_addr)
229c0b746e5SOllivier Robert	= (gethostbyname($ntpserver))[$[,$[+4];
230c0b746e5SOllivier Robert
231c0b746e5SOllivier Robert    die("$0: host \"$ntpserver\" is unknown\n")
232c0b746e5SOllivier Robert	unless defined($server_addr);
233c0b746e5SOllivier Robert}
234c0b746e5SOllivier Robert&msg ("Address of server \"$ntpserver\" is \"%d.%d.%d.%d\"\n",
235c0b746e5SOllivier Robert      unpack("C4",$server_addr));
236c0b746e5SOllivier Robert
237c0b746e5SOllivier Robert$proto_udp = (getprotobyname('udp'))[$[+2] || &IPPROTO_UDP;
238c0b746e5SOllivier Robert
239c0b746e5SOllivier Robert$ntp_port =
240c0b746e5SOllivier Robert    (getservbyname('ntp','udp'))[$[+2] ||
241c0b746e5SOllivier Robert    (warn "Could not get port number for service \"ntp/udp\" using 123\n"),
242c0b746e5SOllivier Robert    ($ntp_port=123);
243c0b746e5SOllivier Robert
244c0b746e5SOllivier Robert;#
245c0b746e5SOllivier Robert0 && &SOCK_DGRAM;		# satisfy perl -w ...
246c0b746e5SOllivier Robertsocket(S, &AF_INET, &SOCK_DGRAM, $proto_udp) ||
247c0b746e5SOllivier Robert    die("Cannot open socket: $!\n");
248c0b746e5SOllivier Robert
249c0b746e5SOllivier Robertbind(S, pack("S n N x8", &AF_INET, 0, &INADDR_ANY)) ||
250c0b746e5SOllivier Robert    die("Cannot bind: $!\n");
251c0b746e5SOllivier Robert
252c0b746e5SOllivier Robert($my_port, $my_addr) = (unpack("S n a4 x8",getsockname(S)))[$[+1,$[+2];
253c0b746e5SOllivier Robert
254c0b746e5SOllivier Robert&msg("Listening at address %d.%d.%d.%d port %d\n",
255c0b746e5SOllivier Robert     unpack("C4",$my_addr), $my_port);
256c0b746e5SOllivier Robert
257c0b746e5SOllivier Robert$server_inaddr = pack("Sna4x8", &AF_INET, $ntp_port, $server_addr);
258c0b746e5SOllivier Robert
259c0b746e5SOllivier Robert;############################################################
260c0b746e5SOllivier Robert;#
261c0b746e5SOllivier Robert;# the main loop:
262c0b746e5SOllivier Robert;#	send request
263c0b746e5SOllivier Robert;#      get reply
264c0b746e5SOllivier Robert;#      wait til next sample time
265c0b746e5SOllivier Robert
266c0b746e5SOllivier Robertundef($lasttime);
267c0b746e5SOllivier Robert$lostpacket = 0;
268c0b746e5SOllivier Robert
269c0b746e5SOllivier Robertwhile(1)
270c0b746e5SOllivier Robert{
271c0b746e5SOllivier Robert    $stime = &time;
272c0b746e5SOllivier Robert
273c0b746e5SOllivier Robert    &msg("Sending request $stime...\n");
274c0b746e5SOllivier Robert
275c0b746e5SOllivier Robert    $ret = send(S,$loopinfo_reqpkt,0,$server_inaddr);
276c0b746e5SOllivier Robert
277c0b746e5SOllivier Robert    if (! defined($ret) || $ret < length($loopinfo_reqpkt))
278c0b746e5SOllivier Robert    {
279c0b746e5SOllivier Robert	warn("$0: send failed ret=($ret): $!\n");
280c0b746e5SOllivier Robert	$fail++;
281c0b746e5SOllivier Robert	next;
282c0b746e5SOllivier Robert    }
283c0b746e5SOllivier Robert
284c0b746e5SOllivier Robert    &msg("Waiting for reply...\n");
285c0b746e5SOllivier Robert
286c0b746e5SOllivier Robert    $mask = ""; vec($mask,fileno(S),1) = 1;
287c0b746e5SOllivier Robert    $ret = select($mask,undef,undef,$timeout);
288c0b746e5SOllivier Robert
289c0b746e5SOllivier Robert    if (! defined($ret))
290c0b746e5SOllivier Robert    {
291c0b746e5SOllivier Robert	warn("$0: select failed: $!\n");
292c0b746e5SOllivier Robert	$fail++;
293c0b746e5SOllivier Robert	next;
294c0b746e5SOllivier Robert    }
295c0b746e5SOllivier Robert    elsif ($ret == 0)
296c0b746e5SOllivier Robert    {
297c0b746e5SOllivier Robert	warn("$0: request to $ntpserver timed out ($timeout seconds)\n");
298c0b746e5SOllivier Robert	;# do not count this event as failure
299c0b746e5SOllivier Robert	;# it usually this happens due to dropped udp packets on noisy and
300c0b746e5SOllivier Robert	;# havily loaded lines, so just try again;
301c0b746e5SOllivier Robert	$lostpacket = 1;
302c0b746e5SOllivier Robert	next;
303c0b746e5SOllivier Robert    }
304c0b746e5SOllivier Robert
305c0b746e5SOllivier Robert    &msg("Receiving reply...\n");
306c0b746e5SOllivier Robert
307c0b746e5SOllivier Robert    $len = 520;				# max size of a mode 7 packet
308c0b746e5SOllivier Robert    $reply = "";			# just make it defined for -w
309c0b746e5SOllivier Robert    $ret = recv(S,$reply,$len,0);
310c0b746e5SOllivier Robert
311c0b746e5SOllivier Robert    if (!defined($ret))
312c0b746e5SOllivier Robert    {
313c0b746e5SOllivier Robert	warn("$0: recv failed: $!\n");
314c0b746e5SOllivier Robert	$fail++;
315c0b746e5SOllivier Robert	next;
316c0b746e5SOllivier Robert    }
317c0b746e5SOllivier Robert
318c0b746e5SOllivier Robert    $etime = &time;
319c0b746e5SOllivier Robert    &msg("Received at\t$etime\n");
320c0b746e5SOllivier Robert
321c0b746e5SOllivier Robert    ;#$time = ($stime + $etime) / 2; # symmetric delay assumed
322c0b746e5SOllivier Robert    $time = $etime;		# the above assumption breaks for X25
323c0b746e5SOllivier Robert			       ;# so taking etime makes timestamps be a
324c0b746e5SOllivier Robert			       ;# little late, but keeps them increasing
325c0b746e5SOllivier Robert			       ;# monotonously
326c0b746e5SOllivier Robert
327c0b746e5SOllivier Robert    &msg(sprintf("Reply from %d.%d.%d.%d took %f seconds\n",
328c0b746e5SOllivier Robert		 (unpack("SnC4",$ret))[$[+2 .. $[+5], ($etime - $stime)));
329c0b746e5SOllivier Robert
330c0b746e5SOllivier Robert    if ($len < $loopinfo_response_size)
331c0b746e5SOllivier Robert    {
332c0b746e5SOllivier Robert	warn("$0: short packet ($len bytes) received ($loopinfo_response_size bytes expected\n");
333c0b746e5SOllivier Robert	$fail++;
334c0b746e5SOllivier Robert	next;
335c0b746e5SOllivier Robert    }
336c0b746e5SOllivier Robert
337c0b746e5SOllivier Robert    ($b1,$b2,$b3,$b4,$s1,$s2,
338c0b746e5SOllivier Robert     $offset_i,$offset_f,$drift_i,$drift_f,$compl,$watchdog)
339c0b746e5SOllivier Robert	= unpack($loopinfo_response_fmt,$reply);
340c0b746e5SOllivier Robert
341c0b746e5SOllivier Robert    ;# check reply
342c0b746e5SOllivier Robert    if (($s1 >> 12) != 0)	      # error !
343c0b746e5SOllivier Robert    {
344c0b746e5SOllivier Robert	die("$0: got error reply ".($s1>>12)."\n");
345c0b746e5SOllivier Robert    }
346c0b746e5SOllivier Robert    if (($b1 != 0x97 && $b1 != 0x9f) || # Reply NotMore V=2 M=7
347c0b746e5SOllivier Robert	($b2 != 0 && $b2 != 0x80) ||	# S=0 Auth no/yes
348c0b746e5SOllivier Robert	$b3 != $IMPL_XNTPD ||		# ! IMPL_XNTPD
349c0b746e5SOllivier Robert	$b4 != $REQ_LOOP_INFO ||	# Ehh.. not loopinfo reply ?
350c0b746e5SOllivier Robert	$s1 != 1 ||			# ????
351c0b746e5SOllivier Robert	($s2 != 24 && $s2 != 28)	#
352c0b746e5SOllivier Robert	)
353c0b746e5SOllivier Robert    {
354c0b746e5SOllivier Robert	warn("$0: Bad/unexpected reply from server:\n");
355c0b746e5SOllivier Robert	warn("  \"".unpack("H*",$reply)."\"\n");
356c0b746e5SOllivier Robert	warn("   ".sprintf("b1=%x b2=%x b3=%x b4=%x s1=%d s2=%d\n",
357c0b746e5SOllivier Robert			   $b1,$b2,$b3,$b4,$s1,$s2));
358c0b746e5SOllivier Robert	$fail++;
359c0b746e5SOllivier Robert	next;
360c0b746e5SOllivier Robert    }
361c0b746e5SOllivier Robert    elsif ($s2 == 28)
362c0b746e5SOllivier Robert    {
363c0b746e5SOllivier Robert      ;# seems to be a version 2 xntpd
364c0b746e5SOllivier Robert      ($b1,$b2,$b3,$b4,$s1,$s2,
365c0b746e5SOllivier Robert       $offset_i,$offset_f,$drift_i,$drift_f,$compl_i,$compl_f,$watchdog)
366c0b746e5SOllivier Robert	  = unpack($loopinfo_response_fmt_v2,$reply);
367c0b746e5SOllivier Robert      $compl = &lfptoa($compl_i, $compl_f);
368c0b746e5SOllivier Robert    }
369c0b746e5SOllivier Robert
370c0b746e5SOllivier Robert    $time -= $watchdog;
371c0b746e5SOllivier Robert
372c0b746e5SOllivier Robert    $offset = &lfptoa($offset_i, $offset_f);
373c0b746e5SOllivier Robert    $drift  = &lfptoa($drift_i, $drift_f);
374c0b746e5SOllivier Robert
375c0b746e5SOllivier Robert    &log($time,$offset,$drift,$compl) && ($fail = 0);;
376c0b746e5SOllivier Robert}
377c0b746e5SOllivier Robertcontinue
378c0b746e5SOllivier Robert{
379c0b746e5SOllivier Robert    die("$0: Too many failures - terminating\n") if $fail > $MAX_FAIL;
380c0b746e5SOllivier Robert    &msg("Sleeping " . ($lostpacket ? ($delay / 2) : $delay) . " seconds...\n");
381c0b746e5SOllivier Robert
382c0b746e5SOllivier Robert    sleep($lostpacket ? ($delay / 2) : $delay);
383c0b746e5SOllivier Robert    $lostpacket = 0;
384c0b746e5SOllivier Robert}
385c0b746e5SOllivier Robert
386c0b746e5SOllivier Robertsub log
387c0b746e5SOllivier Robert{
388c0b746e5SOllivier Robert    local($time,$offs,$freq,$cmpl) = @_;
389c0b746e5SOllivier Robert    local($y,$m,$d);
390c0b746e5SOllivier Robert    local($fname,$suff) = ($logfile);
391c0b746e5SOllivier Robert
392c0b746e5SOllivier Robert
393c0b746e5SOllivier Robert    ;# silently drop sample if distance to last sample is too low
394c0b746e5SOllivier Robert    if (defined($lasttime) && ($lasttime + 2) >= $time)
395c0b746e5SOllivier Robert    {
396c0b746e5SOllivier Robert      &msg("Dropped packet - old sample\n");
397c0b746e5SOllivier Robert      return 1;
398c0b746e5SOllivier Robert    }
399c0b746e5SOllivier Robert
400c0b746e5SOllivier Robert    ;# $suff determines which samples end up in the same file
401c0b746e5SOllivier Robert    ;# could have used $year (;-) or WeekOfYear, DayOfYear,....
402c0b746e5SOllivier Robert    ;# Change it to your suit...
403c0b746e5SOllivier Robert
404c0b746e5SOllivier Robert    ($d,$m,$y) = (localtime($time))[$[+3 .. $[+5];
405c0b746e5SOllivier Robert    $suff = sprintf("%04d%02d%02d",$y+1900,$m+1,$d);
406c0b746e5SOllivier Robert    $fname .= $suff;
407c0b746e5SOllivier Robert    if (!open(LOG,">>$fname"))
408c0b746e5SOllivier Robert    {
409c0b746e5SOllivier Robert	warn("$0: open($fname) failed: $!\n");
410c0b746e5SOllivier Robert	$fail++;
411c0b746e5SOllivier Robert	return 0;
412c0b746e5SOllivier Robert    }
413c0b746e5SOllivier Robert    else
414c0b746e5SOllivier Robert    {
415c0b746e5SOllivier Robert	;# file format
416c0b746e5SOllivier Robert	;#          MJD seconds offset drift compliance
417c0b746e5SOllivier Robert	printf LOG ("%d %.3lf %.8lf %.7lf %d\n",
418c0b746e5SOllivier Robert		    int($time/86400)+$MJD_1970,
419c0b746e5SOllivier Robert		    $time - int($time/86400) * 86400,
420c0b746e5SOllivier Robert		    $offs,$freq,$cmpl);
421c0b746e5SOllivier Robert	close(LOG);
422c0b746e5SOllivier Robert	$lasttime = $time;
423c0b746e5SOllivier Robert    }
424c0b746e5SOllivier Robert    return 1;
425c0b746e5SOllivier Robert}
426c0b746e5SOllivier Robert
427c0b746e5SOllivier Robert;# see ntp_fp.h to understand this
428c0b746e5SOllivier Robertsub lfptoa
429c0b746e5SOllivier Robert{
430c0b746e5SOllivier Robert    local($i,$f) = @_;
431c0b746e5SOllivier Robert    local($sign) = 1;
432c0b746e5SOllivier Robert
433c0b746e5SOllivier Robert
434c0b746e5SOllivier Robert    if ($i & 0x80000000)
435c0b746e5SOllivier Robert    {
436c0b746e5SOllivier Robert	if ($f == 0)
437c0b746e5SOllivier Robert	{
438c0b746e5SOllivier Robert	    $i = -$i;
439c0b746e5SOllivier Robert	}
440c0b746e5SOllivier Robert	else
441c0b746e5SOllivier Robert	{
442c0b746e5SOllivier Robert	    $f = -$f;
443c0b746e5SOllivier Robert	    $i = ~$i;
444c0b746e5SOllivier Robert	    $i += 1;			# 2s complement
445c0b746e5SOllivier Robert	}
446c0b746e5SOllivier Robert	$sign = -1;
447c0b746e5SOllivier Robert	;#print "NEG: $i $f\n";
448c0b746e5SOllivier Robert    }
449c0b746e5SOllivier Robert    else
450c0b746e5SOllivier Robert    {
451c0b746e5SOllivier Robert	;#print "POS: $i $f\n";
452c0b746e5SOllivier Robert    }
453c0b746e5SOllivier Robert    ;# unlike xntpd I have perl do the dirty work.
454c0b746e5SOllivier Robert    ;# Using floats here may affect precision, but
455c0b746e5SOllivier Robert    ;# currently these bits aren't significant anyway
456c0b746e5SOllivier Robert    return $sign * ($i + $f/2**32);
457c0b746e5SOllivier Robert}
458