ntp/ntpd/refclock_datum.c

222 	struct datum_pts_unit *datum_pts;
247 	datum_pts = emalloc_zero(sizeof(*datum_pts));
248 	datum_pts->unit = unit;	/* set my unit id */
249 	datum_pts->yearstart = 0;	/* initialize the yearstart to 0 */
250 	datum_pts->sigma2 = 0.0;	/* initialize the sigma2 to 0 */
252 	datum_pts->PTS_fd = fd;
254 	if (-1 == fcntl(datum_pts->PTS_fd, F_SETFL, 0)) /* clear the descriptor flags */
261 		   datum_pts->PTS_fd);
281 	rc = tcsetattr(datum_pts->PTS_fd, TCSANOW, &arg);
284 		close(datum_pts->PTS_fd);
285 		free(datum_pts);
293 	datum_pts->peer = peer;
298 	pp->io.fd = datum_pts->PTS_fd;
308 		close(datum_pts->PTS_fd);
309 		free(datum_pts);
313 	peer->procptr->unitptr = datum_pts;
337 	struct datum_pts_unit *datum_pts;
351 	datum_pts = pp->unitptr;
352 	if (NULL != datum_pts) {
354 		free(datum_pts);
372 	struct datum_pts_unit *datum_pts;
374 	datum_pts = peer->procptr->unitptr;
384 	error_code = write(datum_pts->PTS_fd, TIME_REQUEST, 6);
387 	datum_pts->nbytes = 0;
491 	struct datum_pts_unit *datum_pts;
508 	datum_pts = p->procptr->unitptr;
529 	nb = datum_pts->nbytes;
531 		datum_pts->lastrec = rbufp->recv_time;
540 	for (i=0; (i < dpend) && (nb < sizeof(datum_pts->retbuf)); i++, nb++) {
541 		datum_pts->retbuf[nb] = dpt[i];
543 	datum_pts->nbytes = nb;
556 	datum_pts->day =	100*(datum_pts->retbuf[0] & 0x0f) +
557 		10*((datum_pts->retbuf[1] & 0xf0)>>4) +
558 		(datum_pts->retbuf[1] & 0x0f);
560 	datum_pts->hour =	10*((datum_pts->retbuf[2] & 0x30)>>4) +
561 		(datum_pts->retbuf[2] & 0x0f);
563 	datum_pts->minute =	10*((datum_pts->retbuf[3] & 0x70)>>4) +
564 		(datum_pts->retbuf[3] & 0x0f);
566 	datum_pts->second =	10*((datum_pts->retbuf[4] & 0x70)>>4) +
567 		(datum_pts->retbuf[4] & 0x0f);
569 	datum_pts->msec =	100*((datum_pts->retbuf[5] & 0xf0) >> 4) +
570 		10*(datum_pts->retbuf[5] & 0x0f) +
571 		((datum_pts->retbuf[6] & 0xf0)>>4);
573 	datum_pts->usec =	1000*datum_pts->msec;
578 		   datum_pts->day,
579 		   datum_pts->hour,
580 		   datum_pts->minute,
581 		   datum_pts->second,
582 		   datum_pts->msec);
610 	** zone offset is stored in the datum_pts structure for future use. Normally,
620 		if (clocktime( datum_pts->day,
621 			       datum_pts->hour,
622 			       datum_pts->minute,
623 			       datum_pts->second,
624 			       (tzoff + datum_pts->tzoff) % 24,
625 			       datum_pts->lastrec.l_ui,
626 			       &datum_pts->yearstart,
627 			       &datum_pts->lastref.l_ui) ) {
629 			datum_pts->lastref.l_uf = 0;
630 			error = datum_pts->lastref.l_ui - datum_pts->lastrec.l_ui;
637 				tzoff = (tzoff + datum_pts->tzoff) % 24;
638 				datum_pts->tzoff = tzoff;
661 		if (!clocktime( datum_pts->day,
662 				datum_pts->hour,
663 				datum_pts->minute,
664 				datum_pts->second,
666 				datum_pts->lastrec.l_ui,
667 				&datum_pts->yearstart,
668 				&datum_pts->lastref.l_ui) ) {
676 				       datum_pts->lastrec.l_ui,
677 				       datum_pts->yearstart,
678 				       datum_pts->lastref.l_ui);
698 	** We have datum_pts->lastref.l_ui set (which is the integer part of the
702 	TVUTOTSF(datum_pts->usec, datum_pts->lastref.l_uf);
709 	tstmp = datum_pts->lastref;		/* tstmp is the datum ntp time */
710 	L_SUB(&tstmp, &datum_pts->lastrec);	/* tstmp is now the correction */
711 	datum_pts->coderecv++;		/* increment a counter */
731 	datum_pts->lastref = datum_pts->lastrec;
732 	refclock_receive(datum_pts->peer);
750 	if (datum_pts->sigma2 == 0.0) {
752 			datum_pts->sigma2 = abserr*abserr;
754 			datum_pts->sigma2 = DATUM_MAX_ERROR2;
758 			datum_pts->sigma2 = 0.95*datum_pts->sigma2 + 0.05*abserr*abserr;
760 			datum_pts->sigma2 = 0.95*datum_pts->sigma2 + 0.05*DATUM_MAX_ERROR2;
772 		   datum_pts->day,
773 		   datum_pts->hour,
774 		   datum_pts->minute,
775 		   datum_pts->second,
776 		   datum_pts->msec,