#include <afsconfig.h>
#include <afs/param.h>
-RCSID("$Header$");
+RCSID
+ ("$Header$");
#include <stdio.h>
#ifdef AFS_AIX32_ENV
#include "ntp.h"
char *modename[8] = {
- "Unspecified",
- "Symmetric Active",
- "Symmetric Passive",
- "Client",
- "Server",
- "Broadcast",
- "Reserved-1",
- "Reserved-2"
- };
+ "Unspecified",
+ "Symmetric Active",
+ "Symmetric Passive",
+ "Client",
+ "Server",
+ "Broadcast",
+ "Reserved-1",
+ "Reserved-2"
+};
#define RETRY_COUNT 2 /* number of times we want to retry */
#define TIME_OUT 10 /* time to wait for reply, in secs */
-struct sockaddr_in sin = {AF_INET};
-struct sockaddr_in dst = {AF_INET};
+struct sockaddr_in sin = { AF_INET };
+struct sockaddr_in dst = { AF_INET };
struct servent *sp;
extern double ul_fixed_to_double(), s_fixed_to_double();
extern int errno;
#include "AFS_component_version_number.c"
main(argc, argv)
- int argc;
- char *argv[];
+ int argc;
+ char *argv[];
{
- struct hostent *hp;
- struct in_addr clock_host;
- struct l_fixedpt in_timestamp;
- static struct ntpdata ntp_data;
- struct ntpdata *pkt = &ntp_data;
- struct timeval tp, timeout;
- int host, n, retry, s;
- fd_set readfds;
- int dstlen = sizeof(dst);
- double t1, t2, t3, t4, offset, delay;
- char ref_clock[5];
- time_t net_time;
+ struct hostent *hp;
+ struct in_addr clock_host;
+ struct l_fixedpt in_timestamp;
+ static struct ntpdata ntp_data;
+ struct ntpdata *pkt = &ntp_data;
+ struct timeval tp, timeout;
+ int host, n, retry, s;
+ fd_set readfds;
+ int dstlen = sizeof(dst);
+ double t1, t2, t3, t4, offset, delay;
+ char ref_clock[5];
+ time_t net_time;
#ifdef AFS_AIX32_ENV
+ /*
+ * The following signal action for AIX is necessary so that in case of a
+ * crash (i.e. core is generated) we can include the user's data section
+ * in the core dump. Unfortunately, by default, only a partial core is
+ * generated which, in many cases, isn't too useful.
+ */
+ struct sigaction nsa;
+
+ sigemptyset(&nsa.sa_mask);
+ nsa.sa_handler = SIG_DFL;
+ nsa.sa_flags = SA_FULLDUMP;
+ sigaction(SIGSEGV, &nsa, NULL);
+#endif
+ ref_clock[4] = '\0';
+ timeout.tv_sec = TIME_OUT;
+ timeout.tv_usec = 0;
+ retry = RETRY_COUNT;
+
+ sp = getservbyname("ntp", "udp");
+ if (sp == NULL) {
+ fprintf(stderr, "udp/ntp: service unknown; using default %d\n",
+ NTP_PORT);
+ dst.sin_port = htons(NTP_PORT);
+ } else
+ dst.sin_port = sp->s_port;
+
+ dst.sin_family = AF_INET;
+ while ((n = getopt(argc, argv, "vsf")) != EOF) {
+ switch (n) {
+ case 'v':
+ verbose = 1;
+ break;
+ case 's':
+ set = 1;
+ break;
+ case 'f':
+ force = 1;
+ break;
+ }
+ }
+ for (host = optind; host < argc; ++host) {
+ afs_int32 HostAddr;
+
+ if (argv[host] == NULL)
+ continue;
+
+ hp = NULL;
+ HostAddr = inet_addr(argv[host]);
+ dst.sin_addr.s_addr = (afs_uint32) HostAddr;
+ if (HostAddr == -1) {
+ hp = gethostbyname(argv[host]);
+ if (hp == NULL) {
+ fprintf(stderr, "\nNo such host: %s\n", argv[host]);
+ continue;
+ }
+ memcpy((char *)&dst.sin_addr, hp->h_addr, hp->h_length);
+ }
+
+ memset((char *)pkt, 0, sizeof(ntp_data));
+
+ pkt->status = NTPVERSION_1 | NO_WARNING | MODE_CLIENT;
+ pkt->stratum = UNSPECIFIED;
+ pkt->ppoll = 0;
+
+ if ((s = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {
+ perror("ntp socket");
+ exit(1);
+ }
+
+ FD_ZERO(&readfds);
+ FD_SET(s, &readfds); /* since it's always modified on ret */
+
+ if (connect(s, (struct sockaddr *)&dst, dstlen)) {
+ perror("connect");
+ exit(1);
+ }
+
/*
- * The following signal action for AIX is necessary so that in case of a
- * crash (i.e. core is generated) we can include the user's data section
- * in the core dump. Unfortunately, by default, only a partial core is
- * generated which, in many cases, isn't too useful.
+ * Needed to fill in the time stamp fields
*/
- struct sigaction nsa;
-
- sigemptyset(&nsa.sa_mask);
- nsa.sa_handler = SIG_DFL;
- nsa.sa_flags = SA_FULLDUMP;
- sigaction(SIGSEGV, &nsa, NULL);
-#endif
- ref_clock[4] = '\0';
- timeout.tv_sec = TIME_OUT;
- timeout.tv_usec = 0;
- retry = RETRY_COUNT;
-
- sp = getservbyname("ntp", "udp");
- if (sp == NULL) {
- fprintf(stderr, "udp/ntp: service unknown; using default %d\n",
- NTP_PORT);
- dst.sin_port = htons(NTP_PORT);
- } else
- dst.sin_port = sp->s_port;
-
- dst.sin_family = AF_INET;
- while ((n = getopt(argc, argv, "vsf")) != EOF) {
- switch (n) {
- case 'v':
- verbose = 1;
- break;
- case 's':
- set = 1;
- break;
- case 'f':
- force = 1;
- break;
- }
+ (void)gettimeofday(&tp, NULL);
+ tstamp(&pkt->xmt, &tp);
+
+ if (send(s, (char *)pkt, sizeof(ntp_data), 0) < 0) {
+ perror("send");
+ exit(1);
}
- for (host = optind; host < argc; ++host) {
- afs_int32 HostAddr;
-
- if (argv[host] == NULL)
- continue;
-
- hp = NULL;
- HostAddr = inet_addr(argv[host]);
- dst.sin_addr.s_addr = (afs_uint32) HostAddr;
- if (HostAddr == -1) {
- hp = gethostbyname(argv[host]);
- if (hp == NULL) {
- fprintf(stderr, "\nNo such host: %s\n",
- argv[host]);
- continue;
- }
- memcpy((char *) &dst.sin_addr, hp->h_addr, hp->h_length);
- }
-
- memset((char *)pkt, 0, sizeof(ntp_data));
-
- pkt->status = NTPVERSION_1 | NO_WARNING | MODE_CLIENT;
- pkt->stratum = UNSPECIFIED;
- pkt->ppoll = 0;
-
- if ((s = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {
- perror("ntp socket");
- exit(1);
- }
-
- FD_ZERO(&readfds);
- FD_SET(s, &readfds); /* since it's always modified on ret */
-
- if (connect(s, (struct sockaddr *)&dst, dstlen)) {
- perror("connect");
- exit(1);
- }
-
- /*
- * Needed to fill in the time stamp fields
- */
- (void) gettimeofday(&tp, NULL);
- tstamp(&pkt->xmt, &tp);
-
- if (send(s, (char *) pkt, sizeof(ntp_data), 0) < 0) {
- perror("send");
- exit(1);
- }
-
- /*
- * Wait for the reply by watching the file descriptor
- */
- if ((n = select(FD_SETSIZE, (fd_set *) & readfds, (fd_set *) 0,
- (fd_set *) 0, &timeout)) < 0) {
- perror("ntp select");
- exit(1);
- }
-
- if (n == 0) {
- fprintf(stderr,"*Timeout*\n");
- if (--retry)
- --host;
- else {
- fprintf(stderr,"Host %s is not responding\n",
- argv[host]);
- retry = RETRY_COUNT;
- }
- continue;
- }
- if ((recvfrom(s, (char *) pkt, sizeof(ntp_data), 0,
- (struct sockaddr *) &sin, &dstlen)) < 0) {
- perror("recvfrom");
- exit(1);
- }
- (void) gettimeofday(&tp, NULL);
- tstamp(&in_timestamp, &tp);
-
- close(s);
- if (verbose) {
- printf("Packet from: [%s]\n", inet_ntoa(sin.sin_addr));
- printf("Leap %d, version %d, mode %s, poll %d, precision %d stratum %d",
- (pkt->status & LEAPMASK) >> 6,
- (pkt->status & VERSIONMASK) >> 3,
- modename[pkt->status & MODEMASK],
- pkt->ppoll, pkt->precision, pkt->stratum);
- switch (pkt->stratum) {
- case 0:
- case 1:
- (void) strncpy(ref_clock, (char *) &pkt->refid, 4);
- ref_clock[4] = '\0';
- printf(" (%s)\n", ref_clock);
- break;
- default:
- clock_host.s_addr = (afs_uint32) pkt->refid;
- printf(" [%s]\n", inet_ntoa(clock_host));
- break;
- }
- printf("Synch Distance is %04X.%04x %f\n",
- ntohs(pkt->distance.int_part),
- ntohs(pkt->distance.fraction),
- s_fixed_to_double(&pkt->distance));
-
- printf("Synch Dispersion is %04X.%04x %f\n",
- ntohs(pkt->dispersion.int_part),
- ntohs(pkt->dispersion.fraction),
- s_fixed_to_double(&pkt->dispersion));
-
- net_time = ntohl(pkt->reftime.int_part) - JAN_1970;
- printf("Reference Timestamp is %08lx.%08lx %s",
- ntohl(pkt->reftime.int_part),
- ntohl(pkt->reftime.fraction),
- ctime(&net_time));
-
- net_time = ntohl(pkt->org.int_part) - JAN_1970;
- printf("Originate Timestamp is %08lx.%08lx %s",
- ntohl(pkt->org.int_part),
- ntohl(pkt->org.fraction),
- ctime(&net_time));
-
- net_time = ntohl(pkt->rec.int_part) - JAN_1970;
- printf("Receive Timestamp is %08lx.%08lx %s",
- ntohl(pkt->rec.int_part),
- ntohl(pkt->rec.fraction),
- ctime(&net_time));
-
- net_time = ntohl(pkt->xmt.int_part) - JAN_1970;
- printf("Transmit Timestamp is %08lx.%08lx %s",
- ntohl(pkt->xmt.int_part),
- ntohl(pkt->xmt.fraction),
- ctime(&net_time));
- }
- t1 = ul_fixed_to_double(&pkt->org);
- t2 = ul_fixed_to_double(&pkt->rec);
- t3 = ul_fixed_to_double(&pkt->xmt);
- t4 = ul_fixed_to_double(&in_timestamp);
-
- net_time = ntohl(in_timestamp.int_part) - JAN_1970;
- if (verbose)
- printf("Input Timestamp is %08lx.%08lx %s",
- ntohl(in_timestamp.int_part),
- ntohl(in_timestamp.fraction), ctime(&net_time));
-
- delay = (t4 - t1) - (t3 - t2);
- offset = (t2 - t1) + (t3 - t4);
- offset = offset / 2.0;
- printf("%.20s: delay:%f offset:%f ",
- hp ? hp->h_name : argv[host],
- delay, offset);
- net_time = ntohl(pkt->xmt.int_part) - JAN_1970 + delay;
- fputs(ctime(&net_time), stdout);
- (void)fflush(stdout);
-
- if (!set)
- continue;
-
- if ((offset < 0 ? -offset : offset) > WAYTOOBIG && !force) {
- fprintf(stderr, "Offset too large - use -f option to force clock set.\n");
- continue;
- }
-
- if (pkt->status & LEAPMASK == ALARM) {
- fprintf(stderr, "Can't set time from %s - unsynchronized\n",
- argv[host]);
- continue;
- }
-
- /* set the clock */
- gettimeofday(&tp, NULL);
- offset += tp.tv_sec;
- offset += tp.tv_usec / 1000000.0;
- tp.tv_sec = offset;
- tp.tv_usec = (offset - tp.tv_sec) * 1000000.0;
-
- if (settimeofday(&tp, NULL)) {
- perror("Can't set time (settimeofday)");
- } else
- set = 0;
- } /* end of for each host */
- exit(0);
+
+ /*
+ * Wait for the reply by watching the file descriptor
+ */
+ if ((n =
+ select(FD_SETSIZE, (fd_set *) & readfds, (fd_set *) 0,
+ (fd_set *) 0, &timeout)) < 0) {
+ perror("ntp select");
+ exit(1);
+ }
+
+ if (n == 0) {
+ fprintf(stderr, "*Timeout*\n");
+ if (--retry)
+ --host;
+ else {
+ fprintf(stderr, "Host %s is not responding\n", argv[host]);
+ retry = RETRY_COUNT;
+ }
+ continue;
+ }
+ if ((recvfrom
+ (s, (char *)pkt, sizeof(ntp_data), 0, (struct sockaddr *)&sin,
+ &dstlen)) < 0) {
+ perror("recvfrom");
+ exit(1);
+ }
+ (void)gettimeofday(&tp, NULL);
+ tstamp(&in_timestamp, &tp);
+
+ close(s);
+ if (verbose) {
+ printf("Packet from: [%s]\n", inet_ntoa(sin.sin_addr));
+ printf
+ ("Leap %d, version %d, mode %s, poll %d, precision %d stratum %d",
+ (pkt->status & LEAPMASK) >> 6,
+ (pkt->status & VERSIONMASK) >> 3,
+ modename[pkt->status & MODEMASK], pkt->ppoll, pkt->precision,
+ pkt->stratum);
+ switch (pkt->stratum) {
+ case 0:
+ case 1:
+ (void)strncpy(ref_clock, (char *)&pkt->refid, 4);
+ ref_clock[4] = '\0';
+ printf(" (%s)\n", ref_clock);
+ break;
+ default:
+ clock_host.s_addr = (afs_uint32) pkt->refid;
+ printf(" [%s]\n", inet_ntoa(clock_host));
+ break;
+ }
+ printf("Synch Distance is %04X.%04x %f\n",
+ ntohs(pkt->distance.int_part),
+ ntohs(pkt->distance.fraction),
+ s_fixed_to_double(&pkt->distance));
+
+ printf("Synch Dispersion is %04X.%04x %f\n",
+ ntohs(pkt->dispersion.int_part),
+ ntohs(pkt->dispersion.fraction),
+ s_fixed_to_double(&pkt->dispersion));
+
+ net_time = ntohl(pkt->reftime.int_part) - JAN_1970;
+ printf("Reference Timestamp is %08lx.%08lx %s",
+ ntohl(pkt->reftime.int_part), ntohl(pkt->reftime.fraction),
+ ctime(&net_time));
+
+ net_time = ntohl(pkt->org.int_part) - JAN_1970;
+ printf("Originate Timestamp is %08lx.%08lx %s",
+ ntohl(pkt->org.int_part), ntohl(pkt->org.fraction),
+ ctime(&net_time));
+
+ net_time = ntohl(pkt->rec.int_part) - JAN_1970;
+ printf("Receive Timestamp is %08lx.%08lx %s",
+ ntohl(pkt->rec.int_part), ntohl(pkt->rec.fraction),
+ ctime(&net_time));
+
+ net_time = ntohl(pkt->xmt.int_part) - JAN_1970;
+ printf("Transmit Timestamp is %08lx.%08lx %s",
+ ntohl(pkt->xmt.int_part), ntohl(pkt->xmt.fraction),
+ ctime(&net_time));
+ }
+ t1 = ul_fixed_to_double(&pkt->org);
+ t2 = ul_fixed_to_double(&pkt->rec);
+ t3 = ul_fixed_to_double(&pkt->xmt);
+ t4 = ul_fixed_to_double(&in_timestamp);
+
+ net_time = ntohl(in_timestamp.int_part) - JAN_1970;
+ if (verbose)
+ printf("Input Timestamp is %08lx.%08lx %s",
+ ntohl(in_timestamp.int_part), ntohl(in_timestamp.fraction),
+ ctime(&net_time));
+
+ delay = (t4 - t1) - (t3 - t2);
+ offset = (t2 - t1) + (t3 - t4);
+ offset = offset / 2.0;
+ printf("%.20s: delay:%f offset:%f ", hp ? hp->h_name : argv[host],
+ delay, offset);
+ net_time = ntohl(pkt->xmt.int_part) - JAN_1970 + delay;
+ fputs(ctime(&net_time), stdout);
+ (void)fflush(stdout);
+
+ if (!set)
+ continue;
+
+ if ((offset < 0 ? -offset : offset) > WAYTOOBIG && !force) {
+ fprintf(stderr,
+ "Offset too large - use -f option to force clock set.\n");
+ continue;
+ }
+
+ if (pkt->status & LEAPMASK == ALARM) {
+ fprintf(stderr, "Can't set time from %s - unsynchronized\n",
+ argv[host]);
+ continue;
+ }
+
+ /* set the clock */
+ gettimeofday(&tp, NULL);
+ offset += tp.tv_sec;
+ offset += tp.tv_usec / 1000000.0;
+ tp.tv_sec = offset;
+ tp.tv_usec = (offset - tp.tv_sec) * 1000000.0;
+
+ if (settimeofday(&tp, NULL)) {
+ perror("Can't set time (settimeofday)");
+ } else
+ set = 0;
+ } /* end of for each host */
+ exit(0);
} /* end of main */
git://git.openafs.org / openafs.git / blobdiff