xref: /netbsd-src/external/bsd/ntp/dist/libntp/machines.c (revision eabc0478de71e4e011a5b4e0392741e01d491794)
1 /*	$NetBSD: machines.c,v 1.7 2024/08/18 20:47:13 christos Exp $	*/
2 
3 /* machines.c - provide special support for peculiar architectures
4  *
5  * Real bummers unite !
6  *
7  */
8 
9 #ifdef HAVE_CONFIG_H
10 #include "config.h"
11 #endif
12 
13 #include "ntp.h"
14 #include "ntp_machine.h"
15 #include "ntp_syslog.h"
16 #include "ntp_stdlib.h"
17 #include "ntp_unixtime.h"
18 #include "ntp_debug.h"
19 #include "ntp_tty.h"
20 
21 #ifdef HAVE_UNISTD_H
22 #include <unistd.h>
23 #endif
24 
25 #ifdef SYS_WINNT
26 #include <conio.h>
27 #else
28 #ifdef SYS_VXWORKS
29 #include "taskLib.h"
30 #include "sysLib.h"
31 #include "time.h"
32 #include "ntp_syslog.h"
33 
34 /*	some translations to the world of vxWorkings -casey */
35 /* first some netdb type things */
36 #include "ioLib.h"
37 #include <socket.h>
38 int h_errno;
39 
40 struct hostent *gethostbyname(char *name)
41 	{
42 	struct hostent *host1;
43 	h_errno = 0;					/* we are always successful!!! */
44 	host1 = (struct hostent *) emalloc (sizeof(struct hostent));
45 	host1->h_name = name;
46 	host1->h_addrtype = AF_INET;
47 	host1->h_aliases = name;
48 	host1->h_length = 4;
49 	host1->h_addr_list[0] = (char *)hostGetByName (name);
50 	host1->h_addr_list[1] = NULL;
51 	return host1;
52 	}
53 
54 struct hostent *gethostbyaddr(char *name, int size, int addr_type)
55 	{
56 	struct hostent *host1;
57 	h_errno = 0;  /* we are always successful!!! */
58 	host1 = (struct hostent *) emalloc (sizeof(struct hostent));
59 	host1->h_name = name;
60 	host1->h_addrtype = AF_INET;
61 	host1->h_aliases = name;
62 	host1->h_length = 4;
63 	host1->h_addr_list = NULL;
64 	return host1;
65 	}
66 
67 struct servent *getservbyname (char *name, char *type)
68 	{
69 	struct servent *serv1;
70 	serv1 = (struct servent *) emalloc (sizeof(struct servent));
71 	serv1->s_name = "ntp";      /* official service name */
72 	serv1->s_aliases = NULL;	/* alias list */
73 	serv1->s_port = 123;		/* port # */
74 	serv1->s_proto = "udp";     /* protocol to use */
75 	return serv1;
76 	}
77 
78 /* second
79  * vxworks thinks it has insomnia
80  * we have to sleep for number of seconds
81  */
82 
83 #define CLKRATE 	sysClkRateGet()
84 
85 /* I am not sure how valid the granularity is - it is from G. Eger's port */
86 #define CLK_GRANULARITY  1		/* Granularity of system clock in usec	*/
87 								/* Used to round down # usecs/tick		*/
88 								/* On a VCOM-100, PIT gets 8 MHz clk,	*/
89 								/*	& it prescales by 32, thus 4 usec	*/
90 								/* on mv167, granularity is 1usec anyway*/
91 								/* To defeat rounding, set to 1 		*/
92 #define USECS_PER_SEC		MILLION		/* Microseconds per second	*/
93 #define TICK (((USECS_PER_SEC / CLKRATE) / CLK_GRANULARITY) * CLK_GRANULARITY)
94 
95 /* emulate unix sleep
96  * casey
97  */
98 void sleep(int seconds)
99 	{
100 	taskDelay(seconds*TICK);
101 	}
102 /* emulate unix alarm
103  * that pauses and calls SIGALRM after the seconds are up...
104  * so ... taskDelay() fudged for seconds should amount to the same thing.
105  * casey
106  */
107 void alarm (int seconds)
108 	{
109 	sleep(seconds);
110 	}
111 
112 #endif /* SYS_VXWORKS */
113 
114 #ifdef SYS_PTX			/* Does PTX still need this? */
115 /*#include <sys/types.h>	*/
116 #include <sys/procstats.h>
117 
118 int
119 gettimeofday(
120 	struct timeval *tvp
121 	)
122 {
123 	/*
124 	 * hi, this is Sequents sneak path to get to a clock
125 	 * this is also the most logical syscall for such a function
126 	 */
127 	return (get_process_stats(tvp, PS_SELF, (struct procstats *) 0,
128 				  (struct procstats *) 0));
129 }
130 #endif /* SYS_PTX */
131 
132 #ifdef MPE
133 /* This is a substitute for bind() that if called for an AF_INET socket
134 port less than 1024, GETPRIVMODE() and GETUSERMODE() calls will be done. */
135 
136 #undef bind
137 #include <sys/types.h>
138 #include <sys/socket.h>
139 #include <netinet/in.h>
140 #include <sys/un.h>
141 
142 extern void GETPRIVMODE(void);
143 extern void GETUSERMODE(void);
144 
145 int __ntp_mpe_bind(int s, void *addr, int addrlen);
146 
147 int __ntp_mpe_bind(int s, void *addr, int addrlen) {
148 	int priv = 0;
149 	int result;
150 
151 if (addrlen == sizeof(struct sockaddr_in)) { /* AF_INET */
152 	if (((struct sockaddr_in *)addr)->sin_port > 0 &&
153 	    ((struct sockaddr_in *)addr)->sin_port < 1024) {
154 		priv = 1;
155 		GETPRIVMODE();
156 	}
157 /*	((struct sockaddr_in *)addr)->sin_addr.s_addr = 0; */
158 	result = bind(s,addr,addrlen);
159 	if (priv == 1) GETUSERMODE();
160 } else /* AF_UNIX */
161 	result = bind(s,addr,addrlen);
162 
163 return result;
164 }
165 
166 /*
167  * MPE stupidly requires sfcntl() to be used on sockets instead of fcntl(),
168  * so we define a wrapper to analyze the file descriptor and call the correct
169  * function.
170  */
171 
172 #undef fcntl
173 #include <errno.h>
174 #include <fcntl.h>
175 
176 int __ntp_mpe_fcntl(int fd, int cmd, int arg);
177 
178 int __ntp_mpe_fcntl(int fd, int cmd, int arg) {
179 	int len;
180 	struct sockaddr sa;
181 
182 	extern int sfcntl(int, int, int);
183 
184 	len = sizeof sa;
185 	if (getsockname(fd, &sa, &len) == -1) {
186 		if (errno == EAFNOSUPPORT) /* AF_UNIX socket */
187 			return sfcntl(fd, cmd, arg);
188 		if (errno == ENOTSOCK) /* file or pipe */
189 			return fcntl(fd, cmd, arg);
190 		return (-1); /* unknown getsockname() failure */
191 	} else /* AF_INET socket */
192 		return sfcntl(fd, cmd, arg);
193 }
194 
195 /*
196  * Setitimer emulation support.  Note that we implement this using alarm(),
197  * and since alarm() only delivers one signal, we must re-enable the alarm
198  * by enabling our own SIGALRM setitimer_mpe_handler routine to be called
199  * before the real handler routine and re-enable the alarm at that time.
200  *
201  * Note that this solution assumes that sigaction(SIGALRM) is called before
202  * calling setitimer().  If it should ever to become necessary to support
203  * sigaction(SIGALRM) after calling setitimer(), it will be necessary to trap
204  * those sigaction() calls.
205  */
206 
207 #include <limits.h>
208 #include <signal.h>
209 
210 /*
211  * Some global data that needs to be shared between setitimer() and
212  * setitimer_mpe_handler().
213  */
214 
215 struct {
216 	unsigned long current_msec;	/* current alarm() value in effect */
217 	unsigned long interval_msec;	/* next alarm() value from setitimer */
218 	unsigned long value_msec;	/* first alarm() value from setitimer */
219 	struct itimerval current_itimerval; /* current itimerval in effect */
220 	struct sigaction oldact;	/* SIGALRM state saved by setitimer */
221 } setitimer_mpe_ctx = { 0, 0, 0 };
222 
223 /*
224  * Undocumented, unsupported function to do alarm() in milliseconds.
225  */
226 
227 extern unsigned int px_alarm(unsigned long, int *);
228 
229 /*
230  * The SIGALRM handler routine enabled by setitimer().  Re-enable the alarm or
231  * restore the original SIGALRM setting if no more alarms are needed.  Then
232  * call the original SIGALRM handler (if any).
233  */
234 
235 static RETSIGTYPE setitimer_mpe_handler(int sig)
236 {
237 int alarm_hpe_status;
238 
239 /* Update the new current alarm value */
240 
241 setitimer_mpe_ctx.current_msec = setitimer_mpe_ctx.interval_msec;
242 
243 if (setitimer_mpe_ctx.interval_msec > 0) {
244   /* Additional intervals needed; re-arm the alarm timer */
245   px_alarm(setitimer_mpe_ctx.interval_msec,&alarm_hpe_status);
246 } else {
247   /* No more intervals, so restore previous original SIGALRM handler */
248   sigaction(SIGALRM, &setitimer_mpe_ctx.oldact, NULL);
249 }
250 
251 /* Call the original SIGALRM handler if it is a function and not just a flag */
252 
253 if (setitimer_mpe_ctx.oldact.sa_handler != SIG_DFL &&
254     setitimer_mpe_ctx.oldact.sa_handler != SIG_ERR &&
255     setitimer_mpe_ctx.oldact.sa_handler != SIG_IGN)
256   (*setitimer_mpe_ctx.oldact.sa_handler)(SIGALRM);
257 
258 }
259 
260 /*
261  * Our implementation of setitimer().
262  */
263 
264 int
265 setitimer(int which, struct itimerval *value,
266 	    struct itimerval *ovalue)
267 {
268 
269 int alarm_hpe_status;
270 unsigned long remaining_msec, value_msec, interval_msec;
271 struct sigaction newact;
272 
273 /*
274  * Convert the initial interval to milliseconds
275  */
276 
277 if (value->it_value.tv_sec > (UINT_MAX / 1000))
278   value_msec = UINT_MAX;
279 else
280   value_msec = value->it_value.tv_sec * 1000;
281 
282 value_msec += value->it_value.tv_usec / 1000;
283 
284 /*
285  * Convert the reset interval to milliseconds
286  */
287 
288 if (value->it_interval.tv_sec > (UINT_MAX / 1000))
289   interval_msec = UINT_MAX;
290 else
291   interval_msec = value->it_interval.tv_sec * 1000;
292 
293 interval_msec += value->it_interval.tv_usec / 1000;
294 
295 if (value_msec > 0 && interval_msec > 0) {
296   /*
297    * We'll be starting an interval timer that will be repeating, so we need to
298    * insert our own SIGALRM signal handler to schedule the repeats.
299    */
300 
301   /* Read the current SIGALRM action */
302 
303   if (sigaction(SIGALRM, NULL, &setitimer_mpe_ctx.oldact) < 0) {
304     fprintf(stderr,"MPE setitimer old handler failed, errno=%d\n",errno);
305     return -1;
306   }
307 
308   /* Initialize the new action to call our SIGALRM handler instead */
309 
310   newact.sa_handler = &setitimer_mpe_handler;
311   newact.sa_mask = setitimer_mpe_ctx.oldact.sa_mask;
312   newact.sa_flags = setitimer_mpe_ctx.oldact.sa_flags;
313 
314   if (sigaction(SIGALRM, &newact, NULL) < 0) {
315     fprintf(stderr,"MPE setitimer new handler failed, errno=%d\n",errno);
316     return -1;
317   }
318 }
319 
320 /*
321  * Return previous itimerval if desired
322  */
323 
324 if (ovalue != NULL) *ovalue = setitimer_mpe_ctx.current_itimerval;
325 
326 /*
327  * Save current parameters for later usage
328  */
329 
330 setitimer_mpe_ctx.current_itimerval = *value;
331 setitimer_mpe_ctx.current_msec = value_msec;
332 setitimer_mpe_ctx.value_msec = value_msec;
333 setitimer_mpe_ctx.interval_msec = interval_msec;
334 
335 /*
336  * Schedule the first alarm
337  */
338 
339 remaining_msec = px_alarm(value_msec, &alarm_hpe_status);
340 if (alarm_hpe_status == 0)
341   return (0);
342 else
343   return (-1);
344 }
345 
346 /*
347  * MPE lacks gettimeofday(), so we define our own.
348  */
349 
350 int gettimeofday(struct timeval *tvp)
351 
352 {
353 /* Documented, supported MPE functions. */
354 extern void GETPRIVMODE(void);
355 extern void GETUSERMODE(void);
356 
357 /* Undocumented, unsupported MPE functions. */
358 extern long long get_time(void);
359 extern void get_time_change_info(long long *, char *, char *);
360 extern long long ticks_to_micro(long long);
361 
362 char pwf_since_boot, recover_pwf_time;
363 long long mpetime, offset_ticks, offset_usec;
364 
365 GETPRIVMODE();
366 mpetime = get_time(); /* MPE local time usecs since Jan 1 1970 */
367 get_time_change_info(&offset_ticks, &pwf_since_boot, &recover_pwf_time);
368 offset_usec = ticks_to_micro(offset_ticks);  /* UTC offset usecs */
369 GETUSERMODE();
370 
371 mpetime = mpetime - offset_usec;  /* Convert from local time to UTC */
372 tvp->tv_sec = mpetime / 1000000LL;
373 tvp->tv_usec = mpetime % 1000000LL;
374 
375 return 0;
376 }
377 
378 /*
379  * MPE lacks settimeofday(), so we define our own.
380  */
381 
382 #define HAVE_SETTIMEOFDAY
383 
384 int settimeofday(struct timeval *tvp)
385 
386 {
387 /* Documented, supported MPE functions. */
388 extern void GETPRIVMODE(void);
389 extern void GETUSERMODE(void);
390 
391 /* Undocumented, unsupported MPE functions. */
392 extern void get_time_change_info(long long *, char *, char *);
393 extern void initialize_system_time(long long, int);
394 extern void set_time_correction(long long, int, int);
395 extern long long ticks_to_micro(long long);
396 
397 char pwf_since_boot, recover_pwf_time;
398 long long big_sec, big_usec, mpetime, offset_ticks, offset_usec;
399 
400 big_sec = tvp->tv_sec;
401 big_usec = tvp->tv_usec;
402 mpetime = (big_sec * 1000000LL) + big_usec;  /* Desired UTC microseconds */
403 
404 GETPRIVMODE();
405 set_time_correction(0LL,0,0); /* Cancel previous time correction, if any */
406 get_time_change_info(&offset_ticks, &pwf_since_boot, &recover_pwf_time);
407 offset_usec = ticks_to_micro(offset_ticks); /* UTC offset microseconds */
408 mpetime = mpetime + offset_usec; /* Convert from UTC to local time */
409 initialize_system_time(mpetime,1);
410 GETUSERMODE();
411 
412 return 0;
413 }
414 #endif /* MPE */
415 
416 #define SET_TOD_UNDETERMINED	0
417 #define SET_TOD_CLOCK_SETTIME	1
418 #define SET_TOD_SETTIMEOFDAY	2
419 #define SET_TOD_STIME		3
420 
421 const char * const set_tod_used[] = {
422 	"undetermined",
423 	"clock_settime",
424 	"settimeofday",
425 	"stime"
426 };
427 
428 pset_tod_using	set_tod_using = NULL;
429 
430 
431 int
432 ntp_set_tod(
433 	struct timeval *tvp,
434 	void *tzp
435 	)
436 {
437 	static int	tod;
438 	int		rc;
439 	int		saved_errno;
440 
441 	TRACE(1, ("In ntp_set_tod\n"));
442 	rc = -1;
443 	saved_errno = 0;
444 
445 #ifdef HAVE_CLOCK_SETTIME
446 	if (rc && (SET_TOD_CLOCK_SETTIME == tod || !tod)) {
447 		struct timespec ts;
448 
449 		/* Convert timeval to timespec */
450 		ts.tv_sec = tvp->tv_sec;
451 		ts.tv_nsec = 1000 *  tvp->tv_usec;
452 
453 		errno = 0;
454 		rc = clock_settime(CLOCK_REALTIME, &ts);
455 		saved_errno = errno;
456 		TRACE(1, ("ntp_set_tod: clock_settime: %d %m\n", rc));
457 		if (!tod && !rc)
458 			tod = SET_TOD_CLOCK_SETTIME;
459 
460 	}
461 #endif /* HAVE_CLOCK_SETTIME */
462 #ifdef HAVE_SETTIMEOFDAY
463 	if (rc && (SET_TOD_SETTIMEOFDAY == tod || !tod)) {
464 		struct timeval adjtv;
465 
466 		/*
467 		 * Some broken systems don't reset adjtime() when the
468 		 * clock is stepped.
469 		 */
470 		adjtv.tv_sec = adjtv.tv_usec = 0;
471 		adjtime(&adjtv, NULL);
472 		errno = 0;
473 		rc = SETTIMEOFDAY(tvp, tzp);
474 		saved_errno = errno;
475 		TRACE(1, ("ntp_set_tod: settimeofday: %d %m\n", rc));
476 		if (!tod && !rc)
477 			tod = SET_TOD_SETTIMEOFDAY;
478 	}
479 #endif /* HAVE_SETTIMEOFDAY */
480 #ifdef HAVE_STIME
481 	if (rc && (SET_TOD_STIME == tod || !tod)) {
482 		long tp = tvp->tv_sec;
483 
484 		errno = 0;
485 		rc = stime(&tp); /* lie as bad as SysVR4 */
486 		saved_errno = errno;
487 		TRACE(1, ("ntp_set_tod: stime: %d %m\n", rc));
488 		if (!tod && !rc)
489 			tod = SET_TOD_STIME;
490 	}
491 #endif /* HAVE_STIME */
492 
493 	errno = saved_errno;	/* for %m below */
494 	TRACE(1, ("ntp_set_tod: Final result: %s: %d %m\n",
495 		  set_tod_used[tod], rc));
496 	/*
497 	 * Say how we're setting the time of day
498 	 */
499 	if (!rc && NULL != set_tod_using) {
500 		(*set_tod_using)(set_tod_used[tod]);
501 		set_tod_using = NULL;
502 	}
503 
504 	if (rc)
505 		errno = saved_errno;
506 
507 	return rc;
508 }
509 
510 #endif /* not SYS_WINNT */
511 
512 #if defined (SYS_WINNT) || defined (SYS_VXWORKS) || defined(MPE)
513 /* getpass is used in ntpq.c and ntpdc.c */
514 
515 char *
516 getpass(const char * prompt)
517 {
518 	int c, i;
519 	static char password[32];
520 
521 	fprintf(stderr, "%s", prompt);
522 	fflush(stderr);
523 
524 	for (i=0; i<sizeof(password)-1 && ((c=_getch())!='\n' && c!='\r'); i++) {
525 		password[i] = (char) c;
526 	}
527 	password[i] = '\0';
528 
529 	fputc('\n', stderr);
530 	fflush(stderr);
531 
532 	return password;
533 }
534 #endif /* SYS_WINNT */
535 
536 
537 static const int baudTable[][2] = {
538 	{B0, 0},
539 	{B50, 50},
540 	{B75, 75},
541 	{B110, 110},
542 	{B134, 134},
543 	{B150, 150},
544 	{B200, 200},
545 	{B300, 300},
546 	{B600, 600},
547 	{B1200, 1200},
548 	{B1800, 1800},
549 	{B2400, 2400},
550 	{B4800, 4800},
551 	{B9600, 9600},
552 	{B19200, 19200},
553 	{B38400, 38400},
554 #   ifdef B57600
555 	{B57600, 57600 },
556 #   endif
557 #   ifdef B115200
558 	{B115200, 115200},
559 #   endif
560 	{-1, -1}
561 };
562 
563 
564 int  symBaud2numBaud(int symBaud)
565 {
566 	int i;
567 
568 	for (i = 0; baudTable[i][1] >= 0; ++i) {
569 		if (baudTable[i][0] == symBaud) {
570 			break;
571 		}
572 	}
573 	return baudTable[i][1];
574 }
575 
576 
577 #if 0	/* unused */
578 int  numBaud2symBaud(int numBaud)
579 {
580 	int i;
581 
582 	for (i = 0; baudTable[i][1] >= 0; ++i) {
583 		if (baudTable[i][1] == numBaud) {
584 			break;
585 		}
586 	}
587 	return baudTable[i][0];
588 }
589 #endif	/* unused fn */
590