diff options
Diffstat (limited to 'contrib/ntp/ntpdc')
-rw-r--r-- | contrib/ntp/ntpdc/Makefile.am | 21 | ||||
-rw-r--r-- | contrib/ntp/ntpdc/Makefile.in | 361 | ||||
-rw-r--r-- | contrib/ntp/ntpdc/README | 6 | ||||
-rw-r--r-- | contrib/ntp/ntpdc/ntpdc.c | 1689 | ||||
-rw-r--r-- | contrib/ntp/ntpdc/ntpdc.h | 59 | ||||
-rw-r--r-- | contrib/ntp/ntpdc/ntpdc_ops.c | 2471 |
6 files changed, 4607 insertions, 0 deletions
diff --git a/contrib/ntp/ntpdc/Makefile.am b/contrib/ntp/ntpdc/Makefile.am new file mode 100644 index 0000000..19e9cfa --- /dev/null +++ b/contrib/ntp/ntpdc/Makefile.am @@ -0,0 +1,21 @@ +#AUTOMAKE_OPTIONS = ../util/ansi2knr no-dependencies +AUTOMAKE_OPTIONS = ../util/ansi2knr +bin_PROGRAMS = ntpdc +INCLUDES = -I$(top_srcdir)/include +# LDADD might need RESLIB and ADJLIB +LDADD = version.o ../libntp/libntp.a @LIBRSAREF@ +DISTCLEANFILES = .version version.c +noinst_HEADERS = ntpdc.h +#EXTRA_DIST = ntpdc.mak +ETAGS_ARGS = Makefile.am + +ntpdc_SOURCES = ntpdc.c ntpdc_ops.c + +$(PROGRAMS): $(LDADD) + +../libntp/libntp.a: + cd ../libntp && $(MAKE) + +version.o: $(ntpdc_OBJECTS) ../libntp/libntp.a @LIBRSAREF@ Makefile + $(top_builddir)/scripts/mkver ntpdc + $(COMPILE) -c version.c diff --git a/contrib/ntp/ntpdc/Makefile.in b/contrib/ntp/ntpdc/Makefile.in new file mode 100644 index 0000000..6466661 --- /dev/null +++ b/contrib/ntp/ntpdc/Makefile.in @@ -0,0 +1,361 @@ +# Makefile.in generated automatically by automake 1.4a from Makefile.am + +# Copyright (C) 1994, 1995-8, 1999 Free Software Foundation, Inc. +# This Makefile.in is free software; the Free Software Foundation +# gives unlimited permission to copy and/or distribute it, +# with or without modifications, as long as this notice is preserved. + +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY, to the extent permitted by law; without +# even the implied warranty of MERCHANTABILITY or FITNESS FOR A +# PARTICULAR PURPOSE. + +SHELL = @SHELL@ + +srcdir = @srcdir@ +top_srcdir = @top_srcdir@ +VPATH = @srcdir@ +prefix = @prefix@ +exec_prefix = @exec_prefix@ + +bindir = @bindir@ +sbindir = @sbindir@ +libexecdir = @libexecdir@ +datadir = @datadir@ +sysconfdir = @sysconfdir@ +sharedstatedir = @sharedstatedir@ +localstatedir = @localstatedir@ +libdir = @libdir@ +infodir = @infodir@ +mandir = @mandir@ +includedir = @includedir@ +oldincludedir = /usr/include + +DESTDIR = + +pkgdatadir = $(datadir)/@PACKAGE@ +pkglibdir = $(libdir)/@PACKAGE@ +pkgincludedir = $(includedir)/@PACKAGE@ + +top_builddir = .. + +ACLOCAL = @ACLOCAL@ +AUTOCONF = @AUTOCONF@ +AUTOMAKE = @AUTOMAKE@ +AUTOHEADER = @AUTOHEADER@ + +INSTALL = @INSTALL@ +INSTALL_PROGRAM = @INSTALL_PROGRAM@ +INSTALL_DATA = @INSTALL_DATA@ +INSTALL_SCRIPT = @INSTALL_SCRIPT@ +INSTALL_STRIP_FLAG = +transform = @program_transform_name@ + +NORMAL_INSTALL = : +PRE_INSTALL = : +POST_INSTALL = : +NORMAL_UNINSTALL = : +PRE_UNINSTALL = : +POST_UNINSTALL = : +build_alias = @build_alias@ +build_triplet = @build@ +host_alias = @host_alias@ +host_triplet = @host@ +target_alias = @target_alias@ +target_triplet = @target@ +AMTAR = @AMTAR@ +AMTARFLAGS = @AMTARFLAGS@ +AWK = @AWK@ +CC = @CC@ +CFLAGS = @CFLAGS@ +CHUTEST = @CHUTEST@ +CLKTEST = @CLKTEST@ +CPP = @CPP@ +DCFD = @DCFD@ +LDFLAGS = @LDFLAGS@ +LIBPARSE = @LIBPARSE@ +LIBRSAREF = @LIBRSAREF@ +LN_S = @LN_S@ +MAKEINFO = @MAKEINFO@ +MAKE_ADJTIMED = @MAKE_ADJTIMED@ +MAKE_CHECK_Y2K = @MAKE_CHECK_Y2K@ +MAKE_LIBPARSE = @MAKE_LIBPARSE@ +MAKE_LIBPARSE_KERNEL = @MAKE_LIBPARSE_KERNEL@ +MAKE_LIBRSAREF = @MAKE_LIBRSAREF@ +MAKE_NTPTIME = @MAKE_NTPTIME@ +MAKE_PARSEKMODULE = @MAKE_PARSEKMODULE@ +MAKE_TICKADJ = @MAKE_TICKADJ@ +PACKAGE = @PACKAGE@ +PATH_SH = @PATH_SH@ +PROPDELAY = @PROPDELAY@ +RANLIB = @RANLIB@ +RSAREF = @RSAREF@ +TESTDCF = @TESTDCF@ +U = @U@ +VERSION = @VERSION@ + +#AUTOMAKE_OPTIONS = ../util/ansi2knr no-dependencies + + +AUTOMAKE_OPTIONS = ../util/ansi2knr +bin_PROGRAMS = ntpdc +INCLUDES = -I$(top_srcdir)/include +# LDADD might need RESLIB and ADJLIB +LDADD = version.o ../libntp/libntp.a @LIBRSAREF@ +DISTCLEANFILES = .version version.c +noinst_HEADERS = ntpdc.h +#EXTRA_DIST = ntpdc.mak +ETAGS_ARGS = Makefile.am + +ntpdc_SOURCES = ntpdc.c ntpdc_ops.c +subdir = ntpdc +mkinstalldirs = $(SHELL) $(top_srcdir)/mkinstalldirs +CONFIG_HEADER = ../config.h +CONFIG_CLEAN_FILES = +PROGRAMS = $(bin_PROGRAMS) + + +DEFS = @DEFS@ -I. -I$(srcdir) -I.. +CPPFLAGS = @CPPFLAGS@ +LIBS = @LIBS@ +ANSI2KNR = ../util/ansi2knr +am_ntpdc_OBJECTS = ntpdc$U.o ntpdc_ops$U.o +ntpdc_OBJECTS = $(am_ntpdc_OBJECTS) +ntpdc_LDADD = $(LDADD) +ntpdc_DEPENDENCIES = version.o ../libntp/libntp.a +ntpdc_LDFLAGS = +COMPILE = $(CC) $(DEFS) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(AM_CFLAGS) $(CFLAGS) +CCLD = $(CC) +LINK = $(CCLD) $(AM_CFLAGS) $(CFLAGS) $(AM_LDFLAGS) $(LDFLAGS) -o $@ +DIST_SOURCES = $(ntpdc_SOURCES) +HEADERS = $(noinst_HEADERS) + +DIST_COMMON = README $(noinst_HEADERS) Makefile.am Makefile.in + + +DISTFILES = $(DIST_COMMON) $(DIST_SOURCES) $(TEXINFOS) $(EXTRA_DIST) + +GZIP_ENV = --best +SOURCES = $(ntpdc_SOURCES) +OBJECTS = $(am_ntpdc_OBJECTS) + +all: all-redirect +.SUFFIXES: +.SUFFIXES: .c .o +$(srcdir)/Makefile.in: Makefile.am $(top_srcdir)/configure.in $(ACLOCAL_M4) + cd $(top_srcdir) && $(AUTOMAKE) --gnu --include-deps ntpdc/Makefile + +Makefile: $(srcdir)/Makefile.in $(top_builddir)/config.status + cd $(top_builddir) \ + && CONFIG_FILES=$(subdir)/$@ CONFIG_HEADERS= $(SHELL) ./config.status + + +mostlyclean-binPROGRAMS: + +clean-binPROGRAMS: + -test -z "$(bin_PROGRAMS)" || rm -f $(bin_PROGRAMS) + +distclean-binPROGRAMS: + +maintainer-clean-binPROGRAMS: + +install-binPROGRAMS: $(bin_PROGRAMS) + @$(NORMAL_INSTALL) + $(mkinstalldirs) $(DESTDIR)$(bindir) + @list='$(bin_PROGRAMS)'; for p in $$list; do \ + if test -f $$p; then \ + f="`echo $$p|sed -e 's/$(EXEEXT)$$//' -e '$(transform)' -e 's/$$/$(EXEEXT)/'`"; \ + echo " $(INSTALL_PROGRAM) $(INSTALL_STRIP_FLAG) $$p $(DESTDIR)$(bindir)/$$f"; \ + $(INSTALL_PROGRAM) $(INSTALL_STRIP_FLAG) $$p $(DESTDIR)$(bindir)/$$f; \ + else :; fi; \ + done + +uninstall-binPROGRAMS: + @$(NORMAL_UNINSTALL) + @list='$(bin_PROGRAMS)'; for p in $$list; do \ + f="`echo $$p|sed -e 's/$(EXEEXT)$$//' -e '$(transform)' -e 's/$$/$(EXEEXT)/'`"; \ + echo " rm -f $(DESTDIR)$(bindir)/$$f"; \ + rm -f $(DESTDIR)$(bindir)/$$f; \ + done + +.c.o: + $(COMPILE) -c $< + +mostlyclean-compile: + -rm -f *.o core *.core + +clean-compile: + +distclean-compile: + -rm -f *.tab.c + +maintainer-clean-compile: +../util/ansi2knr: ../util/ansi2knr.o + cd ../util && $(MAKE) $(AM_MAKEFLAGS) ansi2knr + +../util/ansi2knr.o: + cd ../util && $(MAKE) $(AM_MAKEFLAGS) ansi2knr.o + + +mostlyclean-kr: + -rm -f *_.c + +clean-kr: + +distclean-kr: + +maintainer-clean-kr: +ntpdc$U.o: +ntpdc_ops$U.o: + +ntpdc: $(ntpdc_OBJECTS) $(ntpdc_DEPENDENCIES) + @rm -f ntpdc + $(LINK) $(ntpdc_LDFLAGS) $(ntpdc_OBJECTS) $(ntpdc_LDADD) $(LIBS) +ntpdc_.c: ntpdc.c $(ANSI2KNR) + $(CPP) $(DEFS) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) `if test -f $(srcdir)/ntpdc.c; then echo $(srcdir)/ntpdc.c; else echo ntpdc.c; fi` | sed 's/^# \([0-9]\)/#line \1/' | $(ANSI2KNR) > ntpdc_.c +ntpdc_ops_.c: ntpdc_ops.c $(ANSI2KNR) + $(CPP) $(DEFS) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) `if test -f $(srcdir)/ntpdc_ops.c; then echo $(srcdir)/ntpdc_ops.c; else echo ntpdc_ops.c; fi` | sed 's/^# \([0-9]\)/#line \1/' | $(ANSI2KNR) > ntpdc_ops_.c +ntpdc_.o ntpdc_ops_.o : $(ANSI2KNR) + +tags: TAGS + +ID: $(HEADERS) $(SOURCES) $(LISP) + list='$(SOURCES) $(HEADERS)'; \ + unique=`for i in $$list; do echo $$i; done | \ + ${AWK:-awk} ' { files[$$0] = 1; } \ + END { for (i in files) print i; }'`; \ + here=`pwd` && cd $(srcdir) \ + && mkid -f$$here/ID $$unique $(LISP) + +TAGS: $(HEADERS) $(SOURCES) $(TAGS_DEPENDENCIES) $(LISP) + tags=; \ + here=`pwd`; \ + list='$(SOURCES) $(HEADERS)'; \ + unique=`for i in $$list; do echo $$i; done | \ + ${AWK:-awk} ' { files[$$0] = 1; } \ + END { for (i in files) print i; }'`; \ + test -z "$(ETAGS_ARGS)$$unique$(LISP)$$tags" \ + || (cd $(srcdir) && etags $(ETAGS_ARGS) $$tags $$unique $(LISP) -o $$here/TAGS) + +mostlyclean-tags: + +clean-tags: + +distclean-tags: + -rm -f TAGS ID + +maintainer-clean-tags: + +distdir = $(top_builddir)/$(PACKAGE)-$(VERSION)/$(subdir) + +distdir: $(DISTFILES) + @for file in $(DISTFILES); do \ + d=$(srcdir); \ + if test -d $$d/$$file; then \ + cp -pr $$d/$$file $(distdir)/$$file; \ + else \ + test -f $(distdir)/$$file \ + || ln $$d/$$file $(distdir)/$$file 2> /dev/null \ + || cp -p $$d/$$file $(distdir)/$$file || :; \ + fi; \ + done +ntpdc.o: ntpdc.c ntpdc.h ../include/ntp_fp.h ../include/ntp_types.h \ + ../include/ntp_machine.h ../config.h ../include/ntp_proto.h \ + ../include/ntp.h ../include/ntp_request.h \ + ../include/ntp_string.h ../include/ntp_malloc.h \ + ../include/ntp_select.h ../include/ntp_io.h \ + ../include/ntp_stdlib.h ../include/l_stdlib.h +ntpdc_ops.o: ntpdc_ops.c ../config.h ntpdc.h ../include/ntp_fp.h \ + ../include/ntp_types.h ../include/ntp_machine.h \ + ../include/ntp_proto.h ../include/ntp.h \ + ../include/ntp_request.h ../include/ntp_string.h \ + ../include/ntp_malloc.h ../include/ntp_control.h \ + ../include/ntp_refclock.h ../include/recvbuff.h \ + ../include/ntp_stdlib.h ../include/l_stdlib.h + +info-am: +info: info-am +dvi-am: +dvi: dvi-am +check-am: all-am +check: check-am +installcheck-am: +installcheck: installcheck-am +install-exec-am: install-binPROGRAMS +install-exec: install-exec-am + +install-data-am: +install-data: install-data-am + +install-am: all-am + @$(MAKE) $(AM_MAKEFLAGS) install-exec-am install-data-am +install: install-am +uninstall-am: uninstall-binPROGRAMS +uninstall: uninstall-am +all-am: Makefile $(PROGRAMS) $(HEADERS) +all-redirect: all-am +install-strip: + $(MAKE) $(AM_MAKEFLAGS) INSTALL_STRIP_FLAG=-s install +installdirs: + $(mkinstalldirs) $(DESTDIR)$(bindir) + + +mostlyclean-generic: + +clean-generic: + +distclean-generic: + -rm -f Makefile $(CONFIG_CLEAN_FILES) + -rm -f config.cache config.log stamp-h stamp-h[0-9]* + -test -z "$(DISTCLEANFILES)" || rm -f $(DISTCLEANFILES) + +maintainer-clean-generic: +mostlyclean-am: mostlyclean-binPROGRAMS mostlyclean-compile \ + mostlyclean-kr mostlyclean-tags mostlyclean-generic + +mostlyclean: mostlyclean-am + +clean-am: clean-binPROGRAMS clean-compile clean-kr clean-tags \ + clean-generic mostlyclean-am + +clean: clean-am + +distclean-am: distclean-binPROGRAMS distclean-compile distclean-kr \ + distclean-tags distclean-generic clean-am + +distclean: distclean-am + +maintainer-clean-am: maintainer-clean-binPROGRAMS \ + maintainer-clean-compile maintainer-clean-kr \ + maintainer-clean-tags maintainer-clean-generic \ + distclean-am + @echo "This command is intended for maintainers to use;" + @echo "it deletes files that may require special tools to rebuild." + +maintainer-clean: maintainer-clean-am + +.PHONY: mostlyclean-binPROGRAMS distclean-binPROGRAMS clean-binPROGRAMS \ +maintainer-clean-binPROGRAMS uninstall-binPROGRAMS install-binPROGRAMS \ +mostlyclean-compile distclean-compile clean-compile \ +maintainer-clean-compile mostlyclean-kr distclean-kr clean-kr \ +maintainer-clean-kr tags mostlyclean-tags distclean-tags clean-tags \ +maintainer-clean-tags distdir info-am info dvi-am dvi check check-am \ +installcheck-am installcheck install-exec-am install-exec \ +install-data-am install-data install-am install uninstall-am uninstall \ +all-redirect all-am all install-strip installdirs mostlyclean-generic \ +distclean-generic clean-generic maintainer-clean-generic clean \ +mostlyclean distclean maintainer-clean + + +$(PROGRAMS): $(LDADD) + +../libntp/libntp.a: + cd ../libntp && $(MAKE) + +version.o: $(ntpdc_OBJECTS) ../libntp/libntp.a @LIBRSAREF@ Makefile + $(top_builddir)/scripts/mkver ntpdc + $(COMPILE) -c version.c + +# Tell versions [3.59,3.63) of GNU make to not export all variables. +# Otherwise a system limit (for SysV at least) may be exceeded. +.NOEXPORT: diff --git a/contrib/ntp/ntpdc/README b/contrib/ntp/ntpdc/README new file mode 100644 index 0000000..618e846 --- /dev/null +++ b/contrib/ntp/ntpdc/README @@ -0,0 +1,6 @@ +README file for directory ./xntpdc of the NTP Version 4 distribution + +This directory contains the sources for the xntpdc utility program. See +the README and RELNOTES files in the parent directory for directions on +how to make and install this program. The current version number of this +program is in the version.c file. diff --git a/contrib/ntp/ntpdc/ntpdc.c b/contrib/ntp/ntpdc/ntpdc.c new file mode 100644 index 0000000..a529954 --- /dev/null +++ b/contrib/ntp/ntpdc/ntpdc.c @@ -0,0 +1,1689 @@ +/* + * ntpdc - control and monitor your ntpd daemon + */ +#include <stdio.h> +#include <ctype.h> +#include <signal.h> +#include <setjmp.h> +#include <sys/types.h> +#include <sys/time.h> +#include <netdb.h> + +#ifdef SYS_WINNT +#include <io.h> +#else +#define closesocket close +#endif /* SYS_WINNT */ + + +#include "ntpdc.h" +#include "ntp_select.h" +#include "ntp_io.h" +#include "ntp_stdlib.h" + +#ifdef SYS_VXWORKS +/* vxWorks needs mode flag -casey*/ +#define open(name, flags) open(name, flags, 0777) +#define SERVER_PORT_NUM 123 +#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; + +/* + * Type of key md5 or des + */ +#define KEY_TYPE_DES 3 +#define KEY_TYPE_MD5 4 + +static int info_auth_keytype = KEY_TYPE_MD5; /* MD5*/ +u_long current_time; /* needed by authkeys; not used */ + +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 **)); +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 *, u_int32 *, char *)); +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|UINT, NO, NO, NO }, + { "msec", "", "", "" }, + "set the primary receive time out" }, + { "delay", my_delay, { OPT|INT, NO, NO, NO }, + { "msec", "", "", "" }, + "set the delay added to encryption time stamps" }, + { "host", host, { OPT|NTP_STR, NO, NO, NO }, + { "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|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+MAXARGS+2) /* maximum number of usable tokens */ + +/* + * 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 */ +static struct sockaddr_in hostaddr = { 0 }; /* host address */ +static int showhostnames = 1; /* show host names by default */ + +static int sockfd; /* fd socket is openned on */ +static int havehost = 0; /* set to 1 when host open */ +struct servent *server_entry = NULL; /* server entry for ntp */ + +#if defined (SYS_WINNT) || defined (SYS_VXWORKS) +char password[9]; +#endif /* SYS_WINNT || SYS_VXWORKS */ + +#ifdef SYS_WINNT +WORD wVersionRequested; +WSADATA wsaData; +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; + +/* + * 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) +{ + extern int ntp_optind; + extern char *ntp_optarg; + showhostnames = 0; /* show host names by default */ + ntp_optind = 0; + ntp_optarg = 0; + server_entry = NULL; /* server entry for ntp */ + 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[] + ) +{ + int c; + int errflg = 0; + extern int ntp_optind; + extern char *ntp_optarg; + + delay_time.l_ui = 0; + delay_time.l_uf = DEFDELAY; + +#ifdef SYS_VXWORKS + clear_globals(); + taskPrioritySet(taskIdSelf(), 100 ); +#endif + + progname = argv[0]; + while ((c = ntp_getopt(argc, argv, "c:dilnps")) != EOF) + switch (c) { + 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 [-dilnps] [-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; + } + +#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; + +#ifdef SYS_WINNT + wVersionRequested = MAKEWORD(1,1); + if (WSAStartup(wVersionRequested, &wsaData)) { + fprintf(stderr, "No useable winsock.dll"); + exit(1); + } +#endif /* SYS_WINNT */ + + 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 + ) +{ + u_int32 netnum; + char temphost[LENHOSTNAME]; + + if (server_entry == NULL) { + server_entry = getservbyname("ntp", "udp"); + if (server_entry == NULL) { +#ifdef VMS /* UCX getservbyname() doesn't work [yet], but we do know better */ + server_entry = (struct servent *) + malloc(sizeof(struct servent)); + server_entry->s_port = htons(NTP_PORT); +#else + (void) fprintf(stderr, "%s: ntp/udp: unknown service\n", + progname); + exit(1); +#endif /* VMS & UCX */ + } + if (debug > 2) + printf("Got ntp/udp service entry\n"); + } + + if (!getnetnum(hname, &netnum, temphost)) + return 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); + + hostaddr.sin_family = AF_INET; +#ifndef SYS_VXWORKS + hostaddr.sin_port = server_entry->s_port; +#else + hostaddr.sin_port = htons(SERVER_PORT_NUM); +#endif + hostaddr.sin_addr.s_addr = netnum; + +#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(AF_INET, SOCK_DGRAM, 0); + if (sockfd == INVALID_SOCKET) { + error("socket", "", ""); + exit(-1); + } +#else + sockfd = socket(AF_INET, 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 + + if (connect(sockfd, (struct sockaddr *)&hostaddr, + sizeof(hostaddr)) == -1) + error("connect", "", ""); + + havehost = 1; + 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, 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 + ) +{ + struct resp_pkt rpkt; + struct timeval tvo; + int items; + int size; + int datasize; + char *datap; + char haveseq[MAXSEQ+1]; + int firstpkt; + int lastseq; + int numrecv; + int seq; + fd_set fds; + int n; + + /* + * 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 ((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 && size != *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) > (pktdata + pktdatasize)) { + int offset = datap - pktdata; + growpktdata(); + *rdata = pktdata; /* might have been realloced ! */ + datap = pktdata + offset; + } + memmove(datap, (char *)rpkt.data, (unsigned)datasize); + datap += datasize; + if (firstpkt) { + firstpkt = 0; + *rsize = size; + } + *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(0); + } + + if (!auth) { + qpkt.auth_seq = AUTH_SEQ(0, 0); + return sendpkt((char *)&qpkt, REQ_LEN_NOMAC); + } else { + l_fp ts; + int maclen = 0; + const char *pass = "\0"; + + if (info_auth_keyid == 0) { + 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((info_auth_keytype == KEY_TYPE_DES) + ? "DES Password: " : "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); + qpkt.keyid = htonl(info_auth_keyid); + get_systime(&ts); + L_ADD(&ts, &delay_time); + HTONL_FP(&ts, &qpkt.tstamp); + maclen = authencrypt(info_auth_keyid, (u_int32 *)&qpkt, + REQ_LEN_NOMAC); + if (maclen == 0) { + (void) fprintf(stderr, "Key not found\n"); + return (1); + } + return sendpkt((char *)&qpkt, (int)(REQ_LEN_NOMAC + 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 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 + */ + 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); + + /* log error message if not told to be quiet */ + if ((res > 0) && (((1 << res) & quiet_mask) == 0)) { + switch(res) { + case INFO_ERR_IMPL: + (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) +{ + 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); + } +} + + +/* + * 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); +} + + +/* + * docmd - decode the command line and execute a command + */ +static void +docmd( + const char *cmdline + ) +{ + char *tokens[1+MAXARGS+2]; + struct parse pcmd; + int ntok; + static int i; + struct xcmd *xcmd; + + /* + * 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; + for (i = 0; i < MAXARGS && xcmd->arg[i] != NO; i++) { + if ((i+1) >= ntok) { + if (!(xcmd->arg[i] & OPT)) { + printusage(xcmd, stderr); + return; + } + break; + } + if ((xcmd->arg[i] & OPT) && (*tokens[i+1] == '>')) + break; + if (!getarg(tokens[i+1], (int)xcmd->arg[i], &pcmd.argval[i])) + return; + pcmd.nargs++; + } + + i++; + 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; + } + i = 1; /* flag we need a close */ + } else { + current_output = stdout; + i = 0; /* flag no close */ + } + + if (interactive && setjmp(interrupt_buf)) { + return; + } else { + jump = 1; + (xcmd->handler)(&pcmd, current_output); + jump = 0; + if (i) (void) fclose(current_output); + } +} + + +/* + * 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 + */ +static int +getarg( + char *str, + int code, + arg_v *argp + ) +{ + int isneg; + char *cp, *np; + static const char *digits = "0123456789"; + + switch (code & ~OPT) { + case NTP_STR: + argp->string = str; + break; + case ADD: + if (!getnetnum(str, &(argp->netnum), (char *)0)) { + return 0; + } + break; + case INT: + case 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) == UINT) { + (void) fprintf(stderr, + "***Value %s should be unsigned\n", str); + return 0; + } + argp->ival = -argp->ival; + } + break; + } + + return 1; +} + + +/* + * getnetnum - given a host name, return its net number + * and (optional) full name + */ +static int +getnetnum( + const char *hname, + u_int32 *num, + char *fullhost + ) +{ + struct hostent *hp; + + if (decodenetnum(hname, num)) { + if (fullhost != 0) { + (void) sprintf(fullhost, + "%u.%u.%u.%u", (u_int)((htonl(*num)>>24)&0xff), + (u_int)((htonl(*num)>>16)&0xff), (u_int)((htonl(*num)>>8)&0xff), + (u_int)(htonl(*num)&0xff)); + } + return 1; + } else if ((hp = gethostbyname(hname)) != 0) { + memmove((char *)num, hp->h_addr, sizeof(u_int32)); + if (fullhost != 0) + (void) strcpy(fullhost, hp->h_name); + 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( + u_int32 netnum + ) +{ + if (!showhostnames) + return numtoa(netnum); + if ((ntohl(netnum) & REFCLOCK_MASK) == REFCLOCK_ADDR) + return refnumtoa(netnum); + return numtohost(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 + ) +{ + int i; + int n; + struct xcmd *xcp; + char *cmd; + const char *cmdsort[100]; + int length[100]; + int maxlength; + int numperline; + static const char *spaces = " "; /* 20 spaces */ + + if (pcmd->nargs == 0) { + n = 0; + for (xcp = builtins; xcp->keyword != 0; xcp++) { + if (*(xcp->keyword) != '?') + cmdsort[n++] = xcp->keyword; + } + for (xcp = opcmds; xcp->keyword != 0; xcp++) + cmdsort[n++] = xcp->keyword; + +#ifdef QSORT_USES_VOID_P + qsort(cmdsort, n, sizeof(char *), helpsort); +#else + qsort((char *)cmdsort, n, sizeof(char *), helpsort); +#endif + + maxlength = 0; + for (i = 0; i < n; i++) { + length[i] = strlen(cmdsort[i]); + if (length[i] > maxlength) + maxlength = length[i]; + } + maxlength++; + numperline = 76 / maxlength; + + (void) fprintf(fp, "Commands available:\n"); + for (i = 0; i < n; i++) { + if ((i % numperline) == (numperline-1) + || i == (n-1)) + (void) fprintf(fp, "%s\n", cmdsort[i]); + else + (void) fprintf(fp, "%s%s", cmdsort[i], + spaces+20-maxlength+length[i]); + } + } else { + cmd = pcmd->argval[0].string; + n = findcmd(cmd, builtins, opcmds, &xcp); + if (n == 0) { + (void) fprintf(stderr, + "Command `%s' is unknown\n", cmd); + return; + } else if (n >= 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 + ) +{ + const char **name1 = (const char **)t1; + const char **name2 = (const char **)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 + ) +{ + register int i; + + (void) fprintf(fp, "usage: %s", xcp->keyword); + for (i = 0; i < MAXARGS && xcp->arg[i] != NO; i++) { + 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 + ) +{ + if (pcmd->nargs == 0) { + if (havehost) + (void) fprintf(fp, "current host is %s\n", currenthost); + else + (void) fprintf(fp, "no current host\n"); + } else if (openhost(pcmd->argval[0].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) + (void) fprintf(fp, "no keyid defined\n"); + else + (void) fprintf(fp, "keyid is %lu\n", (u_long)info_auth_keyid); + } else { + info_auth_keyid = pcmd->argval[0].uval; + } +} + + +/* + * 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" : "DES"); + else + switch (*(pcmd->argval[0].string)) { + case 'm': + case 'M': + info_auth_keytype = KEY_TYPE_MD5; + break; + + case 'd': + case 'D': + info_auth_keytype = KEY_TYPE_DES; + break; + + default: + fprintf(fp, "keytype must be 'md5' or 'des'\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); + } else { + pass = getpass((info_auth_keytype == KEY_TYPE_DES) + ? "DES Password: " + : "MD5 Password: " + ); + if (*pass == '\0') + (void) fprintf(fp, "Password unchanged\n"); + else + authusekey(info_auth_keyid, info_auth_keytype, + (u_char *)pass); + } +} + + +/* + * 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++ = c; + } + *p = '\0'; + if (fi != stdin) + fclose(fi); + return (u_int32)atoi(pbuf); +} diff --git a/contrib/ntp/ntpdc/ntpdc.h b/contrib/ntp/ntpdc/ntpdc.h new file mode 100644 index 0000000..8b35d4f --- /dev/null +++ b/contrib/ntp/ntpdc/ntpdc.h @@ -0,0 +1,59 @@ +/* + * ntpdc.h - definitions of interest to ntpdc + */ +#include "ntp_fp.h" +#include "ntp.h" +#include "ntp_request.h" +#include "ntp_string.h" +#include "ntp_malloc.h" + +/* + * Maximum number of arguments + */ +#define MAXARGS 4 + +/* + * Flags for forming descriptors. + */ +#define OPT 0x80 /* this argument is optional, or'd with type */ + +#define NO 0x0 +#define NTP_STR 0x1 /* string argument */ +#define UINT 0x2 /* unsigned integer */ +#define INT 0x3 /* signed integer */ +#define ADD 0x4 /* IP network address */ + +/* + * Arguments are returned in a union + */ +typedef union { + char *string; + long ival; + u_long uval; + u_int32 netnum; +} arg_v; + +/* + * Structure for passing parsed command line + */ +struct parse { + char *keyword; + arg_v argval[MAXARGS]; + int nargs; +}; + +/* + * ntpdc includes a command parser which could charitably be called + * crude. The following structure is used to define the command + * syntax. + */ +struct xcmd { + const char *keyword; /* command key word */ + void (*handler) P((struct parse *, FILE *)); /* command handler */ + u_char arg[MAXARGS]; /* descriptors for arguments */ + const char *desc[MAXARGS]; /* descriptions for arguments */ + const char *comment; +}; + +extern int doquery P((int, int, int, int, int, char *, int *, int *, char **, int)); +extern char * nntohost P((u_int32)); diff --git a/contrib/ntp/ntpdc/ntpdc_ops.c b/contrib/ntp/ntpdc/ntpdc_ops.c new file mode 100644 index 0000000..c4b13e6 --- /dev/null +++ b/contrib/ntp/ntpdc/ntpdc_ops.c @@ -0,0 +1,2471 @@ +/* + * ntpdc_ops.c - subroutines which are called to perform operations by ntpdc + */ + +#ifdef HAVE_CONFIG_H +# include <config.h> +#endif + +#include <stdio.h> +#include <ctype.h> +#include <sys/types.h> +#include <sys/time.h> +#ifdef HAVE_SYS_TIMEX_H +# include <sys/timex.h> +#endif +#include <netdb.h> +#if !defined(__bsdi__) && !defined(apollo) +#include <netinet/in.h> +#endif + +#include "ntpdc.h" +#include "ntp_control.h" +#include "ntp_refclock.h" +#include "ntp_stdlib.h" + +#include <arpa/inet.h> + +/* + * Declarations for command handlers in here + */ +static int checkitems P((int, FILE *)); +static int checkitemsize P((int, int)); +static int check1item P((int, FILE *)); +static void peerlist P((struct parse *, FILE *)); +static void peers P((struct parse *, FILE *)); +static void doconfig P((struct parse *pcmd, FILE *fp, int mode, int refc)); +static void dmpeers P((struct parse *, FILE *)); +static void dopeers P((struct parse *, FILE *, int)); +static void printpeer P((struct info_peer *, FILE *)); +static void showpeer P((struct parse *, FILE *)); +static void peerstats P((struct parse *, FILE *)); +static void loopinfo P((struct parse *, FILE *)); +static void sysinfo P((struct parse *, FILE *)); +static void sysstats P((struct parse *, FILE *)); +static void iostats P((struct parse *, FILE *)); +static void memstats P((struct parse *, FILE *)); +static void timerstats P((struct parse *, FILE *)); +static void addpeer P((struct parse *, FILE *)); +static void addserver P((struct parse *, FILE *)); +static void addrefclock P((struct parse *, FILE *)); +static void broadcast P((struct parse *, FILE *)); +static void doconfig P((struct parse *, FILE *, int, int)); +static void unconfig P((struct parse *, FILE *)); +static void set P((struct parse *, FILE *)); +static void sys_clear P((struct parse *, FILE *)); +static void doset P((struct parse *, FILE *, int)); +static void reslist P((struct parse *, FILE *)); +static void new_restrict P((struct parse *, FILE *)); +static void unrestrict P((struct parse *, FILE *)); +static void delrestrict P((struct parse *, FILE *)); +static void do_restrict P((struct parse *, FILE *, int)); +static void monlist P((struct parse *, FILE *)); +static void reset P((struct parse *, FILE *)); +static void preset P((struct parse *, FILE *)); +static void readkeys P((struct parse *, FILE *)); +static void trustkey P((struct parse *, FILE *)); +static void untrustkey P((struct parse *, FILE *)); +static void do_trustkey P((struct parse *, FILE *, int)); +static void authinfo P((struct parse *, FILE *)); +static void traps P((struct parse *, FILE *)); +static void addtrap P((struct parse *, FILE *)); +static void clrtrap P((struct parse *, FILE *)); +static void do_addclr_trap P((struct parse *, FILE *, int)); +static void requestkey P((struct parse *, FILE *)); +static void controlkey P((struct parse *, FILE *)); +static void do_changekey P((struct parse *, FILE *, int)); +static void ctlstats P((struct parse *, FILE *)); +static void clockstat P((struct parse *, FILE *)); +static void fudge P((struct parse *, FILE *)); +static void clkbug P((struct parse *, FILE *)); +static void kerninfo P((struct parse *, FILE *)); + +/* + * Commands we understand. Ntpdc imports this. + */ +struct xcmd opcmds[] = { + { "listpeers", peerlist, { NO, NO, NO, NO }, + { "", "", "", "" }, + "display list of peers the server knows about" }, + { "peers", peers, { NO, NO, NO, NO }, + { "", "", "", "" }, + "display peer summary information" }, + { "dmpeers", dmpeers, { NO, NO, NO, NO }, + { "", "", "", "" }, + "display peer summary info the way Dave Mills likes it" }, + { "showpeer", showpeer, { ADD, OPT|ADD, OPT|ADD, OPT|ADD }, + { "peer_address", "peer2_addr", "peer3_addr", "peer4_addr" }, + "display detailed information for one or more peers" }, + { "pstats", peerstats, { ADD, OPT|ADD, OPT|ADD, OPT|ADD }, + { "peer_address", "peer2_addr", "peer3_addr", "peer4_addr" }, + "display statistical information for one or more peers" }, + { "loopinfo", loopinfo, { OPT|NTP_STR, NO, NO, NO }, + { "oneline|multiline", "", "", "" }, + "display loop filter information" }, + { "sysinfo", sysinfo, { NO, NO, NO, NO }, + { "", "", "", "" }, + "display local server information" }, + { "sysstats", sysstats, { NO, NO, NO, NO }, + { "", "", "", "" }, + "display local server statistics" }, + { "memstats", memstats, { NO, NO, NO, NO }, + { "", "", "", "" }, + "display peer memory usage statistics" }, + { "iostats", iostats, { NO, NO, NO, NO }, + { "", "", "", "" }, + "display I/O subsystem statistics" }, + { "timerstats", timerstats, { NO, NO, NO, NO }, + { "", "", "", "" }, + "display event timer subsystem statistics" }, + { "addpeer", addpeer, { ADD, OPT|UINT, OPT|UINT, OPT|NTP_STR }, + { "addr", "keyid", "version", "minpoll|prefer" }, + "configure a new peer association" }, + { "addserver", addserver, { ADD, OPT|UINT, OPT|UINT, OPT|NTP_STR }, + { "addr", "keyid", "version", "minpoll|prefer" }, + "configure a new server" }, + { "addrefclock",addrefclock, { ADD, OPT|UINT, OPT|NTP_STR, OPT|NTP_STR }, + { "addr", "mode", "minpoll|prefer", "minpoll|prefer" }, + "configure a new server" }, + { "broadcast", broadcast, { ADD, OPT|UINT, OPT|UINT, OPT|NTP_STR }, + { "addr", "keyid", "version", "minpoll" }, + "configure broadcasting time service" }, + { "unconfig", unconfig, { ADD, OPT|ADD, OPT|ADD, OPT|ADD }, + { "peer_address", "peer2_addr", "peer3_addr", "peer4_addr" }, + "unconfigure existing peer assocations" }, + { "enable", set, { NTP_STR, OPT|NTP_STR, OPT|NTP_STR, OPT|NTP_STR }, + { "auth|bclient|monitor|pll|kernel|stats", "...", "...", "..." }, + "set a system flag (auth, bclient, monitor, pll, kernel, stats)" }, + { "disable", sys_clear, { NTP_STR, OPT|NTP_STR, OPT|NTP_STR, OPT|NTP_STR }, + { "auth|bclient|monitor|pll|kernel|stats", "...", "...", "..." }, + "clear a system flag (auth, bclient, monitor, pll, kernel, stats)" }, + { "reslist", reslist, { NO, NO, NO, NO }, + { "", "", "", "" }, + "display the server's restrict list" }, + { "restrict", new_restrict, { ADD, ADD, NTP_STR, OPT|NTP_STR }, + { "address", "mask", + "ntpport|ignore|noserve|notrust|noquery|nomodify|nopeer", + "..." }, + "create restrict entry/add flags to entry" }, + { "unrestrict", unrestrict, { ADD, ADD, NTP_STR, OPT|NTP_STR }, + { "address", "mask", + "ntpport|ignore|noserve|notrust|noquery|nomodify|nopeer", + "..." }, + "remove flags from a restrict entry" }, + { "delrestrict", delrestrict, { ADD, ADD, OPT|NTP_STR, NO }, + { "address", "mask", "ntpport", "" }, + "delete a restrict entry" }, + { "monlist", monlist, { OPT|INT, NO, NO, NO }, + { "version", "", "", "" }, + "display data the server's monitor routines have collected" }, + { "reset", reset, { NTP_STR, OPT|NTP_STR, OPT|NTP_STR, OPT|NTP_STR }, + { "io|sys|mem|timer|auth|allpeers", "...", "...", "..." }, + "reset various subsystem statistics counters" }, + { "preset", preset, { ADD, OPT|ADD, OPT|ADD, OPT|ADD }, + { "peer_address", "peer2_addr", "peer3_addr", "peer4_addr" }, + "reset stat counters associated with particular peer(s)" }, + { "readkeys", readkeys, { NO, NO, NO, NO }, + { "", "", "", "" }, + "request a reread of the keys file and re-init of system keys" }, + { "trustedkey", trustkey, { UINT, OPT|UINT, OPT|UINT, OPT|UINT }, + { "keyid", "keyid", "keyid", "keyid" }, + "add one or more key ID's to the trusted list" }, + { "untrustedkey", untrustkey, { UINT, OPT|UINT, OPT|UINT, OPT|UINT }, + { "keyid", "keyid", "keyid", "keyid" }, + "remove one or more key ID's from the trusted list" }, + { "authinfo", authinfo, { NO, NO, NO, NO }, + { "", "", "", "" }, + "display the state of the authentication code" }, + { "traps", traps, { NO, NO, NO, NO }, + { "", "", "", "" }, + "display the traps set in the server" }, + { "addtrap", addtrap, { ADD, OPT|UINT, OPT|ADD, NO }, + { "address", "port", "interface", "" }, + "configure a trap in the server" }, + { "clrtrap", clrtrap, { ADD, OPT|UINT, OPT|ADD, NO }, + { "address", "port", "interface", "" }, + "remove a trap (configured or otherwise) from the server" }, + { "requestkey", requestkey, { UINT, NO, NO, NO }, + { "keyid", "", "", "" }, + "change the keyid the server uses to authenticate requests" }, + { "controlkey", controlkey, { UINT, NO, NO, NO }, + { "keyid", "", "", "" }, + "change the keyid the server uses to authenticate control messages" }, + { "ctlstats", ctlstats, { NO, NO, NO, NO }, + { "", "", "", "" }, + "display packet count statistics from the control module" }, + { "clockstat", clockstat, { ADD, OPT|ADD, OPT|ADD, OPT|ADD }, + { "address", "address", "address", "address" }, + "display clock status information" }, + { "fudge", fudge, { ADD, NTP_STR, NTP_STR, NO }, + { "address", "time1|time2|val1|val2|flags", "value", "" }, + "set/change one of a clock's fudge factors" }, + { "clkbug", clkbug, { ADD, OPT|ADD, OPT|ADD, OPT|ADD }, + { "address", "address", "address", "address" }, + "display clock debugging information" }, + { "kerninfo", kerninfo, { NO, NO, NO, NO }, + { "", "", "", "" }, + "display the kernel pll/pps variables" }, + + { 0, 0, { NO, NO, NO, NO }, + { "", "", "", "" }, "" } +}; + + +/* + * Imported from ntpdc.c + */ +extern int showhostnames; +extern struct servent *server_entry; + +/* + * For quick string comparisons + */ +#define STREQ(a, b) (*(a) == *(b) && strcmp((a), (b)) == 0) + + +/* + * checkitems - utility to print a message if no items were returned + */ +static int +checkitems( + int items, + FILE *fp + ) +{ + if (items == 0) { + (void) fprintf(fp, "No data returned in response to query\n"); + return 0; + } + return 1; +} + + +/* + * checkitemsize - utility to print a message if the item size is wrong + */ +static int +checkitemsize( + int itemsize, + int expected + ) +{ + if (itemsize != expected) { + (void) fprintf(stderr, + "***Incorrect item size returned by remote host (%d should be %d)\n", + itemsize, expected); + return 0; + } + return 1; +} + + +/* + * check1item - check to make sure we have exactly one item + */ +static int +check1item( + int items, + FILE *fp + ) +{ + if (items == 0) { + (void) fprintf(fp, "No data returned in response to query\n"); + return 0; + } + if (items > 1) { + (void) fprintf(fp, "Expected one item in response, got %d\n", + items); + return 0; + } + return 1; +} + + + +/* + * peerlist - get a short list of peers + */ +/*ARGSUSED*/ +static void +peerlist( + struct parse *pcmd, + FILE *fp + ) +{ + struct info_peer_list *plist; + int items; + int itemsize; + int res; + + res = doquery(IMPL_XNTPD, REQ_PEER_LIST, 0, 0, 0, (char *)NULL, &items, + &itemsize, (char **)&plist, 0); + + if (res != 0 && items == 0) + return; + + if (!checkitems(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_peer_list))) + return; + + while (items > 0) { + (void) fprintf(fp, "%-9s %s\n", modetoa(plist->hmode), + nntohost(plist->address)); + plist++; + items--; + } +} + + +/* + * peers - show peer summary + */ +static void +peers( + struct parse *pcmd, + FILE *fp + ) +{ + dopeers(pcmd, fp, 0); +} + +/* + * dmpeers - show peer summary, Dave Mills style + */ +static void +dmpeers( + struct parse *pcmd, + FILE *fp + ) +{ + dopeers(pcmd, fp, 1); +} + + +/* + * peers - show peer summary + */ +/*ARGSUSED*/ +static void +dopeers( + struct parse *pcmd, + FILE *fp, + int dmstyle + ) +{ + struct info_peer_summary *plist; + int items; + int itemsize; + int ntp_poll; + int res; + int c; + l_fp tempts; + + res = doquery(IMPL_XNTPD, REQ_PEER_LIST_SUM, 0, 0, 0, (char *)NULL, + &items, &itemsize, (char **)&plist, 0); + + if (res != 0 && items == 0) + return; + + if (!checkitems(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_peer_summary))) + return; + + (void) fprintf(fp, + " remote local st poll reach delay offset disp\n"); + (void) fprintf(fp, + "=======================================================================\n"); + while (items > 0) { + if (!dmstyle) { + if (plist->flags & INFO_FLAG_SYSPEER) + c = '*'; + else if (plist->hmode == MODE_ACTIVE) + c = '+'; + else if (plist->hmode == MODE_PASSIVE) + c = '-'; + else if (plist->hmode == MODE_CLIENT) + c = '='; + else if (plist->hmode == MODE_BROADCAST) + c = '^'; + else if (plist->hmode == MODE_BCLIENT) + c = '~'; + else + c = ' '; + } else { + if (plist->flags & INFO_FLAG_SYSPEER) + c = '*'; + else if (plist->flags & INFO_FLAG_SHORTLIST) + c = '+'; + else if (plist->flags & INFO_FLAG_SEL_CANDIDATE) + c = '.'; + else + c = ' '; + } + NTOHL_FP(&(plist->offset), &tempts); + ntp_poll = 1<<max(min3(plist->ppoll, plist->hpoll, NTP_MAXPOLL), + NTP_MINPOLL); + (void) fprintf(fp, + "%c%-15.15s %-15.15s %2d %4d %3o %7.7s %9.9s %7.7s\n", + c, nntohost(plist->srcadr), + numtoa(plist->dstadr), + plist->stratum, ntp_poll, plist->reach, + fptoa(NTOHS_FP(plist->delay), 5), + lfptoa(&tempts, 6), + ufptoa(NTOHS_FP(plist->dispersion), 5)); + + plist++; + items--; + } +} + +/* Convert a refid & stratum (in host order) to a string */ +static char* +refid_string( + u_int32 refid, + int stratum + ) +{ + if (stratum <= 1) { + static char junk[5]; + junk[4] = 0; + memmove(junk, (char *)&refid, 4); + return junk; + } + + return numtoa(refid); +} + +/* + * printpeer - print detail information for a peer + */ +static void +printpeer( + register struct info_peer *pp, + FILE *fp + ) +{ + register int i; + const char *str; + l_fp tempts; + + (void) fprintf(fp, "remote %s, local %s\n", + numtoa(pp->srcadr), numtoa(pp->dstadr)); + + (void) fprintf(fp, "hmode %s, pmode %s, stratum %d, precision %d\n", + modetoa(pp->hmode), modetoa(pp->pmode), + pp->stratum, pp->precision); + + (void) fprintf(fp, + "leap %c%c, refid [%s], rootdistance %s, rootdispersion %s\n", + pp->leap & 0x2 ? '1' : '0', + pp->leap & 0x1 ? '1' : '0', + refid_string(pp->refid, pp->stratum), fptoa(NTOHS_FP(pp->rootdelay), 5), + ufptoa(NTOHS_FP(pp->rootdispersion), 5)); + + (void) fprintf(fp, + "ppoll %d, hpoll %d, keyid %lu, version %d, association %u\n", + pp->ppoll, pp->hpoll, (u_long)pp->keyid, pp->version, ntohs(pp->associd)); + + (void) fprintf(fp, + "valid %d, reach %03o, unreach %d, flash 0x%04x, ", + pp->valid, pp->reach, pp->unreach, pp->flash2); + + (void) fprintf(fp, "boffset %s, ttl/mode %d\n", + fptoa(NTOHS_FP(pp->estbdelay), 5), pp->ttl); + + (void) fprintf(fp, "timer %lds, flags", (long)ntohl(pp->timer)); + if (pp->flags == 0) { + (void) fprintf(fp, " none\n"); + } else { + str = ""; + if (pp->flags & INFO_FLAG_SYSPEER) { + (void) fprintf(fp, " system_peer"); + str = ","; + } + if (pp->flags & INFO_FLAG_CONFIG) { + (void) fprintf(fp, "%s config", str); + str = ","; + } + if (pp->flags & INFO_FLAG_REFCLOCK) { + (void) fprintf(fp, "%s refclock", str); + str = ","; + } + if (pp->flags & INFO_FLAG_AUTHENABLE) { + (void) fprintf(fp, "%s auth", str); + str = ","; + } + if (pp->flags & INFO_FLAG_BCLIENT) { + (void) fprintf(fp, "%s bclient", str); + str = ","; + } + if (pp->flags & INFO_FLAG_PREFER) { + (void) fprintf(fp, "%s prefer", str); + str = ","; + } + if (pp->flags & INFO_FLAG_BURST) { + (void) fprintf(fp, "%s burst", str); + } + (void) fprintf(fp, "\n"); + } + + NTOHL_FP(&pp->reftime, &tempts); + (void) fprintf(fp, "reference time: %s\n", + prettydate(&tempts)); + NTOHL_FP(&pp->org, &tempts); + (void) fprintf(fp, "originate timestamp: %s\n", + prettydate(&tempts)); + NTOHL_FP(&pp->rec, &tempts); + (void) fprintf(fp, "receive timestamp: %s\n", + prettydate(&tempts)); + NTOHL_FP(&pp->xmt, &tempts); + (void) fprintf(fp, "transmit timestamp: %s\n", + prettydate(&tempts)); + + (void) fprintf(fp, "filter delay: "); + for (i = 0; i < NTP_SHIFT; i++) { + (void) fprintf(fp, " %-8.8s", + fptoa(NTOHS_FP(pp->filtdelay[i]), 5)); + if (i == (NTP_SHIFT>>1)-1) + (void) fprintf(fp, "\n "); + } + (void) fprintf(fp, "\n"); + + (void) fprintf(fp, "filter offset:"); + for (i = 0; i < NTP_SHIFT; i++) { + NTOHL_FP(&pp->filtoffset[i], &tempts); + (void) fprintf(fp, " %-8.8s", lfptoa(&tempts, 6)); + if (i == (NTP_SHIFT>>1)-1) + (void) fprintf(fp, "\n "); + } + (void) fprintf(fp, "\n"); + + (void) fprintf(fp, "filter order: "); + for (i = 0; i < NTP_SHIFT; i++) { + (void) fprintf(fp, " %-8d", pp->order[i]); + if (i == (NTP_SHIFT>>1)-1) + (void) fprintf(fp, "\n "); + } + (void) fprintf(fp, "\n"); + + + NTOHL_FP(&pp->offset, &tempts); + (void) fprintf(fp, + "offset %s, delay %s, error bound %s, filter error %s\n", + lfptoa(&tempts, 6), fptoa(NTOHS_FP(pp->delay), 5), + ufptoa(NTOHS_FP(pp->dispersion), 5), + ufptoa(NTOHS_FP(pp->selectdisp), 5)); +} + + +/* + * showpeer - show detailed information for a peer + */ +static void +showpeer( + struct parse *pcmd, + FILE *fp + ) +{ + struct info_peer *pp; + /* 4 is the maximum number of peers which will fit in a packet */ + struct info_peer_list plist[min(MAXARGS, 4)]; + int qitems; + int items; + int itemsize; + int res; + + for (qitems = 0; qitems < min(pcmd->nargs, 4); qitems++) { + plist[qitems].address = pcmd->argval[qitems].netnum; + plist[qitems].port = server_entry->s_port; + plist[qitems].hmode = plist[qitems].flags = 0; + } + + res = doquery(IMPL_XNTPD, REQ_PEER_INFO, 0, qitems, + sizeof(struct info_peer_list), (char *)plist, &items, + &itemsize, (char **)&pp, 0); + + if (res != 0 && items == 0) + return; + + if (!checkitems(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_peer))) + return; + + while (items-- > 0) { + printpeer(pp, fp); + if (items > 0) + (void) fprintf(fp, "\n"); + pp++; + } +} + + +/* + * peerstats - return statistics for a peer + */ +static void +peerstats( + struct parse *pcmd, + FILE *fp + ) +{ + struct info_peer_stats *pp; + /* 4 is the maximum number of peers which will fit in a packet */ + struct info_peer_list plist[min(MAXARGS, 4)]; + int qitems; + int items; + int itemsize; + int res; + + for (qitems = 0; qitems < min(pcmd->nargs, 4); qitems++) { + plist[qitems].address = pcmd->argval[qitems].netnum; + plist[qitems].port = server_entry->s_port; + plist[qitems].hmode = plist[qitems].flags = 0; + } + + res = doquery(IMPL_XNTPD, REQ_PEER_STATS, 0, qitems, + sizeof(struct info_peer_list), (char *)plist, &items, + &itemsize, (char **)&pp, 0); + + if (res != 0 && items == 0) + return; + + if (!checkitems(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_peer_stats))) + return; + + while (items-- > 0) { + (void) fprintf(fp, "remote host: %s\n", + nntohost(pp->srcadr)); + (void) fprintf(fp, "local interface: %s\n", + numtoa(pp->dstadr)); + (void) fprintf(fp, "time last received: %lds\n", + (long)ntohl(pp->timereceived)); + (void) fprintf(fp, "time until next send: %lds\n", + (long)ntohl(pp->timetosend)); + (void) fprintf(fp, "reachability change: %lds\n", + (long)ntohl(pp->timereachable)); + (void) fprintf(fp, "packets sent: %ld\n", + (long)ntohl(pp->sent)); + (void) fprintf(fp, "packets received: %ld\n", + (long)ntohl(pp->processed)); + (void) fprintf(fp, "bad authentication: %ld\n", + (long)ntohl(pp->badauth)); + (void) fprintf(fp, "bogus origin: %ld\n", + (long)ntohl(pp->bogusorg)); + (void) fprintf(fp, "duplicate: %ld\n", + (long)ntohl(pp->oldpkt)); + (void) fprintf(fp, "bad dispersion: %ld\n", + (long)ntohl(pp->seldisp)); + (void) fprintf(fp, "bad reference time: %ld\n", + (long)ntohl(pp->selbroken)); + (void) fprintf(fp, "candidate order: %d\n", + (int)pp->candidate); + if (items > 0) + (void) fprintf(fp, "\n"); + pp++; + } +} + + +/* + * loopinfo - show loop filter information + */ +static void +loopinfo( + struct parse *pcmd, + FILE *fp + ) +{ + struct info_loop *il; + int items; + int itemsize; + int oneline = 0; + int res; + l_fp tempts; + + if (pcmd->nargs > 0) { + if (STREQ(pcmd->argval[0].string, "oneline")) + oneline = 1; + else if (STREQ(pcmd->argval[0].string, "multiline")) + oneline = 0; + else { + (void) fprintf(stderr, "How many lines?\n"); + return; + } + } + + res = doquery(IMPL_XNTPD, REQ_LOOP_INFO, 0, 0, 0, (char *)NULL, + &items, &itemsize, (char **)&il, 0); + + if (res != 0 && items == 0) + return; + + if (!check1item(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_loop))) + return; + + if (oneline) { + l_fp temp2ts; + + NTOHL_FP(&il->last_offset, &tempts); + NTOHL_FP(&il->drift_comp, &temp2ts); + + (void) fprintf(fp, + "offset %s, frequency %s, time_const %ld, watchdog %ld\n", + lfptoa(&tempts, 6), + lfptoa(&temp2ts, 3), + (u_long)ntohl(il->compliance), + (u_long)ntohl(il->watchdog_timer)); + } else { + NTOHL_FP(&il->last_offset, &tempts); + (void) fprintf(fp, "offset: %s s\n", + lfptoa(&tempts, 6)); + NTOHL_FP(&il->drift_comp, &tempts); + (void) fprintf(fp, "frequency: %s ppm\n", + lfptoa(&tempts, 3)); + (void) fprintf(fp, "poll adjust: %ld\n", + (u_long)ntohl(il->compliance)); + (void) fprintf(fp, "watchdog timer: %ld s\n", + (u_long)ntohl(il->watchdog_timer)); + } +} + + +/* + * sysinfo - show current system state + */ +/*ARGSUSED*/ +static void +sysinfo( + struct parse *pcmd, + FILE *fp + ) +{ + struct info_sys *is; + int items; + int itemsize; + int res; + l_fp tempts; + + res = doquery(IMPL_XNTPD, REQ_SYS_INFO, 0, 0, 0, (char *)NULL, + &items, &itemsize, (char **)&is, 0); + + if (res != 0 && items == 0) + return; + + if (!check1item(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_sys))) + return; + + (void) fprintf(fp, "system peer: %s\n", nntohost(is->peer)); + (void) fprintf(fp, "system peer mode: %s\n", modetoa(is->peer_mode)); + (void) fprintf(fp, "leap indicator: %c%c\n", + is->leap & 0x2 ? '1' : '0', + is->leap & 0x1 ? '1' : '0'); + (void) fprintf(fp, "stratum: %d\n", (int)is->stratum); + (void) fprintf(fp, "precision: %d\n", (int)is->precision); + (void) fprintf(fp, "root distance: %s s\n", + fptoa(NTOHS_FP(is->rootdelay), 5)); + (void) fprintf(fp, "root dispersion: %s s\n", + ufptoa(NTOHS_FP(is->rootdispersion), 5)); + (void) fprintf(fp, "reference ID: [%s]\n", + refid_string(is->refid, is->stratum)); + NTOHL_FP(&is->reftime, &tempts); + (void) fprintf(fp, "reference time: %s\n", prettydate(&tempts)); + + (void) fprintf(fp, "system flags: "); + if ((is->flags & (INFO_FLAG_BCLIENT | INFO_FLAG_AUTHENABLE | + INFO_FLAG_NTP | INFO_FLAG_KERNEL| INFO_FLAG_PLL_SYNC | + INFO_FLAG_PPS_SYNC | INFO_FLAG_MONITOR | INFO_FLAG_FILEGEN)) == 0) { + (void) fprintf(fp, "none\n"); + } else { + if (is->flags & INFO_FLAG_BCLIENT) + (void) fprintf(fp, "bclient "); + if (is->flags & INFO_FLAG_AUTHENTICATE) + (void) fprintf(fp, "auth "); + if (is->flags & INFO_FLAG_MONITOR) + (void) fprintf(fp, "monitor "); + if (is->flags & INFO_FLAG_NTP) + (void) fprintf(fp, "ntp "); + if (is->flags & INFO_FLAG_KERNEL) + (void) fprintf(fp, "kernel "); + if (is->flags & INFO_FLAG_FILEGEN) + (void) fprintf(fp, "stats "); + if (is->flags & INFO_FLAG_PLL_SYNC) + (void) fprintf(fp, "kernel_sync "); + if (is->flags & INFO_FLAG_PPS_SYNC) + (void) fprintf(fp, "pps_sync "); + (void) fprintf(fp, "\n"); + } + (void) fprintf(fp, "jitter: %s s\n", + fptoa(ntohl(is->frequency), 6)); + (void) fprintf(fp, "stability: %s ppm\n", + ufptoa(ntohl(is->stability), 3)); + (void) fprintf(fp, "broadcastdelay: %s s\n", + fptoa(NTOHS_FP(is->bdelay), 6)); + NTOHL_FP(&is->authdelay, &tempts); + (void) fprintf(fp, "authdelay: %s s\n", lfptoa(&tempts, 6)); +} + + +/* + * sysstats - print system statistics + */ +/*ARGSUSED*/ +static void +sysstats( + struct parse *pcmd, + FILE *fp + ) +{ + struct info_sys_stats *ss; + int items; + int itemsize; + int res; + + res = doquery(IMPL_XNTPD, REQ_SYS_STATS, 0, 0, 0, (char *)NULL, + &items, &itemsize, (char **)&ss, 0); + + if (res != 0 && items == 0) + return; + + if (!check1item(items, fp)) + return; + + if (itemsize != sizeof(struct info_sys_stats) && + itemsize != sizeof(struct old_info_sys_stats)) { + /* issue warning according to new structure size */ + checkitemsize(itemsize, sizeof(struct info_sys_stats)); + return; + } + + (void) fprintf(fp, "system uptime: %ld\n", + (u_long)ntohl(ss->timeup)); + (void) fprintf(fp, "time since reset: %ld\n", + (u_long)ntohl(ss->timereset)); + (void) fprintf(fp, "bad stratum in packet: %ld\n", + (u_long)ntohl(ss->badstratum)); + (void) fprintf(fp, "old version packets: %ld\n", + (u_long)ntohl(ss->oldversionpkt)); + (void) fprintf(fp, "new version packets: %ld\n", + (u_long)ntohl(ss->newversionpkt)); + (void) fprintf(fp, "unknown version number: %ld\n", + (u_long)ntohl(ss->unknownversion)); + (void) fprintf(fp, "bad packet length: %ld\n", + (u_long)ntohl(ss->badlength)); + (void) fprintf(fp, "packets processed: %ld\n", + (u_long)ntohl(ss->processed)); + (void) fprintf(fp, "bad authentication: %ld\n", + (u_long)ntohl(ss->badauth)); + if (itemsize != sizeof(struct info_sys_stats)) + return; + + (void) fprintf(fp, "limitation rejects: %ld\n", + (u_long)ntohl(ss->limitrejected)); +} + + + +/* + * iostats - print I/O statistics + */ +/*ARGSUSED*/ +static void +iostats( + struct parse *pcmd, + FILE *fp + ) +{ + struct info_io_stats *io; + int items; + int itemsize; + int res; + + res = doquery(IMPL_XNTPD, REQ_IO_STATS, 0, 0, 0, (char *)NULL, + &items, &itemsize, (char **)&io, 0); + + if (res != 0 && items == 0) + return; + + if (!check1item(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_io_stats))) + return; + + (void) fprintf(fp, "time since reset: %ld\n", + (u_long)ntohl(io->timereset)); + (void) fprintf(fp, "receive buffers: %d\n", + ntohs(io->totalrecvbufs)); + (void) fprintf(fp, "free receive buffers: %d\n", + ntohs(io->freerecvbufs)); + (void) fprintf(fp, "used receive buffers: %d\n", + ntohs(io->fullrecvbufs)); + (void) fprintf(fp, "low water refills: %d\n", + ntohs(io->lowwater)); + (void) fprintf(fp, "dropped packets: %ld\n", + (u_long)ntohl(io->dropped)); + (void) fprintf(fp, "ignored packets: %ld\n", + (u_long)ntohl(io->ignored)); + (void) fprintf(fp, "received packets: %ld\n", + (u_long)ntohl(io->received)); + (void) fprintf(fp, "packets sent: %ld\n", + (u_long)ntohl(io->sent)); + (void) fprintf(fp, "packets not sent: %ld\n", + (u_long)ntohl(io->notsent)); + (void) fprintf(fp, "interrupts handled: %ld\n", + (u_long)ntohl(io->interrupts)); + (void) fprintf(fp, "received by int: %ld\n", + (u_long)ntohl(io->int_received)); +} + + +/* + * memstats - print peer memory statistics + */ +/*ARGSUSED*/ +static void +memstats( + struct parse *pcmd, + FILE *fp + ) +{ + struct info_mem_stats *mem; + int i; + int items; + int itemsize; + int res; + + res = doquery(IMPL_XNTPD, REQ_MEM_STATS, 0, 0, 0, (char *)NULL, + &items, &itemsize, (char **)&mem, 0); + + if (res != 0 && items == 0) + return; + + if (!check1item(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_mem_stats))) + return; + + (void) fprintf(fp, "time since reset: %ld\n", + (u_long)ntohl(mem->timereset)); + (void) fprintf(fp, "total peer memory: %d\n", + ntohs(mem->totalpeermem)); + (void) fprintf(fp, "free peer memory: %d\n", + ntohs(mem->freepeermem)); + (void) fprintf(fp, "calls to findpeer: %ld\n", + (u_long)ntohl(mem->findpeer_calls)); + (void) fprintf(fp, "new peer allocations: %ld\n", + (u_long)ntohl(mem->allocations)); + (void) fprintf(fp, "peer demobilizations: %ld\n", + (u_long)ntohl(mem->demobilizations)); + + (void) fprintf(fp, "hash table counts: "); + for (i = 0; i < HASH_SIZE; i++) { + (void) fprintf(fp, "%4d", (int)mem->hashcount[i]); + if ((i % 8) == 7 && i != (HASH_SIZE-1)) { + (void) fprintf(fp, "\n "); + } + } + (void) fprintf(fp, "\n"); +} + + + +/* + * timerstats - print timer statistics + */ +/*ARGSUSED*/ +static void +timerstats( + struct parse *pcmd, + FILE *fp + ) +{ + struct info_timer_stats *tim; + int items; + int itemsize; + int res; + + res = doquery(IMPL_XNTPD, REQ_TIMER_STATS, 0, 0, 0, (char *)NULL, + &items, &itemsize, (char **)&tim, 0); + + if (res != 0 && items == 0) + return; + + if (!check1item(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_timer_stats))) + return; + + (void) fprintf(fp, "time since reset: %ld\n", + (u_long)ntohl(tim->timereset)); + (void) fprintf(fp, "alarms handled: %ld\n", + (u_long)ntohl(tim->alarms)); + (void) fprintf(fp, "alarm overruns: %ld\n", + (u_long)ntohl(tim->overflows)); + (void) fprintf(fp, "calls to transmit: %ld\n", + (u_long)ntohl(tim->xmtcalls)); +} + + +/* + * addpeer - configure an active mode association + */ +static void +addpeer( + struct parse *pcmd, + FILE *fp + ) +{ + doconfig(pcmd, fp, MODE_ACTIVE, 0); +} + + +/* + * addserver - configure a client mode association + */ +static void +addserver( + struct parse *pcmd, + FILE *fp + ) +{ + doconfig(pcmd, fp, MODE_CLIENT, 0); +} + +/* + * addrefclock - configure a reference clock association + */ +static void +addrefclock( + struct parse *pcmd, + FILE *fp + ) +{ + doconfig(pcmd, fp, MODE_CLIENT, 1); +} + +/* + * broadcast - configure a broadcast mode association + */ +static void +broadcast( + struct parse *pcmd, + FILE *fp + ) +{ + doconfig(pcmd, fp, MODE_BROADCAST, 0); +} + + +/* + * config - configure a new peer association + */ +static void +doconfig( + struct parse *pcmd, + FILE *fp, + int mode, + int refc + ) +{ + struct conf_peer cpeer; + int items; + int itemsize; + char *dummy; + u_long keyid; + u_int version; + u_char minpoll; + u_int flags; + u_char cmode; + int res; + + keyid = 0; + version = NTP_OLDVERSION + 1; + flags = 0; + res = 0; + cmode = 0; + minpoll = NTP_MINDPOLL; + + items = pcmd->nargs; + + if (refc) { + if (pcmd->nargs > 1) { + cmode = (u_char) pcmd->argval[1].uval; + items = 2; + } + } else { + if (pcmd->nargs > 1) { + keyid = pcmd->argval[1].uval; + if (keyid > 0) { + flags |= CONF_FLAG_AUTHENABLE; + } + if (pcmd->nargs > 2) { + version = (u_int)pcmd->argval[2].uval; + if (version > NTP_VERSION || + version < NTP_OLDVERSION) { + (void)fprintf(fp, + "invalid version number %u\n", + version); + res++; + } + items = 3; + } + } + } + + while (pcmd->nargs > items) { + if (STREQ(pcmd->argval[items].string, "prefer")) + flags |= CONF_FLAG_PREFER; + else if (STREQ(pcmd->argval[items].string, "burst")) + flags |= CONF_FLAG_BURST; + else { + long val; + if (!atoint(pcmd->argval[items].string, &val)) { + (void) fprintf(fp, + "%s not understood\n", + pcmd->argval[items].string); + res++; + break; + } else { + if (val >= NTP_MINPOLL && val <= NTP_MAXPOLL) { + minpoll = (u_char)val; + } else { + (void) fprintf(fp, + "minpol must be within %d..%d\n", + NTP_MINPOLL, NTP_MAXPOLL); + res++; + break; + } + } + } + items++; + } + + if (res) + return; + + memset((void *)&cpeer, 0, sizeof cpeer); + + cpeer.peeraddr = pcmd->argval[0].netnum; + cpeer.hmode = (u_char) mode; + cpeer.keyid = keyid; + cpeer.version = (u_char) version; + cpeer.minpoll = minpoll; + cpeer.maxpoll = NTP_MAXDPOLL; + cpeer.flags = (u_char)flags; + cpeer.ttl = cmode; + + res = doquery(IMPL_XNTPD, REQ_CONFIG, 1, 1, + sizeof(struct conf_peer), (char *)&cpeer, &items, + &itemsize, &dummy, 0); + + if (res == 0) + (void) fprintf(fp, "done!\n"); + return; +} + + +/* + * unconfig - unconfigure some associations + */ +static void +unconfig( + struct parse *pcmd, + FILE *fp + ) +{ + /* 8 is the maximum number of peers which will fit in a packet */ + struct conf_unpeer plist[min(MAXARGS, 8)]; + int qitems; + int items; + int itemsize; + char *dummy; + int res; + + for (qitems = 0; qitems < min(pcmd->nargs, 8); qitems++) { + plist[qitems].peeraddr = pcmd->argval[qitems].netnum; + } + + res = doquery(IMPL_XNTPD, REQ_UNCONFIG, 1, qitems, + sizeof(struct conf_unpeer), (char *)plist, &items, + &itemsize, &dummy, 0); + + if (res == 0) + (void) fprintf(fp, "done!\n"); +} + + +/* + * set - set some system flags + */ +static void +set( + struct parse *pcmd, + FILE *fp + ) +{ + doset(pcmd, fp, REQ_SET_SYS_FLAG); +} + + +/* + * clear - clear some system flags + */ +static void +sys_clear( + struct parse *pcmd, + FILE *fp + ) +{ + doset(pcmd, fp, REQ_CLR_SYS_FLAG); +} + + +/* + * doset - set/clear system flags + */ +static void +doset( + struct parse *pcmd, + FILE *fp, + int req + ) +{ + /* 8 is the maximum number of peers which will fit in a packet */ + struct conf_sys_flags sys; + int items; + int itemsize; + char *dummy; + int res; + + sys.flags = 0; + res = 0; + for (items = 0; items < pcmd->nargs; items++) { + if (STREQ(pcmd->argval[items].string, "auth")) + sys.flags |= SYS_FLAG_AUTHENTICATE; + else if (STREQ(pcmd->argval[items].string, "bclient")) + sys.flags |= SYS_FLAG_BCLIENT; + else if (STREQ(pcmd->argval[items].string, "monitor")) + sys.flags |= SYS_FLAG_MONITOR; + else if (STREQ(pcmd->argval[items].string, "ntp")) + sys.flags |= SYS_FLAG_NTP; + else if (STREQ(pcmd->argval[items].string, "kernel")) + sys.flags |= SYS_FLAG_KERNEL; + else if (STREQ(pcmd->argval[items].string, "stats")) + sys.flags |= SYS_FLAG_FILEGEN; + else { + (void) fprintf(fp, "Unknown flag %s\n", + pcmd->argval[items].string); + res = 1; + } + } + + if (res || sys.flags == 0) + return; + + res = doquery(IMPL_XNTPD, req, 1, 1, + sizeof(struct conf_sys_flags), (char *)&sys, &items, + &itemsize, &dummy, 0); + + if (res == 0) + (void) fprintf(fp, "done!\n"); +} + + +/* + * data for printing/interrpreting the restrict flags + */ +struct resflags { + const char *str; + int bit; +}; + +static struct resflags resflags[] = { + { "ignore", RES_IGNORE }, + { "noserve", RES_DONTSERVE }, + { "notrust", RES_DONTTRUST }, + { "noquery", RES_NOQUERY }, + { "nomodify", RES_NOMODIFY }, + { "nopeer", RES_NOPEER }, + { "notrap", RES_NOTRAP }, + { "lptrap", RES_LPTRAP }, + { "limited", RES_LIMITED }, + { "", 0 } +}; + +static struct resflags resmflags[] = { + { "ntpport", RESM_NTPONLY }, + { "interface", RESM_INTERFACE }, + { "", 0 } +}; + + +/* + * reslist - obtain and print the server's restrict list + */ +/*ARGSUSED*/ +static void +reslist( + struct parse *pcmd, + FILE *fp + ) +{ + struct info_restrict *rl; + int items; + int itemsize; + int res; + char *addr; + char *mask; + struct resflags *rf; + u_int32 count; + u_short flags; + u_short mflags; + char flagstr[300]; + static const char *comma = ", "; + + res = doquery(IMPL_XNTPD, REQ_GET_RESTRICT, 0, 0, 0, (char *)NULL, + &items, &itemsize, (char **)&rl, 0); + + if (res != 0 && items == 0) + return; + + if (!checkitems(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_restrict))) + return; + + (void) fprintf(fp, + " address mask count flags\n"); + (void) fprintf(fp, + "=====================================================================\n"); + while (items > 0) { + if ((rl->mask == (u_int32)0xffffffff)) + addr = nntohost(rl->addr); + else + addr = numtoa( rl->addr ); + mask = numtoa(rl->mask); + count = ntohl(rl->count); + flags = ntohs(rl->flags); + mflags = ntohs(rl->mflags); + flagstr[0] = '\0'; + + res = 1; + rf = &resmflags[0]; + while (rf->bit != 0) { + if (mflags & rf->bit) { + if (!res) + (void) strcat(flagstr, comma); + res = 0; + (void) strcat(flagstr, rf->str); + } + rf++; + } + + rf = &resflags[0]; + while (rf->bit != 0) { + if (flags & rf->bit) { + if (!res) + (void) strcat(flagstr, comma); + res = 0; + (void) strcat(flagstr, rf->str); + } + rf++; + } + + if (flagstr[0] == '\0') + (void) strcpy(flagstr, "none"); + + (void) fprintf(fp, "%-15.15s %-15.15s %9ld %s\n", + addr, mask, (u_long)count, flagstr); + rl++; + items--; + } +} + + + +/* + * new_restrict - create/add a set of restrictions + */ +static void +new_restrict( + struct parse *pcmd, + FILE *fp + ) +{ + do_restrict(pcmd, fp, REQ_RESADDFLAGS); +} + + +/* + * unrestrict - remove restriction flags from existing entry + */ +static void +unrestrict( + struct parse *pcmd, + FILE *fp + ) +{ + do_restrict(pcmd, fp, REQ_RESSUBFLAGS); +} + + +/* + * delrestrict - delete an existing restriction + */ +static void +delrestrict( + struct parse *pcmd, + FILE *fp + ) +{ + do_restrict(pcmd, fp, REQ_UNRESTRICT); +} + + +/* + * do_restrict - decode commandline restrictions and make the request + */ +static void +do_restrict( + struct parse *pcmd, + FILE *fp, + int req_code + ) +{ + struct conf_restrict cres; + int items; + int itemsize; + char *dummy; + u_int32 num; + u_long bit; + int i; + int res; + int err; + + cres.addr = pcmd->argval[0].netnum; + cres.mask = pcmd->argval[1].netnum; + cres.flags = 0; + cres.mflags = 0; + err = 0; + for (res = 2; res < pcmd->nargs; res++) { + if (STREQ(pcmd->argval[res].string, "ntpport")) { + cres.mflags |= RESM_NTPONLY; + } else { + for (i = 0; resflags[i].bit != 0; i++) { + if (STREQ(pcmd->argval[res].string, + resflags[i].str)) + break; + } + if (resflags[i].bit != 0) { + cres.flags |= resflags[i].bit; + if (req_code == REQ_UNRESTRICT) { + (void) fprintf(fp, + "Flag %s inappropriate\n", + resflags[i].str); + err++; + } + } else { + (void) fprintf(fp, "Unknown flag %s\n", + pcmd->argval[res].string); + err++; + } + } + } + + /* + * Make sure mask for default address is zero. Otherwise, + * make sure mask bits are contiguous. + */ + if (cres.addr == 0) { + cres.mask = 0; + } else { + num = ntohl(cres.mask); + for (bit = 0x80000000; bit != 0; bit >>= 1) + if ((num & bit) == 0) + break; + for ( ; bit != 0; bit >>= 1) + if ((num & bit) != 0) + break; + if (bit != 0) { + (void) fprintf(fp, "Invalid mask %s\n", + numtoa(cres.mask)); + err++; + } + } + + if (err) + return; + + res = doquery(IMPL_XNTPD, req_code, 1, 1, + sizeof(struct conf_restrict), (char *)&cres, &items, + &itemsize, &dummy, 0); + + if (res == 0) + (void) fprintf(fp, "done!\n"); + return; +} + + +/* + * monlist - obtain and print the server's monitor data + */ +/*ARGSUSED*/ +static void +monlist( + struct parse *pcmd, + FILE *fp + ) +{ + char *struct_star; + struct in_addr addr; + int items; + int itemsize; + int res; + int version = -1; + + if (pcmd->nargs > 0) { + version = pcmd->argval[0].ival; + } + + res = doquery(IMPL_XNTPD, + (version == 1 || version == -1) ? REQ_MON_GETLIST_1 : + REQ_MON_GETLIST, 0, 0, 0, (char *)NULL, + &items, &itemsize, &struct_star, + (version < 0) ? (1 << INFO_ERR_REQ) : 0); + + if (res == INFO_ERR_REQ && version < 0) + res = doquery(IMPL_XNTPD, REQ_MON_GETLIST, 0, 0, 0, (char *)NULL, + &items, &itemsize, &struct_star, 0); + + if (res != 0 && items == 0) + return; + + if (!checkitems(items, fp)) + return; + + if (itemsize == sizeof(struct info_monitor_1)) { + struct info_monitor_1 *ml = (struct info_monitor_1 *) struct_star; + + (void) fprintf(fp, + "remote address port local address count m ver drop last first\n"); + (void) fprintf(fp, + "===============================================================================\n"); + while (items > 0) { + addr.s_addr = ml->daddr; + (void) fprintf(fp, + "%-22.22s %5d %-15s %8ld %1d %1d %6lu %6lu %7lu\n", + nntohost(ml->addr), + ntohs(ml->port), + inet_ntoa(addr), + (u_long)ntohl(ml->count), + ml->mode, + ml->version, + (u_long)ntohl(ml->lastdrop), + (u_long)ntohl(ml->lasttime), + (u_long)ntohl(ml->firsttime)); + ml++; + items--; + } + } else if (itemsize == sizeof(struct info_monitor)) { + struct info_monitor *ml = (struct info_monitor *) struct_star; + + (void) fprintf(fp, + " address port count mode ver lastdrop lasttime firsttime\n"); + (void) fprintf(fp, + "===============================================================================\n"); + while (items > 0) { + addr.s_addr = ml->lastdrop; + (void) fprintf(fp, + "%-25.25s %5d %9ld %4d %2d %9lu %9lu %9lu\n", + nntohost(ml->addr), + ntohs(ml->port), + (u_long)ntohl(ml->count), + ml->mode, + ml->version, + (u_long)ntohl(ml->lastdrop), + (u_long)ntohl(ml->lasttime), + (u_long)ntohl(ml->firsttime)); + ml++; + items--; + } + } else if (itemsize == sizeof(struct old_info_monitor)) { + struct old_info_monitor *oml = (struct old_info_monitor *)struct_star; + (void) fprintf(fp, + " address port count mode version lasttime firsttime\n"); + (void) fprintf(fp, + "======================================================================\n"); + while (items > 0) { + (void) fprintf(fp, "%-20.20s %5d %9ld %4d %3d %9lu %9lu\n", + nntohost(oml->addr), + ntohs(oml->port), + (u_long)ntohl(oml->count), + oml->mode, + oml->version, + (u_long)ntohl(oml->lasttime), + (u_long)ntohl(oml->firsttime)); + oml++; + items--; + } + } else { + /* issue warning according to new info_monitor size */ + checkitemsize(itemsize, sizeof(struct info_monitor)); + } +} + + +/* + * Mapping between command line strings and stat reset flags + */ +struct statreset { + const char *str; + int flag; +} sreset[] = { + { "io", RESET_FLAG_IO }, + { "sys", RESET_FLAG_SYS }, + { "mem", RESET_FLAG_MEM }, + { "timer", RESET_FLAG_TIMER }, + { "auth", RESET_FLAG_AUTH }, + { "allpeers", RESET_FLAG_ALLPEERS }, + { "", 0 } +}; + +/* + * reset - reset statistic counters + */ +static void +reset( + struct parse *pcmd, + FILE *fp + ) +{ + struct reset_flags rflags; + int items; + int itemsize; + char *dummy; + int i; + int res; + int err; + + err = 0; + rflags.flags = 0; + for (res = 0; res < pcmd->nargs; res++) { + for (i = 0; sreset[i].flag != 0; i++) { + if (STREQ(pcmd->argval[res].string, sreset[i].str)) + break; + } + if (sreset[i].flag == 0) { + (void) fprintf(fp, "Flag %s unknown\n", + pcmd->argval[res].string); + err++; + } else { + rflags.flags |= sreset[i].flag; + } + } + + if (err) { + (void) fprintf(fp, "Not done due to errors\n"); + return; + } + + res = doquery(IMPL_XNTPD, REQ_RESET_STATS, 1, 1, + sizeof(struct reset_flags), (char *)&rflags, &items, + &itemsize, &dummy, 0); + + if (res == 0) + (void) fprintf(fp, "done!\n"); + return; +} + + + +/* + * preset - reset stat counters for particular peers + */ +static void +preset( + struct parse *pcmd, + FILE *fp + ) +{ + /* 8 is the maximum number of peers which will fit in a packet */ + struct conf_unpeer plist[min(MAXARGS, 8)]; + int qitems; + int items; + int itemsize; + char *dummy; + int res; + + for (qitems = 0; qitems < min(pcmd->nargs, 8); qitems++) { + plist[qitems].peeraddr = pcmd->argval[qitems].netnum; + } + + res = doquery(IMPL_XNTPD, REQ_RESET_PEER, 1, qitems, + sizeof(struct conf_unpeer), (char *)plist, &items, + &itemsize, &dummy, 0); + + if (res == 0) + (void) fprintf(fp, "done!\n"); +} + + +/* + * readkeys - request the server to reread the keys file + */ +/*ARGSUSED*/ +static void +readkeys( + struct parse *pcmd, + FILE *fp + ) +{ + int items; + int itemsize; + char *dummy; + int res; + + res = doquery(IMPL_XNTPD, REQ_REREAD_KEYS, 1, 0, 0, (char *)0, + &items, &itemsize, &dummy, 0); + + if (res == 0) + (void) fprintf(fp, "done!\n"); + return; +} + + +/* + * trustkey - add some keys to the trusted key list + */ +static void +trustkey( + struct parse *pcmd, + FILE *fp + ) +{ + do_trustkey(pcmd, fp, REQ_TRUSTKEY); +} + + +/* + * untrustkey - remove some keys from the trusted key list + */ +static void +untrustkey( + struct parse *pcmd, + FILE *fp + ) +{ + do_trustkey(pcmd, fp, REQ_UNTRUSTKEY); +} + + +/* + * do_trustkey - do grunge work of adding/deleting keys + */ +static void +do_trustkey( + struct parse *pcmd, + FILE *fp, + int req + ) +{ + u_long keyids[MAXARGS]; + int i; + int items; + int itemsize; + char *dummy; + int ritems; + int res; + + ritems = 0; + for (i = 0; i < pcmd->nargs; i++) { + keyids[ritems++] = pcmd->argval[i].uval; + } + + res = doquery(IMPL_XNTPD, req, 1, ritems, sizeof(u_long), + (char *)keyids, &items, &itemsize, &dummy, 0); + + if (res == 0) + (void) fprintf(fp, "done!\n"); + return; +} + + + +/* + * authinfo - obtain and print info about authentication + */ +/*ARGSUSED*/ +static void +authinfo( + struct parse *pcmd, + FILE *fp + ) +{ + struct info_auth *ia; + int items; + int itemsize; + int res; + + res = doquery(IMPL_XNTPD, REQ_AUTHINFO, 0, 0, 0, (char *)NULL, + &items, &itemsize, (char **)&ia, 0); + + if (res != 0 && items == 0) + return; + + if (!check1item(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_auth))) + return; + + (void) fprintf(fp, "time since reset: %ld\n", + (u_long)ntohl(ia->timereset)); + (void) fprintf(fp, "stored keys: %ld\n", + (u_long)ntohl(ia->numkeys)); + (void) fprintf(fp, "free keys: %ld\n", + (u_long)ntohl(ia->numfreekeys)); + (void) fprintf(fp, "key lookups: %ld\n", + (u_long)ntohl(ia->keylookups)); + (void) fprintf(fp, "keys not found: %ld\n", + (u_long)ntohl(ia->keynotfound)); + (void) fprintf(fp, "uncached keys: %ld\n", + (u_long)ntohl(ia->keyuncached)); + (void) fprintf(fp, "encryptions: %ld\n", + (u_long)ntohl(ia->encryptions)); + (void) fprintf(fp, "decryptions: %ld\n", + (u_long)ntohl(ia->decryptions)); + (void) fprintf(fp, "expired keys: %ld\n", + (u_long)ntohl(ia->expired)); +} + + + +/* + * traps - obtain and print a list of traps + */ +/*ARGSUSED*/ +static void +traps( + struct parse *pcmd, + FILE *fp + ) +{ + int i; + struct info_trap *it; + int items; + int itemsize; + int res; + + res = doquery(IMPL_XNTPD, REQ_TRAPS, 0, 0, 0, (char *)NULL, + &items, &itemsize, (char **)&it, 0); + + if (res != 0 && items == 0) + return; + + if (!checkitems(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_trap))) + return; + + for (i = 0; i < items; i++ ) { + if (i != 0) + (void) fprintf(fp, "\n"); + (void) fprintf(fp, "address %s, port %d\n", + numtoa(it->trap_address), ntohs(it->trap_port)); + (void) fprintf(fp, "interface: %s, ", + (it->local_address == 0) + ? "wildcard" + : numtoa(it->local_address)); + + if (ntohl(it->flags) & TRAP_CONFIGURED) + (void) fprintf(fp, "configured\n"); + else if (ntohl(it->flags) & TRAP_NONPRIO) + (void) fprintf(fp, "low priority\n"); + else + (void) fprintf(fp, "normal priority\n"); + + (void) fprintf(fp, "set for %ld secs, last set %ld secs ago\n", + (long)ntohl(it->origtime), + (long)ntohl(it->settime)); + (void) fprintf(fp, "sequence %d, number of resets %ld\n", + ntohs(it->sequence), + (long)ntohl(it->resets)); + } +} + + +/* + * addtrap - configure a trap + */ +static void +addtrap( + struct parse *pcmd, + FILE *fp + ) +{ + do_addclr_trap(pcmd, fp, REQ_ADD_TRAP); +} + + +/* + * clrtrap - clear a trap from the server + */ +static void +clrtrap( + struct parse *pcmd, + FILE *fp + ) +{ + do_addclr_trap(pcmd, fp, REQ_CLR_TRAP); +} + + +/* + * do_addclr_trap - do grunge work of adding/deleting traps + */ +static void +do_addclr_trap( + struct parse *pcmd, + FILE *fp, + int req + ) +{ + struct conf_trap ctrap; + int items; + int itemsize; + char *dummy; + int res; + + ctrap.trap_address = pcmd->argval[0].netnum; + ctrap.local_address = 0; + ctrap.trap_port = htons(TRAPPORT); + ctrap.unused = 0; + + if (pcmd->nargs > 1) { + ctrap.trap_port + = htons((u_short)(pcmd->argval[1].uval & 0xffff)); + if (pcmd->nargs > 2) + ctrap.local_address = pcmd->argval[2].netnum; + } + + res = doquery(IMPL_XNTPD, req, 1, 1, sizeof(struct conf_trap), + (char *)&ctrap, &items, &itemsize, &dummy, 0); + + if (res == 0) + (void) fprintf(fp, "done!\n"); + return; +} + + + +/* + * requestkey - change the server's request key (a dangerous request) + */ +static void +requestkey( + struct parse *pcmd, + FILE *fp + ) +{ + do_changekey(pcmd, fp, REQ_REQUEST_KEY); +} + + +/* + * controlkey - change the server's control key + */ +static void +controlkey( + struct parse *pcmd, + FILE *fp + ) +{ + do_changekey(pcmd, fp, REQ_CONTROL_KEY); +} + + + +/* + * do_changekey - do grunge work of changing keys + */ +static void +do_changekey( + struct parse *pcmd, + FILE *fp, + int req + ) +{ + u_long key; + int items; + int itemsize; + char *dummy; + int res; + + + key = htonl((u_int32)pcmd->argval[0].uval); + + res = doquery(IMPL_XNTPD, req, 1, 1, sizeof(u_int32), + (char *)&key, &items, &itemsize, &dummy, 0); + + if (res == 0) + (void) fprintf(fp, "done!\n"); + return; +} + + + +/* + * ctlstats - obtain and print info about authentication + */ +/*ARGSUSED*/ +static void +ctlstats( + struct parse *pcmd, + FILE *fp + ) +{ + struct info_control *ic; + int items; + int itemsize; + int res; + + res = doquery(IMPL_XNTPD, REQ_GET_CTLSTATS, 0, 0, 0, (char *)NULL, + &items, &itemsize, (char **)&ic, 0); + + if (res != 0 && items == 0) + return; + + if (!check1item(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_control))) + return; + + (void) fprintf(fp, "time since reset: %ld\n", + (u_long)ntohl(ic->ctltimereset)); + (void) fprintf(fp, "requests received: %ld\n", + (u_long)ntohl(ic->numctlreq)); + (void) fprintf(fp, "responses sent: %ld\n", + (u_long)ntohl(ic->numctlresponses)); + (void) fprintf(fp, "fragments sent: %ld\n", + (u_long)ntohl(ic->numctlfrags)); + (void) fprintf(fp, "async messages sent: %ld\n", + (u_long)ntohl(ic->numasyncmsgs)); + (void) fprintf(fp, "error msgs sent: %ld\n", + (u_long)ntohl(ic->numctlerrors)); + (void) fprintf(fp, "total bad pkts: %ld\n", + (u_long)ntohl(ic->numctlbadpkts)); + (void) fprintf(fp, "packet too short: %ld\n", + (u_long)ntohl(ic->numctltooshort)); + (void) fprintf(fp, "response on input: %ld\n", + (u_long)ntohl(ic->numctlinputresp)); + (void) fprintf(fp, "fragment on input: %ld\n", + (u_long)ntohl(ic->numctlinputfrag)); + (void) fprintf(fp, "error set on input: %ld\n", + (u_long)ntohl(ic->numctlinputerr)); + (void) fprintf(fp, "bad offset on input: %ld\n", + (u_long)ntohl(ic->numctlbadoffset)); + (void) fprintf(fp, "bad version packets: %ld\n", + (u_long)ntohl(ic->numctlbadversion)); + (void) fprintf(fp, "data in pkt too short: %ld\n", + (u_long)ntohl(ic->numctldatatooshort)); + (void) fprintf(fp, "unknown op codes: %ld\n", + (u_long)ntohl(ic->numctlbadop)); +} + + +/* + * clockstat - get and print clock status information + */ +static void +clockstat( + struct parse *pcmd, + FILE *fp + ) +{ + struct info_clock *cl; + /* 8 is the maximum number of clocks which will fit in a packet */ + u_long clist[min(MAXARGS, 8)]; + int qitems; + int items; + int itemsize; + int res; + l_fp ts; + struct clktype *clk; + u_long ltemp; + + for (qitems = 0; qitems < min(pcmd->nargs, 8); qitems++) + clist[qitems] = pcmd->argval[qitems].netnum; + + res = doquery(IMPL_XNTPD, REQ_GET_CLOCKINFO, 0, qitems, + sizeof(u_int32), (char *)clist, &items, + &itemsize, (char **)&cl, 0); + + if (res != 0 && items == 0) + return; + + if (!checkitems(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_clock))) + return; + + while (items-- > 0) { + (void) fprintf(fp, "clock address: %s\n", + numtoa(cl->clockadr)); + for (clk = clktypes; clk->code >= 0; clk++) + if (clk->code == cl->type) + break; + if (clk->code >= 0) + (void) fprintf(fp, "clock type: %s\n", + clk->clocktype); + else + (void) fprintf(fp, "clock type: unknown type (%d)\n", + cl->type); + (void) fprintf(fp, "last event: %d\n", + cl->lastevent); + (void) fprintf(fp, "current status: %d\n", + cl->currentstatus); + (void) fprintf(fp, "number of polls: %lu\n", + (u_long)ntohl(cl->polls)); + (void) fprintf(fp, "no response to poll: %lu\n", + (u_long)ntohl(cl->noresponse)); + (void) fprintf(fp, "bad format responses: %lu\n", + (u_long)ntohl(cl->badformat)); + (void) fprintf(fp, "bad data responses: %lu\n", + (u_long)ntohl(cl->baddata)); + (void) fprintf(fp, "running time: %lu\n", + (u_long)ntohl(cl->timestarted)); + NTOHL_FP(&cl->fudgetime1, &ts); + (void) fprintf(fp, "fudge time 1: %s\n", + lfptoa(&ts, 6)); + NTOHL_FP(&cl->fudgetime2, &ts); + (void) fprintf(fp, "fudge time 2: %s\n", + lfptoa(&ts, 6)); + (void) fprintf(fp, "stratum: %ld\n", + (u_long)ntohl(cl->fudgeval1)); + ltemp = ntohl(cl->fudgeval2); + (void) fprintf(fp, "reference ID: %s\n", + (char *)<emp); + (void) fprintf(fp, "fudge flags: 0x%x\n", + cl->flags); + + if (items > 0) + (void) fprintf(fp, "\n"); + cl++; + } +} + + +/* + * fudge - set clock fudge factors + */ +static void +fudge( + struct parse *pcmd, + FILE *fp + ) +{ + struct conf_fudge fudgedata; + int items; + int itemsize; + char *dummy; + l_fp ts; + int res; + long val; + u_long u_val; + int err; + + + err = 0; + memset((char *)&fudgedata, 0, sizeof fudgedata); + fudgedata.clockadr = pcmd->argval[0].netnum; + + if (STREQ(pcmd->argval[1].string, "time1")) { + fudgedata.which = htonl(FUDGE_TIME1); + if (!atolfp(pcmd->argval[2].string, &ts)) + err = 1; + else + NTOHL_FP(&ts, &fudgedata.fudgetime); + } else if (STREQ(pcmd->argval[1].string, "time2")) { + fudgedata.which = htonl(FUDGE_TIME2); + if (!atolfp(pcmd->argval[2].string, &ts)) + err = 1; + else + NTOHL_FP(&ts, &fudgedata.fudgetime); + } else if (STREQ(pcmd->argval[1].string, "val1")) { + fudgedata.which = htonl(FUDGE_VAL1); + if (!atoint(pcmd->argval[2].string, &val)) + err = 1; + else + fudgedata.fudgeval_flags = htonl(val); + } else if (STREQ(pcmd->argval[1].string, "val2")) { + fudgedata.which = htonl(FUDGE_VAL2); + if (!atoint(pcmd->argval[2].string, &val)) + err = 1; + else + fudgedata.fudgeval_flags = htonl((u_int32)val); + } else if (STREQ(pcmd->argval[1].string, "flags")) { + fudgedata.which = htonl(FUDGE_FLAGS); + if (!hextoint(pcmd->argval[2].string, &u_val)) + err = 1; + else + fudgedata.fudgeval_flags = htonl((u_int32)(u_val & 0xf)); + } else { + (void) fprintf(stderr, "What fudge is %s?\n", + pcmd->argval[1].string); + return; + } + + if (err) { + (void) fprintf(stderr, "Unknown fudge parameter %s\n", + pcmd->argval[2].string); + return; + } + + + res = doquery(IMPL_XNTPD, REQ_SET_CLKFUDGE, 1, 1, + sizeof(struct conf_fudge), (char *)&fudgedata, &items, + &itemsize, &dummy, 0); + + if (res == 0) + (void) fprintf(fp, "done!\n"); + return; +} + +/* + * clkbug - get and print clock debugging information + */ +static void +clkbug( + struct parse *pcmd, + FILE *fp + ) +{ + register int i; + register int n; + register u_int32 s; + struct info_clkbug *cl; + /* 8 is the maximum number of clocks which will fit in a packet */ + u_long clist[min(MAXARGS, 8)]; + u_int32 ltemp; + int qitems; + int items; + int itemsize; + int res; + int needsp; + l_fp ts; + + for (qitems = 0; qitems < min(pcmd->nargs, 8); qitems++) + clist[qitems] = pcmd->argval[qitems].netnum; + + res = doquery(IMPL_XNTPD, REQ_GET_CLKBUGINFO, 0, qitems, + sizeof(u_int32), (char *)clist, &items, + &itemsize, (char **)&cl, 0); + + if (res != 0 && items == 0) + return; + + if (!checkitems(items, fp)) + return; + + if (!checkitemsize(itemsize, sizeof(struct info_clkbug))) + return; + + while (items-- > 0) { + (void) fprintf(fp, "clock address: %s\n", + numtoa(cl->clockadr)); + n = (int)cl->nvalues; + (void) fprintf(fp, "values: %d", n); + s = ntohs(cl->svalues); + if (n > NUMCBUGVALUES) + n = NUMCBUGVALUES; + for (i = 0; i < n; i++) { + ltemp = ntohl(cl->values[i]); + ltemp &= 0xffffffff; /* HMS: This does nothing now */ + if ((i & 0x3) == 0) + (void) fprintf(fp, "\n"); + if (s & (1 << i)) + (void) fprintf(fp, "%12ld", (u_long)ltemp); + else + (void) fprintf(fp, "%12lu", (u_long)ltemp); + } + (void) fprintf(fp, "\n"); + + n = (int)cl->ntimes; + (void) fprintf(fp, "times: %d", n); + s = ntohl(cl->stimes); + if (n > NUMCBUGTIMES) + n = NUMCBUGTIMES; + needsp = 0; + for (i = 0; i < n; i++) { + if ((i & 0x1) == 0) { + (void) fprintf(fp, "\n"); + } else { + for (;needsp > 0; needsp--) + putc(' ', fp); + } + NTOHL_FP(&cl->times[i], &ts); + if (s & (1 << i)) { + (void) fprintf(fp, "%17s", + lfptoa(&ts, 6)); + needsp = 22; + } else { + (void) fprintf(fp, "%37s", + uglydate(&ts)); + needsp = 2; + } + } + (void) fprintf(fp, "\n"); + if (items > 0) { + cl++; + (void) fprintf(fp, "\n"); + } + } +} + + +/* + * kerninfo - display the kernel pll/pps variables + */ +static void +kerninfo( + struct parse *pcmd, + FILE *fp + ) +{ + struct info_kernel *ik; + int items; + int itemsize; + int res; + unsigned status; + double tscale = 1e-6; + + res = doquery(IMPL_XNTPD, REQ_GET_KERNEL, 0, 0, 0, (char *)NULL, + &items, &itemsize, (char **)&ik, 0); + if (res != 0 && items == 0) + return; + if (!check1item(items, fp)) + return; + if (!checkitemsize(itemsize, sizeof(struct info_kernel))) + return; + + status = ntohs(ik->status) & 0xffff; + /* + * pll variables. We know more than we should about the NANO bit. + */ +#ifdef STA_NANO + if (status & STA_NANO) + tscale = 1e-9; +#endif + (void)fprintf(fp, "pll offset: %g s\n", + (long)ntohl(ik->offset) * tscale); + (void)fprintf(fp, "pll frequency: %s ppm\n", + fptoa((s_fp)ntohl(ik->freq), 3)); + (void)fprintf(fp, "maximum error: %g s\n", + (u_long)ntohl(ik->maxerror) * 1e-6); + (void)fprintf(fp, "estimated error: %g s\n", + (u_long)ntohl(ik->esterror) * 1e-6); + (void)fprintf(fp, "status: %04x ", status); +#ifdef STA_PLL + if (status & STA_PLL) (void)fprintf(fp, " pll"); +#endif +#ifdef STA_PPSFREQ + if (status & STA_PPSFREQ) (void)fprintf(fp, " ppsfreq"); +#endif +#ifdef STA_PPSTIME + if (status & STA_PPSTIME) (void)fprintf(fp, " ppstime"); +#endif +#ifdef STA_FLL + if (status & STA_FLL) (void)fprintf(fp, " fll"); +#endif +#ifdef STA_INS + if (status & STA_INS) (void)fprintf(fp, " ins"); +#endif +#ifdef STA_DEL + if (status & STA_DEL) (void)fprintf(fp, " del"); +#endif +#ifdef STA_UNSYNC + if (status & STA_UNSYNC) (void)fprintf(fp, " unsync"); +#endif +#ifdef STA_FREQHOLD + if (status & STA_FREQHOLD) (void)fprintf(fp, " freqhold"); +#endif +#ifdef STA_PPSSIGNAL + if (status & STA_PPSSIGNAL) (void)fprintf(fp, " ppssignal"); +#endif +#ifdef STA_PPSJITTER + if (status & STA_PPSJITTER) (void)fprintf(fp, " ppsjitter"); +#endif +#ifdef STA_PPSWANDER + if (status & STA_PPSWANDER) (void)fprintf(fp, " ppswander"); +#endif +#ifdef STA_PPSERROR + if (status & STA_PPSERROR) (void)fprintf(fp, " ppserror"); +#endif +#ifdef STA_CLOCKERR + if (status & STA_CLOCKERR) (void)fprintf(fp, " clockerr"); +#endif +#ifdef STA_NANO + if (status & STA_NANO) (void)fprintf(fp, " nano"); +#endif +#ifdef STA_MODE + if (status & STA_MODE) (void)fprintf(fp, " mode=fll"); +#endif +#ifdef STA_CLK + if (status & STA_CLK) (void)fprintf(fp, " src=B"); +#endif + (void)fprintf(fp, "\n"); + (void)fprintf(fp, "pll time constant: %ld\n", + (u_long)ntohl(ik->constant)); + (void)fprintf(fp, "precision: %g s\n", + (u_long)ntohl(ik->precision) * tscale); + (void)fprintf(fp, "frequency tolerance: %s ppm\n", + fptoa((s_fp)ntohl(ik->tolerance), 0)); + + /* + * For backwards compatibility (ugh), we find the pps variables + * only if the shift member is nonzero. + */ + if (!ik->shift) + return; + + /* + * pps variables + */ + (void)fprintf(fp, "pps frequency: %s ppm\n", + fptoa((s_fp)ntohl(ik->ppsfreq), 3)); + (void)fprintf(fp, "pps stability: %s ppm\n", + fptoa((s_fp)ntohl(ik->stabil), 3)); + (void)fprintf(fp, "pps jitter: %g s\n", + (u_long)ntohl(ik->jitter) * tscale); + (void)fprintf(fp, "calibration interval: %d s\n", + 1 << ntohs(ik->shift)); + (void)fprintf(fp, "calibration cycles: %ld\n", + (u_long)ntohl(ik->calcnt)); + (void)fprintf(fp, "jitter exceeded: %ld\n", + (u_long)ntohl(ik->jitcnt)); + (void)fprintf(fp, "stability exceeded: %ld\n", + (u_long)ntohl(ik->stbcnt)); + (void)fprintf(fp, "calibration errors: %ld\n", + (u_long)ntohl(ik->errcnt)); +} |