Annotation of embedaddon/ntp/scripts/monitoring/ntptrap, revision 1.1
1.1 ! misho 1: #!/local/bin/perl --*-perl-*-
! 2: ;#
! 3: ;# ntptrap,v 3.1 1993/07/06 01:09:15 jbj Exp
! 4: ;#
! 5: ;# a client for the xntp mode 6 trap mechanism
! 6: ;#
! 7: ;# Copyright (c) 1992
! 8: ;# Rainer Pruy Friedrich-Alexander Universitaet Erlangen-Nuernberg
! 9: ;#
! 10: ;#
! 11: ;#############################################################
! 12: $0 =~ s!^.*/([^/]+)$!$1!; # strip to filename
! 13: ;# enforce STDOUT and STDERR to be line buffered
! 14: $| = 1;
! 15: select((select(STDERR),$|=1)[$[]);
! 16:
! 17: ;#######################################
! 18: ;# load utility routines and definitions
! 19: ;#
! 20: require('ntp.pl'); # implementation of the NTP protocol
! 21: use Socket;
! 22:
! 23: #eval { require('sys/socket.ph'); require('netinet/in.ph') unless defined(&INADDR_ANY); } ||
! 24: #do {
! 25: #die("$0: $@") unless $[ == index($@, "Can't locate ");
! 26: #warn "$0: $@";
! 27: #warn "$0: supplying some default definitions\n";
! 28: #eval 'sub INADDR_ANY { 0; } sub AF_INET {2;} sub SOCK_DGRAM {2;} 1;' || die "$0: $@";
! 29: #};
! 30: require('getopts.pl'); # option parsing
! 31: require('ctime.pl'); # date/time formatting
! 32:
! 33: ;######################################
! 34: ;# define some global constants
! 35: ;#
! 36: $BASE_TIMEOUT=10;
! 37: $FRAG_TIMEOUT=10;
! 38: $MAX_TRY = 5;
! 39: $REFRESH_TIME=60*15; # 15 minutes (server uses 1 hour)
! 40: $ntp'timeout = $FRAG_TIMEOUT; #';
! 41: $ntp'timeout if 0;
! 42:
! 43: ;######################################
! 44: ;# now process options
! 45: ;#
! 46: sub usage
! 47: {
! 48: die("usage: $0 [-n] [-p <port>] [-l <logfile>] [host] ...\n");
! 49: }
! 50:
! 51: $opt_l = "/dev/null"; # where to write debug messages to
! 52: $opt_p = 0; # port to use locally - (0 does mean: will be choosen by kernel)
! 53:
! 54: &usage unless &Getopts('l:p:');
! 55: &Getopts if 0; # make -w happy
! 56:
! 57: @Hosts = ($#ARGV < $[) ? ("localhost") : @ARGV;
! 58:
! 59: ;# setup for debug output
! 60: $DEBUGFILE=$opt_l;
! 61: $DEBUGFILE="&STDERR" if $DEBUGFILE eq '-';
! 62:
! 63: open(DEBUG,">>$DEBUGFILE") || die("Cannot open \"$DEBUGFILE\": $!\n");
! 64: select((select(DEBUG),$|=1)[$[]);
! 65:
! 66: ;# &log prints a single trap record (adding a (local) time stamp)
! 67: sub log
! 68: {
! 69: chop($date=&ctime(time));
! 70: print "$date ",@_,"\n";
! 71: }
! 72:
! 73: sub debug
! 74: {
! 75: print DEBUG @_,"\n";
! 76: }
! 77: ;#
! 78: $proto_udp = (getprotobyname('udp'))[$[+2] ||
! 79: (warn("$0: Could not get protocoll number for 'udp' using 17"), 17);
! 80:
! 81: $ntp_port = (getservbyname('ntp','udp'))[$[+2] ||
! 82: (warn("$0: Could not get port number for service ntp/udp using 123"), 123);
! 83:
! 84: ;#
! 85: socket(S, &AF_INET, &SOCK_DGRAM, $proto_udp) || die("Cannot open socket: $!\n");
! 86:
! 87: ;#
! 88: bind(S, pack("S n a4 x8", &AF_INET, $opt_p, &INADDR_ANY)) ||
! 89: die("Cannot bind: $!\n");
! 90:
! 91: ($my_port, $my_addr) = (unpack("S n a4 x8",getsockname(S)))[$[+1,$[+2];
! 92: &log(sprintf("Listening at address %d.%d.%d.%d port %d",
! 93: unpack("C4",$my_addr), $my_port));
! 94:
! 95: ;# disregister with all servers in case of termination
! 96: sub cleanup
! 97: {
! 98: &log("Aborted by signal \"$_[$[]\"") if defined($_[$[]);
! 99:
! 100: foreach (@Hosts)
! 101: {
! 102: if ( ! defined($Host{$_}) )
! 103: {
! 104: print "no info for host '$_'\n";
! 105: next;
! 106: }
! 107: &ntp'send(S,31,0,"",pack("Sna4x8",&AF_INET,$ntp_port,$Host{$_})); #';
! 108: }
! 109: close(S);
! 110: exit(2);
! 111: }
! 112:
! 113: $SIG{'HUP'} = 'cleanup';
! 114: $SIG{'INT'} = 'cleanup';
! 115: $SIG{'QUIT'} = 'cleanup';
! 116: $SIG{'TERM'} = 'cleanup';
! 117:
! 118: 0 && $a && $b;
! 119: sub timeouts # sort timeout id array
! 120: {
! 121: $TIMEOUTS{$a} <=> $TIMEOUTS{$b};
! 122: }
! 123:
! 124: ;# a Request element looks like: pack("a4SC",addr,associd,op)
! 125: @Requests= ();
! 126:
! 127: ;# compute requests for set trap control msgs to each host given
! 128: {
! 129: local($name,$addr);
! 130:
! 131: foreach (@Hosts)
! 132: {
! 133: if (/^(\d+)\.(\d+)\.(\d+)\.(\d+)$/)
! 134: {
! 135: ($name,$addr) =
! 136: (gethostbyaddr(pack("C4",$1,$2,$3,$4),&AF_INET))[$[,$[+4];
! 137: unless (defined($name))
! 138: {
! 139: $name = sprintf("[[%d.%d.%d.%d]]",$1,$2,$3,$4);
! 140: $addr = pack("C4",$1,$2,$3,$4);
! 141: }
! 142: }
! 143: else
! 144: {
! 145: ($name,$addr) = (gethostbyname($_))[$[,$[+4];
! 146: unless (defined($name))
! 147: {
! 148: warn "$0: unknown host \"$_\" - ignored\n";
! 149: next;
! 150: }
! 151: }
! 152: next if defined($Host{$name});
! 153: $Host{$name} = $addr;
! 154: $Host{$_} = $addr;
! 155: push(@Requests,pack("a4SC",$addr,0,6)); # schedule a set trap request for $name
! 156: }
! 157: }
! 158:
! 159: sub hostname
! 160: {
! 161: local($addr) = @_;
! 162: return $HostName{$addr} if defined($HostName{$addr});
! 163: local($name) = gethostbyaddr($addr,&AF_INET);
! 164: &debug(sprintf("hostname(%d.%d.%d.%d) = \"%s\"",unpack("C4",$addr),$name))
! 165: if defined($name);
! 166: defined($name) && ($HostName{$addr} = $name) && (return $name);
! 167: &debug(sprintf("Failed to get name for %d.%d.%d.%d",unpack("C4",$addr)));
! 168: return sprintf("[%d.%d.%d.%d]",unpack("C4",$addr));
! 169: }
! 170:
! 171: ;# when no hosts were given on the commandline no requests have been scheduled
! 172: &usage unless (@Requests);
! 173:
! 174: &debug(sprintf("%d request(s) scheduled",scalar(@Requests)));
! 175: grep(&debug(" - ".$_),keys(%Host));
! 176:
! 177: ;# allocate variables;
! 178: $addr="";
! 179: $assoc=0;
! 180: $op = 0;
! 181: $timeout = 0;
! 182: $ret="";
! 183: %TIMEOUTS = ();
! 184: %TIMEOUT_PROCS = ();
! 185: @TIMEOUTS = ();
! 186:
! 187: $len = 512;
! 188: $buf = " " x $len;
! 189:
! 190: while (1)
! 191: {
! 192: if (@Requests || @TIMEOUTS) # if there is some work pending
! 193: {
! 194: if (@Requests)
! 195: {
! 196: ($addr,$assoc,$op) = unpack("a4SC",($req = shift(@Requests)));
! 197: &debug(sprintf("Request: %s: %s(%d)",&hostname($addr), &ntp'cntrlop_name($op), $assoc)); #';))
! 198: $ret = &ntp'send(S,$op,$assoc,"", #'(
! 199: pack("Sna4x8",&AF_INET,$ntp_port,$addr));
! 200: &set_timeout("retry-".unpack("H*",$req),time+$BASE_TIMEOUT,
! 201: sprintf("&retry(\"%s\");",unpack("H*",$req)));
! 202:
! 203: last unless (defined($ret)); # warn called by ntp'send();
! 204:
! 205: ;# if there are more requests just have a quick look for new messages
! 206: ;# otherwise grant server time for a response
! 207: $timeout = @Requests ? 0 : $BASE_TIMEOUT;
! 208: }
! 209: if ($timeout && @TIMEOUTS)
! 210: {
! 211: ;# ensure not to miss a timeout
! 212: if ($timeout + time > $TIMEOUTS{$TIMEOUTS[$[]})
! 213: {
! 214: $timeout = $TIMEOUTS{$TIMEOUTS[$[]} - time;
! 215: $timeout = 0 if $timeout < 0;
! 216: }
! 217: }
! 218: }
! 219: else
! 220: {
! 221: ;# no work yet - wait for some messages dropping in
! 222: ;# usually this will not hapen as the refresh semantic will
! 223: ;# always have a pending timeout
! 224: undef($timeout);
! 225: }
! 226:
! 227: vec($mask="",fileno(S),1) = 1;
! 228: $ret = select($mask,undef,undef,$timeout);
! 229:
! 230: warn("$0: select: $!\n"),last if $ret < 0; # give up on error return from select
! 231:
! 232: if ($ret == 0)
! 233: {
! 234: ;# timeout
! 235: if (@TIMEOUTS && time > $TIMEOUTS{$TIMEOUTS[$[]})
! 236: {
! 237: ;# handle timeout
! 238: $timeout_proc =
! 239: (delete $TIMEOUT_PROCS{$TIMEOUTS[$[]},
! 240: delete $TIMEOUTS{shift(@TIMEOUTS)})[$[];
! 241: eval $timeout_proc;
! 242: die "timeout eval (\"$timeout_proc\"): $@\n" if $@;
! 243: }
! 244: ;# else: there may be something to be sent
! 245: }
! 246: else
! 247: {
! 248: ;# data avail
! 249: $from = recv(S,$buf,$len,0);
! 250: ;# give up on error return from recv
! 251: warn("$0: recv: $!\n"), last unless (defined($from));
! 252:
! 253: $from = (unpack("Sna4",$from))[$[+2]; # keep host addr only
! 254: ;# could check for ntp_port - but who cares
! 255: &debug("-Packet from ",&hostname($from));
! 256:
! 257: ;# stuff packet into ntp mode 6 receive machinery
! 258: ($ret,$data,$status,$associd,$op,$seq,$auth_keyid) =
! 259: &ntp'handle_packet($buf,$from); # ';
! 260: &debug(sprintf("%s uses auth_keyid %d",&hostname($from),$auth_keyid)) if defined($auth_keyid);
! 261: next unless defined($ret);
! 262:
! 263: if ($ret eq "")
! 264: {
! 265: ;# handle packet
! 266: ;# simple trap response messages have neither timeout nor retries
! 267: &clear_timeout("retry-".unpack("H*",pack("a4SC",$from,$associd,$op))) unless $op == 7;
! 268: delete $RETRY{pack("a4SC",$from,$associd,$op)} unless $op == 7;
! 269:
! 270: &process_response($from,$ret,$data,$status,$associd,$op,$seq,$auth_keyid);
! 271: }
! 272: else
! 273: {
! 274: ;# some kind of error
! 275: &log(sprintf("%50s: %s: %s",(gethostbyaddr($from,&AF_INET))[$[],$ret,$data));
! 276: if ($ret ne "TIMEOUT" && $ret ne "ERROR")
! 277: {
! 278: &clear_timeout("retry-".unpack("H*",pack("a4SC",$from,$associd,$op)));
! 279: }
! 280: }
! 281: }
! 282:
! 283: }
! 284:
! 285: warn("$0: terminating\n");
! 286: &cleanup;
! 287: exit 0;
! 288:
! 289: ;##################################################
! 290: ;# timeout support
! 291: ;#
! 292: sub set_timeout
! 293: {
! 294: local($id,$time,$proc) = @_;
! 295:
! 296: $TIMEOUTS{$id} = $time;
! 297: $TIMEOUT_PROCS{$id} = $proc;
! 298: @TIMEOUTS = sort timeouts keys(%TIMEOUTS);
! 299: chop($date=&ctime($time));
! 300: &debug(sprintf("Schedule timeout \"%s\" for %s", $id, $date));
! 301: }
! 302:
! 303: sub clear_timeout
! 304: {
! 305: local($id) = @_;
! 306: delete $TIMEOUTS{$id};
! 307: delete $TIMEOUT_PROCS{$id};
! 308: @TIMEOUTS = sort timeouts keys(%TIMEOUTS);
! 309: &debug("Clear timeout \"$id\"");
! 310: }
! 311:
! 312: 0 && &refresh;
! 313: sub refresh
! 314: {
! 315: local($addr) = @_[$[];
! 316: $addr = pack("H*",$addr);
! 317: &debug(sprintf("Refreshing trap for %s", &hostname($addr)));
! 318: push(@Requests,pack("a4SC",$addr,0,6));
! 319: }
! 320:
! 321: 0 && &retry;
! 322: sub retry
! 323: {
! 324: local($tag) = @_;
! 325: $tag = pack("H*",$tag);
! 326: $RETRY{$tag} = 0 if (!defined($RETRY{$tag}));
! 327:
! 328: if (++$RETRY{$tag} > $MAX_TRY)
! 329: {
! 330: &debug(sprintf("Retry failed: %s assoc %5d op %d",
! 331: &hostname(substr($tag,$[,4)),
! 332: unpack("x4SC",$tag)));
! 333: return;
! 334: }
! 335: &debug(sprintf("Retrying: %s assoc %5d op %d",
! 336: &hostname(substr($tag,$[,4)),
! 337: unpack("x4SC",$tag)));
! 338: push(@Requests,$tag);
! 339: }
! 340:
! 341: sub process_response
! 342: {
! 343: local($from,$ret,$data,$status,$associd,$op,$seq,$auth_keyid) = @_;
! 344:
! 345: $msg="";
! 346: if ($op == 7) # trap response
! 347: {
! 348: $msg .= sprintf("%40s trap#%-5d",
! 349: &hostname($from),$seq);
! 350: &debug (sprintf("\nTrap %d associd %d:\n%s\n===============\n",$seq,$associd,$data));
! 351: if ($associd == 0) # system event
! 352: {
! 353: $msg .= " SYSTEM ";
! 354: $evnt = &ntp'SystemEvent($status); #';
! 355: $msg .= "$evnt ";
! 356: ;# for special cases add additional info
! 357: ($stratum) = ($data =~ /stratum=(\d+)/);
! 358: ($refid) = ($data =~ /refid=([\w\.]+)/);
! 359: $msg .= "stratum=$stratum refid=$refid";
! 360: if ($refid =~ /\[?(\d+)\.(\d+)\.(\d+)\.(\d+)/)
! 361: {
! 362: local($x) = (gethostbyaddr(pack("C4",$1,$2,$3,$4),&AF_INET));
! 363: $msg .= " " . $x if defined($x)
! 364: }
! 365: if ($evnt eq "event_sync_chg")
! 366: {
! 367: $msg .= sprintf("%s %s ",
! 368: &ntp'LI($status), #',
! 369: &ntp'ClockSource($status) #'
! 370: );
! 371: }
! 372: elsif ($evnt eq "event_sync/strat_chg")
! 373: {
! 374: ($peer) = ($data =~ /peer=([0-9]+)/);
! 375: $msg .= " peer=$peer";
! 376: }
! 377: elsif ($evnt eq "event_clock_excptn")
! 378: {
! 379: if (($device) = ($data =~ /device=\"([^\"]+)\"/))
! 380: {
! 381: ($cstatus) = ($data =~ /refclockstatus=0?x?([\da-fA-F]+)/);
! 382: $Cstatus = hex($cstatus);
! 383: $msg .= sprintf("- %-32s",&ntp'clock_status($Cstatus)); #');
! 384: ($timecode) = ($data =~ /timecode=\"([^\"]+)\"/);
! 385: $msg .= " \"$device\" \"$timecode\"";
! 386: }
! 387: else
! 388: {
! 389: push(@Requests,pack("a4SC",$from, $associd, 4));
! 390: }
! 391: }
! 392: }
! 393: else # peer event
! 394: {
! 395: $msg .= sprintf("peer %5d ",$associd);
! 396: ($srcadr) = ($data =~ /srcadr=\[?([\d\.]+)/);
! 397: $msg .= sprintf("%-18s %40s ", "[$srcadr]",
! 398: &hostname(pack("C4",split(/\./,$srcadr))));
! 399: $evnt = &ntp'PeerEvent($status); #';
! 400: $msg .= "$evnt ";
! 401: ;# for special cases include additional info
! 402: if ($evnt eq "event_clock_excptn")
! 403: {
! 404: if (($device) = ($data =~ /device=\"([^\"]+)\"/))
! 405: {
! 406: ;#&debug("----\n$data\n====\n");
! 407: ($cstatus) = ($data =~ /refclockstatus=0?x?([\da-fA-F]+)/);
! 408: $Cstatus = hex($cstatus);
! 409: $msg .= sprintf("- %-32s",&ntp'clock_status($Cstatus)); #');
! 410: ($timecode) = ($data =~ /timecode=\"([^\"]+)\"/);
! 411: $msg .= " \"$device\" \"$timecode\"";
! 412: }
! 413: else
! 414: {
! 415: ;# no clockvars included - post a cv request
! 416: push(@Requests,pack("a4SC",$from, $associd, 4));
! 417: }
! 418: }
! 419: elsif ($evnt eq "event_stratum_chg")
! 420: {
! 421: ($stratum) = ($data =~ /stratum=(\d+)/);
! 422: $msg .= "new stratum $stratum";
! 423: }
! 424: }
! 425: }
! 426: elsif ($op == 6) # set trap resonse
! 427: {
! 428: &debug("Set trap ok from ",&hostname($from));
! 429: &set_timeout("refresh-".unpack("H*",$from),time+$REFRESH_TIME,
! 430: sprintf("&refresh(\"%s\");",unpack("H*",$from)));
! 431: return;
! 432: }
! 433: elsif ($op == 4) # read clock variables response
! 434: {
! 435: ;# status of clock
! 436: $msg .= sprintf(" %40s ", &hostname($from));
! 437: if ($associd == 0)
! 438: {
! 439: $msg .= "system clock status: ";
! 440: }
! 441: else
! 442: {
! 443: $msg .= sprintf("peer %5d clock",$associd);
! 444: }
! 445: $msg .= sprintf("%-32s",&ntp'clock_status($status)); #');
! 446: ($device) = ($data =~ /device=\"([^\"]+)\"/);
! 447: ($timecode) = ($data =~ /timecode=\"([^\"]+)\"/);
! 448: $msg .= " \"$device\" \"$timecode\"";
! 449: }
! 450: elsif ($op == 31) # unset trap response (UNOFFICIAL op)
! 451: {
! 452: ;# clear timeout
! 453: &debug("Clear Trap ok from ",&hostname($from));
! 454: &clear_timeout("refresh-".unpack("H*",$from));
! 455: return;
! 456: }
! 457: else # unexpected response
! 458: {
! 459: $msg .= "unexpected response to op $op assoc=$associd";
! 460: $msg .= sprintf(" status=%04x",$status);
! 461: }
! 462: &log($msg);
! 463: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to ntptrap 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