ntp/ntpd/refclock_parse.c

6  * generic reference clock driver for several DCF/GPS/MSF/... receivers
82  * Meinberg generic receiver setup:
393 	struct refclockproc *generic;		/* backlink to refclockproc structure */
462 #define DCF_ID		"DCF"	/* generic DCF */
1535 #define PARSE_STATETIME(parse, i) ((parse->generic->currentstatus == i) ? parse->statetime[i] + current_time - parse->lastchange : parse->statetime[i])
1851 	if (ioctl(parse->generic->io.fd, I_PUSH, (caddr_t)m1) == -1)
1861 		while(ioctl(parse->generic->io.fd, I_POP, (caddr_t)0) == 0)
1868 		if (ioctl(parse->generic->io.fd, I_PUSH, (caddr_t)m1) == -1)
1888 	while(ioctl(parse->generic->io.fd, I_POP, (caddr_t)0) == 0)
1908 	if (ioctl(parse->generic->io.fd, I_STR, (caddr_t)&strioc) == -1)
1931 	if (ioctl(parse->generic->io.fd, I_STR, (caddr_t)&strioc) == -1)
1936 	parse->generic->io.clock_recv = stream_receive; /* ok - parse input in kernel */
1955 	if (ioctl(parse->generic->io.fd, I_STR, (caddr_t)&strioc) == -1)
1960 	parse->generic->io.clock_recv = local_receive; /* ok - parse input in daemon */
1979 	if (ioctl(parse->generic->io.fd, I_STR, (caddr_t)&strioc) == -1)
2003 	if (ioctl(parse->generic->io.fd, I_STR, (caddr_t)&strioc) == -1)
2028 	if (ioctl(parse->generic->io.fd, I_STR, (caddr_t)&strioc) == -1)
2383 					parse->generic->io.recvcount++;
2732 				l_mktime(current_time - parse->generic->timestarted));
2736 				clockstatus(parse->generic->currentstatus));
2741 				u_long percent, d = current_time - parse->generic->timestarted;
2815 	if (parse->generic->io.fd != parse->ppsfd && parse->ppsfd != -1)
2838 	io_closeclock(&parse->generic->io);
2908 	 * collect PPSAPI offset capability - should move into generic handling
2918 	 * initialize generic PPSAPI interface
2922 	 * be part of the generic PPSAPI interface
3041 	parse->generic = peer->procptr;	 /* link up */
3042 	parse->generic->unitptr = (caddr_t)parse; /* link down */
3047 	parse->generic->timestarted    = current_time;
3068 	parse->generic->fudgetime1 = parse->parse_type->cl_basedelay;
3070 	parse->generic->fudgetime2 = 0.0;
3071 	parse->ppsphaseadjust = parse->generic->fudgetime2;
3072 	parse->generic->fudgeminjitter = 0.0;
3074 	parse->generic->clockdesc  = parse->parse_type->cl_description;
3083 	    memmove((char *)&parse->generic->refid, parse->parse_type->cl_id, 4);
3085 	    parse->generic->refid = htonl(PARSEHSREFID);
3087 	parse->generic->io.fd = fd232;
3108 		disablec = fpathconf(parse->generic->io.fd, _PC_VDISABLE);
3236 	parse->generic->io.srcclock = peer;
3237 	parse->generic->io.datalen = 0;
3248 	parse->generic->io.clock_recv = parse->binding->bd_receive; /* pick correct receive routine */
3249 	parse->generic->io.io_input   = parse->binding->bd_io_input; /* pick correct input routine */
3299 	(void) tcflush(parse->generic->io.fd, TCIOFLUSH);
3305 		(void) ioctl(parse->generic->io.fd, TCFLSH, (caddr_t)&flshcmd);
3325 	if (!io_addclock(&parse->generic->io))
3342 				(parse->ppsfd != parse->generic->io.fd) ? parseppsdev : parsedev);
3352 				parse->generic->fudgetime1,
3398 		  parse->generic->fudgetime1 = in->fudgetime1;
3401 			  parse->generic->fudgetime1);
3406 		  parse->generic->fudgetime2 = in->fudgetime2;
3429 		parse->generic->fudgeminjitter = in->fudgeminjitter;
3455 	parse->generic->polls++;
3541 		parse->generic->fudgetime2 = (parse->flags & PARSE_TRUSTTIME) ? (double)parse->maxunsync : parse->ppsphaseadjust;
3647 			u_long d = current_time - parse->generic->timestarted;
3670 					(parse->generic->currentstatus == i) ? "*" : "",
3724 	if (parse->generic->currentstatus != (u_char) event)
3726 		parse->statetime[parse->generic->currentstatus] += current_time - parse->lastchange;
3989 	fudge = parse->generic->fudgetime1; /* standard RS232 Fudgefactor */
4159 		parse->generic->leap = LEAP_NOTINSYNC;
4171 			parse->generic->leap = (parse->flags & PARSE_LEAP_DELETE) ? LEAP_DELSECOND : LEAP_ADDSECOND;
4176 			    parse->generic->leap = LEAP_DELSECOND;
4180 			    parse->generic->leap = LEAP_NOWARNING;
4184 	if (parse->generic->leap != LEAP_NOTINSYNC)
4199 		parse->generic->lastref = reftime;
4201 		refclock_process_offset(parse->generic, reftime, rectime, fudge);
4724 	rtc = (int) write(parse->generic->io.fd, cmd_buffer, (unsigned long)(outp - cmd_buffer));
4791 	rtc = write(parse->generic->io.fd, ps, ct);
4863 	if (TTY_GETATTR(parse->generic->io.fd, &tio) == -1)
4872 		if (TTY_SETATTR(parse->generic->io.fd, &tio) == -1)
4907 				    int rtc = (int) write(parse->generic->io.fd, *iv, strlen(*iv));
5085 	if (write(parse->generic->io.fd, buf->txt, (unsigned long)buf->idx) != buf->idx)
5306 	if (TTY_GETATTR(parse->generic->io.fd, &tio) == -1)
5308 		msyslog(LOG_ERR, "PARSE receiver #%d: trimbletsip_init: tcgetattr(%d, &tio): %m", CLK_UNIT(parse->peer), parse->generic->io.fd);
5323 		if (TTY_SETATTR(parse->generic->io.fd, &tio) == -1)
5325 			msyslog(LOG_ERR, "PARSE receiver #%d: trimbletsip_init: tcsetattr(%d, &tio): %m", CLK_UNIT(parse->peer), parse->generic->io.fd);
5847 	if (ioctl(parse->generic->io.fd, TIOCMGET, (caddr_t)&sl232) == -1)
5859 	if (ioctl(parse->generic->io.fd, TIOCMSET, (caddr_t)&sl232) == -1)
5894 	if (ioctl(parse->generic->io.fd, TIOCMGET, (caddr_t)&sl232) == -1)
5906 	if (ioctl(parse->generic->io.fd, TIOCMSET, (caddr_t)&sl232) == -1)