1 /* $NetBSD: ntpdc_ops.c,v 1.1.1.1 2009/12/13 16:56:25 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 */ 36 static int checkitems (int, FILE *); 37 static int checkitemsize (int, int); 38 static int check1item (int, FILE *); 39 40 /* 41 * Declarations for command handlers in here 42 */ 43 static void peerlist (struct parse *, FILE *); 44 static void peers (struct parse *, FILE *); 45 static void doconfig (struct parse *pcmd, FILE *fp, int mode, int refc); 46 static void dmpeers (struct parse *, FILE *); 47 static void dopeers (struct parse *, FILE *, int); 48 static void printpeer (struct info_peer *, FILE *); 49 static void showpeer (struct parse *, FILE *); 50 static void peerstats (struct parse *, FILE *); 51 static void loopinfo (struct parse *, FILE *); 52 static void sysinfo (struct parse *, FILE *); 53 static void sysstats (struct parse *, FILE *); 54 static void iostats (struct parse *, FILE *); 55 static void memstats (struct parse *, FILE *); 56 static void timerstats (struct parse *, FILE *); 57 static void addpeer (struct parse *, FILE *); 58 static void addserver (struct parse *, FILE *); 59 static void addrefclock (struct parse *, FILE *); 60 static void broadcast (struct parse *, FILE *); 61 static void doconfig (struct parse *, FILE *, int, int); 62 static void unconfig (struct parse *, FILE *); 63 static void set (struct parse *, FILE *); 64 static void sys_clear (struct parse *, FILE *); 65 static void doset (struct parse *, FILE *, int); 66 static void reslist (struct parse *, FILE *); 67 static void new_restrict (struct parse *, FILE *); 68 static void unrestrict (struct parse *, FILE *); 69 static void delrestrict (struct parse *, FILE *); 70 static void do_restrict (struct parse *, FILE *, int); 71 static void monlist (struct parse *, FILE *); 72 static void reset (struct parse *, FILE *); 73 static void preset (struct parse *, FILE *); 74 static void readkeys (struct parse *, FILE *); 75 static void trustkey (struct parse *, FILE *); 76 static void untrustkey (struct parse *, FILE *); 77 static void do_trustkey (struct parse *, FILE *, int); 78 static void authinfo (struct parse *, FILE *); 79 static void traps (struct parse *, FILE *); 80 static void addtrap (struct parse *, FILE *); 81 static void clrtrap (struct parse *, FILE *); 82 static void do_addclr_trap (struct parse *, FILE *, int); 83 static void requestkey (struct parse *, FILE *); 84 static void controlkey (struct parse *, FILE *); 85 static void do_changekey (struct parse *, FILE *, int); 86 static void ctlstats (struct parse *, FILE *); 87 static void clockstat (struct parse *, FILE *); 88 static void fudge (struct parse *, FILE *); 89 static void clkbug (struct parse *, FILE *); 90 static void kerninfo (struct parse *, FILE *); 91 static void get_if_stats (struct parse *, FILE *); 92 static void do_if_reload (struct parse *, FILE *); 93 94 /* 95 * Commands we understand. Ntpdc imports this. 96 */ 97 struct 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)->sas.ss_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) \ 251 do { \ 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) \ 269 do { \ 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) \ 294 do { \ 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 */ 316 static int 317 checkitems( 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 */ 333 static int 334 checkitemsize( 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 */ 352 static int 353 check1item( 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*/ 375 static void 376 peerlist( 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 387 again: 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 */ 424 static void 425 peers( 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 */ 436 static void 437 dmpeers( 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*/ 450 static void 451 dopeers( 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 467 again: 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 %2d %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 */ 537 static char* 538 refid_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 553 static void 554 print_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 */ 602 static void 603 printpeer( 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 */ 693 static void 694 showpeer( 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 709 again: 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 */ 766 static void 767 peerstats( 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 783 again: 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.sas.ss_len = SOCKLEN(&src); 847 dst.sas.ss_len = SOCKLEN(&dst); 848 #endif 849 (void) fprintf(fp, "remote host: %s\n", 850 nntohost(&src)); 851 (void) fprintf(fp, "local interface: %s\n", 852 stoa(&dst)); 853 (void) fprintf(fp, "time last received: %lds\n", 854 (long)ntohl(pp->timereceived)); 855 (void) fprintf(fp, "time until next send: %lds\n", 856 (long)ntohl(pp->timetosend)); 857 (void) fprintf(fp, "reachability change: %lds\n", 858 (long)ntohl(pp->timereachable)); 859 (void) fprintf(fp, "packets sent: %ld\n", 860 (long)ntohl(pp->sent)); 861 (void) fprintf(fp, "packets received: %ld\n", 862 (long)ntohl(pp->processed)); 863 (void) fprintf(fp, "bad authentication: %ld\n", 864 (long)ntohl(pp->badauth)); 865 (void) fprintf(fp, "bogus origin: %ld\n", 866 (long)ntohl(pp->bogusorg)); 867 (void) fprintf(fp, "duplicate: %ld\n", 868 (long)ntohl(pp->oldpkt)); 869 (void) fprintf(fp, "bad dispersion: %ld\n", 870 (long)ntohl(pp->seldisp)); 871 (void) fprintf(fp, "bad reference time: %ld\n", 872 (long)ntohl(pp->selbroken)); 873 (void) fprintf(fp, "candidate order: %d\n", 874 (int)pp->candidate); 875 if (items > 0) 876 (void) fprintf(fp, "\n"); 877 (void) fprintf(fp, "flags: "); 878 print_pflag(fp, ntohs(pp->flags)); 879 pp++; 880 } 881 } 882 883 884 /* 885 * loopinfo - show loop filter information 886 */ 887 static void 888 loopinfo( 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 911 again: 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*/ 961 static void 962 sysinfo( 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 974 again: 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*/ 1051 static void 1052 sysstats( 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 1062 again: 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: %ld\n", 1085 (u_long)ntohl(ss->timeup)); 1086 fprintf(fp, "time since reset: %ld\n", 1087 (u_long)ntohl(ss->timereset)); 1088 fprintf(fp, "packets received: %ld\n", 1089 (u_long)ntohl(ss->received)); 1090 fprintf(fp, "packets processed: %ld\n", 1091 (u_long)ntohl(ss->processed)); 1092 fprintf(fp, "current version: %ld\n", 1093 (u_long)ntohl(ss->newversionpkt)); 1094 fprintf(fp, "previous version: %ld\n", 1095 (u_long)ntohl(ss->oldversionpkt)); 1096 fprintf(fp, "declined: %ld\n", 1097 (u_long)ntohl(ss->unknownversion)); 1098 fprintf(fp, "access denied: %ld\n", 1099 (u_long)ntohl(ss->denied)); 1100 fprintf(fp, "bad length or format: %ld\n", 1101 (u_long)ntohl(ss->badlength)); 1102 fprintf(fp, "bad authentication: %ld\n", 1103 (u_long)ntohl(ss->badauth)); 1104 if (itemsize != sizeof(struct info_sys_stats)) 1105 return; 1106 1107 fprintf(fp, "rate exceeded: %ld\n", 1108 (u_long)ntohl(ss->limitrejected)); 1109 } 1110 1111 1112 1113 /* 1114 * iostats - print I/O statistics 1115 */ 1116 /*ARGSUSED*/ 1117 static void 1118 iostats( 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 1128 again: 1129 res = doquery(impl_ver, REQ_IO_STATS, 0, 0, 0, (char *)NULL, 1130 &items, &itemsize, (void *)&io, 0, 1131 sizeof(struct info_io_stats)); 1132 1133 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1134 impl_ver = IMPL_XNTPD_OLD; 1135 goto again; 1136 } 1137 1138 if (res != 0) 1139 return; 1140 1141 if (!check1item(items, fp)) 1142 return; 1143 1144 if (!checkitemsize(itemsize, sizeof(struct info_io_stats))) 1145 return; 1146 1147 (void) fprintf(fp, "time since reset: %ld\n", 1148 (u_long)ntohl(io->timereset)); 1149 (void) fprintf(fp, "receive buffers: %d\n", 1150 ntohs(io->totalrecvbufs)); 1151 (void) fprintf(fp, "free receive buffers: %d\n", 1152 ntohs(io->freerecvbufs)); 1153 (void) fprintf(fp, "used receive buffers: %d\n", 1154 ntohs(io->fullrecvbufs)); 1155 (void) fprintf(fp, "low water refills: %d\n", 1156 ntohs(io->lowwater)); 1157 (void) fprintf(fp, "dropped packets: %ld\n", 1158 (u_long)ntohl(io->dropped)); 1159 (void) fprintf(fp, "ignored packets: %ld\n", 1160 (u_long)ntohl(io->ignored)); 1161 (void) fprintf(fp, "received packets: %ld\n", 1162 (u_long)ntohl(io->received)); 1163 (void) fprintf(fp, "packets sent: %ld\n", 1164 (u_long)ntohl(io->sent)); 1165 (void) fprintf(fp, "packets not sent: %ld\n", 1166 (u_long)ntohl(io->notsent)); 1167 (void) fprintf(fp, "interrupts handled: %ld\n", 1168 (u_long)ntohl(io->interrupts)); 1169 (void) fprintf(fp, "received by int: %ld\n", 1170 (u_long)ntohl(io->int_received)); 1171 } 1172 1173 1174 /* 1175 * memstats - print peer memory statistics 1176 */ 1177 /*ARGSUSED*/ 1178 static void 1179 memstats( 1180 struct parse *pcmd, 1181 FILE *fp 1182 ) 1183 { 1184 struct info_mem_stats *mem; 1185 int i; 1186 int items; 1187 int itemsize; 1188 int res; 1189 1190 again: 1191 res = doquery(impl_ver, REQ_MEM_STATS, 0, 0, 0, (char *)NULL, 1192 &items, &itemsize, (void *)&mem, 0, 1193 sizeof(struct info_mem_stats)); 1194 1195 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1196 impl_ver = IMPL_XNTPD_OLD; 1197 goto again; 1198 } 1199 1200 if (res != 0) 1201 return; 1202 1203 if (!check1item(items, fp)) 1204 return; 1205 1206 if (!checkitemsize(itemsize, sizeof(struct info_mem_stats))) 1207 return; 1208 1209 (void) fprintf(fp, "time since reset: %ld\n", 1210 (u_long)ntohl(mem->timereset)); 1211 (void) fprintf(fp, "total peer memory: %d\n", 1212 ntohs(mem->totalpeermem)); 1213 (void) fprintf(fp, "free peer memory: %d\n", 1214 ntohs(mem->freepeermem)); 1215 (void) fprintf(fp, "calls to findpeer: %ld\n", 1216 (u_long)ntohl(mem->findpeer_calls)); 1217 (void) fprintf(fp, "new peer allocations: %ld\n", 1218 (u_long)ntohl(mem->allocations)); 1219 (void) fprintf(fp, "peer demobilizations: %ld\n", 1220 (u_long)ntohl(mem->demobilizations)); 1221 1222 (void) fprintf(fp, "hash table counts: "); 1223 for (i = 0; i < NTP_HASH_SIZE; i++) { 1224 (void) fprintf(fp, "%4d", (int)mem->hashcount[i]); 1225 if ((i % 8) == 7 && i != (NTP_HASH_SIZE-1)) { 1226 (void) fprintf(fp, "\n "); 1227 } 1228 } 1229 (void) fprintf(fp, "\n"); 1230 } 1231 1232 1233 1234 /* 1235 * timerstats - print timer statistics 1236 */ 1237 /*ARGSUSED*/ 1238 static void 1239 timerstats( 1240 struct parse *pcmd, 1241 FILE *fp 1242 ) 1243 { 1244 struct info_timer_stats *tim; 1245 int items; 1246 int itemsize; 1247 int res; 1248 1249 again: 1250 res = doquery(impl_ver, REQ_TIMER_STATS, 0, 0, 0, (char *)NULL, 1251 &items, &itemsize, (void *)&tim, 0, 1252 sizeof(struct info_timer_stats)); 1253 1254 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1255 impl_ver = IMPL_XNTPD_OLD; 1256 goto again; 1257 } 1258 1259 if (res != 0) 1260 return; 1261 1262 if (!check1item(items, fp)) 1263 return; 1264 1265 if (!checkitemsize(itemsize, sizeof(struct info_timer_stats))) 1266 return; 1267 1268 (void) fprintf(fp, "time since reset: %ld\n", 1269 (u_long)ntohl(tim->timereset)); 1270 (void) fprintf(fp, "alarms handled: %ld\n", 1271 (u_long)ntohl(tim->alarms)); 1272 (void) fprintf(fp, "alarm overruns: %ld\n", 1273 (u_long)ntohl(tim->overflows)); 1274 (void) fprintf(fp, "calls to transmit: %ld\n", 1275 (u_long)ntohl(tim->xmtcalls)); 1276 } 1277 1278 1279 /* 1280 * addpeer - configure an active mode association 1281 */ 1282 static void 1283 addpeer( 1284 struct parse *pcmd, 1285 FILE *fp 1286 ) 1287 { 1288 doconfig(pcmd, fp, MODE_ACTIVE, 0); 1289 } 1290 1291 1292 /* 1293 * addserver - configure a client mode association 1294 */ 1295 static void 1296 addserver( 1297 struct parse *pcmd, 1298 FILE *fp 1299 ) 1300 { 1301 doconfig(pcmd, fp, MODE_CLIENT, 0); 1302 } 1303 1304 /* 1305 * addrefclock - configure a reference clock association 1306 */ 1307 static void 1308 addrefclock( 1309 struct parse *pcmd, 1310 FILE *fp 1311 ) 1312 { 1313 doconfig(pcmd, fp, MODE_CLIENT, 1); 1314 } 1315 1316 /* 1317 * broadcast - configure a broadcast mode association 1318 */ 1319 static void 1320 broadcast( 1321 struct parse *pcmd, 1322 FILE *fp 1323 ) 1324 { 1325 doconfig(pcmd, fp, MODE_BROADCAST, 0); 1326 } 1327 1328 1329 /* 1330 * config - configure a new peer association 1331 */ 1332 static void 1333 doconfig( 1334 struct parse *pcmd, 1335 FILE *fp, 1336 int mode, 1337 int refc 1338 ) 1339 { 1340 struct conf_peer cpeer; 1341 int items; 1342 int itemsize; 1343 char *dummy; 1344 u_long keyid; 1345 u_int version; 1346 u_char minpoll; 1347 u_char maxpoll; 1348 u_int flags; 1349 u_char cmode; 1350 int res; 1351 int sendsize; 1352 int numtyp; 1353 1354 again: 1355 keyid = 0; 1356 version = 3; 1357 flags = 0; 1358 res = 0; 1359 cmode = 0; 1360 minpoll = NTP_MINDPOLL; 1361 maxpoll = NTP_MAXDPOLL; 1362 numtyp = 1; 1363 if (refc) 1364 numtyp = 5; 1365 1366 if (impl_ver == IMPL_XNTPD) 1367 sendsize = sizeof(struct conf_peer); 1368 else 1369 sendsize = v4sizeof(struct conf_peer); 1370 1371 items = 1; 1372 while (pcmd->nargs > items) { 1373 if (STREQ(pcmd->argval[items].string, "prefer")) 1374 flags |= CONF_FLAG_PREFER; 1375 else if (STREQ(pcmd->argval[items].string, "burst")) 1376 flags |= CONF_FLAG_BURST; 1377 else if (STREQ(pcmd->argval[items].string, "iburst")) 1378 flags |= CONF_FLAG_IBURST; 1379 else if (!refc && STREQ(pcmd->argval[items].string, "keyid")) 1380 numtyp = 1; 1381 else if (!refc && STREQ(pcmd->argval[items].string, "version")) 1382 numtyp = 2; 1383 else if (STREQ(pcmd->argval[items].string, "minpoll")) 1384 numtyp = 3; 1385 else if (STREQ(pcmd->argval[items].string, "maxpoll")) 1386 numtyp = 4; 1387 else { 1388 long val; 1389 if (!atoint(pcmd->argval[items].string, &val)) 1390 numtyp = 0; 1391 switch (numtyp) { 1392 case 1: 1393 keyid = val; 1394 numtyp = 2; 1395 break; 1396 1397 case 2: 1398 version = (u_int) val; 1399 numtyp = 0; 1400 break; 1401 1402 case 3: 1403 minpoll = (u_char)val; 1404 numtyp = 0; 1405 break; 1406 1407 case 4: 1408 maxpoll = (u_char)val; 1409 numtyp = 0; 1410 break; 1411 1412 case 5: 1413 cmode = (u_char)val; 1414 numtyp = 0; 1415 break; 1416 1417 default: 1418 (void) fprintf(fp, "*** '%s' not understood\n", 1419 pcmd->argval[items].string); 1420 res++; 1421 numtyp = 0; 1422 } 1423 if (val < 0) { 1424 (void) fprintf(stderr, 1425 "***Value '%s' should be unsigned\n", 1426 pcmd->argval[items].string); 1427 res++; 1428 } 1429 } 1430 items++; 1431 } 1432 if (keyid > 0) 1433 flags |= CONF_FLAG_AUTHENABLE; 1434 if (version > NTP_VERSION || 1435 version < NTP_OLDVERSION) { 1436 (void)fprintf(fp, "***invalid version number: %u\n", 1437 version); 1438 res++; 1439 } 1440 if (minpoll < NTP_MINPOLL || minpoll > NTP_MAXPOLL || 1441 maxpoll < NTP_MINPOLL || maxpoll > NTP_MAXPOLL || 1442 minpoll > maxpoll) { 1443 (void) fprintf(fp, "***min/max-poll must be within %d..%d\n", 1444 NTP_MINPOLL, NTP_MAXPOLL); 1445 res++; 1446 } 1447 1448 if (res) 1449 return; 1450 1451 memset(&cpeer, 0, sizeof(cpeer)); 1452 1453 if (IS_IPV4(&pcmd->argval[0].netnum)) { 1454 cpeer.peeraddr = NSRCADR(&pcmd->argval[0].netnum); 1455 if (impl_ver == IMPL_XNTPD) 1456 cpeer.v6_flag = 0; 1457 } else { 1458 if (impl_ver == IMPL_XNTPD_OLD) { 1459 fprintf(stderr, 1460 "***Server doesn't understand IPv6 addresses\n"); 1461 return; 1462 } 1463 cpeer.peeraddr6 = SOCK_ADDR6(&pcmd->argval[0].netnum); 1464 cpeer.v6_flag = 1; 1465 } 1466 cpeer.hmode = (u_char) mode; 1467 cpeer.keyid = keyid; 1468 cpeer.version = (u_char) version; 1469 cpeer.minpoll = minpoll; 1470 cpeer.maxpoll = maxpoll; 1471 cpeer.flags = (u_char)flags; 1472 cpeer.ttl = cmode; 1473 1474 res = doquery(impl_ver, REQ_CONFIG, 1, 1, 1475 sendsize, (char *)&cpeer, &items, 1476 &itemsize, &dummy, 0, sizeof(struct conf_peer)); 1477 1478 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1479 impl_ver = IMPL_XNTPD_OLD; 1480 goto again; 1481 } 1482 1483 if (res == INFO_ERR_FMT) { 1484 (void) fprintf(fp, 1485 "***Retrying command with old conf_peer size\n"); 1486 res = doquery(impl_ver, REQ_CONFIG, 1, 1, 1487 sizeof(struct old_conf_peer), (char *)&cpeer, 1488 &items, &itemsize, &dummy, 0, 1489 sizeof(struct conf_peer)); 1490 } 1491 if (res == 0) 1492 (void) fprintf(fp, "done!\n"); 1493 return; 1494 } 1495 1496 1497 /* 1498 * unconfig - unconfigure some associations 1499 */ 1500 static void 1501 unconfig( 1502 struct parse *pcmd, 1503 FILE *fp 1504 ) 1505 { 1506 /* 8 is the maximum number of peers which will fit in a packet */ 1507 struct conf_unpeer *pl, plist[min(MAXARGS, 8)]; 1508 int qitemlim; 1509 int qitems; 1510 int items; 1511 int itemsize; 1512 char *dummy; 1513 int res; 1514 int sendsize; 1515 1516 again: 1517 if (impl_ver == IMPL_XNTPD) 1518 sendsize = sizeof(struct conf_unpeer); 1519 else 1520 sendsize = v4sizeof(struct conf_unpeer); 1521 1522 qitemlim = min(pcmd->nargs, COUNTOF(plist)); 1523 for (qitems = 0, pl = plist; qitems < qitemlim; qitems++) { 1524 if (IS_IPV4(&pcmd->argval[0].netnum)) { 1525 pl->peeraddr = NSRCADR(&pcmd->argval[qitems].netnum); 1526 if (impl_ver == IMPL_XNTPD) 1527 pl->v6_flag = 0; 1528 } else { 1529 if (impl_ver == IMPL_XNTPD_OLD) { 1530 fprintf(stderr, 1531 "***Server doesn't understand IPv6 addresses\n"); 1532 return; 1533 } 1534 pl->peeraddr6 = 1535 SOCK_ADDR6(&pcmd->argval[qitems].netnum); 1536 pl->v6_flag = 1; 1537 } 1538 pl = (struct conf_unpeer *)((char *)pl + sendsize); 1539 } 1540 1541 res = doquery(impl_ver, REQ_UNCONFIG, 1, qitems, 1542 sendsize, (char *)plist, &items, 1543 &itemsize, &dummy, 0, sizeof(struct conf_unpeer)); 1544 1545 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1546 impl_ver = IMPL_XNTPD_OLD; 1547 goto again; 1548 } 1549 1550 if (res == 0) 1551 (void) fprintf(fp, "done!\n"); 1552 } 1553 1554 1555 /* 1556 * set - set some system flags 1557 */ 1558 static void 1559 set( 1560 struct parse *pcmd, 1561 FILE *fp 1562 ) 1563 { 1564 doset(pcmd, fp, REQ_SET_SYS_FLAG); 1565 } 1566 1567 1568 /* 1569 * clear - clear some system flags 1570 */ 1571 static void 1572 sys_clear( 1573 struct parse *pcmd, 1574 FILE *fp 1575 ) 1576 { 1577 doset(pcmd, fp, REQ_CLR_SYS_FLAG); 1578 } 1579 1580 1581 /* 1582 * doset - set/clear system flags 1583 */ 1584 static void 1585 doset( 1586 struct parse *pcmd, 1587 FILE *fp, 1588 int req 1589 ) 1590 { 1591 struct conf_sys_flags sys; 1592 int items; 1593 int itemsize; 1594 char *dummy; 1595 int res; 1596 1597 sys.flags = 0; 1598 res = 0; 1599 for (items = 0; items < pcmd->nargs; items++) { 1600 if (STREQ(pcmd->argval[items].string, "auth")) 1601 sys.flags |= SYS_FLAG_AUTH; 1602 else if (STREQ(pcmd->argval[items].string, "bclient")) 1603 sys.flags |= SYS_FLAG_BCLIENT; 1604 else if (STREQ(pcmd->argval[items].string, "calibrate")) 1605 sys.flags |= SYS_FLAG_CAL; 1606 else if (STREQ(pcmd->argval[items].string, "kernel")) 1607 sys.flags |= SYS_FLAG_KERNEL; 1608 else if (STREQ(pcmd->argval[items].string, "monitor")) 1609 sys.flags |= SYS_FLAG_MONITOR; 1610 else if (STREQ(pcmd->argval[items].string, "ntp")) 1611 sys.flags |= SYS_FLAG_NTP; 1612 else if (STREQ(pcmd->argval[items].string, "pps")) 1613 sys.flags |= SYS_FLAG_PPS; 1614 else if (STREQ(pcmd->argval[items].string, "stats")) 1615 sys.flags |= SYS_FLAG_FILEGEN; 1616 else { 1617 (void) fprintf(fp, "Unknown flag %s\n", 1618 pcmd->argval[items].string); 1619 res = 1; 1620 } 1621 } 1622 1623 sys.flags = htonl(sys.flags); 1624 if (res || sys.flags == 0) 1625 return; 1626 1627 again: 1628 res = doquery(impl_ver, req, 1, 1, 1629 sizeof(struct conf_sys_flags), (char *)&sys, &items, 1630 &itemsize, &dummy, 0, sizeof(struct conf_sys_flags)); 1631 1632 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1633 impl_ver = IMPL_XNTPD_OLD; 1634 goto again; 1635 } 1636 1637 if (res == 0) 1638 (void) fprintf(fp, "done!\n"); 1639 } 1640 1641 1642 /* 1643 * data for printing/interrpreting the restrict flags 1644 */ 1645 struct resflags { 1646 const char *str; 1647 int bit; 1648 }; 1649 1650 /* XXX: HMS: we apparently don't report set bits we do not recognize. */ 1651 1652 static struct resflags resflagsV2[] = { 1653 { "ignore", 0x001 }, 1654 { "noserve", 0x002 }, 1655 { "notrust", 0x004 }, 1656 { "noquery", 0x008 }, 1657 { "nomodify", 0x010 }, 1658 { "nopeer", 0x020 }, 1659 { "notrap", 0x040 }, 1660 { "lptrap", 0x080 }, 1661 { "limited", 0x100 }, 1662 { "", 0 } 1663 }; 1664 1665 static struct resflags resflagsV3[] = { 1666 { "ignore", RES_IGNORE }, 1667 { "noserve", RES_DONTSERVE }, 1668 { "notrust", RES_DONTTRUST }, 1669 { "noquery", RES_NOQUERY }, 1670 { "nomodify", RES_NOMODIFY }, 1671 { "nopeer", RES_NOPEER }, 1672 { "notrap", RES_NOTRAP }, 1673 { "lptrap", RES_LPTRAP }, 1674 { "limited", RES_LIMITED }, 1675 { "version", RES_VERSION }, 1676 { "kod", RES_KOD }, 1677 { "timeout", RES_TIMEOUT }, 1678 1679 { "", 0 } 1680 }; 1681 1682 static struct resflags resmflags[] = { 1683 { "ntpport", RESM_NTPONLY }, 1684 { "interface", RESM_INTERFACE }, 1685 { "", 0 } 1686 }; 1687 1688 1689 /* 1690 * reslist - obtain and print the server's restrict list 1691 */ 1692 /*ARGSUSED*/ 1693 static void 1694 reslist( 1695 struct parse *pcmd, 1696 FILE *fp 1697 ) 1698 { 1699 struct info_restrict *rl; 1700 sockaddr_u resaddr; 1701 sockaddr_u maskaddr; 1702 int items; 1703 int itemsize; 1704 int res; 1705 int skip; 1706 char *addr; 1707 char *mask; 1708 struct resflags *rf; 1709 u_int32 count; 1710 u_short flags; 1711 u_short mflags; 1712 char flagstr[300]; 1713 static const char *comma = ", "; 1714 1715 again: 1716 res = doquery(impl_ver, REQ_GET_RESTRICT, 0, 0, 0, (char *)NULL, 1717 &items, &itemsize, (void *)&rl, 0, 1718 sizeof(struct info_restrict)); 1719 1720 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1721 impl_ver = IMPL_XNTPD_OLD; 1722 goto again; 1723 } 1724 1725 if (res != 0) 1726 return; 1727 1728 if (!checkitems(items, fp)) 1729 return; 1730 1731 if (!checkitemsize(itemsize, sizeof(struct info_restrict)) && 1732 !checkitemsize(itemsize, v4sizeof(struct info_restrict))) 1733 return; 1734 1735 (void) fprintf(fp, 1736 " address mask count flags\n"); 1737 (void) fprintf(fp, 1738 "=====================================================================\n"); 1739 1740 while (items > 0) { 1741 SET_ADDRS(resaddr, maskaddr, rl, addr, mask); 1742 if (rl->v6_flag != 0) { 1743 addr = nntohost(&resaddr); 1744 } else { 1745 if ((rl->mask == (u_int32)0xffffffff)) 1746 addr = nntohost(&resaddr); 1747 else 1748 addr = stoa(&resaddr); 1749 } 1750 mask = stoa(&maskaddr); 1751 skip = 1; 1752 if ((pcmd->nargs == 0) || 1753 ((pcmd->argval->ival == 6) && (rl->v6_flag != 0)) || 1754 ((pcmd->argval->ival == 4) && (rl->v6_flag == 0))) 1755 skip = 0; 1756 count = ntohl(rl->count); 1757 flags = ntohs(rl->flags); 1758 mflags = ntohs(rl->mflags); 1759 flagstr[0] = '\0'; 1760 1761 res = 1; 1762 rf = &resmflags[0]; 1763 while (rf->bit != 0) { 1764 if (mflags & rf->bit) { 1765 if (!res) 1766 (void) strcat(flagstr, comma); 1767 res = 0; 1768 (void) strcat(flagstr, rf->str); 1769 } 1770 rf++; 1771 } 1772 1773 rf = (impl_ver == IMPL_XNTPD_OLD) 1774 ? &resflagsV2[0] 1775 : &resflagsV3[0] 1776 ; 1777 while (rf->bit != 0) { 1778 if (flags & rf->bit) { 1779 if (!res) 1780 (void) strcat(flagstr, comma); 1781 res = 0; 1782 (void) strcat(flagstr, rf->str); 1783 } 1784 rf++; 1785 } 1786 1787 if (flagstr[0] == '\0') 1788 (void) strcpy(flagstr, "none"); 1789 1790 if (!skip) 1791 (void) fprintf(fp, "%-15.15s %-15.15s %9ld %s\n", 1792 addr, mask, (u_long)count, flagstr); 1793 rl++; 1794 items--; 1795 } 1796 } 1797 1798 1799 1800 /* 1801 * new_restrict - create/add a set of restrictions 1802 */ 1803 static void 1804 new_restrict( 1805 struct parse *pcmd, 1806 FILE *fp 1807 ) 1808 { 1809 do_restrict(pcmd, fp, REQ_RESADDFLAGS); 1810 } 1811 1812 1813 /* 1814 * unrestrict - remove restriction flags from existing entry 1815 */ 1816 static void 1817 unrestrict( 1818 struct parse *pcmd, 1819 FILE *fp 1820 ) 1821 { 1822 do_restrict(pcmd, fp, REQ_RESSUBFLAGS); 1823 } 1824 1825 1826 /* 1827 * delrestrict - delete an existing restriction 1828 */ 1829 static void 1830 delrestrict( 1831 struct parse *pcmd, 1832 FILE *fp 1833 ) 1834 { 1835 do_restrict(pcmd, fp, REQ_UNRESTRICT); 1836 } 1837 1838 1839 /* 1840 * do_restrict - decode commandline restrictions and make the request 1841 */ 1842 static void 1843 do_restrict( 1844 struct parse *pcmd, 1845 FILE *fp, 1846 int req_code 1847 ) 1848 { 1849 struct conf_restrict cres; 1850 int items; 1851 int itemsize; 1852 char *dummy; 1853 u_int32 num; 1854 u_long bit; 1855 int i; 1856 int res; 1857 int err; 1858 int sendsize; 1859 1860 /* Initialize cres */ 1861 cres.addr = 0; 1862 cres.mask = 0; 1863 cres.flags = 0; 1864 cres.mflags = 0; 1865 cres.v6_flag = 0; 1866 1867 again: 1868 if (impl_ver == IMPL_XNTPD) 1869 sendsize = sizeof(struct conf_restrict); 1870 else 1871 sendsize = v4sizeof(struct conf_restrict); 1872 1873 if (IS_IPV4(&pcmd->argval[0].netnum)) { 1874 cres.addr = NSRCADR(&pcmd->argval[0].netnum); 1875 cres.mask = NSRCADR(&pcmd->argval[1].netnum); 1876 if (impl_ver == IMPL_XNTPD) 1877 cres.v6_flag = 0; 1878 } else { 1879 if (impl_ver == IMPL_XNTPD_OLD) { 1880 fprintf(stderr, 1881 "***Server doesn't understand IPv6 addresses\n"); 1882 return; 1883 } 1884 cres.addr6 = SOCK_ADDR6(&pcmd->argval[0].netnum); 1885 cres.v6_flag = 1; 1886 } 1887 cres.flags = 0; 1888 cres.mflags = 0; 1889 err = 0; 1890 for (res = 2; res < pcmd->nargs; res++) { 1891 if (STREQ(pcmd->argval[res].string, "ntpport")) { 1892 cres.mflags |= RESM_NTPONLY; 1893 } else { 1894 for (i = 0; resflagsV3[i].bit != 0; i++) { 1895 if (STREQ(pcmd->argval[res].string, 1896 resflagsV3[i].str)) 1897 break; 1898 } 1899 if (resflagsV3[i].bit != 0) { 1900 cres.flags |= resflagsV3[i].bit; 1901 if (req_code == REQ_UNRESTRICT) { 1902 (void) fprintf(fp, 1903 "Flag %s inappropriate\n", 1904 resflagsV3[i].str); 1905 err++; 1906 } 1907 } else { 1908 (void) fprintf(fp, "Unknown flag %s\n", 1909 pcmd->argval[res].string); 1910 err++; 1911 } 1912 } 1913 } 1914 cres.flags = htons(cres.flags); 1915 cres.mflags = htons(cres.mflags); 1916 1917 /* 1918 * Make sure mask for default address is zero. Otherwise, 1919 * make sure mask bits are contiguous. 1920 */ 1921 if (IS_IPV4(&pcmd->argval[0].netnum)) { 1922 if (cres.addr == 0) { 1923 cres.mask = 0; 1924 } else { 1925 num = ntohl(cres.mask); 1926 for (bit = 0x80000000; bit != 0; bit >>= 1) 1927 if ((num & bit) == 0) 1928 break; 1929 for ( ; bit != 0; bit >>= 1) 1930 if ((num & bit) != 0) 1931 break; 1932 if (bit != 0) { 1933 (void) fprintf(fp, "Invalid mask %s\n", 1934 numtoa(cres.mask)); 1935 err++; 1936 } 1937 } 1938 } else { 1939 /* XXX IPv6 sanity checking stuff */ 1940 } 1941 1942 if (err) 1943 return; 1944 1945 res = doquery(impl_ver, req_code, 1, 1, 1946 sendsize, (char *)&cres, &items, 1947 &itemsize, &dummy, 0, sizeof(struct conf_restrict)); 1948 1949 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1950 impl_ver = IMPL_XNTPD_OLD; 1951 goto again; 1952 } 1953 1954 if (res == 0) 1955 (void) fprintf(fp, "done!\n"); 1956 return; 1957 } 1958 1959 1960 /* 1961 * monlist - obtain and print the server's monitor data 1962 */ 1963 /*ARGSUSED*/ 1964 static void 1965 monlist( 1966 struct parse *pcmd, 1967 FILE *fp 1968 ) 1969 { 1970 char *struct_star; 1971 sockaddr_u addr; 1972 sockaddr_u dstadr; 1973 int items; 1974 int itemsize; 1975 int res; 1976 int version = -1; 1977 1978 if (pcmd->nargs > 0) { 1979 version = pcmd->argval[0].ival; 1980 } 1981 1982 again: 1983 res = doquery(impl_ver, 1984 (version == 1 || version == -1) ? REQ_MON_GETLIST_1 : 1985 REQ_MON_GETLIST, 0, 0, 0, (char *)NULL, 1986 &items, &itemsize, &struct_star, 1987 (version < 0) ? (1 << INFO_ERR_REQ) : 0, 1988 sizeof(struct info_monitor_1)); 1989 1990 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 1991 impl_ver = IMPL_XNTPD_OLD; 1992 goto again; 1993 } 1994 1995 if (res == INFO_ERR_REQ && version < 0) 1996 res = doquery(impl_ver, REQ_MON_GETLIST, 0, 0, 0, (char *)NULL, 1997 &items, &itemsize, &struct_star, 0, 1998 sizeof(struct info_monitor)); 1999 2000 if (res != 0) 2001 return; 2002 2003 if (!checkitems(items, fp)) 2004 return; 2005 2006 if (itemsize == sizeof(struct info_monitor_1) || 2007 itemsize == v4sizeof(struct info_monitor_1)) { 2008 struct info_monitor_1 *ml = (struct info_monitor_1 *) struct_star; 2009 2010 (void) fprintf(fp, 2011 "remote address port local address count m ver rstr avgint lstint\n"); 2012 (void) fprintf(fp, 2013 "===============================================================================\n"); 2014 while (items > 0) { 2015 SET_ADDRS(dstadr, addr, ml, daddr, addr); 2016 if ((pcmd->nargs == 0) || 2017 ((pcmd->argval->ival == 6) && (ml->v6_flag != 0)) || 2018 ((pcmd->argval->ival == 4) && (ml->v6_flag == 0))) 2019 (void) fprintf(fp, 2020 "%-22.22s %5d %-15s %8ld %1d %1d %6lx %6lu %7lu\n", 2021 nntohost(&addr), 2022 ntohs(ml->port), 2023 stoa(&dstadr), 2024 (u_long)ntohl(ml->count), 2025 ml->mode, 2026 ml->version, 2027 (u_long)ntohl(ml->restr), 2028 (u_long)ntohl(ml->lasttime), 2029 (u_long)ntohl(ml->firsttime)); 2030 ml++; 2031 items--; 2032 } 2033 } else if (itemsize == sizeof(struct info_monitor) || 2034 itemsize == v4sizeof(struct info_monitor)) { 2035 struct info_monitor *ml = (struct info_monitor *) struct_star; 2036 2037 (void) fprintf(fp, 2038 " address port count mode ver rstr avgint lstint\n"); 2039 (void) fprintf(fp, 2040 "===============================================================================\n"); 2041 while (items > 0) { 2042 SET_ADDR(dstadr, ml->v6_flag, ml->addr, ml->addr6); 2043 if ((pcmd->nargs == 0) || 2044 ((pcmd->argval->ival == 6) && (ml->v6_flag != 0)) || 2045 ((pcmd->argval->ival == 4) && (ml->v6_flag == 0))) 2046 (void) fprintf(fp, 2047 "%-25.25s %5d %9ld %4d %2d %9lx %9lu %9lu\n", 2048 nntohost(&dstadr), 2049 ntohs(ml->port), 2050 (u_long)ntohl(ml->count), 2051 ml->mode, 2052 ml->version, 2053 (u_long)ntohl(ml->restr), 2054 (u_long)ntohl(ml->lasttime), 2055 (u_long)ntohl(ml->firsttime)); 2056 ml++; 2057 items--; 2058 } 2059 } else if (itemsize == sizeof(struct old_info_monitor)) { 2060 struct old_info_monitor *oml = (struct old_info_monitor *)struct_star; 2061 (void) fprintf(fp, 2062 " address port count mode version lasttime firsttime\n"); 2063 (void) fprintf(fp, 2064 "======================================================================\n"); 2065 while (items > 0) { 2066 SET_ADDR(dstadr, oml->v6_flag, oml->addr, oml->addr6); 2067 (void) fprintf(fp, "%-20.20s %5d %9ld %4d %3d %9lu %9lu\n", 2068 nntohost(&dstadr), 2069 ntohs(oml->port), 2070 (u_long)ntohl(oml->count), 2071 oml->mode, 2072 oml->version, 2073 (u_long)ntohl(oml->lasttime), 2074 (u_long)ntohl(oml->firsttime)); 2075 oml++; 2076 items--; 2077 } 2078 } else { 2079 /* issue warning according to new info_monitor size */ 2080 checkitemsize(itemsize, sizeof(struct info_monitor)); 2081 } 2082 } 2083 2084 2085 /* 2086 * Mapping between command line strings and stat reset flags 2087 */ 2088 struct statreset { 2089 const char *str; 2090 int flag; 2091 } sreset[] = { 2092 { "io", RESET_FLAG_IO }, 2093 { "sys", RESET_FLAG_SYS }, 2094 { "mem", RESET_FLAG_MEM }, 2095 { "timer", RESET_FLAG_TIMER }, 2096 { "auth", RESET_FLAG_AUTH }, 2097 { "allpeers", RESET_FLAG_ALLPEERS }, 2098 { "", 0 } 2099 }; 2100 2101 /* 2102 * reset - reset statistic counters 2103 */ 2104 static void 2105 reset( 2106 struct parse *pcmd, 2107 FILE *fp 2108 ) 2109 { 2110 struct reset_flags rflags; 2111 int items; 2112 int itemsize; 2113 char *dummy; 2114 int i; 2115 int res; 2116 int err; 2117 2118 err = 0; 2119 rflags.flags = 0; 2120 for (res = 0; res < pcmd->nargs; res++) { 2121 for (i = 0; sreset[i].flag != 0; i++) { 2122 if (STREQ(pcmd->argval[res].string, sreset[i].str)) 2123 break; 2124 } 2125 if (sreset[i].flag == 0) { 2126 (void) fprintf(fp, "Flag %s unknown\n", 2127 pcmd->argval[res].string); 2128 err++; 2129 } else { 2130 rflags.flags |= sreset[i].flag; 2131 } 2132 } 2133 rflags.flags = htonl(rflags.flags); 2134 2135 if (err) { 2136 (void) fprintf(fp, "Not done due to errors\n"); 2137 return; 2138 } 2139 2140 again: 2141 res = doquery(impl_ver, REQ_RESET_STATS, 1, 1, 2142 sizeof(struct reset_flags), (char *)&rflags, &items, 2143 &itemsize, &dummy, 0, sizeof(struct reset_flags)); 2144 2145 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2146 impl_ver = IMPL_XNTPD_OLD; 2147 goto again; 2148 } 2149 2150 if (res == 0) 2151 (void) fprintf(fp, "done!\n"); 2152 return; 2153 } 2154 2155 2156 2157 /* 2158 * preset - reset stat counters for particular peers 2159 */ 2160 static void 2161 preset( 2162 struct parse *pcmd, 2163 FILE *fp 2164 ) 2165 { 2166 /* 8 is the maximum number of peers which will fit in a packet */ 2167 struct conf_unpeer *pl, plist[min(MAXARGS, 8)]; 2168 int qitemlim; 2169 int qitems; 2170 int items; 2171 int itemsize; 2172 char *dummy; 2173 int res; 2174 int sendsize; 2175 2176 again: 2177 if (impl_ver == IMPL_XNTPD) 2178 sendsize = sizeof(struct conf_unpeer); 2179 else 2180 sendsize = v4sizeof(struct conf_unpeer); 2181 2182 qitemlim = min(pcmd->nargs, COUNTOF(plist)); 2183 for (qitems = 0, pl = plist; qitems < qitemlim; qitems++) { 2184 if (IS_IPV4(&pcmd->argval[qitems].netnum)) { 2185 pl->peeraddr = NSRCADR(&pcmd->argval[qitems].netnum); 2186 if (impl_ver == IMPL_XNTPD) 2187 pl->v6_flag = 0; 2188 } else { 2189 if (impl_ver == IMPL_XNTPD_OLD) { 2190 fprintf(stderr, 2191 "***Server doesn't understand IPv6 addresses\n"); 2192 return; 2193 } 2194 pl->peeraddr6 = 2195 SOCK_ADDR6(&pcmd->argval[qitems].netnum); 2196 pl->v6_flag = 1; 2197 } 2198 pl = (struct conf_unpeer *)((char *)pl + sendsize); 2199 } 2200 2201 res = doquery(impl_ver, REQ_RESET_PEER, 1, qitems, 2202 sendsize, (char *)plist, &items, 2203 &itemsize, &dummy, 0, sizeof(struct conf_unpeer)); 2204 2205 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2206 impl_ver = IMPL_XNTPD_OLD; 2207 goto again; 2208 } 2209 2210 if (res == 0) 2211 (void) fprintf(fp, "done!\n"); 2212 } 2213 2214 2215 /* 2216 * readkeys - request the server to reread the keys file 2217 */ 2218 /*ARGSUSED*/ 2219 static void 2220 readkeys( 2221 struct parse *pcmd, 2222 FILE *fp 2223 ) 2224 { 2225 int items; 2226 int itemsize; 2227 char *dummy; 2228 int res; 2229 2230 again: 2231 res = doquery(impl_ver, REQ_REREAD_KEYS, 1, 0, 0, (char *)0, 2232 &items, &itemsize, &dummy, 0, sizeof(dummy)); 2233 2234 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2235 impl_ver = IMPL_XNTPD_OLD; 2236 goto again; 2237 } 2238 2239 if (res == 0) 2240 (void) fprintf(fp, "done!\n"); 2241 return; 2242 } 2243 2244 2245 /* 2246 * trustkey - add some keys to the trusted key list 2247 */ 2248 static void 2249 trustkey( 2250 struct parse *pcmd, 2251 FILE *fp 2252 ) 2253 { 2254 do_trustkey(pcmd, fp, REQ_TRUSTKEY); 2255 } 2256 2257 2258 /* 2259 * untrustkey - remove some keys from the trusted key list 2260 */ 2261 static void 2262 untrustkey( 2263 struct parse *pcmd, 2264 FILE *fp 2265 ) 2266 { 2267 do_trustkey(pcmd, fp, REQ_UNTRUSTKEY); 2268 } 2269 2270 2271 /* 2272 * do_trustkey - do grunge work of adding/deleting keys 2273 */ 2274 static void 2275 do_trustkey( 2276 struct parse *pcmd, 2277 FILE *fp, 2278 int req 2279 ) 2280 { 2281 u_long keyids[MAXARGS]; 2282 int i; 2283 int items; 2284 int itemsize; 2285 char *dummy; 2286 int ritems; 2287 int res; 2288 2289 ritems = 0; 2290 for (i = 0; i < pcmd->nargs; i++) { 2291 keyids[ritems++] = pcmd->argval[i].uval; 2292 } 2293 2294 again: 2295 res = doquery(impl_ver, req, 1, ritems, sizeof(u_long), 2296 (char *)keyids, &items, &itemsize, &dummy, 0, 2297 sizeof(dummy)); 2298 2299 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2300 impl_ver = IMPL_XNTPD_OLD; 2301 goto again; 2302 } 2303 2304 if (res == 0) 2305 (void) fprintf(fp, "done!\n"); 2306 return; 2307 } 2308 2309 2310 2311 /* 2312 * authinfo - obtain and print info about authentication 2313 */ 2314 /*ARGSUSED*/ 2315 static void 2316 authinfo( 2317 struct parse *pcmd, 2318 FILE *fp 2319 ) 2320 { 2321 struct info_auth *ia; 2322 int items; 2323 int itemsize; 2324 int res; 2325 2326 again: 2327 res = doquery(impl_ver, REQ_AUTHINFO, 0, 0, 0, (char *)NULL, 2328 &items, &itemsize, (void *)&ia, 0, 2329 sizeof(struct info_auth)); 2330 2331 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2332 impl_ver = IMPL_XNTPD_OLD; 2333 goto again; 2334 } 2335 2336 if (res != 0) 2337 return; 2338 2339 if (!check1item(items, fp)) 2340 return; 2341 2342 if (!checkitemsize(itemsize, sizeof(struct info_auth))) 2343 return; 2344 2345 (void) fprintf(fp, "time since reset: %ld\n", 2346 (u_long)ntohl(ia->timereset)); 2347 (void) fprintf(fp, "stored keys: %ld\n", 2348 (u_long)ntohl(ia->numkeys)); 2349 (void) fprintf(fp, "free keys: %ld\n", 2350 (u_long)ntohl(ia->numfreekeys)); 2351 (void) fprintf(fp, "key lookups: %ld\n", 2352 (u_long)ntohl(ia->keylookups)); 2353 (void) fprintf(fp, "keys not found: %ld\n", 2354 (u_long)ntohl(ia->keynotfound)); 2355 (void) fprintf(fp, "uncached keys: %ld\n", 2356 (u_long)ntohl(ia->keyuncached)); 2357 (void) fprintf(fp, "encryptions: %ld\n", 2358 (u_long)ntohl(ia->encryptions)); 2359 (void) fprintf(fp, "decryptions: %ld\n", 2360 (u_long)ntohl(ia->decryptions)); 2361 (void) fprintf(fp, "expired keys: %ld\n", 2362 (u_long)ntohl(ia->expired)); 2363 } 2364 2365 2366 2367 /* 2368 * traps - obtain and print a list of traps 2369 */ 2370 /*ARGSUSED*/ 2371 static void 2372 traps( 2373 struct parse *pcmd, 2374 FILE *fp 2375 ) 2376 { 2377 int i; 2378 struct info_trap *it; 2379 sockaddr_u trap_addr, local_addr; 2380 int items; 2381 int itemsize; 2382 int res; 2383 2384 again: 2385 res = doquery(impl_ver, REQ_TRAPS, 0, 0, 0, (char *)NULL, 2386 &items, &itemsize, (void *)&it, 0, 2387 sizeof(struct info_trap)); 2388 2389 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2390 impl_ver = IMPL_XNTPD_OLD; 2391 goto again; 2392 } 2393 2394 if (res != 0) 2395 return; 2396 2397 if (!checkitems(items, fp)) 2398 return; 2399 2400 if (!checkitemsize(itemsize, sizeof(struct info_trap)) && 2401 !checkitemsize(itemsize, v4sizeof(struct info_trap))) 2402 return; 2403 2404 for (i = 0; i < items; i++ ) { 2405 if (i != 0) 2406 (void) fprintf(fp, "\n"); 2407 SET_ADDRS(trap_addr, local_addr, it, trap_address, local_address); 2408 (void) fprintf(fp, "address %s, port %d\n", 2409 stoa(&trap_addr), 2410 ntohs(it->trap_port)); 2411 (void) fprintf(fp, "interface: %s, ", 2412 (it->local_address == 0) 2413 ? "wildcard" 2414 : stoa(&local_addr)); 2415 if (ntohl(it->flags) & TRAP_CONFIGURED) 2416 (void) fprintf(fp, "configured\n"); 2417 else if (ntohl(it->flags) & TRAP_NONPRIO) 2418 (void) fprintf(fp, "low priority\n"); 2419 else 2420 (void) fprintf(fp, "normal priority\n"); 2421 2422 (void) fprintf(fp, "set for %ld secs, last set %ld secs ago\n", 2423 (long)ntohl(it->origtime), 2424 (long)ntohl(it->settime)); 2425 (void) fprintf(fp, "sequence %d, number of resets %ld\n", 2426 ntohs(it->sequence), 2427 (long)ntohl(it->resets)); 2428 } 2429 } 2430 2431 2432 /* 2433 * addtrap - configure a trap 2434 */ 2435 static void 2436 addtrap( 2437 struct parse *pcmd, 2438 FILE *fp 2439 ) 2440 { 2441 do_addclr_trap(pcmd, fp, REQ_ADD_TRAP); 2442 } 2443 2444 2445 /* 2446 * clrtrap - clear a trap from the server 2447 */ 2448 static void 2449 clrtrap( 2450 struct parse *pcmd, 2451 FILE *fp 2452 ) 2453 { 2454 do_addclr_trap(pcmd, fp, REQ_CLR_TRAP); 2455 } 2456 2457 2458 /* 2459 * do_addclr_trap - do grunge work of adding/deleting traps 2460 */ 2461 static void 2462 do_addclr_trap( 2463 struct parse *pcmd, 2464 FILE *fp, 2465 int req 2466 ) 2467 { 2468 struct conf_trap ctrap; 2469 int items; 2470 int itemsize; 2471 char *dummy; 2472 int res; 2473 int sendsize; 2474 2475 again: 2476 if (impl_ver == IMPL_XNTPD) 2477 sendsize = sizeof(struct conf_trap); 2478 else 2479 sendsize = v4sizeof(struct conf_trap); 2480 2481 if (IS_IPV4(&pcmd->argval[0].netnum)) { 2482 ctrap.trap_address = NSRCADR(&pcmd->argval[0].netnum); 2483 if (impl_ver == IMPL_XNTPD) 2484 ctrap.v6_flag = 0; 2485 } else { 2486 if (impl_ver == IMPL_XNTPD_OLD) { 2487 fprintf(stderr, 2488 "***Server doesn't understand IPv6 addresses\n"); 2489 return; 2490 } 2491 ctrap.trap_address6 = SOCK_ADDR6(&pcmd->argval[0].netnum); 2492 ctrap.v6_flag = 1; 2493 } 2494 ctrap.local_address = 0; 2495 ctrap.trap_port = htons(TRAPPORT); 2496 ctrap.unused = 0; 2497 2498 if (pcmd->nargs > 1) { 2499 ctrap.trap_port = htons((u_short)pcmd->argval[1].uval); 2500 if (pcmd->nargs > 2) { 2501 if (AF(&pcmd->argval[2].netnum) != 2502 AF(&pcmd->argval[0].netnum)) { 2503 fprintf(stderr, 2504 "***Cannot mix IPv4 and IPv6 addresses\n"); 2505 return; 2506 } 2507 if (IS_IPV4(&pcmd->argval[2].netnum)) 2508 ctrap.local_address = NSRCADR(&pcmd->argval[2].netnum); 2509 else 2510 ctrap.local_address6 = SOCK_ADDR6(&pcmd->argval[2].netnum); 2511 } 2512 } 2513 2514 res = doquery(impl_ver, req, 1, 1, sendsize, 2515 (char *)&ctrap, &items, &itemsize, &dummy, 0, 2516 sizeof(struct conf_trap)); 2517 2518 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2519 impl_ver = IMPL_XNTPD_OLD; 2520 goto again; 2521 } 2522 2523 if (res == 0) 2524 (void) fprintf(fp, "done!\n"); 2525 return; 2526 } 2527 2528 2529 2530 /* 2531 * requestkey - change the server's request key (a dangerous request) 2532 */ 2533 static void 2534 requestkey( 2535 struct parse *pcmd, 2536 FILE *fp 2537 ) 2538 { 2539 do_changekey(pcmd, fp, REQ_REQUEST_KEY); 2540 } 2541 2542 2543 /* 2544 * controlkey - change the server's control key 2545 */ 2546 static void 2547 controlkey( 2548 struct parse *pcmd, 2549 FILE *fp 2550 ) 2551 { 2552 do_changekey(pcmd, fp, REQ_CONTROL_KEY); 2553 } 2554 2555 2556 2557 /* 2558 * do_changekey - do grunge work of changing keys 2559 */ 2560 static void 2561 do_changekey( 2562 struct parse *pcmd, 2563 FILE *fp, 2564 int req 2565 ) 2566 { 2567 u_long key; 2568 int items; 2569 int itemsize; 2570 char *dummy; 2571 int res; 2572 2573 2574 key = htonl((u_int32)pcmd->argval[0].uval); 2575 2576 again: 2577 res = doquery(impl_ver, req, 1, 1, sizeof(u_int32), 2578 (char *)&key, &items, &itemsize, &dummy, 0, 2579 sizeof(dummy)); 2580 2581 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2582 impl_ver = IMPL_XNTPD_OLD; 2583 goto again; 2584 } 2585 2586 if (res == 0) 2587 (void) fprintf(fp, "done!\n"); 2588 return; 2589 } 2590 2591 2592 2593 /* 2594 * ctlstats - obtain and print info about authentication 2595 */ 2596 /*ARGSUSED*/ 2597 static void 2598 ctlstats( 2599 struct parse *pcmd, 2600 FILE *fp 2601 ) 2602 { 2603 struct info_control *ic; 2604 int items; 2605 int itemsize; 2606 int res; 2607 2608 again: 2609 res = doquery(impl_ver, REQ_GET_CTLSTATS, 0, 0, 0, (char *)NULL, 2610 &items, &itemsize, (void *)&ic, 0, 2611 sizeof(struct info_control)); 2612 2613 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2614 impl_ver = IMPL_XNTPD_OLD; 2615 goto again; 2616 } 2617 2618 if (res != 0) 2619 return; 2620 2621 if (!check1item(items, fp)) 2622 return; 2623 2624 if (!checkitemsize(itemsize, sizeof(struct info_control))) 2625 return; 2626 2627 (void) fprintf(fp, "time since reset: %ld\n", 2628 (u_long)ntohl(ic->ctltimereset)); 2629 (void) fprintf(fp, "requests received: %ld\n", 2630 (u_long)ntohl(ic->numctlreq)); 2631 (void) fprintf(fp, "responses sent: %ld\n", 2632 (u_long)ntohl(ic->numctlresponses)); 2633 (void) fprintf(fp, "fragments sent: %ld\n", 2634 (u_long)ntohl(ic->numctlfrags)); 2635 (void) fprintf(fp, "async messages sent: %ld\n", 2636 (u_long)ntohl(ic->numasyncmsgs)); 2637 (void) fprintf(fp, "error msgs sent: %ld\n", 2638 (u_long)ntohl(ic->numctlerrors)); 2639 (void) fprintf(fp, "total bad pkts: %ld\n", 2640 (u_long)ntohl(ic->numctlbadpkts)); 2641 (void) fprintf(fp, "packet too short: %ld\n", 2642 (u_long)ntohl(ic->numctltooshort)); 2643 (void) fprintf(fp, "response on input: %ld\n", 2644 (u_long)ntohl(ic->numctlinputresp)); 2645 (void) fprintf(fp, "fragment on input: %ld\n", 2646 (u_long)ntohl(ic->numctlinputfrag)); 2647 (void) fprintf(fp, "error set on input: %ld\n", 2648 (u_long)ntohl(ic->numctlinputerr)); 2649 (void) fprintf(fp, "bad offset on input: %ld\n", 2650 (u_long)ntohl(ic->numctlbadoffset)); 2651 (void) fprintf(fp, "bad version packets: %ld\n", 2652 (u_long)ntohl(ic->numctlbadversion)); 2653 (void) fprintf(fp, "data in pkt too short: %ld\n", 2654 (u_long)ntohl(ic->numctldatatooshort)); 2655 (void) fprintf(fp, "unknown op codes: %ld\n", 2656 (u_long)ntohl(ic->numctlbadop)); 2657 } 2658 2659 2660 /* 2661 * clockstat - get and print clock status information 2662 */ 2663 static void 2664 clockstat( 2665 struct parse *pcmd, 2666 FILE *fp 2667 ) 2668 { 2669 struct info_clock *cl; 2670 /* 8 is the maximum number of clocks which will fit in a packet */ 2671 u_long clist[min(MAXARGS, 8)]; 2672 int qitemlim; 2673 int qitems; 2674 int items; 2675 int itemsize; 2676 int res; 2677 l_fp ts; 2678 struct clktype *clk; 2679 2680 qitemlim = min(pcmd->nargs, COUNTOF(clist)); 2681 for (qitems = 0; qitems < qitemlim; qitems++) 2682 clist[qitems] = NSRCADR(&pcmd->argval[qitems].netnum); 2683 2684 again: 2685 res = doquery(impl_ver, REQ_GET_CLOCKINFO, 0, qitems, 2686 sizeof(u_int32), (char *)clist, &items, 2687 &itemsize, (void *)&cl, 0, sizeof(struct info_clock)); 2688 2689 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2690 impl_ver = IMPL_XNTPD_OLD; 2691 goto again; 2692 } 2693 2694 if (res != 0) 2695 return; 2696 2697 if (!checkitems(items, fp)) 2698 return; 2699 2700 if (!checkitemsize(itemsize, sizeof(struct info_clock))) 2701 return; 2702 2703 while (items-- > 0) { 2704 (void) fprintf(fp, "clock address: %s\n", 2705 numtoa(cl->clockadr)); 2706 for (clk = clktypes; clk->code >= 0; clk++) 2707 if (clk->code == cl->type) 2708 break; 2709 if (clk->code >= 0) 2710 (void) fprintf(fp, "clock type: %s\n", 2711 clk->clocktype); 2712 else 2713 (void) fprintf(fp, "clock type: unknown type (%d)\n", 2714 cl->type); 2715 (void) fprintf(fp, "last event: %d\n", 2716 cl->lastevent); 2717 (void) fprintf(fp, "current status: %d\n", 2718 cl->currentstatus); 2719 (void) fprintf(fp, "number of polls: %lu\n", 2720 (u_long)ntohl(cl->polls)); 2721 (void) fprintf(fp, "no response to poll: %lu\n", 2722 (u_long)ntohl(cl->noresponse)); 2723 (void) fprintf(fp, "bad format responses: %lu\n", 2724 (u_long)ntohl(cl->badformat)); 2725 (void) fprintf(fp, "bad data responses: %lu\n", 2726 (u_long)ntohl(cl->baddata)); 2727 (void) fprintf(fp, "running time: %lu\n", 2728 (u_long)ntohl(cl->timestarted)); 2729 NTOHL_FP(&cl->fudgetime1, &ts); 2730 (void) fprintf(fp, "fudge time 1: %s\n", 2731 lfptoa(&ts, 6)); 2732 NTOHL_FP(&cl->fudgetime2, &ts); 2733 (void) fprintf(fp, "fudge time 2: %s\n", 2734 lfptoa(&ts, 6)); 2735 (void) fprintf(fp, "stratum: %ld\n", 2736 (u_long)ntohl(cl->fudgeval1)); 2737 (void) fprintf(fp, "reference ID: %s\n", 2738 refid_string(ntohl(cl->fudgeval2), 0)); 2739 (void) fprintf(fp, "fudge flags: 0x%x\n", 2740 cl->flags); 2741 2742 if (items > 0) 2743 (void) fprintf(fp, "\n"); 2744 cl++; 2745 } 2746 } 2747 2748 2749 /* 2750 * fudge - set clock fudge factors 2751 */ 2752 static void 2753 fudge( 2754 struct parse *pcmd, 2755 FILE *fp 2756 ) 2757 { 2758 struct conf_fudge fudgedata; 2759 int items; 2760 int itemsize; 2761 char *dummy; 2762 l_fp ts; 2763 int res; 2764 long val; 2765 u_long u_val; 2766 int err; 2767 2768 2769 err = 0; 2770 memset((char *)&fudgedata, 0, sizeof fudgedata); 2771 fudgedata.clockadr = NSRCADR(&pcmd->argval[0].netnum); 2772 2773 if (STREQ(pcmd->argval[1].string, "time1")) { 2774 fudgedata.which = htonl(FUDGE_TIME1); 2775 if (!atolfp(pcmd->argval[2].string, &ts)) 2776 err = 1; 2777 else 2778 NTOHL_FP(&ts, &fudgedata.fudgetime); 2779 } else if (STREQ(pcmd->argval[1].string, "time2")) { 2780 fudgedata.which = htonl(FUDGE_TIME2); 2781 if (!atolfp(pcmd->argval[2].string, &ts)) 2782 err = 1; 2783 else 2784 NTOHL_FP(&ts, &fudgedata.fudgetime); 2785 } else if (STREQ(pcmd->argval[1].string, "val1")) { 2786 fudgedata.which = htonl(FUDGE_VAL1); 2787 if (!atoint(pcmd->argval[2].string, &val)) 2788 err = 1; 2789 else 2790 fudgedata.fudgeval_flags = htonl(val); 2791 } else if (STREQ(pcmd->argval[1].string, "val2")) { 2792 fudgedata.which = htonl(FUDGE_VAL2); 2793 if (!atoint(pcmd->argval[2].string, &val)) 2794 err = 1; 2795 else 2796 fudgedata.fudgeval_flags = htonl((u_int32)val); 2797 } else if (STREQ(pcmd->argval[1].string, "flags")) { 2798 fudgedata.which = htonl(FUDGE_FLAGS); 2799 if (!hextoint(pcmd->argval[2].string, &u_val)) 2800 err = 1; 2801 else 2802 fudgedata.fudgeval_flags = htonl((u_int32)(u_val & 0xf)); 2803 } else { 2804 (void) fprintf(stderr, "What fudge is %s?\n", 2805 pcmd->argval[1].string); 2806 return; 2807 } 2808 2809 if (err) { 2810 (void) fprintf(stderr, "Unknown fudge parameter %s\n", 2811 pcmd->argval[2].string); 2812 return; 2813 } 2814 2815 again: 2816 res = doquery(impl_ver, REQ_SET_CLKFUDGE, 1, 1, 2817 sizeof(struct conf_fudge), (char *)&fudgedata, &items, 2818 &itemsize, &dummy, 0, sizeof(dummy)); 2819 2820 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2821 impl_ver = IMPL_XNTPD_OLD; 2822 goto again; 2823 } 2824 2825 if (res == 0) 2826 (void) fprintf(fp, "done!\n"); 2827 return; 2828 } 2829 2830 /* 2831 * clkbug - get and print clock debugging information 2832 */ 2833 static void 2834 clkbug( 2835 struct parse *pcmd, 2836 FILE *fp 2837 ) 2838 { 2839 register int i; 2840 register int n; 2841 register u_int32 s; 2842 struct info_clkbug *cl; 2843 /* 8 is the maximum number of clocks which will fit in a packet */ 2844 u_long clist[min(MAXARGS, 8)]; 2845 u_int32 ltemp; 2846 int qitemlim; 2847 int qitems; 2848 int items; 2849 int itemsize; 2850 int res; 2851 int needsp; 2852 l_fp ts; 2853 2854 qitemlim = min(pcmd->nargs, COUNTOF(clist)); 2855 for (qitems = 0; qitems < qitemlim; qitems++) 2856 clist[qitems] = NSRCADR(&pcmd->argval[qitems].netnum); 2857 2858 again: 2859 res = doquery(impl_ver, REQ_GET_CLKBUGINFO, 0, qitems, 2860 sizeof(u_int32), (char *)clist, &items, 2861 &itemsize, (void *)&cl, 0, sizeof(struct info_clkbug)); 2862 2863 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2864 impl_ver = IMPL_XNTPD_OLD; 2865 goto again; 2866 } 2867 2868 if (res != 0) 2869 return; 2870 2871 if (!checkitems(items, fp)) 2872 return; 2873 2874 if (!checkitemsize(itemsize, sizeof(struct info_clkbug))) 2875 return; 2876 2877 while (items-- > 0) { 2878 (void) fprintf(fp, "clock address: %s\n", 2879 numtoa(cl->clockadr)); 2880 n = (int)cl->nvalues; 2881 (void) fprintf(fp, "values: %d", n); 2882 s = ntohs(cl->svalues); 2883 if (n > NUMCBUGVALUES) 2884 n = NUMCBUGVALUES; 2885 for (i = 0; i < n; i++) { 2886 ltemp = ntohl(cl->values[i]); 2887 ltemp &= 0xffffffff; /* HMS: This does nothing now */ 2888 if ((i & 0x3) == 0) 2889 (void) fprintf(fp, "\n"); 2890 if (s & (1 << i)) 2891 (void) fprintf(fp, "%12ld", (u_long)ltemp); 2892 else 2893 (void) fprintf(fp, "%12lu", (u_long)ltemp); 2894 } 2895 (void) fprintf(fp, "\n"); 2896 2897 n = (int)cl->ntimes; 2898 (void) fprintf(fp, "times: %d", n); 2899 s = ntohl(cl->stimes); 2900 if (n > NUMCBUGTIMES) 2901 n = NUMCBUGTIMES; 2902 needsp = 0; 2903 for (i = 0; i < n; i++) { 2904 if ((i & 0x1) == 0) { 2905 (void) fprintf(fp, "\n"); 2906 } else { 2907 for (;needsp > 0; needsp--) 2908 putc(' ', fp); 2909 } 2910 NTOHL_FP(&cl->times[i], &ts); 2911 if (s & (1 << i)) { 2912 (void) fprintf(fp, "%17s", 2913 lfptoa(&ts, 6)); 2914 needsp = 22; 2915 } else { 2916 (void) fprintf(fp, "%37s", 2917 uglydate(&ts)); 2918 needsp = 2; 2919 } 2920 } 2921 (void) fprintf(fp, "\n"); 2922 if (items > 0) { 2923 cl++; 2924 (void) fprintf(fp, "\n"); 2925 } 2926 } 2927 } 2928 2929 2930 /* 2931 * kerninfo - display the kernel pll/pps variables 2932 */ 2933 static void 2934 kerninfo( 2935 struct parse *pcmd, 2936 FILE *fp 2937 ) 2938 { 2939 struct info_kernel *ik; 2940 int items; 2941 int itemsize; 2942 int res; 2943 unsigned status; 2944 double tscale = 1e-6; 2945 2946 again: 2947 res = doquery(impl_ver, REQ_GET_KERNEL, 0, 0, 0, (char *)NULL, 2948 &items, &itemsize, (void *)&ik, 0, 2949 sizeof(struct info_kernel)); 2950 2951 if (res == INFO_ERR_IMPL && impl_ver == IMPL_XNTPD) { 2952 impl_ver = IMPL_XNTPD_OLD; 2953 goto again; 2954 } 2955 2956 if (res != 0) 2957 return; 2958 if (!check1item(items, fp)) 2959 return; 2960 if (!checkitemsize(itemsize, sizeof(struct info_kernel))) 2961 return; 2962 2963 status = ntohs(ik->status) & 0xffff; 2964 /* 2965 * pll variables. We know more than we should about the NANO bit. 2966 */ 2967 #ifdef STA_NANO 2968 if (status & STA_NANO) 2969 tscale = 1e-9; 2970 #endif 2971 (void)fprintf(fp, "pll offset: %g s\n", 2972 (int32)ntohl(ik->offset) * tscale); 2973 (void)fprintf(fp, "pll frequency: %s ppm\n", 2974 fptoa((s_fp)ntohl(ik->freq), 3)); 2975 (void)fprintf(fp, "maximum error: %g s\n", 2976 (u_long)ntohl(ik->maxerror) * 1e-6); 2977 (void)fprintf(fp, "estimated error: %g s\n", 2978 (u_long)ntohl(ik->esterror) * 1e-6); 2979 (void)fprintf(fp, "status: %04x ", status); 2980 #ifdef STA_PLL 2981 if (status & STA_PLL) (void)fprintf(fp, " pll"); 2982 #endif 2983 #ifdef STA_PPSFREQ 2984 if (status & STA_PPSFREQ) (void)fprintf(fp, " ppsfreq"); 2985 #endif 2986 #ifdef STA_PPSTIME 2987 if (status & STA_PPSTIME) (void)fprintf(fp, " ppstime"); 2988 #endif 2989 #ifdef STA_FLL 2990 if (status & STA_FLL) (void)fprintf(fp, " fll"); 2991 #endif 2992 #ifdef STA_INS 2993 if (status & STA_INS) (void)fprintf(fp, " ins"); 2994 #endif 2995 #ifdef STA_DEL 2996 if (status & STA_DEL) (void)fprintf(fp, " del"); 2997 #endif 2998 #ifdef STA_UNSYNC 2999 if (status & STA_UNSYNC) (void)fprintf(fp, " unsync"); 3000 #endif 3001 #ifdef STA_FREQHOLD 3002 if (status & STA_FREQHOLD) (void)fprintf(fp, " freqhold"); 3003 #endif 3004 #ifdef STA_PPSSIGNAL 3005 if (status & STA_PPSSIGNAL) (void)fprintf(fp, " ppssignal"); 3006 #endif 3007 #ifdef STA_PPSJITTER 3008 if (status & STA_PPSJITTER) (void)fprintf(fp, " ppsjitter"); 3009 #endif 3010 #ifdef STA_PPSWANDER 3011 if (status & STA_PPSWANDER) (void)fprintf(fp, " ppswander"); 3012 #endif 3013 #ifdef STA_PPSERROR 3014 if (status & STA_PPSERROR) (void)fprintf(fp, " ppserror"); 3015 #endif 3016 #ifdef STA_CLOCKERR 3017 if (status & STA_CLOCKERR) (void)fprintf(fp, " clockerr"); 3018 #endif 3019 #ifdef STA_NANO 3020 if (status & STA_NANO) (void)fprintf(fp, " nano"); 3021 #endif 3022 #ifdef STA_MODE 3023 if (status & STA_MODE) (void)fprintf(fp, " mode=fll"); 3024 #endif 3025 #ifdef STA_CLK 3026 if (status & STA_CLK) (void)fprintf(fp, " src=B"); 3027 #endif 3028 (void)fprintf(fp, "\n"); 3029 (void)fprintf(fp, "pll time constant: %ld\n", 3030 (u_long)ntohl(ik->constant)); 3031 (void)fprintf(fp, "precision: %g s\n", 3032 (u_long)ntohl(ik->precision) * tscale); 3033 (void)fprintf(fp, "frequency tolerance: %s ppm\n", 3034 fptoa((s_fp)ntohl(ik->tolerance), 0)); 3035 3036 /* 3037 * For backwards compatibility (ugh), we find the pps variables 3038 * only if the shift member is nonzero. 3039 */ 3040 if (!ik->shift) 3041 return; 3042 3043 /* 3044 * pps variables 3045 */ 3046 (void)fprintf(fp, "pps frequency: %s ppm\n", 3047 fptoa((s_fp)ntohl(ik->ppsfreq), 3)); 3048 (void)fprintf(fp, "pps stability: %s ppm\n", 3049 fptoa((s_fp)ntohl(ik->stabil), 3)); 3050 (void)fprintf(fp, "pps jitter: %g s\n", 3051 (u_long)ntohl(ik->jitter) * tscale); 3052 (void)fprintf(fp, "calibration interval: %d s\n", 3053 1 << ntohs(ik->shift)); 3054 (void)fprintf(fp, "calibration cycles: %ld\n", 3055 (u_long)ntohl(ik->calcnt)); 3056 (void)fprintf(fp, "jitter exceeded: %ld\n", 3057 (u_long)ntohl(ik->jitcnt)); 3058 (void)fprintf(fp, "stability exceeded: %ld\n", 3059 (u_long)ntohl(ik->stbcnt)); 3060 (void)fprintf(fp, "calibration errors: %ld\n", 3061 (u_long)ntohl(ik->errcnt)); 3062 } 3063 3064 #define IF_LIST_FMT "%2d %c %48s %c %c %12.12s %03x %3d %2d %5d %5d %5d %2d %3d %7d\n" 3065 #define IF_LIST_FMT_STR "%2s %c %48s %c %c %12.12s %3s %3s %2s %5s %5s %5s %2s %3s %7s\n" 3066 #define IF_LIST_AFMT_STR " %48s %c\n" 3067 #define IF_LIST_LABELS "#", 'A', "Address/Mask/Broadcast", 'T', 'E', "IF name", "Flg", "TL", "#M", "recv", "sent", "drop", "S", "PC", "uptime" 3068 #define IF_LIST_LINE "==================================================================================================================\n" 3069 3070 static void 3071 iflist( 3072 FILE *fp, 3073 struct info_if_stats *ifs, 3074 int items, 3075 int itemsize, 3076 int res 3077 ) 3078 { 3079 static char *actions = "?.+-"; 3080 sockaddr_u saddr; 3081 3082 if (res != 0) 3083 return; 3084 3085 if (!checkitems(items, fp)) 3086 return; 3087 3088 if (!checkitemsize(itemsize, sizeof(struct info_if_stats))) 3089 return; 3090 3091 fprintf(fp, IF_LIST_FMT_STR, IF_LIST_LABELS); 3092 fprintf(fp, IF_LIST_LINE); 3093 3094 while (items > 0) { 3095 SET_ADDR(saddr, ntohl(ifs->v6_flag), 3096 ifs->unaddr.addr.s_addr, ifs->unaddr.addr6); 3097 fprintf(fp, IF_LIST_FMT, 3098 ntohl(ifs->ifnum), 3099 actions[(ifs->action >= 1 && ifs->action < 4) ? ifs->action : 0], 3100 stoa((&saddr)), 'A', 3101 ifs->ignore_packets ? 'D' : 'E', 3102 ifs->name, 3103 ntohl(ifs->flags), 3104 ntohl(ifs->last_ttl), 3105 ntohl(ifs->num_mcast), 3106 ntohl(ifs->received), 3107 ntohl(ifs->sent), 3108 ntohl(ifs->notsent), 3109 ntohl(ifs->scopeid), 3110 ntohl(ifs->peercnt), 3111 ntohl(ifs->uptime)); 3112 3113 SET_ADDR(saddr, ntohl(ifs->v6_flag), 3114 ifs->unmask.addr.s_addr, ifs->unmask.addr6); 3115 fprintf(fp, IF_LIST_AFMT_STR, stoa(&saddr), 'M'); 3116 3117 if (!ntohl(ifs->v6_flag) && ntohl(ifs->flags) & (INT_BCASTOPEN)) { 3118 SET_ADDR(saddr, ntohl(ifs->v6_flag), 3119 ifs->unbcast.addr.s_addr, ifs->unbcast.addr6); 3120 fprintf(fp, IF_LIST_AFMT_STR, stoa(&saddr), 'B'); 3121 3122 } 3123 3124 ifs++; 3125 items--; 3126 } 3127 } 3128 3129 /*ARGSUSED*/ 3130 static void 3131 get_if_stats( 3132 struct parse *pcmd, 3133 FILE *fp 3134 ) 3135 { 3136 struct info_if_stats *ifs; 3137 int items; 3138 int itemsize; 3139 int res; 3140 3141 res = doquery(impl_ver, REQ_IF_STATS, 1, 0, 0, (char *)NULL, &items, 3142 &itemsize, (void *)&ifs, 0, 3143 sizeof(struct info_if_stats)); 3144 iflist(fp, ifs, items, itemsize, res); 3145 } 3146 3147 /*ARGSUSED*/ 3148 static void 3149 do_if_reload( 3150 struct parse *pcmd, 3151 FILE *fp 3152 ) 3153 { 3154 struct info_if_stats *ifs; 3155 int items; 3156 int itemsize; 3157 int res; 3158 3159 res = doquery(impl_ver, REQ_IF_RELOAD, 1, 0, 0, (char *)NULL, &items, 3160 &itemsize, (void *)&ifs, 0, 3161 sizeof(struct info_if_stats)); 3162 iflist(fp, ifs, items, itemsize, res); 3163 } 3164