Annotation of embedaddon/ntp/scripts/monitoring/ntp.pl, revision 1.1.1.1
1.1 misho 1: #!/usr/bin/perl -w
2: ;#
3: ;# ntp.pl,v 3.1 1993/07/06 01:09:09 jbj Exp
4: ;#
5: ;# process loop filter statistics file and either
6: ;# - show statistics periodically using gnuplot
7: ;# - or print a single plot
8: ;#
9: ;# Copyright (c) 1992
10: ;# Rainer Pruy Friedrich-Alexander Universitaet Erlangen-Nuernberg
11: ;#
12: ;#
13: ;#############################################################
14:
15: package ntp;
16:
17: $NTP_version = 2;
18: $ctrl_mode=6;
19:
20: $byte1 = (($NTP_version & 0x7)<< 3) & 0x34 | ($ctrl_mode & 0x7);
21: $MAX_DATA = 468;
22:
23: $sequence = 0; # initial sequence number incred before used
24: $pad=4;
25: $do_auth=0; # no possibility today
26: $keyid=0;
27: ;#list if known keys (passwords)
28: %KEYS = ( 0, "\200\200\200\200\200\200\200\200",
29: );
30:
31: ;#-----------------------------------------------------------------------------
32: ;# access routines for ntp control packet
33: ;# NTP control message format
34: ;# C LI|VN|MODE LI 2bit=00 VN 3bit=2(3) MODE 3bit=6 : $byte1
35: ;# C R|E|M|Op R response E error M more Op opcode
36: ;# n sequence
37: ;# n status
38: ;# n associd
39: ;# n offset
40: ;# n count
41: ;# a+ data (+ padding)
42: ;# optional authentication data
43: ;# N key
44: ;# N2 checksum
45:
46: ;# first byte of packet
47: sub pkt_LI { return ($_[$[] >> 6) & 0x3; }
48: sub pkt_VN { return ($_[$[] >> 3) & 0x7; }
49: sub pkt_MODE { return ($_[$[] ) & 0x7; }
50:
51: ;# second byte of packet
52: sub pkt_R { return ($_[$[] & 0x80) == 0x80; }
53: sub pkt_E { return ($_[$[] & 0x40) == 0x40; }
54: sub pkt_M { return ($_[$[] & 0x20) == 0x20; }
55: sub pkt_OP { return $_[$[] & 0x1f; }
56:
57: ;#-----------------------------------------------------------------------------
58:
59: sub setkey
60: {
61: local($id,$key) = @_;
62:
63: $KEYS{$id} = $key if (defined($key));
64: if (! defined($KEYS{$id}))
65: {
66: warn "Key $id not yet specified - key not changed\n";
67: return undef;
68: }
69: return ($keyid,$keyid = $id)[$[];
70: }
71:
72: ;#-----------------------------------------------------------------------------
73: sub numerical { $a <=> $b; }
74:
75: ;#-----------------------------------------------------------------------------
76:
77: sub send #'
78: {
79: local($fh,$opcode, $associd, $data,$address) = @_;
80: $fh = caller(0)."'$fh";
81:
82: local($junksize,$junk,$packet,$offset,$ret);
83: $offset = 0;
84:
85: $sequence++;
86: while(1)
87: {
88: $junksize = length($data);
89: $junksize = $MAX_DATA if $junksize > $MAX_DATA;
90:
91: ($junk,$data) = $data =~ /^(.{$junksize})(.*)$/;
92: $packet
93: = pack("C2n5a".(($junk eq "") ? 0 : &pad($junksize+12,$pad)-12),
94: $byte1,
95: ($opcode & 0x1f) | ($data ? 0x20 : 0),
96: $sequence,
97: 0, $associd,
98: $offset, $junksize, $junk);
99: if ($do_auth)
100: {
101: ;# not yet
102: }
103: $offset += $junksize;
104:
105: if (defined($address))
106: {
107: $ret = send($fh, $packet, 0, $address);
108: }
109: else
110: {
111: $ret = send($fh, $packet, 0);
112: }
113:
114: if (! defined($ret))
115: {
116: warn "send failed: $!\n";
117: return undef;
118: }
119: elsif ($ret != length($packet))
120: {
121: warn "send failed: sent only $ret from ".length($packet). "bytes\n";
122: return undef;
123: }
124: return $sequence unless $data;
125: }
126: }
127:
128: ;#-----------------------------------------------------------------------------
129: ;# status interpretation
130: ;#
131: sub getval
132: {
133: local($val,*list) = @_;
134:
135: return $list{$val} if defined($list{$val});
136: return sprintf("%s#%d",$list{"-"},$val) if defined($list{"-"});
137: return "unknown-$val";
138: }
139:
140: ;#---------------------------------
141: ;# system status
142: ;#
143: ;# format: |LI|CS|SECnt|SECode| LI=2bit CS=6bit SECnt=4bit SECode=4bit
144: sub ssw_LI { return ($_[$[] >> 14) & 0x3; }
145: sub ssw_CS { return ($_[$[] >> 8) & 0x3f; }
146: sub ssw_SECnt { return ($_[$[] >> 4) & 0xf; }
147: sub ssw_SECode { return $_[$[] & 0xf; }
148:
149: %LI = ( 0, "leap_none", 1, "leap_add_sec", 2, "leap_del_sec", 3, "sync_alarm", "-", "leap");
150: %ClockSource = (0, "sync_unspec",
151: 1, "sync_lf_clock",
152: 2, "sync_uhf_clock",
153: 3, "sync_hf_clock",
154: 4, "sync_local_proto",
155: 5, "sync_ntp",
156: 6, "sync_udp/time",
157: 7, "sync_wristwatch",
158: "-", "ClockSource",
159: );
160:
161: %SystemEvent = (0, "event_unspec",
162: 1, "event_restart",
163: 2, "event_fault",
164: 3, "event_sync_chg",
165: 4, "event_sync/strat_chg",
166: 5, "event_clock_reset",
167: 6, "event_bad_date",
168: 7, "event_clock_excptn",
169: "-", "event",
170: );
171: sub LI
172: {
173: &getval(&ssw_LI($_[$[]),*LI);
174: }
175: sub ClockSource
176: {
177: &getval(&ssw_CS($_[$[]),*ClockSource);
178: }
179:
180: sub SystemEvent
181: {
182: &getval(&ssw_SECode($_[$[]),*SystemEvent);
183: }
184:
185: sub system_status
186: {
187: return sprintf("%s, %s, %d event%s, %s", &LI($_[$[]), &ClockSource($_[$[]),
188: &ssw_SECnt($_[$[]), ((&ssw_SECnt($_[$[])==1) ? "" : "s"),
189: &SystemEvent($_[$[]));
190: }
191: ;#---------------------------------
192: ;# peer status
193: ;#
194: ;# format: |PStat|PSel|PCnt|PCode| Pstat=6bit PSel=2bit PCnt=4bit PCode=4bit
195: sub psw_PStat_config { return ($_[$[] & 0x8000) == 0x8000; }
196: sub psw_PStat_authenable { return ($_[$[] & 0x4000) == 0x4000; }
197: sub psw_PStat_authentic { return ($_[$[] & 0x2000) == 0x2000; }
198: sub psw_PStat_reach { return ($_[$[] & 0x1000) == 0x1000; }
199: sub psw_PStat_sane { return ($_[$[] & 0x0800) == 0x0800; }
200: sub psw_PStat_dispok { return ($_[$[] & 0x0400) == 0x0400; }
201: sub psw_PStat { return ($_[$[] >> 10) & 0x3f; }
202: sub psw_PSel { return ($_[$[] >> 8) & 0x3; }
203: sub psw_PCnt { return ($_[$[] >> 4) & 0xf; }
204: sub psw_PCode { return $_[$[] & 0xf; }
205:
206: %PeerSelection = (0, "sel_reject",
207: 1, "sel_candidate",
208: 2, "sel_selcand",
209: 3, "sel_sys.peer",
210: "-", "PeerSel",
211: );
212: %PeerEvent = (0, "event_unspec",
213: 1, "event_ip_err",
214: 2, "event_authen",
215: 3, "event_unreach",
216: 4, "event_reach",
217: 5, "event_clock_excptn",
218: 6, "event_stratum_chg",
219: "-", "event",
220: );
221:
222: sub PeerSelection
223: {
224: &getval(&psw_PSel($_[$[]),*PeerSelection);
225: }
226:
227: sub PeerEvent
228: {
229: &getval(&psw_PCode($_[$[]),*PeerEvent);
230: }
231:
232: sub peer_status
233: {
234: local($x) = ("");
235: $x .= "config," if &psw_PStat_config($_[$[]);
236: $x .= "authenable," if &psw_PStat_authenable($_[$[]);
237: $x .= "authentic," if &psw_PStat_authentic($_[$[]);
238: $x .= "reach," if &psw_PStat_reach($_[$[]);
239: $x .= &psw_PStat_sane($_[$[]) ? "sane," : "insane,";
240: $x .= "hi_disp," unless &psw_PStat_dispok($_[$[]);
241:
242: $x .= sprintf(" %s, %d event%s, %s", &PeerSelection($_[$[]),
243: &psw_PCnt($_[$[]), ((&psw_PCnt($_[$[]) == 1) ? "" : "s"),
244: &PeerEvent($_[$[]));
245: return $x;
246: }
247:
248: ;#---------------------------------
249: ;# clock status
250: ;#
251: ;# format: |CStat|CEvnt| CStat=8bit CEvnt=8bit
252: sub csw_CStat { return ($_[$[] >> 8) & 0xff; }
253: sub csw_CEvnt { return $_[$[] & 0xff; }
254:
255: %ClockStatus = (0, "clk_nominal",
256: 1, "clk_timeout",
257: 2, "clk_badreply",
258: 3, "clk_fault",
259: 4, "clk_prop",
260: 5, "clk_baddate",
261: 6, "clk_badtime",
262: "-", "clk",
263: );
264:
265: sub clock_status
266: {
267: return sprintf("%s, last %s",
268: &getval(&csw_CStat($_[$[]),*ClockStatus),
269: &getval(&csw_CEvnt($_[$[]),*ClockStatus));
270: }
271:
272: ;#---------------------------------
273: ;# error status
274: ;#
275: ;# format: |Err|reserved| Err=8bit
276: ;#
277: sub esw_Err { return ($_[$[] >> 8) & 0xff; }
278:
279: %ErrorStatus = (0, "err_unspec",
280: 1, "err_auth_fail",
281: 2, "err_invalid_fmt",
282: 3, "err_invalid_opcode",
283: 4, "err_unknown_assoc",
284: 5, "err_unknown_var",
285: 6, "err_invalid_value",
286: 7, "err_adm_prohibit",
287: );
288:
289: sub error_status
290: {
291: return sprintf("%s", &getval(&esw_Err($_[$[]),*ErrorStatus));
292: }
293:
294: ;#-----------------------------------------------------------------------------
295: ;#
296: ;# cntrl op name translation
297:
298: %CntrlOpName = (1, "read_status",
299: 2, "read_variables",
300: 3, "write_variables",
301: 4, "read_clock_variables",
302: 5, "write_clock_variables",
303: 6, "set_trap",
304: 7, "trap_response",
305: 31, "unset_trap", # !!! unofficial !!!
306: "-", "cntrlop",
307: );
308:
309: sub cntrlop_name
310: {
311: return &getval($_[$[],*CntrlOpName);
312: }
313:
314: ;#-----------------------------------------------------------------------------
315:
316: $STAT_short_pkt = 0;
317: $STAT_pkt = 0;
318:
319: ;# process a NTP control message (response) packet
320: ;# returns a list ($ret,$data,$status,$associd,$op,$seq,$auth_keyid)
321: ;# $ret: undef --> not yet complete
322: ;# "" --> complete packet received
323: ;# "ERROR" --> error during receive, bad packet, ...
324: ;# else --> error packet - list may contain useful info
325:
326:
327: sub handle_packet
328: {
329: local($pkt,$from) = @_; # parameters
330: local($len_pkt) = (length($pkt));
331: ;# local(*FRAGS,*lastseen);
332: local($li_vn_mode,$r_e_m_op,$seq,$status,$associd,$offset,$count,$data);
333: local($autch_keyid,$auth_cksum);
334:
335: $STAT_pkt++;
336: if ($len_pkt < 12)
337: {
338: $STAT_short_pkt++;
339: return ("ERROR","short packet received");
340: }
341:
342: ;# now break packet apart
343: ($li_vn_mode,$r_e_m_op,$seq,$status,$associd,$offset,$count,$data) =
344: unpack("C2n5a".($len_pkt-12),$pkt);
345: $data=substr($data,$[,$count);
346: if ((($len_pkt - 12) - &pad($count,4)) >= 12)
347: {
348: ;# looks like an authenticator
349: ($auth_keyid,$auth_cksum) =
350: unpack("Na8",substr($pkt,$len_pkt-12+$[,12));
351: $STAT_auth++;
352: ;# no checking of auth_cksum (yet ?)
353: }
354:
355: if (&pkt_VN($li_vn_mode) != $NTP_version)
356: {
357: $STAT_bad_version++;
358: return ("ERROR","version ".&pkt_VN($li_vn_mode)."packet ignored");
359: }
360:
361: if (&pkt_MODE($li_vn_mode) != $ctrl_mode)
362: {
363: $STAT_bad_mode++;
364: return ("ERROR", "mode ".&pkt_MODE($li_vn_mode)." packet ignored");
365: }
366:
367: ;# handle single fragment fast
368: if ($offset == 0 && &pkt_M($r_e_m_op) == 0)
369: {
370: $STAT_single_frag++;
371: if (&pkt_E($r_e_m_op))
372: {
373: $STAT_err_pkt++;
374: return (&error_status($status),
375: $data,$status,$associd,&pkt_OP($r_e_m_op),$seq,
376: $auth_keyid);
377: }
378: else
379: {
380: return ("",
381: $data,$status,$associd,&pkt_OP($r_e_m_op),$seq,
382: $auth_keyid);
383: }
384: }
385: else
386: {
387: ;# fragment - set up local name space
388: $id = "$from$seq".&pkt_OP($r_e_m_op);
389: $ID{$id} = 1;
390: *FRAGS = "$id FRAGS";
391: *lastseen = "$id lastseen";
392:
393: $STAT_frag++;
394:
395: $lastseen = 1 if !&pkt_M($r_e_m_op);
396: if (!defined(%FRAGS))
397: {
398: print((&pkt_M($r_e_m_op) ? " more" : "")."\n");
399: $FRAGS{$offset} = $data;
400: ;# save other info
401: @FRAGS = ($status,$associd,&pkt_OP($r_e_m_op),$seq,$auth_keyid,$r_e_m_op);
402: }
403: else
404: {
405: print((&pkt_M($r_e_m_op) ? " more" : "")."\n");
406: ;# add frag to previous - combine on the fly
407: if (defined($FRAGS{$offset}))
408: {
409: $STAT_dup_frag++;
410: return ("ERROR","duplicate fragment at $offset seq=$seq");
411: }
412:
413: $FRAGS{$offset} = $data;
414:
415: undef($loff);
416: foreach $off (sort numerical keys(%FRAGS))
417: {
418: next unless defined($FRAGS{$off});
419: if (defined($loff) &&
420: ($loff + length($FRAGS{$loff})) == $off)
421: {
422: $FRAGS{$loff} .= $FRAGS{$off};
423: delete $FRAGS{$off};
424: last;
425: }
426: $loff = $off;
427: }
428:
429: ;# return packet if all frags arrived
430: ;# at most two frags with possible padding ???
431: if ($lastseen && defined($FRAGS{0}) &&
432: (((scalar(@x=sort numerical keys(%FRAGS)) == 2) &&
433: (length($FRAGS{0}) + 8) > $x[$[+1]) ||
434: (scalar(@x=sort numerical keys(%FRAGS)) < 2)))
435: {
436: @x=((&pkt_E($r_e_m_op) ? &error_status($status) : ""),
437: $FRAGS{0},@FRAGS);
438: &pkt_E($r_e_m_op) ? $STAT_err_frag++ : $STAT_frag_all++;
439: undef(%FRAGS);
440: undef(@FRAGS);
441: undef($lastseen);
442: delete $ID{$id};
443: &main'clear_timeout($id);
444: return @x;
445: }
446: else
447: {
448: &main'set_timeout($id,time+$timeout,"&ntp'handle_packet_timeout(\"".unpack("H*",$id)."\");"); #'";
449: }
450: }
451: return (undef);
452: }
453: }
454:
455: sub handle_packet_timeout
456: {
457: local($id) = @_;
458: local($r_e_m_op,*FRAGS,*lastseen,@x) = (@FRAGS[$[+5]);
459:
460: *FRAGS = "$id FRAGS";
461: *lastseen = "$id lastseen";
462:
463: @x=((&pkt_E($r_e_m_op) ? &error_status($status) : "TIMEOUT"),
464: $FRAGS{0},@FRAGS[$[ .. $[+4]);
465: $STAT_frag_timeout++;
466: undef(%FRAGS);
467: undef(@FRAGS);
468: undef($lastseen);
469: delete $ID{$id};
470: return @x;
471: }
472:
473:
474: sub pad
475: {
476: return $_[$[+1] * int(($_[$[] + $_[$[+1] - 1) / $_[$[+1]);
477: }
478:
479: 1;
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to ntp.pl 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