1/* $NetBSD: ntpdc_ops.c,v 1.1.1.2 2012/01/31 21:27:01 kardel Exp $ */ 2 3/* 4 * ntpdc_ops.c - subroutines which are called to perform operations by 5 * ntpdc 6 */ 7 8#ifdef HAVE_CONFIG_H 9# include <config.h> 10#endif 11 12#include <stdio.h> 13#include <stddef.h> 14 15#include "ntpdc.h" 16#include "ntp_net.h" 17#include "ntp_control.h" 18#include "ntp_refclock.h" 19#include "ntp_stdlib.h" 20 21#include <ctype.h> 22#ifdef HAVE_SYS_TIMEX_H 23# include <sys/timex.h> 24#endif 25#if !defined(__bsdi__) && !defined(apollo) 26#ifdef HAVE_NETINET_IN_H 27#include <netinet/in.h> 28#endif 29#endif 30 31#include <arpa/inet.h> 32 33/* 34 * utility functions 35 */ 36static int checkitems (int, FILE *); 37static int checkitemsize (int, int); 38static int check1item (int, FILE *); 39 40/* 41 * Declarations for command handlers in here 42 */ 43static void peerlist (struct parse *, FILE *); 44static void peers (struct parse *, FILE *); 45static void doconfig (struct parse *pcmd, FILE *fp, int mode, int refc); 46static void dmpeers (struct parse *, FILE *); 47static void dopeers (struct parse *, FILE *, int); 48static void printpeer (struct info_peer *, FILE *); 49static void showpeer (struct parse *, FILE *); 50static void peerstats (struct parse *, FILE *); 51static void loopinfo (struct parse *, FILE *); 52static void sysinfo (struct parse *, FILE *); 53static void sysstats (struct parse *, FILE *); 54static void iostats (struct parse *, FILE *); 55static void memstats (struct parse *, FILE *); 56static void timerstats (struct parse *, FILE *); 57static void addpeer (struct parse *, FILE *); 58static void addserver (struct parse *, FILE *); 59static void addrefclock (struct parse *, FILE *); 60static void broadcast (struct parse *, FILE *); 61static void doconfig (struct parse *, FILE *, int, int); 62static void unconfig (struct parse *, FILE *); 63static void set (struct parse *, FILE *); 64static void sys_clear (struct parse *, FILE *); 65static void doset (struct parse *, FILE *, int); 66static void reslist (struct parse *, FILE *); 67static void new_restrict (struct parse *, FILE *); 68static void unrestrict (struct parse *, FILE *); 69static void delrestrict (struct parse *, FILE *); 70static void do_restrict (struct parse *, FILE *, int); 71static void monlist (struct parse *, FILE *); 72static void reset (struct parse *, FILE *); 73static void preset (struct parse *, FILE *); 74static void readkeys (struct parse *, FILE *); 75static void trustkey (struct parse *, FILE *); 76static void untrustkey (struct parse *, FILE *); 77static void do_trustkey (struct parse *, FILE *, int); 78static void authinfo (struct parse *, FILE *); 79static void traps (struct parse *, FILE *); 80static void addtrap (struct parse *, FILE *); 81static void clrtrap (struct parse *, FILE *); 82static void do_addclr_trap (struct parse *, FILE *, int); 83static void requestkey (struct parse *, FILE *); 84static void controlkey (struct parse *, FILE *); 85static void do_changekey (struct parse *, FILE *, int); 86static void ctlstats (struct parse *, FILE *); 87static void clockstat (struct parse *, FILE *); 88static void fudge (struct parse *, FILE *); 89static void clkbug (struct parse *, FILE *); 90static void kerninfo (struct parse *, FILE *); 91static void get_if_stats (struct parse *, FILE *); 92static void do_if_reload (struct parse *, FILE *); 93 94/* 95 * Commands we understand. Ntpdc imports this. 96 */ 97struct xcmd opcmds[] = { 98 { "listpeers", peerlist, { OPT|IP_VERSION, NO, NO, NO }, 99 { "-4|-6", "", "", "" }, 100 "display list of peers the server knows about [IP Version]" }, 101 { "peers", peers, { OPT|IP_VERSION, NO, NO, NO }, 102 { "-4|-6", "", "", "" }, 103 "display peer summary information [IP Version]" }, 104 { "dmpeers", dmpeers, { OPT|IP_VERSION, NO, NO, NO }, 105 { "-4|-6", "", "", "" }, 106 "display peer summary info the way Dave Mills likes it (IP Version)" }, 107 { "showpeer", showpeer, { NTP_ADD, OPT|NTP_ADD, OPT|NTP_ADD, OPT|NTP_ADD}, 108 { "peer_address", "peer2_addr", "peer3_addr", "peer4_addr" }, 109 "display detailed information for one or more peers" }, 110 { "pstats", peerstats, { NTP_ADD, OPT|NTP_ADD, OPT|NTP_ADD, OPT|NTP_ADD }, 111 { "peer_address", "peer2_addr", "peer3_addr", "peer4_addr" }, 112 "display statistical information for one or more peers" }, 113 { "loopinfo", loopinfo, { OPT|NTP_STR, NO, NO, NO }, 114 { "oneline|multiline", "", "", "" }, 115 "display loop filter information" }, 116 { "sysinfo", sysinfo, { NO, NO, NO, NO }, 117 { "", "", "", "" }, 118 "display local server information" }, 119 { "sysstats", sysstats, { NO, NO, NO, NO }, 120 { "", "", "", "" }, 121 "display local server statistics" }, 122 { "memstats", memstats, { NO, NO, NO, NO }, 123 { "", "", "", "" }, 124 "display peer memory usage statistics" }, 125 { "iostats", iostats, { NO, NO, NO, NO }, 126 { "", "", "", "" }, 127 "display I/O subsystem statistics" }, 128 { "timerstats", timerstats, { NO, NO, NO, NO }, 129 { "", "", "", "" }, 130 "display event timer subsystem statistics" }, 131 { "addpeer", addpeer, { NTP_ADD, OPT|NTP_STR, OPT|NTP_STR, OPT|NTP_STR }, 132 { "addr", "keyid", "version", "minpoll#|prefer|burst|iburst|'minpoll N'|'maxpoll N'|'keyid N'|'version N' ..." }, 133 "configure a new peer association" }, 134 { "addserver", addserver, { NTP_ADD, OPT|NTP_STR, OPT|NTP_STR, OPT|NTP_STR }, 135 { "addr", "keyid", "version", "minpoll#|prefer|burst|iburst|'minpoll N'|'maxpoll N'|'keyid N'|'version N' ..." }, 136 "configure a new server" }, 137 { "addrefclock",addrefclock, { NTP_ADD, OPT|NTP_UINT, OPT|NTP_STR, OPT|NTP_STR }, 138 { "addr", "mode", "minpoll|prefer", "minpoll|prefer" }, 139 "configure a new server" }, 140 { "broadcast", broadcast, { NTP_ADD, OPT|NTP_STR, OPT|NTP_STR, OPT|NTP_STR }, 141 { "addr", "keyid", "version", "minpoll" }, 142 "configure broadcasting time service" }, 143 { "unconfig", unconfig, { NTP_ADD, OPT|NTP_ADD, OPT|NTP_ADD, OPT|NTP_ADD }, 144 { "peer_address", "peer2_addr", "peer3_addr", "peer4_addr" }, 145 "unconfigure existing peer assocations" }, 146 { "enable", set, { NTP_STR, OPT|NTP_STR, OPT|NTP_STR, OPT|NTP_STR }, 147 { "auth|bclient|monitor|pll|kernel|stats", "...", "...", "..." }, 148 "set a system flag (auth, bclient, monitor, pll, kernel, stats)" }, 149 { "disable", sys_clear, { NTP_STR, OPT|NTP_STR, OPT|NTP_STR, OPT|NTP_STR }, 150 { "auth|bclient|monitor|pll|kernel|stats", "...", "...", "..." }, 151 "clear a system flag (auth, bclient, monitor, pll, kernel, stats)" }, 152 { "reslist", reslist, {OPT|IP_VERSION, NO, NO, NO }, 153 { "-4|-6", "", "", "" }, 154 "display the server's restrict list" }, 155 { "restrict", new_restrict, { NTP_ADD, NTP_ADD, NTP_STR, OPT|NTP_STR }, 156 { "address", "mask", 157 "ntpport|ignore|noserve|notrust|noquery|nomodify|nopeer|version|kod", 158 "..." }, 159 "create restrict entry/add flags to entry" }, 160 { "unrestrict", unrestrict, { NTP_ADD, NTP_ADD, NTP_STR, OPT|NTP_STR }, 161 { "address", "mask", 162 "ntpport|ignore|noserve|notrust|noquery|nomodify|nopeer|version|kod", 163 "..." }, 164 "remove flags from a restrict entry" }, 165 { "delrestrict", delrestrict, { NTP_ADD, NTP_ADD, OPT|NTP_STR, NO }, 166 { "address", "mask", "ntpport", "" }, 167 "delete a restrict entry" }, 168 { "monlist", monlist, { OPT|NTP_INT, NO, NO, NO }, 169 { "version", "", "", "" }, 170 "display data the server's monitor routines have collected" }, 171 { "reset", reset, { NTP_STR, OPT|NTP_STR, OPT|NTP_STR, OPT|NTP_STR }, 172 { "io|sys|mem|timer|auth|allpeers", "...", "...", "..." }, 173 "reset various subsystem statistics counters" }, 174 { "preset", preset, { NTP_ADD, OPT|NTP_ADD, OPT|NTP_ADD, OPT|NTP_ADD }, 175 { "peer_address", "peer2_addr", "peer3_addr", "peer4_addr" }, 176 "reset stat counters associated with particular peer(s)" }, 177 { "readkeys", readkeys, { NO, NO, NO, NO }, 178 { "", "", "", "" }, 179 "request a reread of the keys file and re-init of system keys" }, 180 { "trustedkey", trustkey, { NTP_UINT, OPT|NTP_UINT, OPT|NTP_UINT, OPT|NTP_UINT }, 181 { "keyid", "keyid", "keyid", "keyid" }, 182 "add one or more key ID's to the trusted list" }, 183 { "untrustedkey", untrustkey, { NTP_UINT, OPT|NTP_UINT, OPT|NTP_UINT, OPT|NTP_UINT }, 184 { "keyid", "keyid", "keyid", "keyid" }, 185 "remove one or more key ID's from the trusted list" }, 186 { "authinfo", authinfo, { NO, NO, NO, NO }, 187 { "", "", "", "" }, 188 "display the state of the authentication code" }, 189 { "traps", traps, { NO, NO, NO, NO }, 190 { "", "", "", "" }, 191 "display the traps set in the server" }, 192 { "addtrap", addtrap, { NTP_ADD, OPT|NTP_UINT, OPT|NTP_ADD, NO }, 193 { "address", "port", "interface", "" }, 194 "configure a trap in the server" }, 195 { "clrtrap", clrtrap, { NTP_ADD, OPT|NTP_UINT, OPT|NTP_ADD, NO }, 196 { "address", "port", "interface", "" }, 197 "remove a trap (configured or otherwise) from the server" }, 198 { "requestkey", requestkey, { NTP_UINT, NO, NO, NO }, 199 { "keyid", "", "", "" }, 200 "change the keyid the server uses to authenticate requests" }, 201 { "controlkey", controlkey, { NTP_UINT, NO, NO, NO }, 202 { "keyid", "", "", "" }, 203 "change the keyid the server uses to authenticate control messages" }, 204 { "ctlstats", ctlstats, { NO, NO, NO, NO }, 205 { "", "", "", "" }, 206 "display packet count statistics from the control module" }, 207 { "clockstat", clockstat, { NTP_ADD, OPT|NTP_ADD, OPT|NTP_ADD, OPT|NTP_ADD }, 208 { "address", "address", "address", "address" }, 209 "display clock status information" }, 210 { "fudge", fudge, { NTP_ADD, NTP_STR, NTP_STR, NO }, 211 { "address", "time1|time2|val1|val2|flags", "value", "" }, 212 "set/change one of a clock's fudge factors" }, 213 { "clkbug", clkbug, { NTP_ADD, OPT|NTP_ADD, OPT|NTP_ADD, OPT|NTP_ADD }, 214 { "address", "address", "address", "address" }, 215 "display clock debugging information" }, 216 { "kerninfo", kerninfo, { NO, NO, NO, NO }, 217 { "", "", "", "" }, 218 "display the kernel pll/pps variables" }, 219 { "ifstats", get_if_stats, { NO, NO, NO, NO }, 220 { "", "", "", "" }, 221 "list interface statistics" }, 222 { "ifreload", do_if_reload, { NO, NO, NO, NO }, 223 { "", "", "", "" }, 224 "reload interface configuration" }, 225 { 0, 0, { NO, NO, NO, NO }, 226 { "", "", "", "" }, "" } 227}; 228 229/* 230 * For quick string comparisons 231 */ 232#define STREQ(a, b) (*(a) == *(b) && strcmp((a), (b)) == 0) 233 234/* 235 * SET_SS_LEN_IF_PRESENT - used by SET_ADDR, SET_ADDRS macros 236 */ 237 238#ifdef ISC_PLATFORM_HAVESALEN 239#define SET_SS_LEN_IF_PRESENT(psau) \ 240 do { \ 241 (psau)->sa.sa_len = SOCKLEN(psau); \ 242 } while (0) 243#else 244#define SET_SS_LEN_IF_PRESENT(psau) do { } while (0) 245#endif 246 247/* 248 * SET_ADDR - setup address for v4/v6 as needed 249 */ 250#define SET_ADDR(address, v6flag, v4addr, v6addr) \ 251do { \ 252 memset(&(address), 0, sizeof(address)); \ 253 if (v6flag) { \ 254 AF(&(address)) = AF_INET6; \ 255 SOCK_ADDR6(&(address)) = (v6addr); \ 256 } else { \ 257 AF(&(address)) = AF_INET; \ 258 NSRCADR(&(address)) = (v4addr); \ 259 } \ 260 SET_SS_LEN_IF_PRESENT(&(address)); \ 261} while (0) 262 263 264/* 265 * SET_ADDRS - setup source and destination addresses for 266 * v4/v6 as needed 267 */ 268#define SET_ADDRS(a1, a2, info, a1prefix, a2prefix) \ 269do { \ 270 memset(&(a1), 0, sizeof(a1)); \ 271 memset(&(a2), 0, sizeof(a2)); \ 272 if ((info)->v6_flag) { \ 273 AF(&(a1)) = AF_INET6; \ 274 AF(&(a2)) = AF_INET6; \ 275 SOCK_ADDR6(&(a1)) = (info)->a1prefix##6; \ 276 SOCK_ADDR6(&(a2)) = (info)->a2prefix##6; \ 277 } else { \ 278 AF(&(a1)) = AF_INET; \ 279 AF(&(a2)) = AF_INET; \ 280 NSRCADR(&(a1)) = (info)->a1prefix; \ 281 NSRCADR(&(a2)) = (info)->a2prefix; \ 282 } \ 283 SET_SS_LEN_IF_PRESENT(&(a1)); \ 284 SET_SS_LEN_IF_PRESENT(&(a2)); \ 285} while (0) 286 287 288/* 289 * SET_ADDRS - setup source and destination addresses for 290 * v4/v6 as needed 291 */ 292#if 0 293#define SET_ADDR_MASK(address, addrmask, info) \ 294do { \ 295 memset(&(address), 0, sizeof(address)); \ 296 memset(&(mask), 0, sizeof(mask)); \ 297 if ((info)->v6_flag) { \ 298 AF(&(address)) = AF_INET6; \ 299 AF(&(addrmask)) = AF_INET6; \ 300 SOCK_ADDR6(&(address)) = (info)->addr6; \ 301 SOCK_ADDR6(&(addrmask)) = (info)->mask6; \ 302 } else { \ 303 AF(&(address)) = AF_INET; \ 304 AF(&(addrmask)) = AF_INET; \ 305 NSRCADR(&(address)) = (info)->addr; \ 306 NSRCADR(&(addrmask)) = (info)->mask; \ 307 } \ 308 SET_SS_LEN_IF_PRESENT(&(address)); \ 309 SET_SS_LEN_IF_PRESENT(&(addrmask)); \ 310} while (0) 311#endif 312 313/* 314 * checkitems - utility to print a message if no items were returned 315 */ 316static int 317checkitems( 318 int items, 319 FILE *fp 320 ) 321{ 322 if (items == 0) { 323 (void) fprintf(fp, "No data returned in response to query\n"); 324 return 0; 325 } 326 return 1; 327} 328 329 330/* 331 * checkitemsize - utility to print a message if the item size is wrong 332 */ 333static int 334checkitemsize( 335 int itemsize, 336 int expected 337 ) 338{ 339 if (itemsize != expected) { 340 (void) fprintf(stderr, 341 "***Incorrect item size returned by remote host (%d should be %d)\n", 342 itemsize, expected); 343 return 0; 344 } 345 return 1; 346} 347 348 349/* 350 * check1item - check to make sure we have exactly one item 351 */ 352static int 353check1item( 354 int items, 355 FILE *fp 356 ) 357{ 358 if (items == 0) { 359 (void) fprintf(fp, "No data returned in response to query\n"); 360 return 0; 361 } 362 if (items > 1) { 363 (void) fprintf(fp, "Expected one item in response, got %d\n", 364 items); 365 return 0; 366 } 367 return 1; 368} 369 370 371/* 372 * peerlist - get a short list of peers 373 */ 374/*ARGSUSED*/ 375static void 376peerlist( 377 struct parse *pcmd, 378 FILE *fp 379 ) 380{ 381 struct info_peer_list *plist; 382 sockaddr_u paddr; 383 int items; 384 int itemsize; 385 int res; 386 387again: 388 res = doquery(impl_ver, REQ_PEER_LIST, 0, 0, 0, (char *)NULL, &items, 389 &itemsize, (void *)&plist, 0, 390 sizeof(struct info_peer_list)); 391 392 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 393 impl_ver = IMPL_XNTPD_OLD; 394 goto again; 395 } 396 397 if (res != 0) 398 return; 399 400 if (!checkitems(items, fp)) 401 return; 402 403 if (!checkitemsize(itemsize, sizeof(struct info_peer_list)) && 404 !checkitemsize(itemsize, v4sizeof(struct info_peer_list))) 405 return; 406 407 while (items > 0) { 408 SET_ADDR(paddr, plist->v6_flag, plist->addr, plist->addr6); 409 if ((pcmd->nargs == 0) || 410 ((pcmd->argval->ival == 6) && (plist->v6_flag != 0)) || 411 ((pcmd->argval->ival == 4) && (plist->v6_flag == 0))) 412 (void) fprintf(fp, "%-9s %s\n", 413 modetoa(plist->hmode), 414 nntohost(&paddr)); 415 plist++; 416 items--; 417 } 418} 419 420 421/* 422 * peers - show peer summary 423 */ 424static void 425peers( 426 struct parse *pcmd, 427 FILE *fp 428 ) 429{ 430 dopeers(pcmd, fp, 0); 431} 432 433/* 434 * dmpeers - show peer summary, Dave Mills style 435 */ 436static void 437dmpeers( 438 struct parse *pcmd, 439 FILE *fp 440 ) 441{ 442 dopeers(pcmd, fp, 1); 443} 444 445 446/* 447 * peers - show peer summary 448 */ 449/*ARGSUSED*/ 450static void 451dopeers( 452 struct parse *pcmd, 453 FILE *fp, 454 int dmstyle 455 ) 456{ 457 struct info_peer_summary *plist; 458 sockaddr_u dstadr; 459 sockaddr_u srcadr; 460 int items; 461 int itemsize; 462 int ntp_poll; 463 int res; 464 int c; 465 l_fp tempts; 466 467again: 468 res = doquery(impl_ver, REQ_PEER_LIST_SUM, 0, 0, 0, (char *)NULL, 469 &items, &itemsize, (void *)&plist, 0, 470 sizeof(struct info_peer_summary)); 471 472 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 473 impl_ver = IMPL_XNTPD_OLD; 474 goto again; 475 } 476 477 if (res != 0) 478 return; 479 480 if (!checkitems(items, fp)) 481 return; 482 483 if (!checkitemsize(itemsize, sizeof(struct info_peer_summary)) && 484 !checkitemsize(itemsize, v4sizeof(struct info_peer_summary))) 485 return; 486 487 (void) fprintf(fp, 488 " remote local st poll reach delay offset disp\n"); 489 (void) fprintf(fp, 490 "=======================================================================\n"); 491 while (items > 0) { 492 if (!dmstyle) { 493 if (plist->flags & INFO_FLAG_SYSPEER) 494 c = '*'; 495 else if (plist->hmode == MODE_ACTIVE) 496 c = '+'; 497 else if (plist->hmode == MODE_PASSIVE) 498 c = '-'; 499 else if (plist->hmode == MODE_CLIENT) 500 c = '='; 501 else if (plist->hmode == MODE_BROADCAST) 502 c = '^'; 503 else if (plist->hmode == MODE_BCLIENT) 504 c = '~'; 505 else 506 c = ' '; 507 } else { 508 if (plist->flags & INFO_FLAG_SYSPEER) 509 c = '*'; 510 else if (plist->flags & INFO_FLAG_SHORTLIST) 511 c = '+'; 512 else if (plist->flags & INFO_FLAG_SEL_CANDIDATE) 513 c = '.'; 514 else 515 c = ' '; 516 } 517 NTOHL_FP(&(plist->offset), &tempts); 518 ntp_poll = 1<<max(min3(plist->ppoll, plist->hpoll, NTP_MAXPOLL), 519 NTP_MINPOLL); 520 SET_ADDRS(dstadr, srcadr, plist, dstadr, srcadr); 521 if ((pcmd->nargs == 0) || 522 ((pcmd->argval->ival == 6) && (plist->v6_flag != 0)) || 523 ((pcmd->argval->ival == 4) && (plist->v6_flag == 0))) 524 (void) fprintf(fp, 525 "%c%-15.15s %-15.15s %2u %4d %3o %7.7s %9.9s %7.7s\n", 526 c, nntohost(&srcadr), stoa(&dstadr), 527 plist->stratum, ntp_poll, plist->reach, 528 fptoa(NTOHS_FP(plist->delay), 5), 529 lfptoa(&tempts, 6), 530 ufptoa(NTOHS_FP(plist->dispersion), 5)); 531 plist++; 532 items--; 533 } 534} 535 536/* Convert a refid & stratum (in host order) to a string */ 537static char* 538refid_string( 539 u_int32 refid, 540 int stratum 541 ) 542{ 543 if (stratum <= 1) { 544 static char junk[5]; 545 junk[4] = 0; 546 memmove(junk, (char *)&refid, 4); 547 return junk; 548 } 549 550 return numtoa(refid); 551} 552 553static void 554print_pflag( 555 FILE *fp, 556 u_int32 flags 557 ) 558{ 559 const char *str; 560 561 if (flags == 0) { 562 (void) fprintf(fp, " none\n"); 563 } else { 564 str = ""; 565 if (flags & INFO_FLAG_SYSPEER) { 566 (void) fprintf(fp, " system_peer"); 567 str = ","; 568 } 569 if (flags & INFO_FLAG_CONFIG) { 570 (void) fprintf(fp, "%s config", str); 571 str = ","; 572 } 573 if (flags & INFO_FLAG_REFCLOCK) { 574 (void) fprintf(fp, "%s refclock", str); 575 str = ","; 576 } 577 if (flags & INFO_FLAG_AUTHENABLE) { 578 (void) fprintf(fp, "%s auth", str); 579 str = ","; 580 } 581 if (flags & INFO_FLAG_BCLIENT) { 582 (void) fprintf(fp, "%s bclient", str); 583 str = ","; 584 } 585 if (flags & INFO_FLAG_PREFER) { 586 (void) fprintf(fp, "%s prefer", str); 587 str = ","; 588 } 589 if (flags & INFO_FLAG_IBURST) { 590 (void) fprintf(fp, "%s iburst", str); 591 str = ","; 592 } 593 if (flags & INFO_FLAG_BURST) { 594 (void) fprintf(fp, "%s burst", str); 595 } 596 (void) fprintf(fp, "\n"); 597 } 598} 599/* 600 * printpeer - print detail information for a peer 601 */ 602static void 603printpeer( 604 register struct info_peer *pp, 605 FILE *fp 606 ) 607{ 608 register int i; 609 l_fp tempts; 610 sockaddr_u srcadr, dstadr; 611 612 SET_ADDRS(dstadr, srcadr, pp, dstadr, srcadr); 613 614 (void) fprintf(fp, "remote %s, local %s\n", 615 stoa(&srcadr), stoa(&dstadr)); 616 (void) fprintf(fp, "hmode %s, pmode %s, stratum %d, precision %d\n", 617 modetoa(pp->hmode), modetoa(pp->pmode), 618 pp->stratum, pp->precision); 619 620 (void) fprintf(fp, 621 "leap %c%c, refid [%s], rootdistance %s, rootdispersion %s\n", 622 pp->leap & 0x2 ? '1' : '0', 623 pp->leap & 0x1 ? '1' : '0', 624 refid_string(pp->refid, pp->stratum), fptoa(NTOHS_FP(pp->rootdelay), 5), 625 ufptoa(NTOHS_FP(pp->rootdispersion), 5)); 626 627 (void) fprintf(fp, 628 "ppoll %d, hpoll %d, keyid %lu, version %d, association %u\n", 629 pp->ppoll, pp->hpoll, (u_long)pp->keyid, pp->version, ntohs(pp->associd)); 630 631 (void) fprintf(fp, 632 "reach %03o, unreach %d, flash 0x%04x, ", 633 pp->reach, pp->unreach, pp->flash2); 634 635 (void) fprintf(fp, "boffset %s, ttl/mode %d\n", 636 fptoa(NTOHS_FP(pp->estbdelay), 5), pp->ttl); 637 638 (void) fprintf(fp, "timer %lds, flags", (long)ntohl(pp->timer)); 639 print_pflag(fp, pp->flags); 640 641 NTOHL_FP(&pp->reftime, &tempts); 642 (void) fprintf(fp, "reference time: %s\n", 643 prettydate(&tempts)); 644 NTOHL_FP(&pp->org, &tempts); 645 (void) fprintf(fp, "originate timestamp: %s\n", 646 prettydate(&tempts)); 647 NTOHL_FP(&pp->rec, &tempts); 648 (void) fprintf(fp, "receive timestamp: %s\n", 649 prettydate(&tempts)); 650 NTOHL_FP(&pp->xmt, &tempts); 651 (void) fprintf(fp, "transmit timestamp: %s\n", 652 prettydate(&tempts)); 653 654 (void) fprintf(fp, "filter delay: "); 655 for (i = 0; i < NTP_SHIFT; i++) { 656 (void) fprintf(fp, " %-8.8s", 657 fptoa(NTOHS_FP(pp->filtdelay[i]), 5)); 658 if (i == (NTP_SHIFT>>1)-1) 659 (void) fprintf(fp, "\n "); 660 } 661 (void) fprintf(fp, "\n"); 662 663 (void) fprintf(fp, "filter offset:"); 664 for (i = 0; i < NTP_SHIFT; i++) { 665 NTOHL_FP(&pp->filtoffset[i], &tempts); 666 (void) fprintf(fp, " %-8.8s", lfptoa(&tempts, 6)); 667 if (i == (NTP_SHIFT>>1)-1) 668 (void) fprintf(fp, "\n "); 669 } 670 (void) fprintf(fp, "\n"); 671 672 (void) fprintf(fp, "filter order: "); 673 for (i = 0; i < NTP_SHIFT; i++) { 674 (void) fprintf(fp, " %-8d", pp->order[i]); 675 if (i == (NTP_SHIFT>>1)-1) 676 (void) fprintf(fp, "\n "); 677 } 678 (void) fprintf(fp, "\n"); 679 680 681 NTOHL_FP(&pp->offset, &tempts); 682 (void) fprintf(fp, 683 "offset %s, delay %s, error bound %s, filter error %s\n", 684 lfptoa(&tempts, 6), fptoa(NTOHS_FP(pp->delay), 5), 685 ufptoa(NTOHS_FP(pp->dispersion), 5), 686 ufptoa(NTOHS_FP(pp->selectdisp), 5)); 687} 688 689 690/* 691 * showpeer - show detailed information for a peer 692 */ 693static void 694showpeer( 695 struct parse *pcmd, 696 FILE *fp 697 ) 698{ 699 struct info_peer *pp; 700 /* 4 is the maximum number of peers which will fit in a packet */ 701 struct info_peer_list *pl, plist[min(MAXARGS, 4)]; 702 int qitemlim; 703 int qitems; 704 int items; 705 int itemsize; 706 int res; 707 int sendsize; 708 709again: 710 if (impl_ver == IMPL_XNTPD) 711 sendsize = sizeof(struct info_peer_list); 712 else 713 sendsize = v4sizeof(struct info_peer_list); 714 715 qitemlim = min(pcmd->nargs, COUNTOF(plist)); 716 for (qitems = 0, pl = plist; qitems < qitemlim; qitems++) { 717 if (IS_IPV4(&pcmd->argval[qitems].netnum)) { 718 pl->addr = NSRCADR(&pcmd->argval[qitems].netnum); 719 if (impl_ver == IMPL_XNTPD) 720 pl->v6_flag = 0; 721 } else { 722 if (impl_ver == IMPL_XNTPD_OLD) { 723 fprintf(stderr, 724 "***Server doesn't understand IPv6 addresses\n"); 725 return; 726 } 727 pl->addr6 = SOCK_ADDR6(&pcmd->argval[qitems].netnum); 728 pl->v6_flag = 1; 729 } 730 pl->port = (u_short)s_port; 731 pl->hmode = pl->flags = 0; 732 pl = (struct info_peer_list *)((char *)pl + sendsize); 733 } 734 735 res = doquery(impl_ver, REQ_PEER_INFO, 0, qitems, 736 sendsize, (char *)plist, &items, 737 &itemsize, (void *)&pp, 0, sizeof(struct info_peer)); 738 739 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 740 impl_ver = IMPL_XNTPD_OLD; 741 goto again; 742 } 743 744 if (res != 0) 745 return; 746 747 if (!checkitems(items, fp)) 748 return; 749 750 if (!checkitemsize(itemsize, sizeof(struct info_peer)) && 751 !checkitemsize(itemsize, v4sizeof(struct info_peer))) 752 return; 753 754 while (items-- > 0) { 755 printpeer(pp, fp); 756 if (items > 0) 757 (void) fprintf(fp, "\n"); 758 pp++; 759 } 760} 761 762 763/* 764 * peerstats - return statistics for a peer 765 */ 766static void 767peerstats( 768 struct parse *pcmd, 769 FILE *fp 770 ) 771{ 772 struct info_peer_stats *pp; 773 /* 4 is the maximum number of peers which will fit in a packet */ 774 struct info_peer_list *pl, plist[min(MAXARGS, 4)]; 775 sockaddr_u src, dst; 776 int qitemlim; 777 int qitems; 778 int items; 779 int itemsize; 780 int res; 781 int sendsize; 782 783again: 784 if (impl_ver == IMPL_XNTPD) 785 sendsize = sizeof(struct info_peer_list); 786 else 787 sendsize = v4sizeof(struct info_peer_list); 788 789 memset(plist, 0, sizeof(plist)); 790 791 qitemlim = min(pcmd->nargs, COUNTOF(plist)); 792 for (qitems = 0, pl = plist; qitems < qitemlim; qitems++) { 793 if (IS_IPV4(&pcmd->argval[qitems].netnum)) { 794 pl->addr = NSRCADR(&pcmd->argval[qitems].netnum); 795 if (impl_ver == IMPL_XNTPD) 796 pl->v6_flag = 0; 797 } else { 798 if (impl_ver == IMPL_XNTPD_OLD) { 799 fprintf(stderr, 800 "***Server doesn't understand IPv6 addresses\n"); 801 return; 802 } 803 pl->addr6 = SOCK_ADDR6(&pcmd->argval[qitems].netnum); 804 pl->v6_flag = 1; 805 } 806 pl->port = (u_short)s_port; 807 pl->hmode = plist[qitems].flags = 0; 808 pl = (struct info_peer_list *)((char *)pl + sendsize); 809 } 810 811 res = doquery(impl_ver, REQ_PEER_STATS, 0, qitems, 812 sendsize, (char *)plist, &items, 813 &itemsize, (void *)&pp, 0, 814 sizeof(struct info_peer_stats)); 815 816 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 817 impl_ver = IMPL_XNTPD_OLD; 818 goto again; 819 } 820 821 if (res != 0) 822 return; 823 824 if (!checkitems(items, fp)) 825 return; 826 827 if (!checkitemsize(itemsize, sizeof(struct info_peer_stats)) && 828 !checkitemsize(itemsize, v4sizeof(struct info_peer_stats))) 829 return; 830 831 while (items-- > 0) { 832 ZERO_SOCK(&dst); 833 ZERO_SOCK(&src); 834 if (pp->v6_flag != 0) { 835 AF(&dst) = AF_INET6; 836 AF(&src) = AF_INET6; 837 SOCK_ADDR6(&dst) = pp->dstadr6; 838 SOCK_ADDR6(&src) = pp->srcadr6; 839 } else { 840 AF(&dst) = AF_INET; 841 AF(&src) = AF_INET; 842 NSRCADR(&dst) = pp->dstadr; 843 NSRCADR(&src) = pp->srcadr; 844 } 845#ifdef ISC_PLATFORM_HAVESALEN 846 src.sa.sa_len = SOCKLEN(&src); 847 dst.sa.sa_len = SOCKLEN(&dst); 848#endif 849 fprintf(fp, "remote host: %s\n", 850 nntohost(&src)); 851 fprintf(fp, "local interface: %s\n", 852 stoa(&dst)); 853 fprintf(fp, "time last received: %lus\n", 854 (u_long)ntohl(pp->timereceived)); 855 fprintf(fp, "time until next send: %lus\n", 856 (u_long)ntohl(pp->timetosend)); 857 fprintf(fp, "reachability change: %lus\n", 858 (u_long)ntohl(pp->timereachable)); 859 fprintf(fp, "packets sent: %lu\n", 860 (u_long)ntohl(pp->sent)); 861 fprintf(fp, "packets received: %lu\n", 862 (u_long)ntohl(pp->processed)); 863 fprintf(fp, "bad authentication: %lu\n", 864 (u_long)ntohl(pp->badauth)); 865 fprintf(fp, "bogus origin: %lu\n", 866 (u_long)ntohl(pp->bogusorg)); 867 fprintf(fp, "duplicate: %lu\n", 868 (u_long)ntohl(pp->oldpkt)); 869 fprintf(fp, "bad dispersion: %lu\n", 870 (u_long)ntohl(pp->seldisp)); 871 fprintf(fp, "bad reference time: %lu\n", 872 (u_long)ntohl(pp->selbroken)); 873 fprintf(fp, "candidate order: %u\n", 874 pp->candidate); 875 if (items > 0) 876 fprintf(fp, "\n"); 877 fprintf(fp, "flags: "); 878 print_pflag(fp, ntohs(pp->flags)); 879 pp++; 880 } 881} 882 883 884/* 885 * loopinfo - show loop filter information 886 */ 887static void 888loopinfo( 889 struct parse *pcmd, 890 FILE *fp 891 ) 892{ 893 struct info_loop *il; 894 int items; 895 int itemsize; 896 int oneline = 0; 897 int res; 898 l_fp tempts; 899 900 if (pcmd->nargs > 0) { 901 if (STREQ(pcmd->argval[0].string, "oneline")) 902 oneline = 1; 903 else if (STREQ(pcmd->argval[0].string, "multiline")) 904 oneline = 0; 905 else { 906 (void) fprintf(stderr, "How many lines?\n"); 907 return; 908 } 909 } 910 911again: 912 res = doquery(impl_ver, REQ_LOOP_INFO, 0, 0, 0, (char *)NULL, 913 &items, &itemsize, (void *)&il, 0, 914 sizeof(struct info_loop)); 915 916 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 917 impl_ver = IMPL_XNTPD_OLD; 918 goto again; 919 } 920 921 if (res != 0) 922 return; 923 924 if (!check1item(items, fp)) 925 return; 926 927 if (!checkitemsize(itemsize, sizeof(struct info_loop))) 928 return; 929 930 if (oneline) { 931 l_fp temp2ts; 932 933 NTOHL_FP(&il->last_offset, &tempts); 934 NTOHL_FP(&il->drift_comp, &temp2ts); 935 936 (void) fprintf(fp, 937 "offset %s, frequency %s, time_const %ld, watchdog %ld\n", 938 lfptoa(&tempts, 6), 939 lfptoa(&temp2ts, 3), 940 (long)(int32)ntohl((u_long)il->compliance), 941 (u_long)ntohl((u_long)il->watchdog_timer)); 942 } else { 943 NTOHL_FP(&il->last_offset, &tempts); 944 (void) fprintf(fp, "offset: %s s\n", 945 lfptoa(&tempts, 6)); 946 NTOHL_FP(&il->drift_comp, &tempts); 947 (void) fprintf(fp, "frequency: %s ppm\n", 948 lfptoa(&tempts, 3)); 949 (void) fprintf(fp, "poll adjust: %ld\n", 950 (long)(int32)ntohl(il->compliance)); 951 (void) fprintf(fp, "watchdog timer: %ld s\n", 952 (u_long)ntohl(il->watchdog_timer)); 953 } 954} 955 956 957/* 958 * sysinfo - show current system state 959 */ 960/*ARGSUSED*/ 961static void 962sysinfo( 963 struct parse *pcmd, 964 FILE *fp 965 ) 966{ 967 struct info_sys *is; 968 sockaddr_u peeraddr; 969 int items; 970 int itemsize; 971 int res; 972 l_fp tempts; 973 974again: 975 res = doquery(impl_ver, REQ_SYS_INFO, 0, 0, 0, (char *)NULL, 976 &items, &itemsize, (void *)&is, 0, 977 sizeof(struct info_sys)); 978 979 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 980 impl_ver = IMPL_XNTPD_OLD; 981 goto again; 982 } 983 984 if (res != 0) 985 return; 986 987 if (!check1item(items, fp)) 988 return; 989 990 if (!checkitemsize(itemsize, sizeof(struct info_sys)) && 991 !checkitemsize(itemsize, v4sizeof(struct info_sys))) 992 return; 993 994 SET_ADDR(peeraddr, is->v6_flag, is->peer, is->peer6); 995 996 (void) fprintf(fp, "system peer: %s\n", nntohost(&peeraddr)); 997 (void) fprintf(fp, "system peer mode: %s\n", modetoa(is->peer_mode)); 998 (void) fprintf(fp, "leap indicator: %c%c\n", 999 is->leap & 0x2 ? '1' : '0', 1000 is->leap & 0x1 ? '1' : '0'); 1001 (void) fprintf(fp, "stratum: %d\n", (int)is->stratum); 1002 (void) fprintf(fp, "precision: %d\n", (int)is->precision); 1003 (void) fprintf(fp, "root distance: %s s\n", 1004 fptoa(NTOHS_FP(is->rootdelay), 5)); 1005 (void) fprintf(fp, "root dispersion: %s s\n", 1006 ufptoa(NTOHS_FP(is->rootdispersion), 5)); 1007 (void) fprintf(fp, "reference ID: [%s]\n", 1008 refid_string(is->refid, is->stratum)); 1009 NTOHL_FP(&is->reftime, &tempts); 1010 (void) fprintf(fp, "reference time: %s\n", prettydate(&tempts)); 1011 1012 (void) fprintf(fp, "system flags: "); 1013 if ((is->flags & (INFO_FLAG_BCLIENT | INFO_FLAG_AUTHENABLE | 1014 INFO_FLAG_NTP | INFO_FLAG_KERNEL| INFO_FLAG_CAL | 1015 INFO_FLAG_PPS_SYNC | INFO_FLAG_MONITOR | INFO_FLAG_FILEGEN)) == 0) { 1016 (void) fprintf(fp, "none\n"); 1017 } else { 1018 if (is->flags & INFO_FLAG_BCLIENT) 1019 (void) fprintf(fp, "bclient "); 1020 if (is->flags & INFO_FLAG_AUTHENTICATE) 1021 (void) fprintf(fp, "auth "); 1022 if (is->flags & INFO_FLAG_MONITOR) 1023 (void) fprintf(fp, "monitor "); 1024 if (is->flags & INFO_FLAG_NTP) 1025 (void) fprintf(fp, "ntp "); 1026 if (is->flags & INFO_FLAG_KERNEL) 1027 (void) fprintf(fp, "kernel "); 1028 if (is->flags & INFO_FLAG_FILEGEN) 1029 (void) fprintf(fp, "stats "); 1030 if (is->flags & INFO_FLAG_CAL) 1031 (void) fprintf(fp, "calibrate "); 1032 if (is->flags & INFO_FLAG_PPS_SYNC) 1033 (void) fprintf(fp, "pps "); 1034 (void) fprintf(fp, "\n"); 1035 } 1036 (void) fprintf(fp, "jitter: %s s\n", 1037 fptoa(ntohl(is->frequency), 6)); 1038 (void) fprintf(fp, "stability: %s ppm\n", 1039 ufptoa(ntohl(is->stability), 3)); 1040 (void) fprintf(fp, "broadcastdelay: %s s\n", 1041 fptoa(NTOHS_FP(is->bdelay), 6)); 1042 NTOHL_FP(&is->authdelay, &tempts); 1043 (void) fprintf(fp, "authdelay: %s s\n", lfptoa(&tempts, 6)); 1044} 1045 1046 1047/* 1048 * sysstats - print system statistics 1049 */ 1050/*ARGSUSED*/ 1051static void 1052sysstats( 1053 struct parse *pcmd, 1054 FILE *fp 1055 ) 1056{ 1057 struct info_sys_stats *ss; 1058 int items; 1059 int itemsize; 1060 int res; 1061 1062again: 1063 res = doquery(impl_ver, REQ_SYS_STATS, 0, 0, 0, (char *)NULL, 1064 &items, &itemsize, (void *)&ss, 0, 1065 sizeof(struct info_sys_stats)); 1066 1067 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1068 impl_ver = IMPL_XNTPD_OLD; 1069 goto again; 1070 } 1071 1072 if (res != 0) 1073 return; 1074 1075 if (!check1item(items, fp)) 1076 return; 1077 1078 if (itemsize != sizeof(struct info_sys_stats) && 1079 itemsize != sizeof(struct old_info_sys_stats)) { 1080 /* issue warning according to new structure size */ 1081 checkitemsize(itemsize, sizeof(struct info_sys_stats)); 1082 return; 1083 } 1084 fprintf(fp, "time since restart: %lu\n", 1085 (u_long)ntohl(ss->timeup)); 1086 fprintf(fp, "time since reset: %lu\n", 1087 (u_long)ntohl(ss->timereset)); 1088 fprintf(fp, "packets received: %lu\n", 1089 (u_long)ntohl(ss->received)); 1090 fprintf(fp, "packets processed: %lu\n", 1091 (u_long)ntohl(ss->processed)); 1092 fprintf(fp, "current version: %lu\n", 1093 (u_long)ntohl(ss->newversionpkt)); 1094 fprintf(fp, "previous version: %lu\n", 1095 (u_long)ntohl(ss->oldversionpkt)); 1096 fprintf(fp, "declined: %lu\n", 1097 (u_long)ntohl(ss->unknownversion)); 1098 fprintf(fp, "access denied: %lu\n", 1099 (u_long)ntohl(ss->denied)); 1100 fprintf(fp, "bad length or format: %lu\n", 1101 (u_long)ntohl(ss->badlength)); 1102 fprintf(fp, "bad authentication: %lu\n", 1103 (u_long)ntohl(ss->badauth)); 1104 if (itemsize != sizeof(struct info_sys_stats)) 1105 return; 1106 1107 fprintf(fp, "rate exceeded: %lu\n", 1108 (u_long)ntohl(ss->limitrejected)); 1109} 1110 1111 1112 1113/* 1114 * iostats - print I/O statistics 1115 */ 1116/*ARGSUSED*/ 1117static void 1118iostats( 1119 struct parse *pcmd, 1120 FILE *fp 1121 ) 1122{ 1123 struct info_io_stats *io; 1124 int items; 1125 int itemsize; 1126 int res; 1127 1128again: 1129 res = doquery(impl_ver, REQ_IO_STATS, 0, 0, 0, NULL, &items, 1130 &itemsize, (void *)&io, 0, sizeof(*io)); 1131 1132 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1133 impl_ver = IMPL_XNTPD_OLD; 1134 goto again; 1135 } 1136 1137 if (res != 0) 1138 return; 1139 1140 if (!check1item(items, fp)) 1141 return; 1142 1143 if (!checkitemsize(itemsize, sizeof(*io))) 1144 return; 1145 1146 fprintf(fp, "time since reset: %lu\n", 1147 (u_long)ntohl(io->timereset)); 1148 fprintf(fp, "receive buffers: %u\n", 1149 (u_int)ntohs(io->totalrecvbufs)); 1150 fprintf(fp, "free receive buffers: %u\n", 1151 (u_int)ntohs(io->freerecvbufs)); 1152 fprintf(fp, "used receive buffers: %u\n", 1153 (u_int)ntohs(io->fullrecvbufs)); 1154 fprintf(fp, "low water refills: %u\n", 1155 (u_int)ntohs(io->lowwater)); 1156 fprintf(fp, "dropped packets: %lu\n", 1157 (u_long)ntohl(io->dropped)); 1158 fprintf(fp, "ignored packets: %lu\n", 1159 (u_long)ntohl(io->ignored)); 1160 fprintf(fp, "received packets: %lu\n", 1161 (u_long)ntohl(io->received)); 1162 fprintf(fp, "packets sent: %lu\n", 1163 (u_long)ntohl(io->sent)); 1164 fprintf(fp, "packets not sent: %lu\n", 1165 (u_long)ntohl(io->notsent)); 1166 fprintf(fp, "interrupts handled: %lu\n", 1167 (u_long)ntohl(io->interrupts)); 1168 fprintf(fp, "received by int: %lu\n", 1169 (u_long)ntohl(io->int_received)); 1170} 1171 1172 1173/* 1174 * memstats - print peer memory statistics 1175 */ 1176/*ARGSUSED*/ 1177static void 1178memstats( 1179 struct parse *pcmd, 1180 FILE *fp 1181 ) 1182{ 1183 struct info_mem_stats *mem; 1184 int i; 1185 int items; 1186 int itemsize; 1187 int res; 1188 1189again: 1190 res = doquery(impl_ver, REQ_MEM_STATS, 0, 0, 0, NULL, &items, 1191 &itemsize, (void *)&mem, 0, sizeof(*mem)); 1192 1193 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1194 impl_ver = IMPL_XNTPD_OLD; 1195 goto again; 1196 } 1197 1198 if (res != 0) 1199 return; 1200 1201 if (!check1item(items, fp)) 1202 return; 1203 1204 if (!checkitemsize(itemsize, sizeof(*mem))) 1205 return; 1206 1207 fprintf(fp, "time since reset: %lu\n", 1208 (u_long)ntohl(mem->timereset)); 1209 fprintf(fp, "total peer memory: %u\n", 1210 (u_int)ntohs(mem->totalpeermem)); 1211 fprintf(fp, "free peer memory: %u\n", 1212 (u_int)ntohs(mem->freepeermem)); 1213 fprintf(fp, "calls to findpeer: %lu\n", 1214 (u_long)ntohl(mem->findpeer_calls)); 1215 fprintf(fp, "new peer allocations: %lu\n", 1216 (u_long)ntohl(mem->allocations)); 1217 fprintf(fp, "peer demobilizations: %lu\n", 1218 (u_long)ntohl(mem->demobilizations)); 1219 1220 fprintf(fp, "hash table counts: "); 1221 for (i = 0; i < NTP_HASH_SIZE; i++) { 1222 fprintf(fp, "%4d", (int)mem->hashcount[i]); 1223 if ((i % 8) == 7 && i != (NTP_HASH_SIZE-1)) 1224 fprintf(fp, "\n "); 1225 } 1226 fprintf(fp, "\n"); 1227} 1228 1229 1230 1231/* 1232 * timerstats - print timer statistics 1233 */ 1234/*ARGSUSED*/ 1235static void 1236timerstats( 1237 struct parse *pcmd, 1238 FILE *fp 1239 ) 1240{ 1241 struct info_timer_stats *tim; 1242 int items; 1243 int itemsize; 1244 int res; 1245 1246again: 1247 res = doquery(impl_ver, REQ_TIMER_STATS, 0, 0, 0, NULL, &items, 1248 &itemsize, (void *)&tim, 0, sizeof(*tim)); 1249 1250 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1251 impl_ver = IMPL_XNTPD_OLD; 1252 goto again; 1253 } 1254 1255 if (res != 0) 1256 return; 1257 1258 if (!check1item(items, fp)) 1259 return; 1260 1261 if (!checkitemsize(itemsize, sizeof(*tim))) 1262 return; 1263 1264 fprintf(fp, "time since reset: %lu\n", 1265 (u_long)ntohl(tim->timereset)); 1266 fprintf(fp, "alarms handled: %lu\n", 1267 (u_long)ntohl(tim->alarms)); 1268 fprintf(fp, "alarm overruns: %lu\n", 1269 (u_long)ntohl(tim->overflows)); 1270 fprintf(fp, "calls to transmit: %lu\n", 1271 (u_long)ntohl(tim->xmtcalls)); 1272} 1273 1274 1275/* 1276 * addpeer - configure an active mode association 1277 */ 1278static void 1279addpeer( 1280 struct parse *pcmd, 1281 FILE *fp 1282 ) 1283{ 1284 doconfig(pcmd, fp, MODE_ACTIVE, 0); 1285} 1286 1287 1288/* 1289 * addserver - configure a client mode association 1290 */ 1291static void 1292addserver( 1293 struct parse *pcmd, 1294 FILE *fp 1295 ) 1296{ 1297 doconfig(pcmd, fp, MODE_CLIENT, 0); 1298} 1299 1300/* 1301 * addrefclock - configure a reference clock association 1302 */ 1303static void 1304addrefclock( 1305 struct parse *pcmd, 1306 FILE *fp 1307 ) 1308{ 1309 doconfig(pcmd, fp, MODE_CLIENT, 1); 1310} 1311 1312/* 1313 * broadcast - configure a broadcast mode association 1314 */ 1315static void 1316broadcast( 1317 struct parse *pcmd, 1318 FILE *fp 1319 ) 1320{ 1321 doconfig(pcmd, fp, MODE_BROADCAST, 0); 1322} 1323 1324 1325/* 1326 * config - configure a new peer association 1327 */ 1328static void 1329doconfig( 1330 struct parse *pcmd, 1331 FILE *fp, 1332 int mode, 1333 int refc 1334 ) 1335{ 1336 struct conf_peer cpeer; 1337 int items; 1338 int itemsize; 1339 char *dummy; 1340 u_long keyid; 1341 u_int version; 1342 u_char minpoll; 1343 u_char maxpoll; 1344 u_int flags; 1345 u_char cmode; 1346 int res; 1347 int sendsize; 1348 int numtyp; 1349 long val; 1350 1351again: 1352 keyid = 0; 1353 version = 3; 1354 flags = 0; 1355 res = FALSE; 1356 cmode = 0; 1357 minpoll = NTP_MINDPOLL; 1358 maxpoll = NTP_MAXDPOLL; 1359 numtyp = 1; 1360 if (refc) 1361 numtyp = 5; 1362 1363 if (impl_ver == IMPL_XNTPD) 1364 sendsize = sizeof(struct conf_peer); 1365 else 1366 sendsize = v4sizeof(struct conf_peer); 1367 1368 items = 1; 1369 while (pcmd->nargs > (size_t)items) { 1370 if (STREQ(pcmd->argval[items].string, "prefer")) 1371 flags |= CONF_FLAG_PREFER; 1372 else if (STREQ(pcmd->argval[items].string, "burst")) 1373 flags |= CONF_FLAG_BURST; 1374 else if (STREQ(pcmd->argval[items].string, "iburst")) 1375 flags |= CONF_FLAG_IBURST; 1376 else if (!refc && STREQ(pcmd->argval[items].string, "keyid")) 1377 numtyp = 1; 1378 else if (!refc && STREQ(pcmd->argval[items].string, "version")) 1379 numtyp = 2; 1380 else if (STREQ(pcmd->argval[items].string, "minpoll")) 1381 numtyp = 3; 1382 else if (STREQ(pcmd->argval[items].string, "maxpoll")) 1383 numtyp = 4; 1384 else { 1385 if (!atoint(pcmd->argval[items].string, &val)) 1386 numtyp = 0; 1387 switch (numtyp) { 1388 case 1: 1389 keyid = val; 1390 numtyp = 2; 1391 break; 1392 1393 case 2: 1394 version = (u_int)val; 1395 numtyp = 0; 1396 break; 1397 1398 case 3: 1399 minpoll = (u_char)val; 1400 numtyp = 0; 1401 break; 1402 1403 case 4: 1404 maxpoll = (u_char)val; 1405 numtyp = 0; 1406 break; 1407 1408 case 5: 1409 cmode = (u_char)val; 1410 numtyp = 0; 1411 break; 1412 1413 default: 1414 fprintf(fp, "*** '%s' not understood\n", 1415 pcmd->argval[items].string); 1416 res = TRUE; 1417 numtyp = 0; 1418 } 1419 if (val < 0) { 1420 fprintf(stderr, 1421 "*** Value '%s' should be unsigned\n", 1422 pcmd->argval[items].string); 1423 res = TRUE; 1424 } 1425 } 1426 items++; 1427 } 1428 if (keyid > 0) 1429 flags |= CONF_FLAG_AUTHENABLE; 1430 if (version > NTP_VERSION || version < NTP_OLDVERSION) { 1431 fprintf(fp, "***invalid version number: %u\n", 1432 version); 1433 res = TRUE; 1434 } 1435 if (minpoll < NTP_MINPOLL || minpoll > NTP_MAXPOLL || 1436 maxpoll < NTP_MINPOLL || maxpoll > NTP_MAXPOLL || 1437 minpoll > maxpoll) { 1438 fprintf(fp, "***min/max-poll must be within %d..%d\n", 1439 NTP_MINPOLL, NTP_MAXPOLL); 1440 res = TRUE; 1441 } 1442 1443 if (res) 1444 return; 1445 1446 memset(&cpeer, 0, sizeof(cpeer)); 1447 1448 if (IS_IPV4(&pcmd->argval[0].netnum)) { 1449 cpeer.peeraddr = NSRCADR(&pcmd->argval[0].netnum); 1450 if (impl_ver == IMPL_XNTPD) 1451 cpeer.v6_flag = 0; 1452 } else { 1453 if (impl_ver == IMPL_XNTPD_OLD) { 1454 fprintf(stderr, 1455 "***Server doesn't understand IPv6 addresses\n"); 1456 return; 1457 } 1458 cpeer.peeraddr6 = SOCK_ADDR6(&pcmd->argval[0].netnum); 1459 cpeer.v6_flag = 1; 1460 } 1461 cpeer.hmode = (u_char) mode; 1462 cpeer.keyid = keyid; 1463 cpeer.version = (u_char) version; 1464 cpeer.minpoll = minpoll; 1465 cpeer.maxpoll = maxpoll; 1466 cpeer.flags = (u_char)flags; 1467 cpeer.ttl = cmode; 1468 1469 res = doquery(impl_ver, REQ_CONFIG, 1, 1, 1470 sendsize, (char *)&cpeer, &items, 1471 &itemsize, &dummy, 0, sizeof(struct conf_peer)); 1472 1473 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1474 impl_ver = IMPL_XNTPD_OLD; 1475 goto again; 1476 } 1477 1478 if (res == INFO_ERR_FMT) { 1479 (void) fprintf(fp, 1480 "***Retrying command with old conf_peer size\n"); 1481 res = doquery(impl_ver, REQ_CONFIG, 1, 1, 1482 sizeof(struct old_conf_peer), (char *)&cpeer, 1483 &items, &itemsize, &dummy, 0, 1484 sizeof(struct conf_peer)); 1485 } 1486 if (res == 0) 1487 (void) fprintf(fp, "done!\n"); 1488 return; 1489} 1490 1491 1492/* 1493 * unconfig - unconfigure some associations 1494 */ 1495static void 1496unconfig( 1497 struct parse *pcmd, 1498 FILE *fp 1499 ) 1500{ 1501 /* 8 is the maximum number of peers which will fit in a packet */ 1502 struct conf_unpeer *pl, plist[min(MAXARGS, 8)]; 1503 int qitemlim; 1504 int qitems; 1505 int items; 1506 int itemsize; 1507 char *dummy; 1508 int res; 1509 int sendsize; 1510 1511again: 1512 if (impl_ver == IMPL_XNTPD) 1513 sendsize = sizeof(struct conf_unpeer); 1514 else 1515 sendsize = v4sizeof(struct conf_unpeer); 1516 1517 qitemlim = min(pcmd->nargs, COUNTOF(plist)); 1518 for (qitems = 0, pl = plist; qitems < qitemlim; qitems++) { 1519 if (IS_IPV4(&pcmd->argval[0].netnum)) { 1520 pl->peeraddr = NSRCADR(&pcmd->argval[qitems].netnum); 1521 if (impl_ver == IMPL_XNTPD) 1522 pl->v6_flag = 0; 1523 } else { 1524 if (impl_ver == IMPL_XNTPD_OLD) { 1525 fprintf(stderr, 1526 "***Server doesn't understand IPv6 addresses\n"); 1527 return; 1528 } 1529 pl->peeraddr6 = 1530 SOCK_ADDR6(&pcmd->argval[qitems].netnum); 1531 pl->v6_flag = 1; 1532 } 1533 pl = (struct conf_unpeer *)((char *)pl + sendsize); 1534 } 1535 1536 res = doquery(impl_ver, REQ_UNCONFIG, 1, qitems, 1537 sendsize, (char *)plist, &items, 1538 &itemsize, &dummy, 0, sizeof(struct conf_unpeer)); 1539 1540 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1541 impl_ver = IMPL_XNTPD_OLD; 1542 goto again; 1543 } 1544 1545 if (res == 0) 1546 (void) fprintf(fp, "done!\n"); 1547} 1548 1549 1550/* 1551 * set - set some system flags 1552 */ 1553static void 1554set( 1555 struct parse *pcmd, 1556 FILE *fp 1557 ) 1558{ 1559 doset(pcmd, fp, REQ_SET_SYS_FLAG); 1560} 1561 1562 1563/* 1564 * clear - clear some system flags 1565 */ 1566static void 1567sys_clear( 1568 struct parse *pcmd, 1569 FILE *fp 1570 ) 1571{ 1572 doset(pcmd, fp, REQ_CLR_SYS_FLAG); 1573} 1574 1575 1576/* 1577 * doset - set/clear system flags 1578 */ 1579static void 1580doset( 1581 struct parse *pcmd, 1582 FILE *fp, 1583 int req 1584 ) 1585{ 1586 struct conf_sys_flags sys; 1587 int items; 1588 int itemsize; 1589 char *dummy; 1590 int res; 1591 1592 sys.flags = 0; 1593 res = 0; 1594 for (items = 0; (size_t)items < pcmd->nargs; items++) { 1595 if (STREQ(pcmd->argval[items].string, "auth")) 1596 sys.flags |= SYS_FLAG_AUTH; 1597 else if (STREQ(pcmd->argval[items].string, "bclient")) 1598 sys.flags |= SYS_FLAG_BCLIENT; 1599 else if (STREQ(pcmd->argval[items].string, "calibrate")) 1600 sys.flags |= SYS_FLAG_CAL; 1601 else if (STREQ(pcmd->argval[items].string, "kernel")) 1602 sys.flags |= SYS_FLAG_KERNEL; 1603 else if (STREQ(pcmd->argval[items].string, "monitor")) 1604 sys.flags |= SYS_FLAG_MONITOR; 1605 else if (STREQ(pcmd->argval[items].string, "ntp")) 1606 sys.flags |= SYS_FLAG_NTP; 1607 else if (STREQ(pcmd->argval[items].string, "pps")) 1608 sys.flags |= SYS_FLAG_PPS; 1609 else if (STREQ(pcmd->argval[items].string, "stats")) 1610 sys.flags |= SYS_FLAG_FILEGEN; 1611 else { 1612 (void) fprintf(fp, "Unknown flag %s\n", 1613 pcmd->argval[items].string); 1614 res = 1; 1615 } 1616 } 1617 1618 sys.flags = htonl(sys.flags); 1619 if (res || sys.flags == 0) 1620 return; 1621 1622again: 1623 res = doquery(impl_ver, req, 1, 1, 1624 sizeof(struct conf_sys_flags), (char *)&sys, &items, 1625 &itemsize, &dummy, 0, sizeof(struct conf_sys_flags)); 1626 1627 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1628 impl_ver = IMPL_XNTPD_OLD; 1629 goto again; 1630 } 1631 1632 if (res == 0) 1633 (void) fprintf(fp, "done!\n"); 1634} 1635 1636 1637/* 1638 * data for printing/interrpreting the restrict flags 1639 */ 1640struct resflags { 1641 const char *str; 1642 int bit; 1643}; 1644 1645/* XXX: HMS: we apparently don't report set bits we do not recognize. */ 1646 1647static struct resflags resflagsV2[] = { 1648 { "ignore", 0x001 }, 1649 { "noserve", 0x002 }, 1650 { "notrust", 0x004 }, 1651 { "noquery", 0x008 }, 1652 { "nomodify", 0x010 }, 1653 { "nopeer", 0x020 }, 1654 { "notrap", 0x040 }, 1655 { "lptrap", 0x080 }, 1656 { "limited", 0x100 }, 1657 { "", 0 } 1658}; 1659 1660static struct resflags resflagsV3[] = { 1661 { "ignore", RES_IGNORE }, 1662 { "noserve", RES_DONTSERVE }, 1663 { "notrust", RES_DONTTRUST }, 1664 { "noquery", RES_NOQUERY }, 1665 { "nomodify", RES_NOMODIFY }, 1666 { "nopeer", RES_NOPEER }, 1667 { "notrap", RES_NOTRAP }, 1668 { "lptrap", RES_LPTRAP }, 1669 { "limited", RES_LIMITED }, 1670 { "version", RES_VERSION }, 1671 { "kod", RES_KOD }, 1672 { "timeout", RES_TIMEOUT }, 1673 1674 { "", 0 } 1675}; 1676 1677static struct resflags resmflags[] = { 1678 { "ntpport", RESM_NTPONLY }, 1679 { "interface", RESM_INTERFACE }, 1680 { "", 0 } 1681}; 1682 1683 1684/* 1685 * reslist - obtain and print the server's restrict list 1686 */ 1687/*ARGSUSED*/ 1688static void 1689reslist( 1690 struct parse *pcmd, 1691 FILE *fp 1692 ) 1693{ 1694 struct info_restrict *rl; 1695 sockaddr_u resaddr; 1696 sockaddr_u maskaddr; 1697 int items; 1698 int itemsize; 1699 int res; 1700 int skip; 1701 char *addr; 1702 char *mask; 1703 struct resflags *rf; 1704 u_int32 count; 1705 u_short flags; 1706 u_short mflags; 1707 char flagstr[300]; 1708 static const char *comma = ", "; 1709 1710again: 1711 res = doquery(impl_ver, REQ_GET_RESTRICT, 0, 0, 0, (char *)NULL, 1712 &items, &itemsize, (void *)&rl, 0, 1713 sizeof(struct info_restrict)); 1714 1715 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1716 impl_ver = IMPL_XNTPD_OLD; 1717 goto again; 1718 } 1719 1720 if (res != 0) 1721 return; 1722 1723 if (!checkitems(items, fp)) 1724 return; 1725 1726 if (!checkitemsize(itemsize, sizeof(struct info_restrict)) && 1727 !checkitemsize(itemsize, v4sizeof(struct info_restrict))) 1728 return; 1729 1730 (void) fprintf(fp, 1731 " address mask count flags\n"); 1732 (void) fprintf(fp, 1733 "=====================================================================\n"); 1734 1735 while (items > 0) { 1736 SET_ADDRS(resaddr, maskaddr, rl, addr, mask); 1737 if (rl->v6_flag != 0) { 1738 addr = nntohost(&resaddr); 1739 } else { 1740 if ((rl->mask == (u_int32)0xffffffff)) 1741 addr = nntohost(&resaddr); 1742 else 1743 addr = stoa(&resaddr); 1744 } 1745 mask = stoa(&maskaddr); 1746 skip = 1; 1747 if ((pcmd->nargs == 0) || 1748 ((pcmd->argval->ival == 6) && (rl->v6_flag != 0)) || 1749 ((pcmd->argval->ival == 4) && (rl->v6_flag == 0))) 1750 skip = 0; 1751 count = ntohl(rl->count); 1752 flags = ntohs(rl->flags); 1753 mflags = ntohs(rl->mflags); 1754 flagstr[0] = '\0'; 1755 1756 res = 1; 1757 rf = &resmflags[0]; 1758 while (rf->bit != 0) { 1759 if (mflags & rf->bit) { 1760 if (!res) 1761 (void) strcat(flagstr, comma); 1762 res = 0; 1763 (void) strcat(flagstr, rf->str); 1764 } 1765 rf++; 1766 } 1767 1768 rf = (impl_ver == IMPL_XNTPD_OLD) 1769 ? &resflagsV2[0] 1770 : &resflagsV3[0] 1771 ; 1772 while (rf->bit != 0) { 1773 if (flags & rf->bit) { 1774 if (!res) 1775 (void) strcat(flagstr, comma); 1776 res = 0; 1777 (void) strcat(flagstr, rf->str); 1778 } 1779 rf++; 1780 } 1781 1782 if (flagstr[0] == '\0') 1783 strcpy(flagstr, "none"); 1784 1785 if (!skip) 1786 fprintf(fp, "%-15.15s %-15.15s %9lu %s\n", 1787 addr, mask, (u_long)count, flagstr); 1788 rl++; 1789 items--; 1790 } 1791} 1792 1793 1794 1795/* 1796 * new_restrict - create/add a set of restrictions 1797 */ 1798static void 1799new_restrict( 1800 struct parse *pcmd, 1801 FILE *fp 1802 ) 1803{ 1804 do_restrict(pcmd, fp, REQ_RESADDFLAGS); 1805} 1806 1807 1808/* 1809 * unrestrict - remove restriction flags from existing entry 1810 */ 1811static void 1812unrestrict( 1813 struct parse *pcmd, 1814 FILE *fp 1815 ) 1816{ 1817 do_restrict(pcmd, fp, REQ_RESSUBFLAGS); 1818} 1819 1820 1821/* 1822 * delrestrict - delete an existing restriction 1823 */ 1824static void 1825delrestrict( 1826 struct parse *pcmd, 1827 FILE *fp 1828 ) 1829{ 1830 do_restrict(pcmd, fp, REQ_UNRESTRICT); 1831} 1832 1833 1834/* 1835 * do_restrict - decode commandline restrictions and make the request 1836 */ 1837static void 1838do_restrict( 1839 struct parse *pcmd, 1840 FILE *fp, 1841 int req_code 1842 ) 1843{ 1844 struct conf_restrict cres; 1845 int items; 1846 int itemsize; 1847 char *dummy; 1848 u_int32 num; 1849 u_long bit; 1850 int i; 1851 size_t res; 1852 int err; 1853 int sendsize; 1854 1855 /* Initialize cres */ 1856 cres.addr = 0; 1857 cres.mask = 0; 1858 cres.flags = 0; 1859 cres.mflags = 0; 1860 cres.v6_flag = 0; 1861 1862again: 1863 if (impl_ver == IMPL_XNTPD) 1864 sendsize = sizeof(struct conf_restrict); 1865 else 1866 sendsize = v4sizeof(struct conf_restrict); 1867 1868 if (IS_IPV4(&pcmd->argval[0].netnum)) { 1869 cres.addr = NSRCADR(&pcmd->argval[0].netnum); 1870 cres.mask = NSRCADR(&pcmd->argval[1].netnum); 1871 if (impl_ver == IMPL_XNTPD) 1872 cres.v6_flag = 0; 1873 } else { 1874 if (impl_ver == IMPL_XNTPD_OLD) { 1875 fprintf(stderr, 1876 "***Server doesn't understand IPv6 addresses\n"); 1877 return; 1878 } 1879 cres.addr6 = SOCK_ADDR6(&pcmd->argval[0].netnum); 1880 cres.v6_flag = 1; 1881 } 1882 cres.flags = 0; 1883 cres.mflags = 0; 1884 err = FALSE; 1885 for (res = 2; res < pcmd->nargs; res++) { 1886 if (STREQ(pcmd->argval[res].string, "ntpport")) { 1887 cres.mflags |= RESM_NTPONLY; 1888 } else { 1889 for (i = 0; resflagsV3[i].bit != 0; i++) { 1890 if (STREQ(pcmd->argval[res].string, 1891 resflagsV3[i].str)) 1892 break; 1893 } 1894 if (resflagsV3[i].bit != 0) { 1895 cres.flags |= resflagsV3[i].bit; 1896 if (req_code == REQ_UNRESTRICT) { 1897 fprintf(fp, 1898 "Flag %s inappropriate\n", 1899 resflagsV3[i].str); 1900 err = TRUE; 1901 } 1902 } else { 1903 fprintf(fp, "Unknown flag %s\n", 1904 pcmd->argval[res].string); 1905 err = TRUE; 1906 } 1907 } 1908 } 1909 cres.flags = htons(cres.flags); 1910 cres.mflags = htons(cres.mflags); 1911 1912 /* 1913 * Make sure mask for default address is zero. Otherwise, 1914 * make sure mask bits are contiguous. 1915 */ 1916 if (IS_IPV4(&pcmd->argval[0].netnum)) { 1917 if (cres.addr == 0) { 1918 cres.mask = 0; 1919 } else { 1920 num = ntohl(cres.mask); 1921 for (bit = 0x80000000; bit != 0; bit >>= 1) 1922 if ((num & bit) == 0) 1923 break; 1924 for ( ; bit != 0; bit >>= 1) 1925 if ((num & bit) != 0) 1926 break; 1927 if (bit != 0) { 1928 fprintf(fp, "Invalid mask %s\n", 1929 numtoa(cres.mask)); 1930 err = TRUE; 1931 } 1932 } 1933 } else { 1934 /* XXX IPv6 sanity checking stuff */ 1935 } 1936 1937 if (err) 1938 return; 1939 1940 res = doquery(impl_ver, req_code, 1, 1, sendsize, (char *)&cres, 1941 &items, &itemsize, &dummy, 0, sizeof(cres)); 1942 1943 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1944 impl_ver = IMPL_XNTPD_OLD; 1945 goto again; 1946 } 1947 1948 if (res == 0) 1949 (void) fprintf(fp, "done!\n"); 1950 return; 1951} 1952 1953 1954/* 1955 * monlist - obtain and print the server's monitor data 1956 */ 1957/*ARGSUSED*/ 1958static void 1959monlist( 1960 struct parse *pcmd, 1961 FILE *fp 1962 ) 1963{ 1964 char *struct_star; 1965 sockaddr_u addr; 1966 sockaddr_u dstadr; 1967 int items; 1968 int itemsize; 1969 int res; 1970 int version = -1; 1971 1972 if (pcmd->nargs > 0) { 1973 version = pcmd->argval[0].ival; 1974 } 1975 1976again: 1977 res = doquery(impl_ver, 1978 (version == 1 || version == -1) ? REQ_MON_GETLIST_1 : 1979 REQ_MON_GETLIST, 0, 0, 0, (char *)NULL, 1980 &items, &itemsize, &struct_star, 1981 (version < 0) ? (1 << INFO_ERR_REQ) : 0, 1982 sizeof(struct info_monitor_1)); 1983 1984 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1985 impl_ver = IMPL_XNTPD_OLD; 1986 goto again; 1987 } 1988 1989 if (res == INFO_ERR_REQ && version < 0) 1990 res = doquery(impl_ver, REQ_MON_GETLIST, 0, 0, 0, (char *)NULL, 1991 &items, &itemsize, &struct_star, 0, 1992 sizeof(struct info_monitor)); 1993 1994 if (res != 0) 1995 return; 1996 1997 if (!checkitems(items, fp)) 1998 return; 1999 2000 if (itemsize == sizeof(struct info_monitor_1) || 2001 itemsize == v4sizeof(struct info_monitor_1)) { 2002 struct info_monitor_1 *ml = (struct info_monitor_1 *) struct_star; 2003 2004 (void) fprintf(fp, 2005 "remote address port local address count m ver rstr avgint lstint\n"); 2006 (void) fprintf(fp, 2007 "===============================================================================\n"); 2008 while (items > 0) { 2009 SET_ADDRS(dstadr, addr, ml, daddr, addr); 2010 if ((pcmd->nargs == 0) || 2011 ((pcmd->argval->ival == 6) && (ml->v6_flag != 0)) || 2012 ((pcmd->argval->ival == 4) && (ml->v6_flag == 0))) 2013 fprintf(fp, 2014 "%-22.22s %5d %-15s %8lu %1u %1u %6lx %6lu %7lu\n", 2015 nntohost(&addr), 2016 ntohs(ml->port), 2017 stoa(&dstadr), 2018 (u_long)ntohl(ml->count), 2019 ml->mode, 2020 ml->version, 2021 (u_long)ntohl(ml->restr), 2022 (u_long)ntohl(ml->lasttime), 2023 (u_long)ntohl(ml->firsttime)); 2024 ml++; 2025 items--; 2026 } 2027 } else if (itemsize == sizeof(struct info_monitor) || 2028 itemsize == v4sizeof(struct info_monitor)) { 2029 struct info_monitor *ml = (struct info_monitor *) struct_star; 2030 2031 (void) fprintf(fp, 2032 " address port count mode ver rstr avgint lstint\n"); 2033 (void) fprintf(fp, 2034 "===============================================================================\n"); 2035 while (items > 0) { 2036 SET_ADDR(dstadr, ml->v6_flag, ml->addr, ml->addr6); 2037 if ((pcmd->nargs == 0) || 2038 ((pcmd->argval->ival == 6) && (ml->v6_flag != 0)) || 2039 ((pcmd->argval->ival == 4) && (ml->v6_flag == 0))) 2040 (void) fprintf(fp, 2041 "%-25.25s %5u %9lu %4u %2u %9lx %9lu %9lu\n", 2042 nntohost(&dstadr), 2043 ntohs(ml->port), 2044 (u_long)ntohl(ml->count), 2045 ml->mode, 2046 ml->version, 2047 (u_long)ntohl(ml->restr), 2048 (u_long)ntohl(ml->lasttime), 2049 (u_long)ntohl(ml->firsttime)); 2050 ml++; 2051 items--; 2052 } 2053 } else if (itemsize == sizeof(struct old_info_monitor)) { 2054 struct old_info_monitor *oml = (struct old_info_monitor *)struct_star; 2055 (void) fprintf(fp, 2056 " address port count mode version lasttime firsttime\n"); 2057 (void) fprintf(fp, 2058 "======================================================================\n"); 2059 while (items > 0) { 2060 SET_ADDR(dstadr, oml->v6_flag, oml->addr, oml->addr6); 2061 (void) fprintf(fp, "%-20.20s %5u %9lu %4u %3u %9lu %9lu\n", 2062 nntohost(&dstadr), 2063 ntohs(oml->port), 2064 (u_long)ntohl(oml->count), 2065 oml->mode, 2066 oml->version, 2067 (u_long)ntohl(oml->lasttime), 2068 (u_long)ntohl(oml->firsttime)); 2069 oml++; 2070 items--; 2071 } 2072 } else { 2073 /* issue warning according to new info_monitor size */ 2074 checkitemsize(itemsize, sizeof(struct info_monitor)); 2075 } 2076} 2077 2078 2079/* 2080 * Mapping between command line strings and stat reset flags 2081 */ 2082struct statreset { 2083 const char *str; 2084 int flag; 2085} sreset[] = { 2086 { "io", RESET_FLAG_IO }, 2087 { "sys", RESET_FLAG_SYS }, 2088 { "mem", RESET_FLAG_MEM }, 2089 { "timer", RESET_FLAG_TIMER }, 2090 { "auth", RESET_FLAG_AUTH }, 2091 { "allpeers", RESET_FLAG_ALLPEERS }, 2092 { "", 0 } 2093}; 2094 2095/* 2096 * reset - reset statistic counters 2097 */ 2098static void 2099reset( 2100 struct parse *pcmd, 2101 FILE *fp 2102 ) 2103{ 2104 struct reset_flags rflags; 2105 int items; 2106 int itemsize; 2107 char *dummy; 2108 int i; 2109 size_t res; 2110 int err; 2111 2112 err = 0; 2113 rflags.flags = 0; 2114 for (res = 0; res < pcmd->nargs; res++) { 2115 for (i = 0; sreset[i].flag != 0; i++) { 2116 if (STREQ(pcmd->argval[res].string, sreset[i].str)) 2117 break; 2118 } 2119 if (sreset[i].flag == 0) { 2120 (void) fprintf(fp, "Flag %s unknown\n", 2121 pcmd->argval[res].string); 2122 err++; 2123 } else { 2124 rflags.flags |= sreset[i].flag; 2125 } 2126 } 2127 rflags.flags = htonl(rflags.flags); 2128 2129 if (err) { 2130 (void) fprintf(fp, "Not done due to errors\n"); 2131 return; 2132 } 2133 2134again: 2135 res = doquery(impl_ver, REQ_RESET_STATS, 1, 1, 2136 sizeof(struct reset_flags), (char *)&rflags, &items, 2137 &itemsize, &dummy, 0, sizeof(struct reset_flags)); 2138 2139 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2140 impl_ver = IMPL_XNTPD_OLD; 2141 goto again; 2142 } 2143 2144 if (res == 0) 2145 (void) fprintf(fp, "done!\n"); 2146 return; 2147} 2148 2149 2150 2151/* 2152 * preset - reset stat counters for particular peers 2153 */ 2154static void 2155preset( 2156 struct parse *pcmd, 2157 FILE *fp 2158 ) 2159{ 2160 /* 8 is the maximum number of peers which will fit in a packet */ 2161 struct conf_unpeer *pl, plist[min(MAXARGS, 8)]; 2162 int qitemlim; 2163 int qitems; 2164 int items; 2165 int itemsize; 2166 char *dummy; 2167 int res; 2168 int sendsize; 2169 2170again: 2171 if (impl_ver == IMPL_XNTPD) 2172 sendsize = sizeof(struct conf_unpeer); 2173 else 2174 sendsize = v4sizeof(struct conf_unpeer); 2175 2176 qitemlim = min(pcmd->nargs, COUNTOF(plist)); 2177 for (qitems = 0, pl = plist; qitems < qitemlim; qitems++) { 2178 if (IS_IPV4(&pcmd->argval[qitems].netnum)) { 2179 pl->peeraddr = NSRCADR(&pcmd->argval[qitems].netnum); 2180 if (impl_ver == IMPL_XNTPD) 2181 pl->v6_flag = 0; 2182 } else { 2183 if (impl_ver == IMPL_XNTPD_OLD) { 2184 fprintf(stderr, 2185 "***Server doesn't understand IPv6 addresses\n"); 2186 return; 2187 } 2188 pl->peeraddr6 = 2189 SOCK_ADDR6(&pcmd->argval[qitems].netnum); 2190 pl->v6_flag = 1; 2191 } 2192 pl = (struct conf_unpeer *)((char *)pl + sendsize); 2193 } 2194 2195 res = doquery(impl_ver, REQ_RESET_PEER, 1, qitems, 2196 sendsize, (char *)plist, &items, 2197 &itemsize, &dummy, 0, sizeof(struct conf_unpeer)); 2198 2199 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2200 impl_ver = IMPL_XNTPD_OLD; 2201 goto again; 2202 } 2203 2204 if (res == 0) 2205 (void) fprintf(fp, "done!\n"); 2206} 2207 2208 2209/* 2210 * readkeys - request the server to reread the keys file 2211 */ 2212/*ARGSUSED*/ 2213static void 2214readkeys( 2215 struct parse *pcmd, 2216 FILE *fp 2217 ) 2218{ 2219 int items; 2220 int itemsize; 2221 char *dummy; 2222 int res; 2223 2224again: 2225 res = doquery(impl_ver, REQ_REREAD_KEYS, 1, 0, 0, (char *)0, 2226 &items, &itemsize, &dummy, 0, sizeof(dummy)); 2227 2228 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2229 impl_ver = IMPL_XNTPD_OLD; 2230 goto again; 2231 } 2232 2233 if (res == 0) 2234 (void) fprintf(fp, "done!\n"); 2235 return; 2236} 2237 2238 2239/* 2240 * trustkey - add some keys to the trusted key list 2241 */ 2242static void 2243trustkey( 2244 struct parse *pcmd, 2245 FILE *fp 2246 ) 2247{ 2248 do_trustkey(pcmd, fp, REQ_TRUSTKEY); 2249} 2250 2251 2252/* 2253 * untrustkey - remove some keys from the trusted key list 2254 */ 2255static void 2256untrustkey( 2257 struct parse *pcmd, 2258 FILE *fp 2259 ) 2260{ 2261 do_trustkey(pcmd, fp, REQ_UNTRUSTKEY); 2262} 2263 2264 2265/* 2266 * do_trustkey - do grunge work of adding/deleting keys 2267 */ 2268static void 2269do_trustkey( 2270 struct parse *pcmd, 2271 FILE *fp, 2272 int req 2273 ) 2274{ 2275 u_long keyids[MAXARGS]; 2276 size_t i; 2277 int items; 2278 int itemsize; 2279 char *dummy; 2280 int ritems; 2281 int res; 2282 2283 ritems = 0; 2284 for (i = 0; i < pcmd->nargs; i++) { 2285 keyids[ritems++] = pcmd->argval[i].uval; 2286 } 2287 2288again: 2289 res = doquery(impl_ver, req, 1, ritems, sizeof(u_long), 2290 (char *)keyids, &items, &itemsize, &dummy, 0, 2291 sizeof(dummy)); 2292 2293 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2294 impl_ver = IMPL_XNTPD_OLD; 2295 goto again; 2296 } 2297 2298 if (res == 0) 2299 (void) fprintf(fp, "done!\n"); 2300 return; 2301} 2302 2303 2304 2305/* 2306 * authinfo - obtain and print info about authentication 2307 */ 2308/*ARGSUSED*/ 2309static void 2310authinfo( 2311 struct parse *pcmd, 2312 FILE *fp 2313 ) 2314{ 2315 struct info_auth *ia; 2316 int items; 2317 int itemsize; 2318 int res; 2319 2320again: 2321 res = doquery(impl_ver, REQ_AUTHINFO, 0, 0, 0, NULL, &items, 2322 &itemsize, (void *)&ia, 0, sizeof(*ia)); 2323 2324 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2325 impl_ver = IMPL_XNTPD_OLD; 2326 goto again; 2327 } 2328 2329 if (res != 0) 2330 return; 2331 2332 if (!check1item(items, fp)) 2333 return; 2334 2335 if (!checkitemsize(itemsize, sizeof(*ia))) 2336 return; 2337 2338 fprintf(fp, "time since reset: %lu\n", 2339 (u_long)ntohl(ia->timereset)); 2340 fprintf(fp, "stored keys: %lu\n", 2341 (u_long)ntohl(ia->numkeys)); 2342 fprintf(fp, "free keys: %lu\n", 2343 (u_long)ntohl(ia->numfreekeys)); 2344 fprintf(fp, "key lookups: %lu\n", 2345 (u_long)ntohl(ia->keylookups)); 2346 fprintf(fp, "keys not found: %lu\n", 2347 (u_long)ntohl(ia->keynotfound)); 2348 fprintf(fp, "uncached keys: %lu\n", 2349 (u_long)ntohl(ia->keyuncached)); 2350 fprintf(fp, "encryptions: %lu\n", 2351 (u_long)ntohl(ia->encryptions)); 2352 fprintf(fp, "decryptions: %lu\n", 2353 (u_long)ntohl(ia->decryptions)); 2354 fprintf(fp, "expired keys: %lu\n", 2355 (u_long)ntohl(ia->expired)); 2356} 2357 2358 2359 2360/* 2361 * traps - obtain and print a list of traps 2362 */ 2363/*ARGSUSED*/ 2364static void 2365traps( 2366 struct parse *pcmd, 2367 FILE *fp 2368 ) 2369{ 2370 int i; 2371 struct info_trap *it; 2372 sockaddr_u trap_addr, local_addr; 2373 int items; 2374 int itemsize; 2375 int res; 2376 2377again: 2378 res = doquery(impl_ver, REQ_TRAPS, 0, 0, 0, (char *)NULL, 2379 &items, &itemsize, (void *)&it, 0, 2380 sizeof(struct info_trap)); 2381 2382 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2383 impl_ver = IMPL_XNTPD_OLD; 2384 goto again; 2385 } 2386 2387 if (res != 0) 2388 return; 2389 2390 if (!checkitems(items, fp)) 2391 return; 2392 2393 if (!checkitemsize(itemsize, sizeof(struct info_trap)) && 2394 !checkitemsize(itemsize, v4sizeof(struct info_trap))) 2395 return; 2396 2397 for (i = 0; i < items; i++ ) { 2398 if (i != 0) 2399 (void) fprintf(fp, "\n"); 2400 SET_ADDRS(trap_addr, local_addr, it, trap_address, local_address); 2401 (void) fprintf(fp, "address %s, port %d\n", 2402 stoa(&trap_addr), 2403 ntohs(it->trap_port)); 2404 (void) fprintf(fp, "interface: %s, ", 2405 (it->local_address == 0) 2406 ? "wildcard" 2407 : stoa(&local_addr)); 2408 if (ntohl(it->flags) & TRAP_CONFIGURED) 2409 (void) fprintf(fp, "configured\n"); 2410 else if (ntohl(it->flags) & TRAP_NONPRIO) 2411 (void) fprintf(fp, "low priority\n"); 2412 else 2413 (void) fprintf(fp, "normal priority\n"); 2414 2415 (void) fprintf(fp, "set for %ld secs, last set %ld secs ago\n", 2416 (long)ntohl(it->origtime), 2417 (long)ntohl(it->settime)); 2418 (void) fprintf(fp, "sequence %d, number of resets %ld\n", 2419 ntohs(it->sequence), 2420 (long)ntohl(it->resets)); 2421 } 2422} 2423 2424 2425/* 2426 * addtrap - configure a trap 2427 */ 2428static void 2429addtrap( 2430 struct parse *pcmd, 2431 FILE *fp 2432 ) 2433{ 2434 do_addclr_trap(pcmd, fp, REQ_ADD_TRAP); 2435} 2436 2437 2438/* 2439 * clrtrap - clear a trap from the server 2440 */ 2441static void 2442clrtrap( 2443 struct parse *pcmd, 2444 FILE *fp 2445 ) 2446{ 2447 do_addclr_trap(pcmd, fp, REQ_CLR_TRAP); 2448} 2449 2450 2451/* 2452 * do_addclr_trap - do grunge work of adding/deleting traps 2453 */ 2454static void 2455do_addclr_trap( 2456 struct parse *pcmd, 2457 FILE *fp, 2458 int req 2459 ) 2460{ 2461 struct conf_trap ctrap; 2462 int items; 2463 int itemsize; 2464 char *dummy; 2465 int res; 2466 int sendsize; 2467 2468again: 2469 if (impl_ver == IMPL_XNTPD) 2470 sendsize = sizeof(struct conf_trap); 2471 else 2472 sendsize = v4sizeof(struct conf_trap); 2473 2474 if (IS_IPV4(&pcmd->argval[0].netnum)) { 2475 ctrap.trap_address = NSRCADR(&pcmd->argval[0].netnum); 2476 if (impl_ver == IMPL_XNTPD) 2477 ctrap.v6_flag = 0; 2478 } else { 2479 if (impl_ver == IMPL_XNTPD_OLD) { 2480 fprintf(stderr, 2481 "***Server doesn't understand IPv6 addresses\n"); 2482 return; 2483 } 2484 ctrap.trap_address6 = SOCK_ADDR6(&pcmd->argval[0].netnum); 2485 ctrap.v6_flag = 1; 2486 } 2487 ctrap.local_address = 0; 2488 ctrap.trap_port = htons(TRAPPORT); 2489 ctrap.unused = 0; 2490 2491 if (pcmd->nargs > 1) { 2492 ctrap.trap_port = htons((u_short)pcmd->argval[1].uval); 2493 if (pcmd->nargs > 2) { 2494 if (AF(&pcmd->argval[2].netnum) != 2495 AF(&pcmd->argval[0].netnum)) { 2496 fprintf(stderr, 2497 "***Cannot mix IPv4 and IPv6 addresses\n"); 2498 return; 2499 } 2500 if (IS_IPV4(&pcmd->argval[2].netnum)) 2501 ctrap.local_address = NSRCADR(&pcmd->argval[2].netnum); 2502 else 2503 ctrap.local_address6 = SOCK_ADDR6(&pcmd->argval[2].netnum); 2504 } 2505 } 2506 2507 res = doquery(impl_ver, req, 1, 1, sendsize, 2508 (char *)&ctrap, &items, &itemsize, &dummy, 0, 2509 sizeof(struct conf_trap)); 2510 2511 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2512 impl_ver = IMPL_XNTPD_OLD; 2513 goto again; 2514 } 2515 2516 if (res == 0) 2517 (void) fprintf(fp, "done!\n"); 2518 return; 2519} 2520 2521 2522 2523/* 2524 * requestkey - change the server's request key (a dangerous request) 2525 */ 2526static void 2527requestkey( 2528 struct parse *pcmd, 2529 FILE *fp 2530 ) 2531{ 2532 do_changekey(pcmd, fp, REQ_REQUEST_KEY); 2533} 2534 2535 2536/* 2537 * controlkey - change the server's control key 2538 */ 2539static void 2540controlkey( 2541 struct parse *pcmd, 2542 FILE *fp 2543 ) 2544{ 2545 do_changekey(pcmd, fp, REQ_CONTROL_KEY); 2546} 2547 2548 2549 2550/* 2551 * do_changekey - do grunge work of changing keys 2552 */ 2553static void 2554do_changekey( 2555 struct parse *pcmd, 2556 FILE *fp, 2557 int req 2558 ) 2559{ 2560 u_long key; 2561 int items; 2562 int itemsize; 2563 char *dummy; 2564 int res; 2565 2566 2567 key = htonl((u_int32)pcmd->argval[0].uval); 2568 2569again: 2570 res = doquery(impl_ver, req, 1, 1, sizeof(u_int32), 2571 (char *)&key, &items, &itemsize, &dummy, 0, 2572 sizeof(dummy)); 2573 2574 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2575 impl_ver = IMPL_XNTPD_OLD; 2576 goto again; 2577 } 2578 2579 if (res == 0) 2580 (void) fprintf(fp, "done!\n"); 2581 return; 2582} 2583 2584 2585 2586/* 2587 * ctlstats - obtain and print info about authentication 2588 */ 2589/*ARGSUSED*/ 2590static void 2591ctlstats( 2592 struct parse *pcmd, 2593 FILE *fp 2594 ) 2595{ 2596 struct info_control *ic; 2597 int items; 2598 int itemsize; 2599 int res; 2600 2601again: 2602 res = doquery(impl_ver, REQ_GET_CTLSTATS, 0, 0, 0, NULL, &items, 2603 &itemsize, (void *)&ic, 0, sizeof(*ic)); 2604 2605 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2606 impl_ver = IMPL_XNTPD_OLD; 2607 goto again; 2608 } 2609 2610 if (res != 0) 2611 return; 2612 2613 if (!check1item(items, fp)) 2614 return; 2615 2616 if (!checkitemsize(itemsize, sizeof(*ic))) 2617 return; 2618 2619 fprintf(fp, "time since reset: %lu\n", 2620 (u_long)ntohl(ic->ctltimereset)); 2621 fprintf(fp, "requests received: %lu\n", 2622 (u_long)ntohl(ic->numctlreq)); 2623 fprintf(fp, "responses sent: %lu\n", 2624 (u_long)ntohl(ic->numctlresponses)); 2625 fprintf(fp, "fragments sent: %lu\n", 2626 (u_long)ntohl(ic->numctlfrags)); 2627 fprintf(fp, "async messages sent: %lu\n", 2628 (u_long)ntohl(ic->numasyncmsgs)); 2629 fprintf(fp, "error msgs sent: %lu\n", 2630 (u_long)ntohl(ic->numctlerrors)); 2631 fprintf(fp, "total bad pkts: %lu\n", 2632 (u_long)ntohl(ic->numctlbadpkts)); 2633 fprintf(fp, "packet too short: %lu\n", 2634 (u_long)ntohl(ic->numctltooshort)); 2635 fprintf(fp, "response on input: %lu\n", 2636 (u_long)ntohl(ic->numctlinputresp)); 2637 fprintf(fp, "fragment on input: %lu\n", 2638 (u_long)ntohl(ic->numctlinputfrag)); 2639 fprintf(fp, "error set on input: %lu\n", 2640 (u_long)ntohl(ic->numctlinputerr)); 2641 fprintf(fp, "bad offset on input: %lu\n", 2642 (u_long)ntohl(ic->numctlbadoffset)); 2643 fprintf(fp, "bad version packets: %lu\n", 2644 (u_long)ntohl(ic->numctlbadversion)); 2645 fprintf(fp, "data in pkt too short: %lu\n", 2646 (u_long)ntohl(ic->numctldatatooshort)); 2647 fprintf(fp, "unknown op codes: %lu\n", 2648 (u_long)ntohl(ic->numctlbadop)); 2649} 2650 2651 2652/* 2653 * clockstat - get and print clock status information 2654 */ 2655static void 2656clockstat( 2657 struct parse *pcmd, 2658 FILE *fp 2659 ) 2660{ 2661 struct info_clock *cl; 2662 /* 8 is the maximum number of clocks which will fit in a packet */ 2663 u_long clist[min(MAXARGS, 8)]; 2664 int qitemlim; 2665 int qitems; 2666 int items; 2667 int itemsize; 2668 int res; 2669 l_fp ts; 2670 struct clktype *clk; 2671 2672 qitemlim = min(pcmd->nargs, COUNTOF(clist)); 2673 for (qitems = 0; qitems < qitemlim; qitems++) 2674 clist[qitems] = NSRCADR(&pcmd->argval[qitems].netnum); 2675 2676again: 2677 res = doquery(impl_ver, REQ_GET_CLOCKINFO, 0, qitems, 2678 sizeof(u_int32), (char *)clist, &items, 2679 &itemsize, (void *)&cl, 0, sizeof(struct info_clock)); 2680 2681 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2682 impl_ver = IMPL_XNTPD_OLD; 2683 goto again; 2684 } 2685 2686 if (res != 0) 2687 return; 2688 2689 if (!checkitems(items, fp)) 2690 return; 2691 2692 if (!checkitemsize(itemsize, sizeof(struct info_clock))) 2693 return; 2694 2695 while (items-- > 0) { 2696 (void) fprintf(fp, "clock address: %s\n", 2697 numtoa(cl->clockadr)); 2698 for (clk = clktypes; clk->code >= 0; clk++) 2699 if (clk->code == cl->type) 2700 break; 2701 if (clk->code >= 0) 2702 (void) fprintf(fp, "clock type: %s\n", 2703 clk->clocktype); 2704 else 2705 (void) fprintf(fp, "clock type: unknown type (%d)\n", 2706 cl->type); 2707 (void) fprintf(fp, "last event: %d\n", 2708 cl->lastevent); 2709 (void) fprintf(fp, "current status: %d\n", 2710 cl->currentstatus); 2711 (void) fprintf(fp, "number of polls: %lu\n", 2712 (u_long)ntohl(cl->polls)); 2713 (void) fprintf(fp, "no response to poll: %lu\n", 2714 (u_long)ntohl(cl->noresponse)); 2715 (void) fprintf(fp, "bad format responses: %lu\n", 2716 (u_long)ntohl(cl->badformat)); 2717 (void) fprintf(fp, "bad data responses: %lu\n", 2718 (u_long)ntohl(cl->baddata)); 2719 (void) fprintf(fp, "running time: %lu\n", 2720 (u_long)ntohl(cl->timestarted)); 2721 NTOHL_FP(&cl->fudgetime1, &ts); 2722 (void) fprintf(fp, "fudge time 1: %s\n", 2723 lfptoa(&ts, 6)); 2724 NTOHL_FP(&cl->fudgetime2, &ts); 2725 (void) fprintf(fp, "fudge time 2: %s\n", 2726 lfptoa(&ts, 6)); 2727 (void) fprintf(fp, "stratum: %ld\n", 2728 (u_long)ntohl(cl->fudgeval1)); 2729 (void) fprintf(fp, "reference ID: %s\n", 2730 refid_string(ntohl(cl->fudgeval2), 0)); 2731 (void) fprintf(fp, "fudge flags: 0x%x\n", 2732 cl->flags); 2733 2734 if (items > 0) 2735 (void) fprintf(fp, "\n"); 2736 cl++; 2737 } 2738} 2739 2740 2741/* 2742 * fudge - set clock fudge factors 2743 */ 2744static void 2745fudge( 2746 struct parse *pcmd, 2747 FILE *fp 2748 ) 2749{ 2750 struct conf_fudge fudgedata; 2751 int items; 2752 int itemsize; 2753 char *dummy; 2754 l_fp ts; 2755 int res; 2756 long val; 2757 u_long u_val; 2758 int err; 2759 2760 2761 err = 0; 2762 memset((char *)&fudgedata, 0, sizeof fudgedata); 2763 fudgedata.clockadr = NSRCADR(&pcmd->argval[0].netnum); 2764 2765 if (STREQ(pcmd->argval[1].string, "time1")) { 2766 fudgedata.which = htonl(FUDGE_TIME1); 2767 if (!atolfp(pcmd->argval[2].string, &ts)) 2768 err = 1; 2769 else 2770 NTOHL_FP(&ts, &fudgedata.fudgetime); 2771 } else if (STREQ(pcmd->argval[1].string, "time2")) { 2772 fudgedata.which = htonl(FUDGE_TIME2); 2773 if (!atolfp(pcmd->argval[2].string, &ts)) 2774 err = 1; 2775 else 2776 NTOHL_FP(&ts, &fudgedata.fudgetime); 2777 } else if (STREQ(pcmd->argval[1].string, "val1")) { 2778 fudgedata.which = htonl(FUDGE_VAL1); 2779 if (!atoint(pcmd->argval[2].string, &val)) 2780 err = 1; 2781 else 2782 fudgedata.fudgeval_flags = htonl(val); 2783 } else if (STREQ(pcmd->argval[1].string, "val2")) { 2784 fudgedata.which = htonl(FUDGE_VAL2); 2785 if (!atoint(pcmd->argval[2].string, &val)) 2786 err = 1; 2787 else 2788 fudgedata.fudgeval_flags = htonl((u_int32)val); 2789 } else if (STREQ(pcmd->argval[1].string, "flags")) { 2790 fudgedata.which = htonl(FUDGE_FLAGS); 2791 if (!hextoint(pcmd->argval[2].string, &u_val)) 2792 err = 1; 2793 else 2794 fudgedata.fudgeval_flags = htonl((u_int32)(u_val & 0xf)); 2795 } else { 2796 (void) fprintf(stderr, "What fudge is %s?\n", 2797 pcmd->argval[1].string); 2798 return; 2799 } 2800 2801 if (err) { 2802 (void) fprintf(stderr, "Unknown fudge parameter %s\n", 2803 pcmd->argval[2].string); 2804 return; 2805 } 2806 2807again: 2808 res = doquery(impl_ver, REQ_SET_CLKFUDGE, 1, 1, 2809 sizeof(struct conf_fudge), (char *)&fudgedata, &items, 2810 &itemsize, &dummy, 0, sizeof(dummy)); 2811 2812 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2813 impl_ver = IMPL_XNTPD_OLD; 2814 goto again; 2815 } 2816 2817 if (res == 0) 2818 (void) fprintf(fp, "done!\n"); 2819 return; 2820} 2821 2822/* 2823 * clkbug - get and print clock debugging information 2824 */ 2825static void 2826clkbug( 2827 struct parse *pcmd, 2828 FILE *fp 2829 ) 2830{ 2831 register int i; 2832 register int n; 2833 register u_int32 s; 2834 struct info_clkbug *cl; 2835 /* 8 is the maximum number of clocks which will fit in a packet */ 2836 u_long clist[min(MAXARGS, 8)]; 2837 u_int32 ltemp; 2838 int qitemlim; 2839 int qitems; 2840 int items; 2841 int itemsize; 2842 int res; 2843 int needsp; 2844 l_fp ts; 2845 2846 qitemlim = min(pcmd->nargs, COUNTOF(clist)); 2847 for (qitems = 0; qitems < qitemlim; qitems++) 2848 clist[qitems] = NSRCADR(&pcmd->argval[qitems].netnum); 2849 2850again: 2851 res = doquery(impl_ver, REQ_GET_CLKBUGINFO, 0, qitems, 2852 sizeof(u_int32), (char *)clist, &items, 2853 &itemsize, (void *)&cl, 0, sizeof(struct info_clkbug)); 2854 2855 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2856 impl_ver = IMPL_XNTPD_OLD; 2857 goto again; 2858 } 2859 2860 if (res != 0) 2861 return; 2862 2863 if (!checkitems(items, fp)) 2864 return; 2865 2866 if (!checkitemsize(itemsize, sizeof(struct info_clkbug))) 2867 return; 2868 2869 while (items-- > 0) { 2870 (void) fprintf(fp, "clock address: %s\n", 2871 numtoa(cl->clockadr)); 2872 n = (int)cl->nvalues; 2873 (void) fprintf(fp, "values: %d", n); 2874 s = ntohs(cl->svalues); 2875 if (n > NUMCBUGVALUES) 2876 n = NUMCBUGVALUES; 2877 for (i = 0; i < n; i++) { 2878 ltemp = ntohl(cl->values[i]); 2879 ltemp &= 0xffffffff; /* HMS: This does nothing now */ 2880 if ((i & 0x3) == 0) 2881 (void) fprintf(fp, "\n"); 2882 if (s & (1 << i)) 2883 (void) fprintf(fp, "%12ld", (u_long)ltemp); 2884 else 2885 (void) fprintf(fp, "%12lu", (u_long)ltemp); 2886 } 2887 (void) fprintf(fp, "\n"); 2888 2889 n = (int)cl->ntimes; 2890 (void) fprintf(fp, "times: %d", n); 2891 s = ntohl(cl->stimes); 2892 if (n > NUMCBUGTIMES) 2893 n = NUMCBUGTIMES; 2894 needsp = 0; 2895 for (i = 0; i < n; i++) { 2896 if ((i & 0x1) == 0) { 2897 (void) fprintf(fp, "\n"); 2898 } else { 2899 for (;needsp > 0; needsp--) 2900 putc(' ', fp); 2901 } 2902 NTOHL_FP(&cl->times[i], &ts); 2903 if (s & (1 << i)) { 2904 (void) fprintf(fp, "%17s", 2905 lfptoa(&ts, 6)); 2906 needsp = 22; 2907 } else { 2908 (void) fprintf(fp, "%37s", 2909 uglydate(&ts)); 2910 needsp = 2; 2911 } 2912 } 2913 (void) fprintf(fp, "\n"); 2914 if (items > 0) { 2915 cl++; 2916 (void) fprintf(fp, "\n"); 2917 } 2918 } 2919} 2920 2921 2922/* 2923 * kerninfo - display the kernel pll/pps variables 2924 */ 2925static void 2926kerninfo( 2927 struct parse *pcmd, 2928 FILE *fp 2929 ) 2930{ 2931 struct info_kernel *ik; 2932 int items; 2933 int itemsize; 2934 int res; 2935 unsigned status; 2936 double tscale = 1e-6; 2937 2938again: 2939 res = doquery(impl_ver, REQ_GET_KERNEL, 0, 0, 0, (char *)NULL, 2940 &items, &itemsize, (void *)&ik, 0, 2941 sizeof(struct info_kernel)); 2942 2943 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2944 impl_ver = IMPL_XNTPD_OLD; 2945 goto again; 2946 } 2947 2948 if (res != 0) 2949 return; 2950 if (!check1item(items, fp)) 2951 return; 2952 if (!checkitemsize(itemsize, sizeof(struct info_kernel))) 2953 return; 2954 2955 status = ntohs(ik->status) & 0xffff; 2956 /* 2957 * pll variables. We know more than we should about the NANO bit. 2958 */ 2959#ifdef STA_NANO 2960 if (status & STA_NANO) 2961 tscale = 1e-9; 2962#endif 2963 (void)fprintf(fp, "pll offset: %g s\n", 2964 (int32)ntohl(ik->offset) * tscale); 2965 (void)fprintf(fp, "pll frequency: %s ppm\n", 2966 fptoa((s_fp)ntohl(ik->freq), 3)); 2967 (void)fprintf(fp, "maximum error: %g s\n", 2968 (u_long)ntohl(ik->maxerror) * 1e-6); 2969 (void)fprintf(fp, "estimated error: %g s\n", 2970 (u_long)ntohl(ik->esterror) * 1e-6); 2971 (void)fprintf(fp, "status: %04x ", status); 2972#ifdef STA_PLL 2973 if (status & STA_PLL) (void)fprintf(fp, " pll"); 2974#endif 2975#ifdef STA_PPSFREQ 2976 if (status & STA_PPSFREQ) (void)fprintf(fp, " ppsfreq"); 2977#endif 2978#ifdef STA_PPSTIME 2979 if (status & STA_PPSTIME) (void)fprintf(fp, " ppstime"); 2980#endif 2981#ifdef STA_FLL 2982 if (status & STA_FLL) (void)fprintf(fp, " fll"); 2983#endif 2984#ifdef STA_INS 2985 if (status & STA_INS) (void)fprintf(fp, " ins"); 2986#endif 2987#ifdef STA_DEL 2988 if (status & STA_DEL) (void)fprintf(fp, " del"); 2989#endif 2990#ifdef STA_UNSYNC 2991 if (status & STA_UNSYNC) (void)fprintf(fp, " unsync"); 2992#endif 2993#ifdef STA_FREQHOLD 2994 if (status & STA_FREQHOLD) (void)fprintf(fp, " freqhold"); 2995#endif 2996#ifdef STA_PPSSIGNAL 2997 if (status & STA_PPSSIGNAL) (void)fprintf(fp, " ppssignal"); 2998#endif 2999#ifdef STA_PPSJITTER 3000 if (status & STA_PPSJITTER) (void)fprintf(fp, " ppsjitter"); 3001#endif 3002#ifdef STA_PPSWANDER 3003 if (status & STA_PPSWANDER) (void)fprintf(fp, " ppswander"); 3004#endif 3005#ifdef STA_PPSERROR 3006 if (status & STA_PPSERROR) (void)fprintf(fp, " ppserror"); 3007#endif 3008#ifdef STA_CLOCKERR 3009 if (status & STA_CLOCKERR) (void)fprintf(fp, " clockerr"); 3010#endif 3011#ifdef STA_NANO 3012 if (status & STA_NANO) (void)fprintf(fp, " nano"); 3013#endif 3014#ifdef STA_MODE 3015 if (status & STA_MODE) (void)fprintf(fp, " mode=fll"); 3016#endif 3017#ifdef STA_CLK 3018 if (status & STA_CLK) (void)fprintf(fp, " src=B"); 3019#endif 3020 (void)fprintf(fp, "\n"); 3021 (void)fprintf(fp, "pll time constant: %ld\n", 3022 (u_long)ntohl(ik->constant)); 3023 (void)fprintf(fp, "precision: %g s\n", 3024 (u_long)ntohl(ik->precision) * tscale); 3025 (void)fprintf(fp, "frequency tolerance: %s ppm\n", 3026 fptoa((s_fp)ntohl(ik->tolerance), 0)); 3027 3028 /* 3029 * For backwards compatibility (ugh), we find the pps variables 3030 * only if the shift member is nonzero. 3031 */ 3032 if (!ik->shift) 3033 return; 3034 3035 /* 3036 * pps variables 3037 */ 3038 (void)fprintf(fp, "pps frequency: %s ppm\n", 3039 fptoa((s_fp)ntohl(ik->ppsfreq), 3)); 3040 (void)fprintf(fp, "pps stability: %s ppm\n", 3041 fptoa((s_fp)ntohl(ik->stabil), 3)); 3042 (void)fprintf(fp, "pps jitter: %g s\n", 3043 (u_long)ntohl(ik->jitter) * tscale); 3044 (void)fprintf(fp, "calibration interval: %d s\n", 3045 1 << ntohs(ik->shift)); 3046 (void)fprintf(fp, "calibration cycles: %ld\n", 3047 (u_long)ntohl(ik->calcnt)); 3048 (void)fprintf(fp, "jitter exceeded: %ld\n", 3049 (u_long)ntohl(ik->jitcnt)); 3050 (void)fprintf(fp, "stability exceeded: %ld\n", 3051 (u_long)ntohl(ik->stbcnt)); 3052 (void)fprintf(fp, "calibration errors: %ld\n", 3053 (u_long)ntohl(ik->errcnt)); 3054} 3055 3056#define IF_LIST_FMT "%2d %c %48s %c %c %12.12s %03lx %3lu %2lu %5lu %5lu %5lu %2lu %3lu %7lu\n" 3057#define IF_LIST_FMT_STR "%2s %c %48s %c %c %12.12s %3s %3s %2s %5s %5s %5s %2s %3s %7s\n" 3058#define IF_LIST_AFMT_STR " %48s %c\n" 3059#define IF_LIST_LABELS "#", 'A', "Address/Mask/Broadcast", 'T', 'E', "IF name", "Flg", "TL", "#M", "recv", "sent", "drop", "S", "PC", "uptime" 3060#define IF_LIST_LINE "==================================================================================================================\n" 3061 3062static void 3063iflist( 3064 FILE *fp, 3065 struct info_if_stats *ifs, 3066 int items, 3067 int itemsize, 3068 int res 3069 ) 3070{ 3071 static const char *actions = "?.+-"; 3072 sockaddr_u saddr; 3073 3074 if (res != 0) 3075 return; 3076 3077 if (!checkitems(items, fp)) 3078 return; 3079 3080 if (!checkitemsize(itemsize, sizeof(struct info_if_stats))) 3081 return; 3082 3083 fprintf(fp, IF_LIST_FMT_STR, IF_LIST_LABELS); 3084 fprintf(fp, IF_LIST_LINE); 3085 3086 while (items > 0) { 3087 SET_ADDR(saddr, ntohl(ifs->v6_flag), 3088 ifs->unaddr.addr.s_addr, ifs->unaddr.addr6); 3089 fprintf(fp, IF_LIST_FMT, 3090 ntohl(ifs->ifnum), 3091 actions[(ifs->action >= 1 && ifs->action < 4) ? ifs->action : 0], 3092 stoa((&saddr)), 'A', 3093 ifs->ignore_packets ? 'D' : 'E', 3094 ifs->name, 3095 (u_long)ntohl(ifs->flags), 3096 (u_long)ntohl(ifs->last_ttl), 3097 (u_long)ntohl(ifs->num_mcast), 3098 (u_long)ntohl(ifs->received), 3099 (u_long)ntohl(ifs->sent), 3100 (u_long)ntohl(ifs->notsent), 3101 (u_long)ntohl(ifs->scopeid), 3102 (u_long)ntohl(ifs->peercnt), 3103 (u_long)ntohl(ifs->uptime)); 3104 3105 SET_ADDR(saddr, ntohl(ifs->v6_flag), 3106 ifs->unmask.addr.s_addr, ifs->unmask.addr6); 3107 fprintf(fp, IF_LIST_AFMT_STR, stoa(&saddr), 'M'); 3108 3109 if (!ntohl(ifs->v6_flag) && ntohl(ifs->flags) & (INT_BCASTOPEN)) { 3110 SET_ADDR(saddr, ntohl(ifs->v6_flag), 3111 ifs->unbcast.addr.s_addr, ifs->unbcast.addr6); 3112 fprintf(fp, IF_LIST_AFMT_STR, stoa(&saddr), 'B'); 3113 3114 } 3115 3116 ifs++; 3117 items--; 3118 } 3119} 3120 3121/*ARGSUSED*/ 3122static void 3123get_if_stats( 3124 struct parse *pcmd, 3125 FILE *fp 3126 ) 3127{ 3128 struct info_if_stats *ifs; 3129 int items; 3130 int itemsize; 3131 int res; 3132 3133 res = doquery(impl_ver, REQ_IF_STATS, 1, 0, 0, (char *)NULL, &items, 3134 &itemsize, (void *)&ifs, 0, 3135 sizeof(struct info_if_stats)); 3136 iflist(fp, ifs, items, itemsize, res); 3137} 3138 3139/*ARGSUSED*/ 3140static void 3141do_if_reload( 3142 struct parse *pcmd, 3143 FILE *fp 3144 ) 3145{ 3146 struct info_if_stats *ifs; 3147 int items; 3148 int itemsize; 3149 int res; 3150 3151 res = doquery(impl_ver, REQ_IF_RELOAD, 1, 0, 0, (char *)NULL, &items, 3152 &itemsize, (void *)&ifs, 0, 3153 sizeof(struct info_if_stats)); 3154 iflist(fp, ifs, items, itemsize, res); 3155} 3156