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