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