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