2000 lines
42 KiB
C
2000 lines
42 KiB
C
/*
|
|
* ntpdc - control and monitor your ntpd daemon
|
|
*/
|
|
|
|
#include <stdio.h>
|
|
|
|
#include <ctype.h>
|
|
#include <signal.h>
|
|
#include <setjmp.h>
|
|
|
|
#include "ntpdc.h"
|
|
#include "ntp_select.h"
|
|
#include "ntp_io.h"
|
|
#include "ntp_stdlib.h"
|
|
/* Don't include ISC's version of IPv6 variables and structures */
|
|
#define ISC_IPV6_H 1
|
|
#include "isc/net.h"
|
|
#include "isc/result.h"
|
|
|
|
#include "ntpdc-opts.h"
|
|
|
|
#ifdef SYS_WINNT
|
|
# include <Mswsock.h>
|
|
# include <io.h>
|
|
#else
|
|
# define closesocket close
|
|
#endif /* SYS_WINNT */
|
|
|
|
#if defined(HAVE_LIBREADLINE) || defined (HAVE_LIBEDIT)
|
|
# include <readline/readline.h>
|
|
# include <readline/history.h>
|
|
#endif /* HAVE_LIBREADLINE || HAVE_LIBEDIT */
|
|
|
|
#ifdef SYS_VXWORKS
|
|
/* vxWorks needs mode flag -casey*/
|
|
# define open(name, flags) open(name, flags, 0777)
|
|
# define SERVER_PORT_NUM 123
|
|
#endif
|
|
|
|
/* We use COMMAND as an autogen keyword */
|
|
#ifdef COMMAND
|
|
# undef COMMAND
|
|
#endif
|
|
|
|
/*
|
|
* Because we now potentially understand a lot of commands (and
|
|
* it requires a lot of commands to talk to ntpd) we will run
|
|
* interactive if connected to a terminal.
|
|
*/
|
|
static int interactive = 0; /* set to 1 when we should prompt */
|
|
static const char * prompt = "ntpdc> "; /* prompt to ask him about */
|
|
|
|
/*
|
|
* Keyid used for authenticated requests. Obtained on the fly.
|
|
*/
|
|
static u_long info_auth_keyid;
|
|
static int keyid_entered = 0;
|
|
|
|
/*
|
|
* Type of key md5
|
|
*/
|
|
#define KEY_TYPE_MD5 4
|
|
|
|
static int info_auth_keytype = KEY_TYPE_MD5; /* MD5 */
|
|
u_long current_time; /* needed by authkeys; not used */
|
|
|
|
/*
|
|
* for get_systime()
|
|
*/
|
|
s_char sys_precision; /* local clock precision (log2 s) */
|
|
|
|
int ntpdcmain P((int, char **));
|
|
/*
|
|
* Built in command handler declarations
|
|
*/
|
|
static int openhost P((const char *));
|
|
static int sendpkt P((char *, int));
|
|
static void growpktdata P((void));
|
|
static int getresponse P((int, int, int *, int *, char **, int));
|
|
static int sendrequest P((int, int, int, int, int, char *));
|
|
static void getcmds P((void));
|
|
static RETSIGTYPE abortcmd P((int));
|
|
static void docmd P((const char *));
|
|
static void tokenize P((const char *, char **, int *));
|
|
static int findcmd P((char *, struct xcmd *, struct xcmd *, struct xcmd **));
|
|
static int getarg P((char *, int, arg_v *));
|
|
static int getnetnum P((const char *, struct sockaddr_storage *, char *, int));
|
|
static void help P((struct parse *, FILE *));
|
|
#ifdef QSORT_USES_VOID_P
|
|
static int helpsort P((const void *, const void *));
|
|
#else
|
|
static int helpsort P((char **, char **));
|
|
#endif
|
|
static void printusage P((struct xcmd *, FILE *));
|
|
static void timeout P((struct parse *, FILE *));
|
|
static void my_delay P((struct parse *, FILE *));
|
|
static void host P((struct parse *, FILE *));
|
|
static void keyid P((struct parse *, FILE *));
|
|
static void keytype P((struct parse *, FILE *));
|
|
static void passwd P((struct parse *, FILE *));
|
|
static void hostnames P((struct parse *, FILE *));
|
|
static void setdebug P((struct parse *, FILE *));
|
|
static void quit P((struct parse *, FILE *));
|
|
static void version P((struct parse *, FILE *));
|
|
static void warning P((const char *, const char *, const char *));
|
|
static void error P((const char *, const char *, const char *));
|
|
static u_long getkeyid P((const char *));
|
|
|
|
|
|
|
|
/*
|
|
* Built-in commands we understand
|
|
*/
|
|
static struct xcmd builtins[] = {
|
|
{ "?", help, { OPT|NTP_STR, NO, NO, NO },
|
|
{ "command", "", "", "" },
|
|
"tell the use and syntax of commands" },
|
|
{ "help", help, { OPT|NTP_STR, NO, NO, NO },
|
|
{ "command", "", "", "" },
|
|
"tell the use and syntax of commands" },
|
|
{ "timeout", timeout, { OPT|NTP_UINT, NO, NO, NO },
|
|
{ "msec", "", "", "" },
|
|
"set the primary receive time out" },
|
|
{ "delay", my_delay, { OPT|NTP_INT, NO, NO, NO },
|
|
{ "msec", "", "", "" },
|
|
"set the delay added to encryption time stamps" },
|
|
{ "host", host, { OPT|NTP_STR, OPT|NTP_STR, NO, NO },
|
|
{ "-4|-6", "hostname", "", "" },
|
|
"specify the host whose NTP server we talk to" },
|
|
{ "passwd", passwd, { OPT|NTP_STR, NO, NO, NO },
|
|
{ "", "", "", "" },
|
|
"specify a password to use for authenticated requests"},
|
|
{ "hostnames", hostnames, { OPT|NTP_STR, NO, NO, NO },
|
|
{ "yes|no", "", "", "" },
|
|
"specify whether hostnames or net numbers are printed"},
|
|
{ "debug", setdebug, { OPT|NTP_STR, NO, NO, NO },
|
|
{ "no|more|less", "", "", "" },
|
|
"set/change debugging level" },
|
|
{ "quit", quit, { NO, NO, NO, NO },
|
|
{ "", "", "", "" },
|
|
"exit ntpdc" },
|
|
{ "exit", quit, { NO, NO, NO, NO },
|
|
{ "", "", "", "" },
|
|
"exit ntpdc" },
|
|
{ "keyid", keyid, { OPT|NTP_UINT, NO, NO, NO },
|
|
{ "key#", "", "", "" },
|
|
"set/show keyid to use for authenticated requests" },
|
|
{ "keytype", keytype, { OPT|NTP_STR, NO, NO, NO },
|
|
{ "(md5|des)", "", "", "" },
|
|
"set/show key authentication type for authenticated requests (des|md5)" },
|
|
{ "version", version, { NO, NO, NO, NO },
|
|
{ "", "", "", "" },
|
|
"print version number" },
|
|
{ 0, 0, { NO, NO, NO, NO },
|
|
{ "", "", "", "" }, "" }
|
|
};
|
|
|
|
|
|
/*
|
|
* Default values we use.
|
|
*/
|
|
#define DEFTIMEOUT (5) /* 5 second time out */
|
|
#define DEFSTIMEOUT (2) /* 2 second time out after first */
|
|
#define DEFDELAY 0x51EB852 /* 20 milliseconds, l_fp fraction */
|
|
#define DEFHOST "localhost" /* default host name */
|
|
#define LENHOSTNAME 256 /* host name is 256 characters long */
|
|
#define MAXCMDS 100 /* maximum commands on cmd line */
|
|
#define MAXHOSTS 200 /* maximum hosts on cmd line */
|
|
#define MAXLINE 512 /* maximum line length */
|
|
#define MAXTOKENS (1+1+MAXARGS+MOREARGS+2) /* maximum number of usable tokens */
|
|
#define SCREENWIDTH 78 /* nominal screen width in columns */
|
|
|
|
/*
|
|
* Some variables used and manipulated locally
|
|
*/
|
|
static struct timeval tvout = { DEFTIMEOUT, 0 }; /* time out for reads */
|
|
static struct timeval tvsout = { DEFSTIMEOUT, 0 }; /* secondary time out */
|
|
static l_fp delay_time; /* delay time */
|
|
static char currenthost[LENHOSTNAME]; /* current host name */
|
|
int showhostnames = 1; /* show host names by default */
|
|
|
|
static int ai_fam_templ; /* address family */
|
|
static int ai_fam_default; /* default address family */
|
|
static SOCKET sockfd; /* fd socket is opened on */
|
|
static int havehost = 0; /* set to 1 when host open */
|
|
int s_port = 0;
|
|
|
|
#if defined (SYS_WINNT) || defined (SYS_VXWORKS)
|
|
char password[9];
|
|
#endif /* SYS_WINNT || SYS_VXWORKS */
|
|
|
|
#ifdef SYS_WINNT
|
|
DWORD NumberOfBytesWritten;
|
|
|
|
HANDLE TimerThreadHandle = NULL; /* 1998/06/03 - Used in ntplib/machines.c */
|
|
void timer(void) { ; }; /* 1998/06/03 - Used in ntplib/machines.c */
|
|
|
|
#endif /* SYS_WINNT */
|
|
|
|
/*
|
|
* Holds data returned from queries. We allocate INITDATASIZE
|
|
* octets to begin with, increasing this as we need to.
|
|
*/
|
|
#define INITDATASIZE (sizeof(struct resp_pkt) * 16)
|
|
#define INCDATASIZE (sizeof(struct resp_pkt) * 8)
|
|
|
|
static char *pktdata;
|
|
static int pktdatasize;
|
|
|
|
/*
|
|
* These are used to help the magic with old and new versions of ntpd.
|
|
*/
|
|
int impl_ver = IMPL_XNTPD;
|
|
static int req_pkt_size = REQ_LEN_NOMAC;
|
|
|
|
/*
|
|
* For commands typed on the command line (with the -c option)
|
|
*/
|
|
static int numcmds = 0;
|
|
static const char *ccmds[MAXCMDS];
|
|
#define ADDCMD(cp) if (numcmds < MAXCMDS) ccmds[numcmds++] = (cp)
|
|
|
|
/*
|
|
* When multiple hosts are specified.
|
|
*/
|
|
static int numhosts = 0;
|
|
static const char *chosts[MAXHOSTS];
|
|
#define ADDHOST(cp) if (numhosts < MAXHOSTS) chosts[numhosts++] = (cp)
|
|
|
|
/*
|
|
* Error codes for internal use
|
|
*/
|
|
#define ERR_INCOMPLETE 16
|
|
#define ERR_TIMEOUT 17
|
|
|
|
/*
|
|
* Macro definitions we use
|
|
*/
|
|
#define ISSPACE(c) ((c) == ' ' || (c) == '\t')
|
|
#define ISEOL(c) ((c) == '\n' || (c) == '\r' || (c) == '\0')
|
|
#define STREQ(a, b) (*(a) == *(b) && strcmp((a), (b)) == 0)
|
|
|
|
/*
|
|
* For converting time stamps to dates
|
|
*/
|
|
#define JAN_1970 2208988800 /* 1970 - 1900 in seconds */
|
|
|
|
/*
|
|
* Jump buffer for longjumping back to the command level
|
|
*/
|
|
static jmp_buf interrupt_buf;
|
|
static volatile int jump = 0;
|
|
|
|
/*
|
|
* Pointer to current output unit
|
|
*/
|
|
static FILE *current_output;
|
|
|
|
/*
|
|
* Command table imported from ntpdc_ops.c
|
|
*/
|
|
extern struct xcmd opcmds[];
|
|
|
|
char *progname;
|
|
volatile int debug;
|
|
|
|
#ifdef NO_MAIN_ALLOWED
|
|
CALL(ntpdc,"ntpdc",ntpdcmain);
|
|
#else
|
|
int
|
|
main(
|
|
int argc,
|
|
char *argv[]
|
|
)
|
|
{
|
|
return ntpdcmain(argc, argv);
|
|
}
|
|
#endif
|
|
|
|
#ifdef SYS_VXWORKS
|
|
void clear_globals(void)
|
|
{
|
|
showhostnames = 0; /* show host names by default */
|
|
havehost = 0; /* set to 1 when host open */
|
|
numcmds = 0;
|
|
numhosts = 0;
|
|
}
|
|
#endif
|
|
|
|
/*
|
|
* main - parse arguments and handle options
|
|
*/
|
|
int
|
|
ntpdcmain(
|
|
int argc,
|
|
char *argv[]
|
|
)
|
|
{
|
|
extern int ntp_optind;
|
|
|
|
delay_time.l_ui = 0;
|
|
delay_time.l_uf = DEFDELAY;
|
|
|
|
#ifdef SYS_VXWORKS
|
|
clear_globals();
|
|
taskPrioritySet(taskIdSelf(), 100 );
|
|
#endif
|
|
|
|
#ifdef SYS_WINNT
|
|
if (!Win32InitSockets())
|
|
{
|
|
fprintf(stderr, "No useable winsock.dll:");
|
|
exit(1);
|
|
}
|
|
#endif /* SYS_WINNT */
|
|
|
|
/* Check to see if we have IPv6. Otherwise force the -4 flag */
|
|
if (isc_net_probeipv6() != ISC_R_SUCCESS) {
|
|
ai_fam_default = AF_INET;
|
|
}
|
|
|
|
progname = argv[0];
|
|
|
|
{
|
|
int optct = optionProcess(&ntpdcOptions, argc, argv);
|
|
argc -= optct;
|
|
argv += optct;
|
|
}
|
|
|
|
switch (WHICH_IDX_IPV4) {
|
|
case INDEX_OPT_IPV4:
|
|
ai_fam_templ = AF_INET;
|
|
break;
|
|
case INDEX_OPT_IPV6:
|
|
ai_fam_templ = AF_INET6;
|
|
break;
|
|
default:
|
|
ai_fam_templ = ai_fam_default;
|
|
break;
|
|
}
|
|
|
|
if (HAVE_OPT(COMMAND)) {
|
|
int cmdct = STACKCT_OPT( COMMAND );
|
|
const char** cmds = STACKLST_OPT( COMMAND );
|
|
|
|
while (cmdct-- > 0) {
|
|
ADDCMD(*cmds++);
|
|
}
|
|
}
|
|
|
|
debug = DESC(DEBUG_LEVEL).optOccCt;
|
|
|
|
if (HAVE_OPT(INTERACTIVE)) {
|
|
interactive = 1;
|
|
}
|
|
|
|
if (HAVE_OPT(NUMERIC)) {
|
|
showhostnames = 0;
|
|
}
|
|
|
|
if (HAVE_OPT(LISTPEERS)) {
|
|
ADDCMD("listpeers");
|
|
}
|
|
|
|
if (HAVE_OPT(PEERS)) {
|
|
ADDCMD("peers");
|
|
}
|
|
|
|
if (HAVE_OPT(SHOWPEERS)) {
|
|
ADDCMD("dmpeers");
|
|
}
|
|
|
|
if (ntp_optind == argc) {
|
|
ADDHOST(DEFHOST);
|
|
} else {
|
|
for (; ntp_optind < argc; ntp_optind++)
|
|
ADDHOST(argv[ntp_optind]);
|
|
}
|
|
|
|
if (numcmds == 0 && interactive == 0
|
|
&& isatty(fileno(stdin)) && isatty(fileno(stderr))) {
|
|
interactive = 1;
|
|
}
|
|
|
|
#if 0
|
|
ai_fam_templ = ai_fam_default;
|
|
while ((c = ntp_getopt(argc, argv, "46c:dilnps")) != EOF)
|
|
switch (c) {
|
|
case '4':
|
|
ai_fam_templ = AF_INET;
|
|
break;
|
|
case '6':
|
|
ai_fam_templ = AF_INET6;
|
|
break;
|
|
case 'c':
|
|
ADDCMD(ntp_optarg);
|
|
break;
|
|
case 'd':
|
|
++debug;
|
|
break;
|
|
case 'i':
|
|
interactive = 1;
|
|
break;
|
|
case 'l':
|
|
ADDCMD("listpeers");
|
|
break;
|
|
case 'n':
|
|
showhostnames = 0;
|
|
break;
|
|
case 'p':
|
|
ADDCMD("peers");
|
|
break;
|
|
case 's':
|
|
ADDCMD("dmpeers");
|
|
break;
|
|
default:
|
|
errflg++;
|
|
break;
|
|
}
|
|
|
|
if (errflg) {
|
|
(void) fprintf(stderr,
|
|
"usage: %s [-46dilnps] [-c cmd] host ...\n",
|
|
progname);
|
|
exit(2);
|
|
}
|
|
|
|
if (ntp_optind == argc) {
|
|
ADDHOST(DEFHOST);
|
|
} else {
|
|
for (; ntp_optind < argc; ntp_optind++)
|
|
ADDHOST(argv[ntp_optind]);
|
|
}
|
|
|
|
if (numcmds == 0 && interactive == 0
|
|
&& isatty(fileno(stdin)) && isatty(fileno(stderr))) {
|
|
interactive = 1;
|
|
}
|
|
#endif
|
|
|
|
#ifndef SYS_WINNT /* Under NT cannot handle SIGINT, WIN32 spawns a handler */
|
|
if (interactive)
|
|
(void) signal_no_reset(SIGINT, abortcmd);
|
|
#endif /* SYS_WINNT */
|
|
|
|
/*
|
|
* Initialize the packet data buffer
|
|
*/
|
|
pktdata = (char *)malloc(INITDATASIZE);
|
|
if (pktdata == NULL) {
|
|
(void) fprintf(stderr, "%s: malloc() failed!\n", progname);
|
|
exit(1);
|
|
}
|
|
pktdatasize = INITDATASIZE;
|
|
|
|
if (numcmds == 0) {
|
|
(void) openhost(chosts[0]);
|
|
getcmds();
|
|
} else {
|
|
int ihost;
|
|
int icmd;
|
|
|
|
for (ihost = 0; ihost < numhosts; ihost++) {
|
|
if (openhost(chosts[ihost]))
|
|
for (icmd = 0; icmd < numcmds; icmd++) {
|
|
if (numhosts > 1)
|
|
printf ("--- %s ---\n",chosts[ihost]);
|
|
docmd(ccmds[icmd]);
|
|
}
|
|
}
|
|
}
|
|
#ifdef SYS_WINNT
|
|
WSACleanup();
|
|
#endif
|
|
return(0);
|
|
} /* main end */
|
|
|
|
|
|
/*
|
|
* openhost - open a socket to a host
|
|
*/
|
|
static int
|
|
openhost(
|
|
const char *hname
|
|
)
|
|
{
|
|
char temphost[LENHOSTNAME];
|
|
int a_info, i;
|
|
struct addrinfo hints, *ai = NULL;
|
|
register const char *cp;
|
|
char name[LENHOSTNAME];
|
|
char service[5];
|
|
|
|
/*
|
|
* We need to get by the [] if they were entered
|
|
*/
|
|
|
|
cp = hname;
|
|
|
|
if (*cp == '[') {
|
|
cp++;
|
|
for(i = 0; *cp != ']'; cp++, i++)
|
|
name[i] = *cp;
|
|
name[i] = '\0';
|
|
hname = name;
|
|
}
|
|
|
|
/*
|
|
* First try to resolve it as an ip address and if that fails,
|
|
* do a fullblown (dns) lookup. That way we only use the dns
|
|
* when it is needed and work around some implementations that
|
|
* will return an "IPv4-mapped IPv6 address" address if you
|
|
* give it an IPv4 address to lookup.
|
|
*/
|
|
strcpy(service, "ntp");
|
|
memset((char *)&hints, 0, sizeof(struct addrinfo));
|
|
hints.ai_family = ai_fam_templ;
|
|
hints.ai_protocol = IPPROTO_UDP;
|
|
hints.ai_socktype = SOCK_DGRAM;
|
|
hints.ai_flags = AI_NUMERICHOST;
|
|
|
|
a_info = getaddrinfo(hname, service, &hints, &ai);
|
|
if (a_info == EAI_NONAME
|
|
#ifdef EAI_NODATA
|
|
|| a_info == EAI_NODATA
|
|
#endif
|
|
) {
|
|
hints.ai_flags = AI_CANONNAME;
|
|
#ifdef AI_ADDRCONFIG
|
|
hints.ai_flags |= AI_ADDRCONFIG;
|
|
#endif
|
|
a_info = getaddrinfo(hname, service, &hints, &ai);
|
|
}
|
|
/* Some older implementations don't like AI_ADDRCONFIG. */
|
|
if (a_info == EAI_BADFLAGS) {
|
|
hints.ai_flags = AI_CANONNAME;
|
|
a_info = getaddrinfo(hname, service, &hints, &ai);
|
|
}
|
|
if (a_info != 0) {
|
|
(void) fprintf(stderr, "%s\n", gai_strerror(a_info));
|
|
if (ai != NULL)
|
|
freeaddrinfo(ai);
|
|
return 0;
|
|
}
|
|
|
|
if (ai->ai_canonname == NULL) {
|
|
strncpy(temphost, stoa((struct sockaddr_storage *)ai->ai_addr),
|
|
LENHOSTNAME);
|
|
temphost[LENHOSTNAME-1] = '\0';
|
|
} else {
|
|
strncpy(temphost, ai->ai_canonname, LENHOSTNAME);
|
|
temphost[LENHOSTNAME-1] = '\0';
|
|
}
|
|
|
|
if (debug > 2)
|
|
printf("Opening host %s\n", temphost);
|
|
|
|
if (havehost == 1) {
|
|
if (debug > 2)
|
|
printf("Closing old host %s\n", currenthost);
|
|
(void) closesocket(sockfd);
|
|
havehost = 0;
|
|
}
|
|
(void) strcpy(currenthost, temphost);
|
|
|
|
/* port maps to the same in both families */
|
|
s_port = ((struct sockaddr_in6 *)ai->ai_addr)->sin6_port;
|
|
#ifdef SYS_VXWORKS
|
|
((struct sockaddr_in6 *)&hostaddr)->sin6_port = htons(SERVER_PORT_NUM);
|
|
if (ai->ai_family == AF_INET)
|
|
*(struct sockaddr_in *)&hostaddr=
|
|
*((struct sockaddr_in *)ai->ai_addr);
|
|
else
|
|
*(struct sockaddr_in6 *)&hostaddr=
|
|
*((struct sockaddr_in6 *)ai->ai_addr);
|
|
#endif /* SYS_VXWORKS */
|
|
|
|
#ifdef SYS_WINNT
|
|
{
|
|
int optionValue = SO_SYNCHRONOUS_NONALERT;
|
|
int err;
|
|
|
|
err = setsockopt(INVALID_SOCKET, SOL_SOCKET, SO_OPENTYPE, (char *)&optionValue, sizeof(optionValue));
|
|
if (err != NO_ERROR) {
|
|
(void) fprintf(stderr, "cannot open nonoverlapped sockets\n");
|
|
exit(1);
|
|
}
|
|
}
|
|
|
|
sockfd = socket(ai->ai_family, SOCK_DGRAM, 0);
|
|
if (sockfd == INVALID_SOCKET) {
|
|
error("socket", "", "");
|
|
exit(-1);
|
|
}
|
|
#else
|
|
sockfd = socket(ai->ai_family, SOCK_DGRAM, 0);
|
|
if (sockfd == -1)
|
|
error("socket", "", "");
|
|
#endif /* SYS_WINNT */
|
|
|
|
|
|
#ifdef NEED_RCVBUF_SLOP
|
|
# ifdef SO_RCVBUF
|
|
{
|
|
int rbufsize = INITDATASIZE + 2048; /* 2K for slop */
|
|
|
|
if (setsockopt(sockfd, SOL_SOCKET, SO_RCVBUF,
|
|
&rbufsize, sizeof(int)) == -1)
|
|
error("setsockopt", "", "");
|
|
}
|
|
# endif
|
|
#endif
|
|
|
|
#ifdef SYS_VXWORKS
|
|
if (connect(sockfd, (struct sockaddr *)&hostaddr,
|
|
sizeof(hostaddr)) == -1)
|
|
#else
|
|
if (connect(sockfd, (struct sockaddr *)ai->ai_addr,
|
|
ai->ai_addrlen) == -1)
|
|
#endif /* SYS_VXWORKS */
|
|
error("connect", "", "");
|
|
if (ai != NULL)
|
|
freeaddrinfo(ai);
|
|
havehost = 1;
|
|
req_pkt_size = REQ_LEN_NOMAC;
|
|
impl_ver = IMPL_XNTPD;
|
|
return 1;
|
|
}
|
|
|
|
|
|
/* XXX ELIMINATE sendpkt similar in ntpq.c, ntpdc.c, ntp_io.c, ntptrace.c */
|
|
/*
|
|
* sendpkt - send a packet to the remote host
|
|
*/
|
|
static int
|
|
sendpkt(
|
|
char *xdata,
|
|
int xdatalen
|
|
)
|
|
{
|
|
if (send(sockfd, xdata, (size_t)xdatalen, 0) == -1) {
|
|
warning("write to %s failed", currenthost, "");
|
|
return -1;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
|
|
/*
|
|
* growpktdata - grow the packet data area
|
|
*/
|
|
static void
|
|
growpktdata(void)
|
|
{
|
|
pktdatasize += INCDATASIZE;
|
|
pktdata = (char *)realloc(pktdata, (unsigned)pktdatasize);
|
|
if (pktdata == 0) {
|
|
(void) fprintf(stderr, "%s: realloc() failed!\n", progname);
|
|
exit(1);
|
|
}
|
|
}
|
|
|
|
|
|
/*
|
|
* getresponse - get a (series of) response packet(s) and return the data
|
|
*/
|
|
static int
|
|
getresponse(
|
|
int implcode,
|
|
int reqcode,
|
|
int *ritems,
|
|
int *rsize,
|
|
char **rdata,
|
|
int esize
|
|
)
|
|
{
|
|
struct resp_pkt rpkt;
|
|
struct timeval tvo;
|
|
int items;
|
|
int i;
|
|
int size;
|
|
int datasize;
|
|
char *datap;
|
|
char *tmp_data;
|
|
char haveseq[MAXSEQ+1];
|
|
int firstpkt;
|
|
int lastseq;
|
|
int numrecv;
|
|
int seq;
|
|
fd_set fds;
|
|
int n;
|
|
int pad;
|
|
|
|
/*
|
|
* This is pretty tricky. We may get between 1 and many packets
|
|
* back in response to the request. We peel the data out of
|
|
* each packet and collect it in one long block. When the last
|
|
* packet in the sequence is received we'll know how many we
|
|
* should have had. Note we use one long time out, should reconsider.
|
|
*/
|
|
*ritems = 0;
|
|
*rsize = 0;
|
|
firstpkt = 1;
|
|
numrecv = 0;
|
|
*rdata = datap = pktdata;
|
|
lastseq = 999; /* too big to be a sequence number */
|
|
memset(haveseq, 0, sizeof(haveseq));
|
|
FD_ZERO(&fds);
|
|
|
|
again:
|
|
if (firstpkt)
|
|
tvo = tvout;
|
|
else
|
|
tvo = tvsout;
|
|
|
|
FD_SET(sockfd, &fds);
|
|
n = select(sockfd+1, &fds, (fd_set *)0, (fd_set *)0, &tvo);
|
|
|
|
if (n == -1) {
|
|
warning("select fails", "", "");
|
|
return -1;
|
|
}
|
|
if (n == 0) {
|
|
/*
|
|
* Timed out. Return what we have
|
|
*/
|
|
if (firstpkt) {
|
|
(void) fprintf(stderr,
|
|
"%s: timed out, nothing received\n", currenthost);
|
|
return ERR_TIMEOUT;
|
|
} else {
|
|
(void) fprintf(stderr,
|
|
"%s: timed out with incomplete data\n",
|
|
currenthost);
|
|
if (debug) {
|
|
printf("Received sequence numbers");
|
|
for (n = 0; n <= MAXSEQ; n++)
|
|
if (haveseq[n])
|
|
printf(" %d,", n);
|
|
if (lastseq != 999)
|
|
printf(" last frame received\n");
|
|
else
|
|
printf(" last frame not received\n");
|
|
}
|
|
return ERR_INCOMPLETE;
|
|
}
|
|
}
|
|
|
|
n = recv(sockfd, (char *)&rpkt, sizeof(rpkt), 0);
|
|
if (n == -1) {
|
|
warning("read", "", "");
|
|
return -1;
|
|
}
|
|
|
|
|
|
/*
|
|
* Check for format errors. Bug proofing.
|
|
*/
|
|
if (n < RESP_HEADER_SIZE) {
|
|
if (debug)
|
|
printf("Short (%d byte) packet received\n", n);
|
|
goto again;
|
|
}
|
|
if (INFO_VERSION(rpkt.rm_vn_mode) > NTP_VERSION ||
|
|
INFO_VERSION(rpkt.rm_vn_mode) < NTP_OLDVERSION) {
|
|
if (debug)
|
|
printf("Packet received with version %d\n",
|
|
INFO_VERSION(rpkt.rm_vn_mode));
|
|
goto again;
|
|
}
|
|
if (INFO_MODE(rpkt.rm_vn_mode) != MODE_PRIVATE) {
|
|
if (debug)
|
|
printf("Packet received with mode %d\n",
|
|
INFO_MODE(rpkt.rm_vn_mode));
|
|
goto again;
|
|
}
|
|
if (INFO_IS_AUTH(rpkt.auth_seq)) {
|
|
if (debug)
|
|
printf("Encrypted packet received\n");
|
|
goto again;
|
|
}
|
|
if (!ISRESPONSE(rpkt.rm_vn_mode)) {
|
|
if (debug)
|
|
printf("Received request packet, wanted response\n");
|
|
goto again;
|
|
}
|
|
if (INFO_MBZ(rpkt.mbz_itemsize) != 0) {
|
|
if (debug)
|
|
printf("Received packet with nonzero MBZ field!\n");
|
|
goto again;
|
|
}
|
|
|
|
/*
|
|
* Check implementation/request. Could be old data getting to us.
|
|
*/
|
|
if (rpkt.implementation != implcode || rpkt.request != reqcode) {
|
|
if (debug)
|
|
printf(
|
|
"Received implementation/request of %d/%d, wanted %d/%d",
|
|
rpkt.implementation, rpkt.request,
|
|
implcode, reqcode);
|
|
goto again;
|
|
}
|
|
|
|
/*
|
|
* Check the error code. If non-zero, return it.
|
|
*/
|
|
if (INFO_ERR(rpkt.err_nitems) != INFO_OKAY) {
|
|
if (debug && ISMORE(rpkt.rm_vn_mode)) {
|
|
printf("Error code %d received on not-final packet\n",
|
|
INFO_ERR(rpkt.err_nitems));
|
|
}
|
|
return (int)INFO_ERR(rpkt.err_nitems);
|
|
}
|
|
|
|
/*
|
|
* Collect items and size. Make sure they make sense.
|
|
*/
|
|
items = INFO_NITEMS(rpkt.err_nitems);
|
|
size = INFO_ITEMSIZE(rpkt.mbz_itemsize);
|
|
if (esize > size)
|
|
pad = esize - size;
|
|
else
|
|
pad = 0;
|
|
if ((datasize = items*size) > (n-RESP_HEADER_SIZE)) {
|
|
if (debug)
|
|
printf(
|
|
"Received items %d, size %d (total %d), data in packet is %d\n",
|
|
items, size, datasize, n-RESP_HEADER_SIZE);
|
|
goto again;
|
|
}
|
|
|
|
/*
|
|
* If this isn't our first packet, make sure the size matches
|
|
* the other ones.
|
|
*/
|
|
if (!firstpkt && esize != *rsize) {
|
|
if (debug)
|
|
printf("Received itemsize %d, previous %d\n",
|
|
size, *rsize);
|
|
goto again;
|
|
}
|
|
/*
|
|
* If we've received this before, +toss it
|
|
*/
|
|
seq = INFO_SEQ(rpkt.auth_seq);
|
|
if (haveseq[seq]) {
|
|
if (debug)
|
|
printf("Received duplicate sequence number %d\n", seq);
|
|
goto again;
|
|
}
|
|
haveseq[seq] = 1;
|
|
|
|
/*
|
|
* If this is the last in the sequence, record that.
|
|
*/
|
|
if (!ISMORE(rpkt.rm_vn_mode)) {
|
|
if (lastseq != 999) {
|
|
printf("Received second end sequence packet\n");
|
|
goto again;
|
|
}
|
|
lastseq = seq;
|
|
}
|
|
|
|
/*
|
|
* So far, so good. Copy this data into the output array.
|
|
*/
|
|
if ((datap + datasize + (pad * items)) > (pktdata + pktdatasize)) {
|
|
int offset = datap - pktdata;
|
|
growpktdata();
|
|
*rdata = pktdata; /* might have been realloced ! */
|
|
datap = pktdata + offset;
|
|
}
|
|
/*
|
|
* We now move the pointer along according to size and number of
|
|
* items. This is so we can play nice with older implementations
|
|
*/
|
|
|
|
tmp_data = (char *)rpkt.data;
|
|
for(i = 0; i <items; i++){
|
|
memmove(datap, tmp_data, (unsigned)size);
|
|
tmp_data += size;
|
|
memset(datap + size, 0, pad);
|
|
datap += size + pad;
|
|
}
|
|
|
|
if (firstpkt) {
|
|
firstpkt = 0;
|
|
*rsize = size + pad;
|
|
}
|
|
*ritems += items;
|
|
|
|
/*
|
|
* Finally, check the count of received packets. If we've got them
|
|
* all, return
|
|
*/
|
|
++numrecv;
|
|
if (numrecv <= lastseq)
|
|
goto again;
|
|
return INFO_OKAY;
|
|
}
|
|
|
|
|
|
/*
|
|
* sendrequest - format and send a request packet
|
|
*/
|
|
static int
|
|
sendrequest(
|
|
int implcode,
|
|
int reqcode,
|
|
int auth,
|
|
int qitems,
|
|
int qsize,
|
|
char *qdata
|
|
)
|
|
{
|
|
struct req_pkt qpkt;
|
|
int datasize;
|
|
|
|
memset((char *)&qpkt, 0, sizeof qpkt);
|
|
|
|
qpkt.rm_vn_mode = RM_VN_MODE(0, 0, 0);
|
|
qpkt.implementation = (u_char)implcode;
|
|
qpkt.request = (u_char)reqcode;
|
|
|
|
datasize = qitems * qsize;
|
|
if (datasize != 0 && qdata != NULL) {
|
|
memmove((char *)qpkt.data, qdata, (unsigned)datasize);
|
|
qpkt.err_nitems = ERR_NITEMS(0, qitems);
|
|
qpkt.mbz_itemsize = MBZ_ITEMSIZE(qsize);
|
|
} else {
|
|
qpkt.err_nitems = ERR_NITEMS(0, 0);
|
|
qpkt.mbz_itemsize = MBZ_ITEMSIZE(qsize); /* allow for optional first item */
|
|
}
|
|
|
|
if (!auth || (keyid_entered && info_auth_keyid == 0)) {
|
|
qpkt.auth_seq = AUTH_SEQ(0, 0);
|
|
return sendpkt((char *)&qpkt, req_pkt_size);
|
|
} else {
|
|
l_fp ts;
|
|
int maclen = 0;
|
|
const char *pass = "\0";
|
|
struct req_pkt_tail *qpktail;
|
|
|
|
qpktail = (struct req_pkt_tail *)((char *)&qpkt + req_pkt_size
|
|
+ MAX_MAC_LEN - sizeof(struct req_pkt_tail));
|
|
|
|
if (info_auth_keyid == 0) {
|
|
if (((struct conf_peer *)qpkt.data)->keyid > 0)
|
|
info_auth_keyid = ((struct conf_peer *)qpkt.data)->keyid;
|
|
else {
|
|
maclen = getkeyid("Keyid: ");
|
|
if (maclen == 0) {
|
|
(void) fprintf(stderr,
|
|
"Invalid key identifier\n");
|
|
return 1;
|
|
}
|
|
info_auth_keyid = maclen;
|
|
}
|
|
}
|
|
if (!authistrusted(info_auth_keyid)) {
|
|
pass = getpass("MD5 Password: ");
|
|
if (*pass == '\0') {
|
|
(void) fprintf(stderr,
|
|
"Invalid password\n");
|
|
return (1);
|
|
}
|
|
}
|
|
authusekey(info_auth_keyid, info_auth_keytype, (const u_char *)pass);
|
|
authtrust(info_auth_keyid, 1);
|
|
qpkt.auth_seq = AUTH_SEQ(1, 0);
|
|
qpktail->keyid = htonl(info_auth_keyid);
|
|
get_systime(&ts);
|
|
L_ADD(&ts, &delay_time);
|
|
HTONL_FP(&ts, &qpktail->tstamp);
|
|
maclen = authencrypt(info_auth_keyid, (u_int32 *)&qpkt,
|
|
req_pkt_size);
|
|
if (maclen == 0) {
|
|
(void) fprintf(stderr, "Key not found\n");
|
|
return (1);
|
|
}
|
|
return sendpkt((char *)&qpkt, (int)(req_pkt_size + maclen));
|
|
}
|
|
/*NOTREACHED*/
|
|
}
|
|
|
|
|
|
/*
|
|
* doquery - send a request and process the response
|
|
*/
|
|
int
|
|
doquery(
|
|
int implcode,
|
|
int reqcode,
|
|
int auth,
|
|
int qitems,
|
|
int qsize,
|
|
char *qdata,
|
|
int *ritems,
|
|
int *rsize,
|
|
char **rdata,
|
|
int quiet_mask,
|
|
int esize
|
|
)
|
|
{
|
|
int res;
|
|
char junk[512];
|
|
fd_set fds;
|
|
struct timeval tvzero;
|
|
|
|
/*
|
|
* Check to make sure host is open
|
|
*/
|
|
if (!havehost) {
|
|
(void) fprintf(stderr, "***No host open, use `host' command\n");
|
|
return -1;
|
|
}
|
|
|
|
/*
|
|
* Poll the socket and clear out any pending data
|
|
*/
|
|
again:
|
|
do {
|
|
tvzero.tv_sec = tvzero.tv_usec = 0;
|
|
FD_ZERO(&fds);
|
|
FD_SET(sockfd, &fds);
|
|
res = select(sockfd+1, &fds, (fd_set *)0, (fd_set *)0, &tvzero);
|
|
|
|
if (res == -1) {
|
|
warning("polling select", "", "");
|
|
return -1;
|
|
} else if (res > 0)
|
|
|
|
(void) recv(sockfd, junk, sizeof junk, 0);
|
|
} while (res > 0);
|
|
|
|
|
|
/*
|
|
* send a request
|
|
*/
|
|
res = sendrequest(implcode, reqcode, auth, qitems, qsize, qdata);
|
|
if (res != 0)
|
|
return res;
|
|
|
|
/*
|
|
* Get the response. If we got a standard error, print a message
|
|
*/
|
|
res = getresponse(implcode, reqcode, ritems, rsize, rdata, esize);
|
|
|
|
/*
|
|
* Try to be compatible with older implementations of ntpd.
|
|
*/
|
|
if (res == INFO_ERR_FMT && req_pkt_size != 48) {
|
|
int oldsize;
|
|
|
|
oldsize = req_pkt_size;
|
|
|
|
switch(req_pkt_size) {
|
|
case REQ_LEN_NOMAC:
|
|
req_pkt_size = 160;
|
|
break;
|
|
case 160:
|
|
req_pkt_size = 48;
|
|
break;
|
|
}
|
|
if (impl_ver == IMPL_XNTPD) {
|
|
fprintf(stderr,
|
|
"***Warning changing to older implementation\n");
|
|
return INFO_ERR_IMPL;
|
|
}
|
|
|
|
fprintf(stderr,
|
|
"***Warning changing the request packet size from %d to %d\n",
|
|
oldsize, req_pkt_size);
|
|
goto again;
|
|
}
|
|
|
|
/* log error message if not told to be quiet */
|
|
if ((res > 0) && (((1 << res) & quiet_mask) == 0)) {
|
|
switch(res) {
|
|
case INFO_ERR_IMPL:
|
|
/* Give us a chance to try the older implementation. */
|
|
if (implcode == IMPL_XNTPD)
|
|
break;
|
|
(void) fprintf(stderr,
|
|
"***Server implementation incompatable with our own\n");
|
|
break;
|
|
case INFO_ERR_REQ:
|
|
(void) fprintf(stderr,
|
|
"***Server doesn't implement this request\n");
|
|
break;
|
|
case INFO_ERR_FMT:
|
|
(void) fprintf(stderr,
|
|
"***Server reports a format error in the received packet (shouldn't happen)\n");
|
|
break;
|
|
case INFO_ERR_NODATA:
|
|
(void) fprintf(stderr,
|
|
"***Server reports data not found\n");
|
|
break;
|
|
case INFO_ERR_AUTH:
|
|
(void) fprintf(stderr, "***Permission denied\n");
|
|
break;
|
|
case ERR_TIMEOUT:
|
|
(void) fprintf(stderr, "***Request timed out\n");
|
|
break;
|
|
case ERR_INCOMPLETE:
|
|
(void) fprintf(stderr,
|
|
"***Response from server was incomplete\n");
|
|
break;
|
|
default:
|
|
(void) fprintf(stderr,
|
|
"***Server returns unknown error code %d\n", res);
|
|
break;
|
|
}
|
|
}
|
|
return res;
|
|
}
|
|
|
|
|
|
/*
|
|
* getcmds - read commands from the standard input and execute them
|
|
*/
|
|
static void
|
|
getcmds(void)
|
|
{
|
|
#if defined(HAVE_LIBREADLINE) || defined(HAVE_LIBEDIT)
|
|
char *line;
|
|
|
|
for (;;) {
|
|
if ((line = readline(interactive?prompt:"")) == NULL) return;
|
|
if (*line) add_history(line);
|
|
docmd(line);
|
|
free(line);
|
|
}
|
|
#else /* not (HAVE_LIBREADLINE || HAVE_LIBEDIT) */
|
|
char line[MAXLINE];
|
|
|
|
for (;;) {
|
|
if (interactive) {
|
|
#ifdef VMS /* work around a problem with mixing stdout & stderr */
|
|
fputs("",stdout);
|
|
#endif
|
|
(void) fputs(prompt, stderr);
|
|
(void) fflush(stderr);
|
|
}
|
|
|
|
if (fgets(line, sizeof line, stdin) == NULL)
|
|
return;
|
|
|
|
docmd(line);
|
|
}
|
|
#endif /* not HAVE_LIBREADLINE || HAVE_LIBEDIT */
|
|
}
|
|
|
|
|
|
#ifndef SYS_WINNT /* Under NT cannot handle SIGINT, WIN32 spawns a handler */
|
|
/*
|
|
* abortcmd - catch interrupts and abort the current command
|
|
*/
|
|
static RETSIGTYPE
|
|
abortcmd(
|
|
int sig
|
|
)
|
|
{
|
|
|
|
if (current_output == stdout)
|
|
(void) fflush(stdout);
|
|
putc('\n', stderr);
|
|
(void) fflush(stderr);
|
|
if (jump) longjmp(interrupt_buf, 1);
|
|
}
|
|
#endif /* SYS_WINNT */
|
|
|
|
/*
|
|
* docmd - decode the command line and execute a command
|
|
*/
|
|
static void
|
|
docmd(
|
|
const char *cmdline
|
|
)
|
|
{
|
|
char *tokens[1+MAXARGS+MOREARGS+2];
|
|
struct parse pcmd;
|
|
int ntok;
|
|
int i, ti;
|
|
int rval;
|
|
struct xcmd *xcmd;
|
|
|
|
ai_fam_templ = ai_fam_default;
|
|
/*
|
|
* Tokenize the command line. If nothing on it, return.
|
|
*/
|
|
tokenize(cmdline, tokens, &ntok);
|
|
if (ntok == 0)
|
|
return;
|
|
|
|
/*
|
|
* Find the appropriate command description.
|
|
*/
|
|
i = findcmd(tokens[0], builtins, opcmds, &xcmd);
|
|
if (i == 0) {
|
|
(void) fprintf(stderr, "***Command `%s' unknown\n",
|
|
tokens[0]);
|
|
return;
|
|
} else if (i >= 2) {
|
|
(void) fprintf(stderr, "***Command `%s' ambiguous\n",
|
|
tokens[0]);
|
|
return;
|
|
}
|
|
|
|
/*
|
|
* Save the keyword, then walk through the arguments, interpreting
|
|
* as we go.
|
|
*/
|
|
pcmd.keyword = tokens[0];
|
|
pcmd.nargs = 0;
|
|
ti = 1;
|
|
for (i = 0; i < MAXARGS && xcmd->arg[i] != NO;) {
|
|
if ((i+ti) >= ntok) {
|
|
if (!(xcmd->arg[i] & OPT)) {
|
|
printusage(xcmd, stderr);
|
|
return;
|
|
}
|
|
break;
|
|
}
|
|
if ((xcmd->arg[i] & OPT) && (*tokens[i+ti] == '>'))
|
|
break;
|
|
rval = getarg(tokens[i+ti], (int)xcmd->arg[i], &pcmd.argval[i]);
|
|
if (rval == -1) {
|
|
ti++;
|
|
continue;
|
|
}
|
|
if (rval == 0)
|
|
return;
|
|
pcmd.nargs++;
|
|
i++;
|
|
}
|
|
|
|
/* Any extra args are assumed to be "OPT|NTP_STR". */
|
|
for ( ; i < MAXARGS + MOREARGS;) {
|
|
if ((i+ti) >= ntok)
|
|
break;
|
|
rval = getarg(tokens[i+ti], (int)(OPT|NTP_STR), &pcmd.argval[i]);
|
|
if (rval == -1) {
|
|
ti++;
|
|
continue;
|
|
}
|
|
if (rval == 0)
|
|
return;
|
|
pcmd.nargs++;
|
|
i++;
|
|
}
|
|
|
|
i += ti;
|
|
if (i < ntok && *tokens[i] == '>') {
|
|
char *fname;
|
|
|
|
if (*(tokens[i]+1) != '\0')
|
|
fname = tokens[i]+1;
|
|
else if ((i+1) < ntok)
|
|
fname = tokens[i+1];
|
|
else {
|
|
(void) fprintf(stderr, "***No file for redirect\n");
|
|
return;
|
|
}
|
|
|
|
current_output = fopen(fname, "w");
|
|
if (current_output == NULL) {
|
|
(void) fprintf(stderr, "***Error opening %s: ", fname);
|
|
perror("");
|
|
return;
|
|
}
|
|
} else {
|
|
current_output = stdout;
|
|
}
|
|
|
|
if (interactive && setjmp(interrupt_buf)) {
|
|
return;
|
|
} else {
|
|
jump = 1;
|
|
(xcmd->handler)(&pcmd, current_output);
|
|
jump = 0;
|
|
if (current_output != stdout)
|
|
(void) fclose(current_output);
|
|
current_output = NULL;
|
|
}
|
|
}
|
|
|
|
|
|
/*
|
|
* tokenize - turn a command line into tokens
|
|
*/
|
|
static void
|
|
tokenize(
|
|
const char *line,
|
|
char **tokens,
|
|
int *ntok
|
|
)
|
|
{
|
|
register const char *cp;
|
|
register char *sp;
|
|
static char tspace[MAXLINE];
|
|
|
|
sp = tspace;
|
|
cp = line;
|
|
for (*ntok = 0; *ntok < MAXTOKENS; (*ntok)++) {
|
|
tokens[*ntok] = sp;
|
|
while (ISSPACE(*cp))
|
|
cp++;
|
|
if (ISEOL(*cp))
|
|
break;
|
|
do {
|
|
*sp++ = *cp++;
|
|
} while (!ISSPACE(*cp) && !ISEOL(*cp));
|
|
|
|
*sp++ = '\0';
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
* findcmd - find a command in a command description table
|
|
*/
|
|
static int
|
|
findcmd(
|
|
register char *str,
|
|
struct xcmd *clist1,
|
|
struct xcmd *clist2,
|
|
struct xcmd **cmd
|
|
)
|
|
{
|
|
register struct xcmd *cl;
|
|
register int clen;
|
|
int nmatch;
|
|
struct xcmd *nearmatch = NULL;
|
|
struct xcmd *clist;
|
|
|
|
clen = strlen(str);
|
|
nmatch = 0;
|
|
if (clist1 != 0)
|
|
clist = clist1;
|
|
else if (clist2 != 0)
|
|
clist = clist2;
|
|
else
|
|
return 0;
|
|
|
|
again:
|
|
for (cl = clist; cl->keyword != 0; cl++) {
|
|
/* do a first character check, for efficiency */
|
|
if (*str != *(cl->keyword))
|
|
continue;
|
|
if (strncmp(str, cl->keyword, (unsigned)clen) == 0) {
|
|
/*
|
|
* Could be extact match, could be approximate.
|
|
* Is exact if the length of the keyword is the
|
|
* same as the str.
|
|
*/
|
|
if (*((cl->keyword) + clen) == '\0') {
|
|
*cmd = cl;
|
|
return 1;
|
|
}
|
|
nmatch++;
|
|
nearmatch = cl;
|
|
}
|
|
}
|
|
|
|
/*
|
|
* See if there is more to do. If so, go again. Sorry about the
|
|
* goto, too much looking at BSD sources...
|
|
*/
|
|
if (clist == clist1 && clist2 != 0) {
|
|
clist = clist2;
|
|
goto again;
|
|
}
|
|
|
|
/*
|
|
* If we got extactly 1 near match, use it, else return number
|
|
* of matches.
|
|
*/
|
|
if (nmatch == 1) {
|
|
*cmd = nearmatch;
|
|
return 1;
|
|
}
|
|
return nmatch;
|
|
}
|
|
|
|
|
|
/*
|
|
* getarg - interpret an argument token
|
|
*
|
|
* string is always set.
|
|
* type is set to the decoded type.
|
|
*
|
|
* return: 0 - failure
|
|
* 1 - success
|
|
* -1 - skip to next token
|
|
*/
|
|
static int
|
|
getarg(
|
|
char *str,
|
|
int code,
|
|
arg_v *argp
|
|
)
|
|
{
|
|
int isneg;
|
|
char *cp, *np;
|
|
static const char *digits = "0123456789";
|
|
|
|
memset(argp, 0, sizeof(*argp));
|
|
|
|
argp->string = str;
|
|
argp->type = code & ~OPT;
|
|
|
|
switch (argp->type) {
|
|
case NTP_STR:
|
|
break;
|
|
case NTP_ADD:
|
|
if (!strcmp("-6", str)) {
|
|
ai_fam_templ = AF_INET6;
|
|
return -1;
|
|
} else if (!strcmp("-4", str)) {
|
|
ai_fam_templ = AF_INET;
|
|
return -1;
|
|
}
|
|
if (!getnetnum(str, &(argp->netnum), (char *)0, 0)) {
|
|
return 0;
|
|
}
|
|
break;
|
|
case NTP_INT:
|
|
case NTP_UINT:
|
|
isneg = 0;
|
|
np = str;
|
|
if (*np == '-') {
|
|
np++;
|
|
isneg = 1;
|
|
}
|
|
|
|
argp->uval = 0;
|
|
do {
|
|
cp = strchr(digits, *np);
|
|
if (cp == NULL) {
|
|
(void) fprintf(stderr,
|
|
"***Illegal integer value %s\n", str);
|
|
return 0;
|
|
}
|
|
argp->uval *= 10;
|
|
argp->uval += (cp - digits);
|
|
} while (*(++np) != '\0');
|
|
|
|
if (isneg) {
|
|
if ((code & ~OPT) == NTP_UINT) {
|
|
(void) fprintf(stderr,
|
|
"***Value %s should be unsigned\n", str);
|
|
return 0;
|
|
}
|
|
argp->ival = -argp->ival;
|
|
}
|
|
break;
|
|
case IP_VERSION:
|
|
if (!strcmp("-6", str))
|
|
argp->ival = 6 ;
|
|
else if (!strcmp("-4", str))
|
|
argp->ival = 4 ;
|
|
else {
|
|
(void) fprintf(stderr,
|
|
"***Version must be either 4 or 6\n");
|
|
return 0;
|
|
}
|
|
break;
|
|
}
|
|
|
|
return 1;
|
|
}
|
|
|
|
|
|
/*
|
|
* getnetnum - given a host name, return its net number
|
|
* and (optional) full name
|
|
*/
|
|
static int
|
|
getnetnum(
|
|
const char *hname,
|
|
struct sockaddr_storage *num,
|
|
char *fullhost,
|
|
int af
|
|
)
|
|
{
|
|
int sockaddr_len;
|
|
struct addrinfo hints, *ai = NULL;
|
|
|
|
sockaddr_len = (af == AF_INET)
|
|
? sizeof(struct sockaddr_in)
|
|
: sizeof(struct sockaddr_in6);
|
|
memset((char *)&hints, 0, sizeof(struct addrinfo));
|
|
hints.ai_flags = AI_CANONNAME;
|
|
#ifdef AI_ADDRCONFIG
|
|
hints.ai_flags |= AI_ADDRCONFIG;
|
|
#endif
|
|
|
|
/* decodenetnum only works with addresses */
|
|
if (decodenetnum(hname, num)) {
|
|
if (fullhost != 0) {
|
|
getnameinfo((struct sockaddr *)num, sockaddr_len,
|
|
fullhost, sizeof(fullhost), NULL, 0,
|
|
NI_NUMERICHOST);
|
|
}
|
|
return 1;
|
|
} else if (getaddrinfo(hname, "ntp", &hints, &ai) == 0) {
|
|
memmove((char *)num, ai->ai_addr, ai->ai_addrlen);
|
|
if (fullhost != 0)
|
|
(void) strcpy(fullhost, ai->ai_canonname);
|
|
return 1;
|
|
} else {
|
|
(void) fprintf(stderr, "***Can't find host %s\n", hname);
|
|
return 0;
|
|
}
|
|
/*NOTREACHED*/
|
|
}
|
|
|
|
/*
|
|
* nntohost - convert network number to host name. This routine enforces
|
|
* the showhostnames setting.
|
|
*/
|
|
char *
|
|
nntohost(
|
|
struct sockaddr_storage *netnum
|
|
)
|
|
{
|
|
if (!showhostnames)
|
|
return stoa(netnum);
|
|
|
|
if ((netnum->ss_family == AF_INET) && ISREFCLOCKADR(netnum))
|
|
return refnumtoa(netnum);
|
|
return socktohost(netnum);
|
|
}
|
|
|
|
|
|
/*
|
|
* Finally, the built in command handlers
|
|
*/
|
|
|
|
/*
|
|
* help - tell about commands, or details of a particular command
|
|
*/
|
|
static void
|
|
help(
|
|
struct parse *pcmd,
|
|
FILE *fp
|
|
)
|
|
{
|
|
struct xcmd *xcp;
|
|
char *cmd;
|
|
const char *list[100];
|
|
int word, words;
|
|
int row, rows;
|
|
int col, cols;
|
|
|
|
if (pcmd->nargs == 0) {
|
|
words = 0;
|
|
for (xcp = builtins; xcp->keyword != 0; xcp++) {
|
|
if (*(xcp->keyword) != '?')
|
|
list[words++] = xcp->keyword;
|
|
}
|
|
for (xcp = opcmds; xcp->keyword != 0; xcp++)
|
|
list[words++] = xcp->keyword;
|
|
|
|
qsort(
|
|
#ifdef QSORT_USES_VOID_P
|
|
(void *)
|
|
#else
|
|
(char *)
|
|
#endif
|
|
(list), (size_t)(words), sizeof(char *), helpsort);
|
|
col = 0;
|
|
for (word = 0; word < words; word++) {
|
|
int length = strlen(list[word]);
|
|
if (col < length) {
|
|
col = length;
|
|
}
|
|
}
|
|
|
|
cols = SCREENWIDTH / ++col;
|
|
rows = (words + cols - 1) / cols;
|
|
|
|
(void) fprintf(fp, "ntpdc commands:\n");
|
|
|
|
for (row = 0; row < rows; row++) {
|
|
for (word = row; word < words; word += rows) {
|
|
(void) fprintf(fp, "%-*.*s", col, col-1, list[word]);
|
|
}
|
|
(void) fprintf(fp, "\n");
|
|
}
|
|
} else {
|
|
cmd = pcmd->argval[0].string;
|
|
words = findcmd(cmd, builtins, opcmds, &xcp);
|
|
if (words == 0) {
|
|
(void) fprintf(stderr,
|
|
"Command `%s' is unknown\n", cmd);
|
|
return;
|
|
} else if (words >= 2) {
|
|
(void) fprintf(stderr,
|
|
"Command `%s' is ambiguous\n", cmd);
|
|
return;
|
|
}
|
|
(void) fprintf(fp, "function: %s\n", xcp->comment);
|
|
printusage(xcp, fp);
|
|
}
|
|
}
|
|
|
|
|
|
/*
|
|
* helpsort - do hostname qsort comparisons
|
|
*/
|
|
#ifdef QSORT_USES_VOID_P
|
|
static int
|
|
helpsort(
|
|
const void *t1,
|
|
const void *t2
|
|
)
|
|
{
|
|
char const * const * name1 = (char const * const *)t1;
|
|
char const * const * name2 = (char const * const *)t2;
|
|
|
|
return strcmp(*name1, *name2);
|
|
}
|
|
#else
|
|
static int
|
|
helpsort(
|
|
char **name1,
|
|
char **name2
|
|
)
|
|
{
|
|
return strcmp(*name1, *name2);
|
|
}
|
|
#endif
|
|
|
|
|
|
/*
|
|
* printusage - print usage information for a command
|
|
*/
|
|
static void
|
|
printusage(
|
|
struct xcmd *xcp,
|
|
FILE *fp
|
|
)
|
|
{
|
|
int i, opt46;
|
|
|
|
opt46 = 0;
|
|
(void) fprintf(fp, "usage: %s", xcp->keyword);
|
|
for (i = 0; i < MAXARGS && xcp->arg[i] != NO; i++) {
|
|
if (opt46 == 0 && (xcp->arg[i] & ~OPT) == NTP_ADD) {
|
|
(void) fprintf(fp, " [ -4|-6 ]");
|
|
opt46 = 1;
|
|
}
|
|
if (xcp->arg[i] & OPT)
|
|
(void) fprintf(fp, " [ %s ]", xcp->desc[i]);
|
|
else
|
|
(void) fprintf(fp, " %s", xcp->desc[i]);
|
|
}
|
|
(void) fprintf(fp, "\n");
|
|
}
|
|
|
|
|
|
/*
|
|
* timeout - set time out time
|
|
*/
|
|
static void
|
|
timeout(
|
|
struct parse *pcmd,
|
|
FILE *fp
|
|
)
|
|
{
|
|
int val;
|
|
|
|
if (pcmd->nargs == 0) {
|
|
val = tvout.tv_sec * 1000 + tvout.tv_usec / 1000;
|
|
(void) fprintf(fp, "primary timeout %d ms\n", val);
|
|
} else {
|
|
tvout.tv_sec = pcmd->argval[0].uval / 1000;
|
|
tvout.tv_usec = (pcmd->argval[0].uval - (tvout.tv_sec * 1000))
|
|
* 1000;
|
|
}
|
|
}
|
|
|
|
|
|
/*
|
|
* my_delay - set delay for auth requests
|
|
*/
|
|
static void
|
|
my_delay(
|
|
struct parse *pcmd,
|
|
FILE *fp
|
|
)
|
|
{
|
|
int isneg;
|
|
u_long val;
|
|
|
|
if (pcmd->nargs == 0) {
|
|
val = delay_time.l_ui * 1000 + delay_time.l_uf / 4294967;
|
|
(void) fprintf(fp, "delay %lu ms\n", val);
|
|
} else {
|
|
if (pcmd->argval[0].ival < 0) {
|
|
isneg = 1;
|
|
val = (u_long)(-pcmd->argval[0].ival);
|
|
} else {
|
|
isneg = 0;
|
|
val = (u_long)pcmd->argval[0].ival;
|
|
}
|
|
|
|
delay_time.l_ui = val / 1000;
|
|
val %= 1000;
|
|
delay_time.l_uf = val * 4294967; /* 2**32/1000 */
|
|
|
|
if (isneg)
|
|
L_NEG(&delay_time);
|
|
}
|
|
}
|
|
|
|
|
|
/*
|
|
* host - set the host we are dealing with.
|
|
*/
|
|
static void
|
|
host(
|
|
struct parse *pcmd,
|
|
FILE *fp
|
|
)
|
|
{
|
|
int i;
|
|
|
|
if (pcmd->nargs == 0) {
|
|
if (havehost)
|
|
(void) fprintf(fp, "current host is %s\n", currenthost);
|
|
else
|
|
(void) fprintf(fp, "no current host\n");
|
|
return;
|
|
}
|
|
|
|
i = 0;
|
|
if (pcmd->nargs == 2) {
|
|
if (!strcmp("-4", pcmd->argval[i].string))
|
|
ai_fam_templ = AF_INET;
|
|
else if (!strcmp("-6", pcmd->argval[i].string))
|
|
ai_fam_templ = AF_INET6;
|
|
else {
|
|
if (havehost)
|
|
(void) fprintf(fp,
|
|
"current host remains %s\n", currenthost);
|
|
else
|
|
(void) fprintf(fp, "still no current host\n");
|
|
return;
|
|
}
|
|
i = 1;
|
|
}
|
|
if (openhost(pcmd->argval[i].string)) {
|
|
(void) fprintf(fp, "current host set to %s\n", currenthost);
|
|
} else {
|
|
if (havehost)
|
|
(void) fprintf(fp,
|
|
"current host remains %s\n", currenthost);
|
|
else
|
|
(void) fprintf(fp, "still no current host\n");
|
|
}
|
|
}
|
|
|
|
|
|
/*
|
|
* keyid - get a keyid to use for authenticating requests
|
|
*/
|
|
static void
|
|
keyid(
|
|
struct parse *pcmd,
|
|
FILE *fp
|
|
)
|
|
{
|
|
if (pcmd->nargs == 0) {
|
|
if (info_auth_keyid == 0 && !keyid_entered)
|
|
(void) fprintf(fp, "no keyid defined\n");
|
|
else if (info_auth_keyid == 0 && keyid_entered)
|
|
(void) fprintf(fp, "no keyid will be sent\n");
|
|
else
|
|
(void) fprintf(fp, "keyid is %lu\n", (u_long)info_auth_keyid);
|
|
} else {
|
|
info_auth_keyid = pcmd->argval[0].uval;
|
|
keyid_entered = 1;
|
|
}
|
|
}
|
|
|
|
|
|
/*
|
|
* keytype - get type of key to use for authenticating requests
|
|
*/
|
|
static void
|
|
keytype(
|
|
struct parse *pcmd,
|
|
FILE *fp
|
|
)
|
|
{
|
|
if (pcmd->nargs == 0)
|
|
fprintf(fp, "keytype is %s\n",
|
|
(info_auth_keytype == KEY_TYPE_MD5) ? "MD5" : "???");
|
|
else
|
|
switch (*(pcmd->argval[0].string)) {
|
|
case 'm':
|
|
case 'M':
|
|
info_auth_keytype = KEY_TYPE_MD5;
|
|
break;
|
|
|
|
default:
|
|
fprintf(fp, "keytype must be 'md5'\n");
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
* passwd - get an authentication key
|
|
*/
|
|
/*ARGSUSED*/
|
|
static void
|
|
passwd(
|
|
struct parse *pcmd,
|
|
FILE *fp
|
|
)
|
|
{
|
|
char *pass;
|
|
|
|
if (info_auth_keyid == 0) {
|
|
info_auth_keyid = getkeyid("Keyid: ");
|
|
if (info_auth_keyid == 0) {
|
|
(void)fprintf(fp, "Keyid must be defined\n");
|
|
return;
|
|
}
|
|
}
|
|
if (!interactive) {
|
|
authusekey(info_auth_keyid, info_auth_keytype,
|
|
(u_char *)pcmd->argval[0].string);
|
|
authtrust(info_auth_keyid, 1);
|
|
} else {
|
|
pass = getpass("MD5 Password: ");
|
|
if (*pass == '\0')
|
|
(void) fprintf(fp, "Password unchanged\n");
|
|
else {
|
|
authusekey(info_auth_keyid, info_auth_keytype,
|
|
(u_char *)pass);
|
|
authtrust(info_auth_keyid, 1);
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
/*
|
|
* hostnames - set the showhostnames flag
|
|
*/
|
|
static void
|
|
hostnames(
|
|
struct parse *pcmd,
|
|
FILE *fp
|
|
)
|
|
{
|
|
if (pcmd->nargs == 0) {
|
|
if (showhostnames)
|
|
(void) fprintf(fp, "hostnames being shown\n");
|
|
else
|
|
(void) fprintf(fp, "hostnames not being shown\n");
|
|
} else {
|
|
if (STREQ(pcmd->argval[0].string, "yes"))
|
|
showhostnames = 1;
|
|
else if (STREQ(pcmd->argval[0].string, "no"))
|
|
showhostnames = 0;
|
|
else
|
|
(void)fprintf(stderr, "What?\n");
|
|
}
|
|
}
|
|
|
|
|
|
/*
|
|
* setdebug - set/change debugging level
|
|
*/
|
|
static void
|
|
setdebug(
|
|
struct parse *pcmd,
|
|
FILE *fp
|
|
)
|
|
{
|
|
if (pcmd->nargs == 0) {
|
|
(void) fprintf(fp, "debug level is %d\n", debug);
|
|
return;
|
|
} else if (STREQ(pcmd->argval[0].string, "no")) {
|
|
debug = 0;
|
|
} else if (STREQ(pcmd->argval[0].string, "more")) {
|
|
debug++;
|
|
} else if (STREQ(pcmd->argval[0].string, "less")) {
|
|
debug--;
|
|
} else {
|
|
(void) fprintf(fp, "What?\n");
|
|
return;
|
|
}
|
|
(void) fprintf(fp, "debug level set to %d\n", debug);
|
|
}
|
|
|
|
|
|
/*
|
|
* quit - stop this nonsense
|
|
*/
|
|
/*ARGSUSED*/
|
|
static void
|
|
quit(
|
|
struct parse *pcmd,
|
|
FILE *fp
|
|
)
|
|
{
|
|
if (havehost)
|
|
closesocket(sockfd);
|
|
exit(0);
|
|
}
|
|
|
|
|
|
/*
|
|
* version - print the current version number
|
|
*/
|
|
/*ARGSUSED*/
|
|
static void
|
|
version(
|
|
struct parse *pcmd,
|
|
FILE *fp
|
|
)
|
|
{
|
|
|
|
(void) fprintf(fp, "%s\n", Version);
|
|
return;
|
|
}
|
|
|
|
|
|
/*
|
|
* warning - print a warning message
|
|
*/
|
|
static void
|
|
warning(
|
|
const char *fmt,
|
|
const char *st1,
|
|
const char *st2
|
|
)
|
|
{
|
|
(void) fprintf(stderr, "%s: ", progname);
|
|
(void) fprintf(stderr, fmt, st1, st2);
|
|
(void) fprintf(stderr, ": ");
|
|
perror("");
|
|
}
|
|
|
|
|
|
/*
|
|
* error - print a message and exit
|
|
*/
|
|
static void
|
|
error(
|
|
const char *fmt,
|
|
const char *st1,
|
|
const char *st2
|
|
)
|
|
{
|
|
warning(fmt, st1, st2);
|
|
exit(1);
|
|
}
|
|
|
|
/*
|
|
* getkeyid - prompt the user for a keyid to use
|
|
*/
|
|
static u_long
|
|
getkeyid(
|
|
const char *keyprompt
|
|
)
|
|
{
|
|
register char *p;
|
|
register int c;
|
|
FILE *fi;
|
|
char pbuf[20];
|
|
|
|
#ifndef SYS_WINNT
|
|
if ((fi = fdopen(open("/dev/tty", 2), "r")) == NULL)
|
|
#else
|
|
if ((fi = _fdopen((int)GetStdHandle(STD_INPUT_HANDLE), "r")) == NULL)
|
|
#endif /* SYS_WINNT */
|
|
fi = stdin;
|
|
else
|
|
setbuf(fi, (char *)NULL);
|
|
fprintf(stderr, "%s", keyprompt); fflush(stderr);
|
|
for (p=pbuf; (c = getc(fi))!='\n' && c!=EOF;) {
|
|
if (p < &pbuf[18])
|
|
*p++ = (char) c;
|
|
}
|
|
*p = '\0';
|
|
if (fi != stdin)
|
|
fclose(fi);
|
|
return (u_int32)atoi(pbuf);
|
|
}
|