1 /* 2 * ntpdc - control and monitor your ntpd daemon 3 */ 4 5 #include <stdio.h> 6 7 #include "ntpdc.h" 8 #include "ntp_select.h" 9 #include "ntp_io.h" 10 #include "ntp_stdlib.h" 11 /* Don't include ISC's version of IPv6 variables and structures */ 12 #define ISC_IPV6_H 1 13 #include "isc/net.h" 14 #include "isc/result.h" 15 16 #include <ctype.h> 17 #include <signal.h> 18 #include <setjmp.h> 19 #include <netdb.h> 20 21 #ifdef SYS_WINNT 22 # include <io.h> 23 #else 24 # define closesocket close 25 #endif /* SYS_WINNT */ 26 27 #if defined(HAVE_LIBREADLINE) || defined (HAVE_LIBEDIT) 28 # include <readline/readline.h> 29 # include <readline/history.h> 30 #endif /* HAVE_LIBREADLINE || HAVE_LIBEDIT */ 31 32 #ifdef SYS_VXWORKS 33 /* vxWorks needs mode flag -casey*/ 34 #define open(name, flags) open(name, flags, 0777) 35 #define SERVER_PORT_NUM 123 36 #endif 37 38 /* 39 * Because we now potentially understand a lot of commands (and 40 * it requires a lot of commands to talk to ntpd) we will run 41 * interactive if connected to a terminal. 42 */ 43 static int interactive = 0; /* set to 1 when we should prompt */ 44 static const char * prompt = "ntpdc> "; /* prompt to ask him about */ 45 46 /* 47 * Keyid used for authenticated requests. Obtained on the fly. 48 */ 49 static u_long info_auth_keyid; 50 51 /* 52 * Type of key md5 53 */ 54 #define KEY_TYPE_MD5 4 55 56 static int info_auth_keytype = KEY_TYPE_MD5; /* MD5 */ 57 u_long current_time; /* needed by authkeys; not used */ 58 59 int ntpdcmain P((int, char **)); 60 /* 61 * Built in command handler declarations 62 */ 63 static int openhost P((const char *)); 64 static int sendpkt P((char *, int)); 65 static void growpktdata P((void)); 66 static int getresponse P((int, int, int *, int *, char **, int)); 67 static int sendrequest P((int, int, int, int, int, char *)); 68 static void getcmds P((void)); 69 static RETSIGTYPE abortcmd P((int)); 70 static void docmd P((const char *)); 71 static void tokenize P((const char *, char **, int *)); 72 static int findcmd P((char *, struct xcmd *, struct xcmd *, struct xcmd **)); 73 static int getarg P((char *, int, arg_v *)); 74 static int getnetnum P((const char *, struct sockaddr_storage *, char *, int)); 75 static void help P((struct parse *, FILE *)); 76 #ifdef QSORT_USES_VOID_P 77 static int helpsort P((const void *, const void *)); 78 #else 79 static int helpsort P((char **, char **)); 80 #endif 81 static void printusage P((struct xcmd *, FILE *)); 82 static void timeout P((struct parse *, FILE *)); 83 static void my_delay P((struct parse *, FILE *)); 84 static void host P((struct parse *, FILE *)); 85 static void keyid P((struct parse *, FILE *)); 86 static void keytype P((struct parse *, FILE *)); 87 static void passwd P((struct parse *, FILE *)); 88 static void hostnames P((struct parse *, FILE *)); 89 static void setdebug P((struct parse *, FILE *)); 90 static void quit P((struct parse *, FILE *)); 91 static void version P((struct parse *, FILE *)); 92 static void warning P((const char *, const char *, const char *)); 93 static void error P((const char *, const char *, const char *)); 94 static u_long getkeyid P((const char *)); 95 96 97 98 /* 99 * Built-in commands we understand 100 */ 101 static struct xcmd builtins[] = { 102 { "?", help, { OPT|NTP_STR, NO, NO, NO }, 103 { "command", "", "", "" }, 104 "tell the use and syntax of commands" }, 105 { "help", help, { OPT|NTP_STR, NO, NO, NO }, 106 { "command", "", "", "" }, 107 "tell the use and syntax of commands" }, 108 { "timeout", timeout, { OPT|UINT, NO, NO, NO }, 109 { "msec", "", "", "" }, 110 "set the primary receive time out" }, 111 { "delay", my_delay, { OPT|INT, NO, NO, NO }, 112 { "msec", "", "", "" }, 113 "set the delay added to encryption time stamps" }, 114 { "host", host, { OPT|NTP_STR, OPT|NTP_STR, NO, NO }, 115 { "-4|-6", "hostname", "", "" }, 116 "specify the host whose NTP server we talk to" }, 117 { "passwd", passwd, { OPT|NTP_STR, NO, NO, NO }, 118 { "", "", "", "" }, 119 "specify a password to use for authenticated requests"}, 120 { "hostnames", hostnames, { OPT|NTP_STR, NO, NO, NO }, 121 { "yes|no", "", "", "" }, 122 "specify whether hostnames or net numbers are printed"}, 123 { "debug", setdebug, { OPT|NTP_STR, NO, NO, NO }, 124 { "no|more|less", "", "", "" }, 125 "set/change debugging level" }, 126 { "quit", quit, { NO, NO, NO, NO }, 127 { "", "", "", "" }, 128 "exit ntpdc" }, 129 { "exit", quit, { NO, NO, NO, NO }, 130 { "", "", "", "" }, 131 "exit ntpdc" }, 132 { "keyid", keyid, { OPT|UINT, NO, NO, NO }, 133 { "key#", "", "", "" }, 134 "set/show keyid to use for authenticated requests" }, 135 { "keytype", keytype, { OPT|NTP_STR, NO, NO, NO }, 136 { "(md5|des)", "", "", "" }, 137 "set/show key authentication type for authenticated requests (des|md5)" }, 138 { "version", version, { NO, NO, NO, NO }, 139 { "", "", "", "" }, 140 "print version number" }, 141 { 0, 0, { NO, NO, NO, NO }, 142 { "", "", "", "" }, "" } 143 }; 144 145 146 /* 147 * Default values we use. 148 */ 149 #define DEFTIMEOUT (5) /* 5 second time out */ 150 #define DEFSTIMEOUT (2) /* 2 second time out after first */ 151 #define DEFDELAY 0x51EB852 /* 20 milliseconds, l_fp fraction */ 152 #define DEFHOST "localhost" /* default host name */ 153 #define LENHOSTNAME 256 /* host name is 256 characters long */ 154 #define MAXCMDS 100 /* maximum commands on cmd line */ 155 #define MAXHOSTS 200 /* maximum hosts on cmd line */ 156 #define MAXLINE 512 /* maximum line length */ 157 #define MAXTOKENS (1+1+MAXARGS+2) /* maximum number of usable tokens */ 158 /* command + -4|-6 + MAXARGS + */ 159 /* redirection */ 160 161 /* 162 * Some variables used and manipulated locally 163 */ 164 static struct timeval tvout = { DEFTIMEOUT, 0 }; /* time out for reads */ 165 static struct timeval tvsout = { DEFSTIMEOUT, 0 }; /* secondary time out */ 166 static l_fp delay_time; /* delay time */ 167 static char currenthost[LENHOSTNAME]; /* current host name */ 168 int showhostnames = 1; /* show host names by default */ 169 170 static int ai_fam_templ; /* address family */ 171 static int ai_fam_default; /* default address family */ 172 static SOCKET sockfd; /* fd socket is opened on */ 173 static int havehost = 0; /* set to 1 when host open */ 174 int s_port = 0; 175 176 #if defined (SYS_WINNT) || defined (SYS_VXWORKS) 177 char password[9]; 178 #endif /* SYS_WINNT || SYS_VXWORKS */ 179 180 #ifdef SYS_WINNT 181 DWORD NumberOfBytesWritten; 182 183 HANDLE TimerThreadHandle = NULL; /* 1998/06/03 - Used in ntplib/machines.c */ 184 void timer(void) { ; }; /* 1998/06/03 - Used in ntplib/machines.c */ 185 186 #endif /* SYS_WINNT */ 187 188 /* 189 * Holds data returned from queries. We allocate INITDATASIZE 190 * octets to begin with, increasing this as we need to. 191 */ 192 #define INITDATASIZE (sizeof(struct resp_pkt) * 16) 193 #define INCDATASIZE (sizeof(struct resp_pkt) * 8) 194 195 static char *pktdata; 196 static int pktdatasize; 197 198 /* 199 * These are used to help the magic with old and new versions of ntpd. 200 */ 201 int impl_ver = IMPL_XNTPD; 202 static int req_pkt_size = REQ_LEN_NOMAC; 203 204 /* 205 * For commands typed on the command line (with the -c option) 206 */ 207 static int numcmds = 0; 208 static const char *ccmds[MAXCMDS]; 209 #define ADDCMD(cp) if (numcmds < MAXCMDS) ccmds[numcmds++] = (cp) 210 211 /* 212 * When multiple hosts are specified. 213 */ 214 static int numhosts = 0; 215 static const char *chosts[MAXHOSTS]; 216 #define ADDHOST(cp) if (numhosts < MAXHOSTS) chosts[numhosts++] = (cp) 217 218 /* 219 * Error codes for internal use 220 */ 221 #define ERR_INCOMPLETE 16 222 #define ERR_TIMEOUT 17 223 224 /* 225 * Macro definitions we use 226 */ 227 #define ISSPACE(c) ((c) == ' ' || (c) == '\t') 228 #define ISEOL(c) ((c) == '\n' || (c) == '\r' || (c) == '\0') 229 #define STREQ(a, b) (*(a) == *(b) && strcmp((a), (b)) == 0) 230 231 /* 232 * For converting time stamps to dates 233 */ 234 #define JAN_1970 2208988800 /* 1970 - 1900 in seconds */ 235 236 /* 237 * Jump buffer for longjumping back to the command level 238 */ 239 static jmp_buf interrupt_buf; 240 static volatile int jump = 0; 241 242 /* 243 * Pointer to current output unit 244 */ 245 static FILE *current_output; 246 247 /* 248 * Command table imported from ntpdc_ops.c 249 */ 250 extern struct xcmd opcmds[]; 251 252 char *progname; 253 volatile int debug; 254 255 #ifdef NO_MAIN_ALLOWED 256 CALL(ntpdc,"ntpdc",ntpdcmain); 257 #else 258 int 259 main( 260 int argc, 261 char *argv[] 262 ) 263 { 264 return ntpdcmain(argc, argv); 265 } 266 #endif 267 268 #ifdef SYS_VXWORKS 269 void clear_globals(void) 270 { 271 extern int ntp_optind; 272 extern char *ntp_optarg; 273 showhostnames = 0; /* show host names by default */ 274 ntp_optind = 0; 275 ntp_optarg = 0; 276 havehost = 0; /* set to 1 when host open */ 277 numcmds = 0; 278 numhosts = 0; 279 } 280 #endif 281 282 /* 283 * main - parse arguments and handle options 284 */ 285 int 286 ntpdcmain( 287 int argc, 288 char *argv[] 289 ) 290 { 291 int c; 292 int errflg = 0; 293 extern int ntp_optind; 294 extern char *ntp_optarg; 295 296 delay_time.l_ui = 0; 297 delay_time.l_uf = DEFDELAY; 298 299 #ifdef SYS_VXWORKS 300 clear_globals(); 301 taskPrioritySet(taskIdSelf(), 100 ); 302 #endif 303 304 #ifdef SYS_WINNT 305 if (!Win32InitSockets()) 306 { 307 fprintf(stderr, "No useable winsock.dll:"); 308 exit(1); 309 } 310 #endif /* SYS_WINNT */ 311 312 /* Check to see if we have IPv6. Otherwise force the -4 flag */ 313 if (isc_net_probeipv6() != ISC_R_SUCCESS) { 314 ai_fam_default = AF_INET; 315 } 316 317 progname = argv[0]; 318 ai_fam_templ = ai_fam_default; 319 while ((c = ntp_getopt(argc, argv, "46c:dilnps")) != EOF) 320 switch (c) { 321 case '4': 322 ai_fam_templ = AF_INET; 323 break; 324 case '6': 325 ai_fam_templ = AF_INET6; 326 break; 327 case 'c': 328 ADDCMD(ntp_optarg); 329 break; 330 case 'd': 331 ++debug; 332 break; 333 case 'i': 334 interactive = 1; 335 break; 336 case 'l': 337 ADDCMD("listpeers"); 338 break; 339 case 'n': 340 showhostnames = 0; 341 break; 342 case 'p': 343 ADDCMD("peers"); 344 break; 345 case 's': 346 ADDCMD("dmpeers"); 347 break; 348 default: 349 errflg++; 350 break; 351 } 352 if (errflg) { 353 (void) fprintf(stderr, 354 "usage: %s [-46dilnps] [-c cmd] host ...\n", 355 progname); 356 exit(2); 357 } 358 if (ntp_optind == argc) { 359 ADDHOST(DEFHOST); 360 } else { 361 for (; ntp_optind < argc; ntp_optind++) 362 ADDHOST(argv[ntp_optind]); 363 } 364 365 if (numcmds == 0 && interactive == 0 366 && isatty(fileno(stdin)) && isatty(fileno(stderr))) { 367 interactive = 1; 368 } 369 370 #ifndef SYS_WINNT /* Under NT cannot handle SIGINT, WIN32 spawns a handler */ 371 if (interactive) 372 (void) signal_no_reset(SIGINT, abortcmd); 373 #endif /* SYS_WINNT */ 374 375 /* 376 * Initialize the packet data buffer 377 */ 378 pktdata = (char *)malloc(INITDATASIZE); 379 if (pktdata == NULL) { 380 (void) fprintf(stderr, "%s: malloc() failed!\n", progname); 381 exit(1); 382 } 383 pktdatasize = INITDATASIZE; 384 385 if (numcmds == 0) { 386 (void) openhost(chosts[0]); 387 getcmds(); 388 } else { 389 int ihost; 390 int icmd; 391 392 for (ihost = 0; ihost < numhosts; ihost++) { 393 if (openhost(chosts[ihost])) 394 for (icmd = 0; icmd < numcmds; icmd++) { 395 if (numhosts > 1) 396 printf ("--- %s ---\n",chosts[ihost]); 397 docmd(ccmds[icmd]); 398 } 399 } 400 } 401 #ifdef SYS_WINNT 402 WSACleanup(); 403 #endif 404 return(0); 405 } /* main end */ 406 407 408 /* 409 * openhost - open a socket to a host 410 */ 411 static int 412 openhost( 413 const char *hname 414 ) 415 { 416 char temphost[LENHOSTNAME]; 417 int a_info, i; 418 struct addrinfo hints, *ai = NULL; 419 register const char *cp; 420 char name[LENHOSTNAME]; 421 char service[5]; 422 423 /* 424 * We need to get by the [] if they were entered 425 */ 426 427 cp = hname; 428 429 if (*cp == '[') { 430 cp++; 431 for(i = 0; *cp != ']'; cp++, i++) 432 name[i] = *cp; 433 name[i] = '\0'; 434 hname = name; 435 } 436 437 /* 438 * First try to resolve it as an ip address and if that fails, 439 * do a fullblown (dns) lookup. That way we only use the dns 440 * when it is needed and work around some implementations that 441 * will return an "IPv4-mapped IPv6 address" address if you 442 * give it an IPv4 address to lookup. 443 */ 444 strcpy(service, "ntp"); 445 memset((char *)&hints, 0, sizeof(struct addrinfo)); 446 hints.ai_family = ai_fam_templ; 447 hints.ai_protocol = IPPROTO_UDP; 448 hints.ai_socktype = SOCK_DGRAM; 449 hints.ai_flags = AI_NUMERICHOST; 450 451 a_info = getaddrinfo(hname, service, &hints, &ai); 452 if (a_info == EAI_NONAME || a_info == EAI_NODATA) { 453 hints.ai_flags = AI_CANONNAME; 454 #ifdef AI_ADDRCONFIG 455 hints.ai_flags |= AI_ADDRCONFIG; 456 #endif 457 a_info = getaddrinfo(hname, service, &hints, &ai); 458 } 459 /* Some older implementations don't like AI_ADDRCONFIG. */ 460 if (a_info == EAI_BADFLAGS) { 461 hints.ai_flags = AI_CANONNAME; 462 a_info = getaddrinfo(hname, service, &hints, &ai); 463 } 464 if (a_info != 0) { 465 (void) fprintf(stderr, "%s\n", gai_strerror(a_info)); 466 return 0; 467 } 468 469 if (ai->ai_canonname == NULL) { 470 strncpy(temphost, stoa((struct sockaddr_storage *)ai->ai_addr), 471 LENHOSTNAME); 472 temphost[LENHOSTNAME-1] = '\0'; 473 } else { 474 strncpy(temphost, ai->ai_canonname, LENHOSTNAME); 475 temphost[LENHOSTNAME-1] = '\0'; 476 } 477 478 if (debug > 2) 479 printf("Opening host %s\n", temphost); 480 481 if (havehost == 1) { 482 if (debug > 2) 483 printf("Closing old host %s\n", currenthost); 484 (void) closesocket(sockfd); 485 havehost = 0; 486 } 487 (void) strcpy(currenthost, temphost); 488 489 /* port maps to the same in both families */ 490 s_port = ((struct sockaddr_in6 *)ai->ai_addr)->sin6_port; 491 #ifdef SYS_VXWORKS 492 ((struct sockaddr_in6 *)&hostaddr)->sin6_port = htons(SERVER_PORT_NUM); 493 if (ai->ai_family == AF_INET) 494 *(struct sockaddr_in *)&hostaddr= 495 *((struct sockaddr_in *)ai->ai_addr); 496 else 497 *(struct sockaddr_in6 *)&hostaddr= 498 *((struct sockaddr_in6 *)ai->ai_addr); 499 #endif /* SYS_VXWORKS */ 500 501 #ifdef SYS_WINNT 502 { 503 int optionValue = SO_SYNCHRONOUS_NONALERT; 504 int err; 505 err = setsockopt(INVALID_SOCKET, SOL_SOCKET, SO_OPENTYPE, (char *)&optionValue, sizeof(optionValue)); 506 if (err != NO_ERROR) { 507 (void) fprintf(stderr, "cannot open nonoverlapped sockets\n"); 508 exit(1); 509 } 510 } 511 512 sockfd = socket(ai->ai_family, SOCK_DGRAM, 0); 513 if (sockfd == INVALID_SOCKET) { 514 error("socket", "", ""); 515 exit(-1); 516 } 517 #else 518 sockfd = socket(ai->ai_family, SOCK_DGRAM, 0); 519 if (sockfd == -1) 520 error("socket", "", ""); 521 #endif /* SYS_WINNT */ 522 523 524 #ifdef NEED_RCVBUF_SLOP 525 # ifdef SO_RCVBUF 526 { 527 int rbufsize = INITDATASIZE + 2048; /* 2K for slop */ 528 529 if (setsockopt(sockfd, SOL_SOCKET, SO_RCVBUF, 530 &rbufsize, sizeof(int)) == -1) 531 error("setsockopt", "", ""); 532 } 533 # endif 534 #endif 535 536 #ifdef SYS_VXWORKS 537 if (connect(sockfd, (struct sockaddr *)&hostaddr, 538 sizeof(hostaddr)) == -1) 539 #else 540 if (connect(sockfd, (struct sockaddr *)ai->ai_addr, 541 ai->ai_addrlen) == -1) 542 #endif /* SYS_VXWORKS */ 543 error("connect", "", ""); 544 if (a_info) 545 freeaddrinfo(ai); 546 havehost = 1; 547 req_pkt_size = REQ_LEN_NOMAC; 548 impl_ver = IMPL_XNTPD; 549 return 1; 550 } 551 552 553 /* XXX ELIMINATE sendpkt similar in ntpq.c, ntpdc.c, ntp_io.c, ntptrace.c */ 554 /* 555 * sendpkt - send a packet to the remote host 556 */ 557 static int 558 sendpkt( 559 char *xdata, 560 int xdatalen 561 ) 562 { 563 if (send(sockfd, xdata, (size_t)xdatalen, 0) == -1) { 564 warning("write to %s failed", currenthost, ""); 565 return -1; 566 } 567 568 return 0; 569 } 570 571 572 /* 573 * growpktdata - grow the packet data area 574 */ 575 static void 576 growpktdata(void) 577 { 578 pktdatasize += INCDATASIZE; 579 pktdata = (char *)realloc(pktdata, (unsigned)pktdatasize); 580 if (pktdata == 0) { 581 (void) fprintf(stderr, "%s: realloc() failed!\n", progname); 582 exit(1); 583 } 584 } 585 586 587 /* 588 * getresponse - get a (series of) response packet(s) and return the data 589 */ 590 static int 591 getresponse( 592 int implcode, 593 int reqcode, 594 int *ritems, 595 int *rsize, 596 char **rdata, 597 int esize 598 ) 599 { 600 struct resp_pkt rpkt; 601 struct timeval tvo; 602 int items; 603 int i; 604 int size; 605 int datasize; 606 char *datap; 607 char *tmp_data; 608 char haveseq[MAXSEQ+1]; 609 int firstpkt; 610 int lastseq; 611 int numrecv; 612 int seq; 613 fd_set fds; 614 int n; 615 int pad; 616 617 /* 618 * This is pretty tricky. We may get between 1 and many packets 619 * back in response to the request. We peel the data out of 620 * each packet and collect it in one long block. When the last 621 * packet in the sequence is received we'll know how many we 622 * should have had. Note we use one long time out, should reconsider. 623 */ 624 *ritems = 0; 625 *rsize = 0; 626 firstpkt = 1; 627 numrecv = 0; 628 *rdata = datap = pktdata; 629 lastseq = 999; /* too big to be a sequence number */ 630 memset(haveseq, 0, sizeof(haveseq)); 631 FD_ZERO(&fds); 632 633 again: 634 if (firstpkt) 635 tvo = tvout; 636 else 637 tvo = tvsout; 638 639 FD_SET(sockfd, &fds); 640 n = select(sockfd+1, &fds, (fd_set *)0, (fd_set *)0, &tvo); 641 642 if (n == -1) { 643 warning("select fails", "", ""); 644 return -1; 645 } 646 if (n == 0) { 647 /* 648 * Timed out. Return what we have 649 */ 650 if (firstpkt) { 651 (void) fprintf(stderr, 652 "%s: timed out, nothing received\n", currenthost); 653 return ERR_TIMEOUT; 654 } else { 655 (void) fprintf(stderr, 656 "%s: timed out with incomplete data\n", 657 currenthost); 658 if (debug) { 659 printf("Received sequence numbers"); 660 for (n = 0; n <= MAXSEQ; n++) 661 if (haveseq[n]) 662 printf(" %d,", n); 663 if (lastseq != 999) 664 printf(" last frame received\n"); 665 else 666 printf(" last frame not received\n"); 667 } 668 return ERR_INCOMPLETE; 669 } 670 } 671 672 n = recv(sockfd, (char *)&rpkt, sizeof(rpkt), 0); 673 if (n == -1) { 674 warning("read", "", ""); 675 return -1; 676 } 677 678 679 /* 680 * Check for format errors. Bug proofing. 681 */ 682 if (n < RESP_HEADER_SIZE) { 683 if (debug) 684 printf("Short (%d byte) packet received\n", n); 685 goto again; 686 } 687 if (INFO_VERSION(rpkt.rm_vn_mode) > NTP_VERSION || 688 INFO_VERSION(rpkt.rm_vn_mode) < NTP_OLDVERSION) { 689 if (debug) 690 printf("Packet received with version %d\n", 691 INFO_VERSION(rpkt.rm_vn_mode)); 692 goto again; 693 } 694 if (INFO_MODE(rpkt.rm_vn_mode) != MODE_PRIVATE) { 695 if (debug) 696 printf("Packet received with mode %d\n", 697 INFO_MODE(rpkt.rm_vn_mode)); 698 goto again; 699 } 700 if (INFO_IS_AUTH(rpkt.auth_seq)) { 701 if (debug) 702 printf("Encrypted packet received\n"); 703 goto again; 704 } 705 if (!ISRESPONSE(rpkt.rm_vn_mode)) { 706 if (debug) 707 printf("Received request packet, wanted response\n"); 708 goto again; 709 } 710 if (INFO_MBZ(rpkt.mbz_itemsize) != 0) { 711 if (debug) 712 printf("Received packet with nonzero MBZ field!\n"); 713 goto again; 714 } 715 716 /* 717 * Check implementation/request. Could be old data getting to us. 718 */ 719 if (rpkt.implementation != implcode || rpkt.request != reqcode) { 720 if (debug) 721 printf( 722 "Received implementation/request of %d/%d, wanted %d/%d", 723 rpkt.implementation, rpkt.request, 724 implcode, reqcode); 725 goto again; 726 } 727 728 /* 729 * Check the error code. If non-zero, return it. 730 */ 731 if (INFO_ERR(rpkt.err_nitems) != INFO_OKAY) { 732 if (debug && ISMORE(rpkt.rm_vn_mode)) { 733 printf("Error code %d received on not-final packet\n", 734 INFO_ERR(rpkt.err_nitems)); 735 } 736 return (int)INFO_ERR(rpkt.err_nitems); 737 } 738 739 /* 740 * Collect items and size. Make sure they make sense. 741 */ 742 items = INFO_NITEMS(rpkt.err_nitems); 743 size = INFO_ITEMSIZE(rpkt.mbz_itemsize); 744 if (esize > size) 745 pad = esize - size; 746 else 747 pad = 0; 748 if ((datasize = items*size) > (n-RESP_HEADER_SIZE)) { 749 if (debug) 750 printf( 751 "Received items %d, size %d (total %d), data in packet is %d\n", 752 items, size, datasize, n-RESP_HEADER_SIZE); 753 goto again; 754 } 755 756 /* 757 * If this isn't our first packet, make sure the size matches 758 * the other ones. 759 */ 760 if (!firstpkt && esize != *rsize) { 761 if (debug) 762 printf("Received itemsize %d, previous %d\n", 763 size, *rsize); 764 goto again; 765 } 766 /* 767 * If we've received this before, +toss it 768 */ 769 seq = INFO_SEQ(rpkt.auth_seq); 770 if (haveseq[seq]) { 771 if (debug) 772 printf("Received duplicate sequence number %d\n", seq); 773 goto again; 774 } 775 haveseq[seq] = 1; 776 777 /* 778 * If this is the last in the sequence, record that. 779 */ 780 if (!ISMORE(rpkt.rm_vn_mode)) { 781 if (lastseq != 999) { 782 printf("Received second end sequence packet\n"); 783 goto again; 784 } 785 lastseq = seq; 786 } 787 788 /* 789 * So far, so good. Copy this data into the output array. 790 */ 791 if ((datap + datasize + (pad * items)) > (pktdata + pktdatasize)) { 792 int offset = datap - pktdata; 793 growpktdata(); 794 *rdata = pktdata; /* might have been realloced ! */ 795 datap = pktdata + offset; 796 } 797 /* 798 * We now move the pointer along according to size and number of 799 * items. This is so we can play nice with older implementations 800 */ 801 802 tmp_data = (char *)rpkt.data; 803 for(i = 0; i <items; i++){ 804 memmove(datap, tmp_data, (unsigned)size); 805 tmp_data += size; 806 memset(datap + size, 0, pad); 807 datap += size + pad; 808 } 809 810 if (firstpkt) { 811 firstpkt = 0; 812 *rsize = size + pad; 813 } 814 *ritems += items; 815 816 /* 817 * Finally, check the count of received packets. If we've got them 818 * all, return 819 */ 820 ++numrecv; 821 if (numrecv <= lastseq) 822 goto again; 823 return INFO_OKAY; 824 } 825 826 827 /* 828 * sendrequest - format and send a request packet 829 */ 830 static int 831 sendrequest( 832 int implcode, 833 int reqcode, 834 int auth, 835 int qitems, 836 int qsize, 837 char *qdata 838 ) 839 { 840 struct req_pkt qpkt; 841 int datasize; 842 843 memset((char *)&qpkt, 0, sizeof qpkt); 844 845 qpkt.rm_vn_mode = RM_VN_MODE(0, 0, 0); 846 qpkt.implementation = (u_char)implcode; 847 qpkt.request = (u_char)reqcode; 848 849 datasize = qitems * qsize; 850 if (datasize != 0 && qdata != NULL) { 851 memmove((char *)qpkt.data, qdata, (unsigned)datasize); 852 qpkt.err_nitems = ERR_NITEMS(0, qitems); 853 qpkt.mbz_itemsize = MBZ_ITEMSIZE(qsize); 854 } else { 855 qpkt.err_nitems = ERR_NITEMS(0, 0); 856 qpkt.mbz_itemsize = MBZ_ITEMSIZE(0); 857 } 858 859 if (!auth) { 860 qpkt.auth_seq = AUTH_SEQ(0, 0); 861 return sendpkt((char *)&qpkt, req_pkt_size); 862 } else { 863 l_fp ts; 864 int maclen = 0; 865 const char *pass = "\0"; 866 struct req_pkt_tail *qpktail; 867 868 qpktail = (struct req_pkt_tail *)((char *)&qpkt + req_pkt_size 869 + MAX_MAC_LEN - sizeof(struct req_pkt_tail)); 870 871 if (info_auth_keyid == 0) { 872 maclen = getkeyid("Keyid: "); 873 if (maclen == 0) { 874 (void) fprintf(stderr, 875 "Invalid key identifier\n"); 876 return 1; 877 } 878 info_auth_keyid = maclen; 879 } 880 if (!authistrusted(info_auth_keyid)) { 881 pass = getpass("MD5 Password: "); 882 if (*pass == '\0') { 883 (void) fprintf(stderr, 884 "Invalid password\n"); 885 return (1); 886 } 887 } 888 authusekey(info_auth_keyid, info_auth_keytype, (const u_char *)pass); 889 authtrust(info_auth_keyid, 1); 890 qpkt.auth_seq = AUTH_SEQ(1, 0); 891 qpktail->keyid = htonl(info_auth_keyid); 892 get_systime(&ts); 893 L_ADD(&ts, &delay_time); 894 HTONL_FP(&ts, &qpktail->tstamp); 895 maclen = authencrypt(info_auth_keyid, (u_int32 *)&qpkt, 896 req_pkt_size); 897 if (maclen == 0) { 898 (void) fprintf(stderr, "Key not found\n"); 899 return (1); 900 } 901 return sendpkt((char *)&qpkt, (int)(req_pkt_size + maclen)); 902 } 903 /*NOTREACHED*/ 904 } 905 906 907 /* 908 * doquery - send a request and process the response 909 */ 910 int 911 doquery( 912 int implcode, 913 int reqcode, 914 int auth, 915 int qitems, 916 int qsize, 917 char *qdata, 918 int *ritems, 919 int *rsize, 920 char **rdata, 921 int quiet_mask, 922 int esize 923 ) 924 { 925 int res; 926 char junk[512]; 927 fd_set fds; 928 struct timeval tvzero; 929 930 /* 931 * Check to make sure host is open 932 */ 933 if (!havehost) { 934 (void) fprintf(stderr, "***No host open, use `host' command\n"); 935 return -1; 936 } 937 938 /* 939 * Poll the socket and clear out any pending data 940 */ 941 again: 942 do { 943 tvzero.tv_sec = tvzero.tv_usec = 0; 944 FD_ZERO(&fds); 945 FD_SET(sockfd, &fds); 946 res = select(sockfd+1, &fds, (fd_set *)0, (fd_set *)0, &tvzero); 947 948 if (res == -1) { 949 warning("polling select", "", ""); 950 return -1; 951 } else if (res > 0) 952 953 (void) recv(sockfd, junk, sizeof junk, 0); 954 } while (res > 0); 955 956 957 /* 958 * send a request 959 */ 960 res = sendrequest(implcode, reqcode, auth, qitems, qsize, qdata); 961 if (res != 0) 962 return res; 963 964 /* 965 * Get the response. If we got a standard error, print a message 966 */ 967 res = getresponse(implcode, reqcode, ritems, rsize, rdata, esize); 968 969 /* 970 * Try to be compatible with older implementations of ntpd. 971 */ 972 if (res == INFO_ERR_FMT && req_pkt_size != 48) { 973 int oldsize; 974 975 oldsize = req_pkt_size; 976 977 switch(req_pkt_size) { 978 case REQ_LEN_NOMAC: 979 req_pkt_size = 160; 980 break; 981 case 160: 982 req_pkt_size = 48; 983 break; 984 } 985 if (impl_ver == IMPL_XNTPD) { 986 fprintf(stderr, 987 "***Warning changing to older implementation\n"); 988 return INFO_ERR_IMPL; 989 } 990 991 fprintf(stderr, 992 "***Warning changing the request packet size from %d to %d\n", 993 oldsize, req_pkt_size); 994 goto again; 995 } 996 997 /* log error message if not told to be quiet */ 998 if ((res > 0) && (((1 << res) & quiet_mask) == 0)) { 999 switch(res) { 1000 case INFO_ERR_IMPL: 1001 /* Give us a chance to try the older implementation. */ 1002 if (implcode == IMPL_XNTPD) 1003 break; 1004 (void) fprintf(stderr, 1005 "***Server implementation incompatable with our own\n"); 1006 break; 1007 case INFO_ERR_REQ: 1008 (void) fprintf(stderr, 1009 "***Server doesn't implement this request\n"); 1010 break; 1011 case INFO_ERR_FMT: 1012 (void) fprintf(stderr, 1013 "***Server reports a format error in the received packet (shouldn't happen)\n"); 1014 break; 1015 case INFO_ERR_NODATA: 1016 (void) fprintf(stderr, 1017 "***Server reports data not found\n"); 1018 break; 1019 case INFO_ERR_AUTH: 1020 (void) fprintf(stderr, "***Permission denied\n"); 1021 break; 1022 case ERR_TIMEOUT: 1023 (void) fprintf(stderr, "***Request timed out\n"); 1024 break; 1025 case ERR_INCOMPLETE: 1026 (void) fprintf(stderr, 1027 "***Response from server was incomplete\n"); 1028 break; 1029 default: 1030 (void) fprintf(stderr, 1031 "***Server returns unknown error code %d\n", res); 1032 break; 1033 } 1034 } 1035 return res; 1036 } 1037 1038 1039 /* 1040 * getcmds - read commands from the standard input and execute them 1041 */ 1042 static void 1043 getcmds(void) 1044 { 1045 #if defined(HAVE_LIBREADLINE) || defined(HAVE_LIBEDIT) 1046 char *line; 1047 1048 for (;;) { 1049 if ((line = readline(interactive?prompt:"")) == NULL) return; 1050 if (*line) add_history(line); 1051 docmd(line); 1052 free(line); 1053 } 1054 #else /* not (HAVE_LIBREADLINE || HAVE_LIBEDIT) */ 1055 char line[MAXLINE]; 1056 1057 for (;;) { 1058 if (interactive) { 1059 #ifdef VMS /* work around a problem with mixing stdout & stderr */ 1060 fputs("",stdout); 1061 #endif 1062 (void) fputs(prompt, stderr); 1063 (void) fflush(stderr); 1064 } 1065 1066 if (fgets(line, sizeof line, stdin) == NULL) 1067 return; 1068 1069 docmd(line); 1070 } 1071 #endif /* not HAVE_LIBREADLINE || HAVE_LIBEDIT */ 1072 } 1073 1074 1075 #ifndef SYS_WINNT /* Under NT cannot handle SIGINT, WIN32 spawns a handler */ 1076 /* 1077 * abortcmd - catch interrupts and abort the current command 1078 */ 1079 static RETSIGTYPE 1080 abortcmd( 1081 int sig 1082 ) 1083 { 1084 1085 if (current_output == stdout) 1086 (void) fflush(stdout); 1087 putc('\n', stderr); 1088 (void) fflush(stderr); 1089 if (jump) longjmp(interrupt_buf, 1); 1090 } 1091 #endif /* SYS_WINNT */ 1092 1093 /* 1094 * docmd - decode the command line and execute a command 1095 */ 1096 static void 1097 docmd( 1098 const char *cmdline 1099 ) 1100 { 1101 char *tokens[1+MAXARGS+2]; 1102 struct parse pcmd; 1103 int ntok; 1104 int i, ti; 1105 int rval; 1106 struct xcmd *xcmd; 1107 1108 ai_fam_templ = ai_fam_default; 1109 /* 1110 * Tokenize the command line. If nothing on it, return. 1111 */ 1112 tokenize(cmdline, tokens, &ntok); 1113 if (ntok == 0) 1114 return; 1115 1116 /* 1117 * Find the appropriate command description. 1118 */ 1119 i = findcmd(tokens[0], builtins, opcmds, &xcmd); 1120 if (i == 0) { 1121 (void) fprintf(stderr, "***Command `%s' unknown\n", 1122 tokens[0]); 1123 return; 1124 } else if (i >= 2) { 1125 (void) fprintf(stderr, "***Command `%s' ambiguous\n", 1126 tokens[0]); 1127 return; 1128 } 1129 1130 /* 1131 * Save the keyword, then walk through the arguments, interpreting 1132 * as we go. 1133 */ 1134 pcmd.keyword = tokens[0]; 1135 pcmd.nargs = 0; 1136 ti = 1; 1137 for (i = 0; i < MAXARGS && xcmd->arg[i] != NO;) { 1138 if ((i+ti) >= ntok) { 1139 if (!(xcmd->arg[i] & OPT)) { 1140 printusage(xcmd, stderr); 1141 return; 1142 } 1143 break; 1144 } 1145 if ((xcmd->arg[i] & OPT) && (*tokens[i+ti] == '>')) 1146 break; 1147 rval = getarg(tokens[i+ti], (int)xcmd->arg[i], &pcmd.argval[i]); 1148 if (rval == -1) { 1149 ti++; 1150 continue; 1151 } 1152 if (rval == 0) 1153 return; 1154 pcmd.nargs++; 1155 i++; 1156 } 1157 1158 i += ti; 1159 if (i < ntok && *tokens[i] == '>') { 1160 char *fname; 1161 1162 if (*(tokens[i]+1) != '\0') 1163 fname = tokens[i]+1; 1164 else if ((i+1) < ntok) 1165 fname = tokens[i+1]; 1166 else { 1167 (void) fprintf(stderr, "***No file for redirect\n"); 1168 return; 1169 } 1170 1171 current_output = fopen(fname, "w"); 1172 if (current_output == NULL) { 1173 (void) fprintf(stderr, "***Error opening %s: ", fname); 1174 perror(""); 1175 return; 1176 } 1177 } else { 1178 current_output = stdout; 1179 } 1180 1181 if (interactive && setjmp(interrupt_buf)) { 1182 return; 1183 } else { 1184 jump = 1; 1185 (xcmd->handler)(&pcmd, current_output); 1186 jump = 0; 1187 if (current_output != stdout) 1188 (void) fclose(current_output); 1189 current_output = NULL; 1190 } 1191 } 1192 1193 1194 /* 1195 * tokenize - turn a command line into tokens 1196 */ 1197 static void 1198 tokenize( 1199 const char *line, 1200 char **tokens, 1201 int *ntok 1202 ) 1203 { 1204 register const char *cp; 1205 register char *sp; 1206 static char tspace[MAXLINE]; 1207 1208 sp = tspace; 1209 cp = line; 1210 for (*ntok = 0; *ntok < MAXTOKENS; (*ntok)++) { 1211 tokens[*ntok] = sp; 1212 while (ISSPACE(*cp)) 1213 cp++; 1214 if (ISEOL(*cp)) 1215 break; 1216 do { 1217 *sp++ = *cp++; 1218 } while (!ISSPACE(*cp) && !ISEOL(*cp)); 1219 1220 *sp++ = '\0'; 1221 } 1222 } 1223 1224 1225 1226 /* 1227 * findcmd - find a command in a command description table 1228 */ 1229 static int 1230 findcmd( 1231 register char *str, 1232 struct xcmd *clist1, 1233 struct xcmd *clist2, 1234 struct xcmd **cmd 1235 ) 1236 { 1237 register struct xcmd *cl; 1238 register int clen; 1239 int nmatch; 1240 struct xcmd *nearmatch = NULL; 1241 struct xcmd *clist; 1242 1243 clen = strlen(str); 1244 nmatch = 0; 1245 if (clist1 != 0) 1246 clist = clist1; 1247 else if (clist2 != 0) 1248 clist = clist2; 1249 else 1250 return 0; 1251 1252 again: 1253 for (cl = clist; cl->keyword != 0; cl++) { 1254 /* do a first character check, for efficiency */ 1255 if (*str != *(cl->keyword)) 1256 continue; 1257 if (strncmp(str, cl->keyword, (unsigned)clen) == 0) { 1258 /* 1259 * Could be extact match, could be approximate. 1260 * Is exact if the length of the keyword is the 1261 * same as the str. 1262 */ 1263 if (*((cl->keyword) + clen) == '\0') { 1264 *cmd = cl; 1265 return 1; 1266 } 1267 nmatch++; 1268 nearmatch = cl; 1269 } 1270 } 1271 1272 /* 1273 * See if there is more to do. If so, go again. Sorry about the 1274 * goto, too much looking at BSD sources... 1275 */ 1276 if (clist == clist1 && clist2 != 0) { 1277 clist = clist2; 1278 goto again; 1279 } 1280 1281 /* 1282 * If we got extactly 1 near match, use it, else return number 1283 * of matches. 1284 */ 1285 if (nmatch == 1) { 1286 *cmd = nearmatch; 1287 return 1; 1288 } 1289 return nmatch; 1290 } 1291 1292 1293 /* 1294 * getarg - interpret an argument token 1295 * 1296 * return: 0 - failure 1297 * 1 - success 1298 * -1 - skip to next token 1299 */ 1300 static int 1301 getarg( 1302 char *str, 1303 int code, 1304 arg_v *argp 1305 ) 1306 { 1307 int isneg; 1308 char *cp, *np; 1309 static const char *digits = "0123456789"; 1310 1311 switch (code & ~OPT) { 1312 case NTP_STR: 1313 argp->string = str; 1314 break; 1315 case ADD: 1316 if (!strcmp("-6", str)) { 1317 ai_fam_templ = AF_INET6; 1318 return -1; 1319 } else if (!strcmp("-4", str)) { 1320 ai_fam_templ = AF_INET; 1321 return -1; 1322 } 1323 if (!getnetnum(str, &(argp->netnum), (char *)0, 0)) { 1324 return 0; 1325 } 1326 break; 1327 case INT: 1328 case UINT: 1329 isneg = 0; 1330 np = str; 1331 if (*np == '-') { 1332 np++; 1333 isneg = 1; 1334 } 1335 1336 argp->uval = 0; 1337 do { 1338 cp = strchr(digits, *np); 1339 if (cp == NULL) { 1340 (void) fprintf(stderr, 1341 "***Illegal integer value %s\n", str); 1342 return 0; 1343 } 1344 argp->uval *= 10; 1345 argp->uval += (cp - digits); 1346 } while (*(++np) != '\0'); 1347 1348 if (isneg) { 1349 if ((code & ~OPT) == UINT) { 1350 (void) fprintf(stderr, 1351 "***Value %s should be unsigned\n", str); 1352 return 0; 1353 } 1354 argp->ival = -argp->ival; 1355 } 1356 break; 1357 case IP_VERSION: 1358 if (!strcmp("-6", str)) 1359 argp->ival = 6 ; 1360 else if (!strcmp("-4", str)) 1361 argp->ival = 4 ; 1362 else { 1363 (void) fprintf(stderr, 1364 "***Version must be either 4 or 6\n"); 1365 return 0; 1366 } 1367 break; 1368 } 1369 1370 return 1; 1371 } 1372 1373 1374 /* 1375 * getnetnum - given a host name, return its net number 1376 * and (optional) full name 1377 */ 1378 static int 1379 getnetnum( 1380 const char *hname, 1381 struct sockaddr_storage *num, 1382 char *fullhost, 1383 int af 1384 ) 1385 { 1386 int err; 1387 int sockaddr_len; 1388 struct addrinfo hints, *ai = NULL; 1389 1390 sockaddr_len = (af == AF_INET) 1391 ? sizeof(struct sockaddr_in) 1392 : sizeof(struct sockaddr_in6); 1393 memset((char *)&hints, 0, sizeof(struct addrinfo)); 1394 hints.ai_flags = AI_CANONNAME; 1395 #ifdef AI_ADDRCONFIG 1396 hints.ai_flags |= AI_ADDRCONFIG; 1397 #endif 1398 1399 /* decodenetnum only works with addresses */ 1400 if (decodenetnum(hname, num)) { 1401 if (fullhost != 0) { 1402 getnameinfo((struct sockaddr *)num, sockaddr_len, 1403 fullhost, sizeof(fullhost), NULL, 0, 1404 NI_NUMERICHOST); 1405 } 1406 return 1; 1407 } else if ((err = getaddrinfo(hname, "ntp", &hints, &ai)) == 0) { 1408 memmove((char *)num, ai->ai_addr, ai->ai_addrlen); 1409 if (fullhost != 0) 1410 (void) strcpy(fullhost, ai->ai_canonname); 1411 return 1; 1412 } else { 1413 (void) fprintf(stderr, "***Can't find host %s\n", hname); 1414 return 0; 1415 } 1416 /*NOTREACHED*/ 1417 } 1418 1419 /* 1420 * nntohost - convert network number to host name. This routine enforces 1421 * the showhostnames setting. 1422 */ 1423 char * 1424 nntohost( 1425 struct sockaddr_storage *netnum 1426 ) 1427 { 1428 if (!showhostnames) 1429 return stoa(netnum); 1430 1431 if ((netnum->ss_family == AF_INET) && ISREFCLOCKADR(netnum)) 1432 return refnumtoa(netnum); 1433 return socktohost(netnum); 1434 } 1435 1436 1437 /* 1438 * Finally, the built in command handlers 1439 */ 1440 1441 /* 1442 * help - tell about commands, or details of a particular command 1443 */ 1444 static void 1445 help( 1446 struct parse *pcmd, 1447 FILE *fp 1448 ) 1449 { 1450 int i; 1451 int n; 1452 struct xcmd *xcp; 1453 char *cmd; 1454 const char *cmdsort[100]; 1455 int length[100]; 1456 int maxlength; 1457 int numperline; 1458 static const char *spaces = " "; /* 20 spaces */ 1459 1460 if (pcmd->nargs == 0) { 1461 n = 0; 1462 for (xcp = builtins; xcp->keyword != 0; xcp++) { 1463 if (*(xcp->keyword) != '?') 1464 cmdsort[n++] = xcp->keyword; 1465 } 1466 for (xcp = opcmds; xcp->keyword != 0; xcp++) 1467 cmdsort[n++] = xcp->keyword; 1468 1469 #ifdef QSORT_USES_VOID_P 1470 qsort(cmdsort, (size_t)n, sizeof(char *), helpsort); 1471 #else 1472 qsort((char *)cmdsort, (size_t)n, sizeof(char *), helpsort); 1473 #endif 1474 1475 maxlength = 0; 1476 for (i = 0; i < n; i++) { 1477 length[i] = strlen(cmdsort[i]); 1478 if (length[i] > maxlength) 1479 maxlength = length[i]; 1480 } 1481 maxlength++; 1482 numperline = 76 / maxlength; 1483 1484 (void) fprintf(fp, "Commands available:\n"); 1485 for (i = 0; i < n; i++) { 1486 if ((i % numperline) == (numperline-1) 1487 || i == (n-1)) 1488 (void) fprintf(fp, "%s\n", cmdsort[i]); 1489 else 1490 (void) fprintf(fp, "%s%s", cmdsort[i], 1491 spaces+20-maxlength+length[i]); 1492 } 1493 } else { 1494 cmd = pcmd->argval[0].string; 1495 n = findcmd(cmd, builtins, opcmds, &xcp); 1496 if (n == 0) { 1497 (void) fprintf(stderr, 1498 "Command `%s' is unknown\n", cmd); 1499 return; 1500 } else if (n >= 2) { 1501 (void) fprintf(stderr, 1502 "Command `%s' is ambiguous\n", cmd); 1503 return; 1504 } 1505 (void) fprintf(fp, "function: %s\n", xcp->comment); 1506 printusage(xcp, fp); 1507 } 1508 } 1509 1510 1511 /* 1512 * helpsort - do hostname qsort comparisons 1513 */ 1514 #ifdef QSORT_USES_VOID_P 1515 static int 1516 helpsort( 1517 const void *t1, 1518 const void *t2 1519 ) 1520 { 1521 char const * const * name1 = (char const * const *)t1; 1522 char const * const * name2 = (char const * const *)t2; 1523 1524 return strcmp(*name1, *name2); 1525 } 1526 #else 1527 static int 1528 helpsort( 1529 char **name1, 1530 char **name2 1531 ) 1532 { 1533 return strcmp(*name1, *name2); 1534 } 1535 #endif 1536 1537 1538 /* 1539 * printusage - print usage information for a command 1540 */ 1541 static void 1542 printusage( 1543 struct xcmd *xcp, 1544 FILE *fp 1545 ) 1546 { 1547 int i, opt46; 1548 1549 opt46 = 0; 1550 (void) fprintf(fp, "usage: %s", xcp->keyword); 1551 for (i = 0; i < MAXARGS && xcp->arg[i] != NO; i++) { 1552 if (opt46 == 0 && (xcp->arg[i] & ~OPT) == ADD) { 1553 (void) fprintf(fp, " [ -4|-6 ]"); 1554 opt46 = 1; 1555 } 1556 if (xcp->arg[i] & OPT) 1557 (void) fprintf(fp, " [ %s ]", xcp->desc[i]); 1558 else 1559 (void) fprintf(fp, " %s", xcp->desc[i]); 1560 } 1561 (void) fprintf(fp, "\n"); 1562 } 1563 1564 1565 /* 1566 * timeout - set time out time 1567 */ 1568 static void 1569 timeout( 1570 struct parse *pcmd, 1571 FILE *fp 1572 ) 1573 { 1574 int val; 1575 1576 if (pcmd->nargs == 0) { 1577 val = tvout.tv_sec * 1000 + tvout.tv_usec / 1000; 1578 (void) fprintf(fp, "primary timeout %d ms\n", val); 1579 } else { 1580 tvout.tv_sec = pcmd->argval[0].uval / 1000; 1581 tvout.tv_usec = (pcmd->argval[0].uval - (tvout.tv_sec * 1000)) 1582 * 1000; 1583 } 1584 } 1585 1586 1587 /* 1588 * my_delay - set delay for auth requests 1589 */ 1590 static void 1591 my_delay( 1592 struct parse *pcmd, 1593 FILE *fp 1594 ) 1595 { 1596 int isneg; 1597 u_long val; 1598 1599 if (pcmd->nargs == 0) { 1600 val = delay_time.l_ui * 1000 + delay_time.l_uf / 4294967; 1601 (void) fprintf(fp, "delay %lu ms\n", val); 1602 } else { 1603 if (pcmd->argval[0].ival < 0) { 1604 isneg = 1; 1605 val = (u_long)(-pcmd->argval[0].ival); 1606 } else { 1607 isneg = 0; 1608 val = (u_long)pcmd->argval[0].ival; 1609 } 1610 1611 delay_time.l_ui = val / 1000; 1612 val %= 1000; 1613 delay_time.l_uf = val * 4294967; /* 2**32/1000 */ 1614 1615 if (isneg) 1616 L_NEG(&delay_time); 1617 } 1618 } 1619 1620 1621 /* 1622 * host - set the host we are dealing with. 1623 */ 1624 static void 1625 host( 1626 struct parse *pcmd, 1627 FILE *fp 1628 ) 1629 { 1630 int i; 1631 1632 if (pcmd->nargs == 0) { 1633 if (havehost) 1634 (void) fprintf(fp, "current host is %s\n", currenthost); 1635 else 1636 (void) fprintf(fp, "no current host\n"); 1637 return; 1638 } 1639 1640 i = 0; 1641 if (pcmd->nargs == 2) { 1642 if (!strcmp("-4", pcmd->argval[i].string)) 1643 ai_fam_templ = AF_INET; 1644 else if (!strcmp("-6", pcmd->argval[i].string)) 1645 ai_fam_templ = AF_INET6; 1646 else { 1647 if (havehost) 1648 (void) fprintf(fp, 1649 "current host remains %s\n", currenthost); 1650 else 1651 (void) fprintf(fp, "still no current host\n"); 1652 return; 1653 } 1654 i = 1; 1655 } 1656 if (openhost(pcmd->argval[i].string)) { 1657 (void) fprintf(fp, "current host set to %s\n", currenthost); 1658 } else { 1659 if (havehost) 1660 (void) fprintf(fp, 1661 "current host remains %s\n", currenthost); 1662 else 1663 (void) fprintf(fp, "still no current host\n"); 1664 } 1665 } 1666 1667 1668 /* 1669 * keyid - get a keyid to use for authenticating requests 1670 */ 1671 static void 1672 keyid( 1673 struct parse *pcmd, 1674 FILE *fp 1675 ) 1676 { 1677 if (pcmd->nargs == 0) { 1678 if (info_auth_keyid == 0) 1679 (void) fprintf(fp, "no keyid defined\n"); 1680 else 1681 (void) fprintf(fp, "keyid is %lu\n", (u_long)info_auth_keyid); 1682 } else { 1683 info_auth_keyid = pcmd->argval[0].uval; 1684 } 1685 } 1686 1687 1688 /* 1689 * keytype - get type of key to use for authenticating requests 1690 */ 1691 static void 1692 keytype( 1693 struct parse *pcmd, 1694 FILE *fp 1695 ) 1696 { 1697 if (pcmd->nargs == 0) 1698 fprintf(fp, "keytype is %s\n", 1699 (info_auth_keytype == KEY_TYPE_MD5) ? "MD5" : "???"); 1700 else 1701 switch (*(pcmd->argval[0].string)) { 1702 case 'm': 1703 case 'M': 1704 info_auth_keytype = KEY_TYPE_MD5; 1705 break; 1706 1707 default: 1708 fprintf(fp, "keytype must be 'md5'\n"); 1709 } 1710 } 1711 1712 1713 1714 /* 1715 * passwd - get an authentication key 1716 */ 1717 /*ARGSUSED*/ 1718 static void 1719 passwd( 1720 struct parse *pcmd, 1721 FILE *fp 1722 ) 1723 { 1724 char *pass; 1725 1726 if (info_auth_keyid == 0) { 1727 info_auth_keyid = getkeyid("Keyid: "); 1728 if (info_auth_keyid == 0) { 1729 (void)fprintf(fp, "Keyid must be defined\n"); 1730 return; 1731 } 1732 } 1733 if (!interactive) { 1734 authusekey(info_auth_keyid, info_auth_keytype, 1735 (u_char *)pcmd->argval[0].string); 1736 authtrust(info_auth_keyid, 1); 1737 } else { 1738 pass = getpass("MD5 Password: "); 1739 if (*pass == '\0') 1740 (void) fprintf(fp, "Password unchanged\n"); 1741 else { 1742 authusekey(info_auth_keyid, info_auth_keytype, 1743 (u_char *)pass); 1744 authtrust(info_auth_keyid, 1); 1745 } 1746 } 1747 } 1748 1749 1750 /* 1751 * hostnames - set the showhostnames flag 1752 */ 1753 static void 1754 hostnames( 1755 struct parse *pcmd, 1756 FILE *fp 1757 ) 1758 { 1759 if (pcmd->nargs == 0) { 1760 if (showhostnames) 1761 (void) fprintf(fp, "hostnames being shown\n"); 1762 else 1763 (void) fprintf(fp, "hostnames not being shown\n"); 1764 } else { 1765 if (STREQ(pcmd->argval[0].string, "yes")) 1766 showhostnames = 1; 1767 else if (STREQ(pcmd->argval[0].string, "no")) 1768 showhostnames = 0; 1769 else 1770 (void)fprintf(stderr, "What?\n"); 1771 } 1772 } 1773 1774 1775 /* 1776 * setdebug - set/change debugging level 1777 */ 1778 static void 1779 setdebug( 1780 struct parse *pcmd, 1781 FILE *fp 1782 ) 1783 { 1784 if (pcmd->nargs == 0) { 1785 (void) fprintf(fp, "debug level is %d\n", debug); 1786 return; 1787 } else if (STREQ(pcmd->argval[0].string, "no")) { 1788 debug = 0; 1789 } else if (STREQ(pcmd->argval[0].string, "more")) { 1790 debug++; 1791 } else if (STREQ(pcmd->argval[0].string, "less")) { 1792 debug--; 1793 } else { 1794 (void) fprintf(fp, "What?\n"); 1795 return; 1796 } 1797 (void) fprintf(fp, "debug level set to %d\n", debug); 1798 } 1799 1800 1801 /* 1802 * quit - stop this nonsense 1803 */ 1804 /*ARGSUSED*/ 1805 static void 1806 quit( 1807 struct parse *pcmd, 1808 FILE *fp 1809 ) 1810 { 1811 if (havehost) 1812 closesocket(sockfd); 1813 exit(0); 1814 } 1815 1816 1817 /* 1818 * version - print the current version number 1819 */ 1820 /*ARGSUSED*/ 1821 static void 1822 version( 1823 struct parse *pcmd, 1824 FILE *fp 1825 ) 1826 { 1827 1828 (void) fprintf(fp, "%s\n", Version); 1829 return; 1830 } 1831 1832 1833 /* 1834 * warning - print a warning message 1835 */ 1836 static void 1837 warning( 1838 const char *fmt, 1839 const char *st1, 1840 const char *st2 1841 ) 1842 { 1843 (void) fprintf(stderr, "%s: ", progname); 1844 (void) fprintf(stderr, fmt, st1, st2); 1845 (void) fprintf(stderr, ": "); 1846 perror(""); 1847 } 1848 1849 1850 /* 1851 * error - print a message and exit 1852 */ 1853 static void 1854 error( 1855 const char *fmt, 1856 const char *st1, 1857 const char *st2 1858 ) 1859 { 1860 warning(fmt, st1, st2); 1861 exit(1); 1862 } 1863 1864 /* 1865 * getkeyid - prompt the user for a keyid to use 1866 */ 1867 static u_long 1868 getkeyid( 1869 const char *keyprompt 1870 ) 1871 { 1872 register char *p; 1873 register int c; 1874 FILE *fi; 1875 char pbuf[20]; 1876 1877 #ifndef SYS_WINNT 1878 if ((fi = fdopen(open("/dev/tty", 2), "r")) == NULL) 1879 #else 1880 if ((fi = _fdopen((int)GetStdHandle(STD_INPUT_HANDLE), "r")) == NULL) 1881 #endif /* SYS_WINNT */ 1882 fi = stdin; 1883 else 1884 setbuf(fi, (char *)NULL); 1885 fprintf(stderr, "%s", keyprompt); fflush(stderr); 1886 for (p=pbuf; (c = getc(fi))!='\n' && c!=EOF;) { 1887 if (p < &pbuf[18]) 1888 *p++ = (char) c; 1889 } 1890 *p = '\0'; 1891 if (fi != stdin) 1892 fclose(fi); 1893 return (u_int32)atoi(pbuf); 1894 } 1895