ntp/ntpd/refclock_arbiter.c

158 	struct refclockproc *pp;
174 	pp = peer->procptr;
175 	pp->io.clock_recv = arb_receive;
176 	pp->io.srcclock = peer;
177 	pp->io.datalen = 0;
178 	pp->io.fd = fd;
179 	if (!io_addclock(&pp->io)) {
181 		pp->io.fd = -1;
185 	pp->unitptr = up;
191 	pp->clockdesc = DESCRIPTION;
192 	memcpy((char *)&pp->refid, REFID, 4);
196 		pp->io.fd = -1;
203 	write(pp->io.fd, COMMAND_HALT_BCAST, 2);
218 	struct refclockproc *pp;
220 	pp = peer->procptr;
221 	up = pp->unitptr;
222 	if (-1 != pp->io.fd)
223 		io_closeclock(&pp->io);
238 	struct refclockproc *pp;
249 	pp = peer->procptr;
250 	up = pp->unitptr;
270 	pp->lastrec = up->laststamp;
288 			write(pp->io.fd, "SR", 2);
294 			if (pp->sloppyclockflag & CLK_FLAG4)
295 				write(pp->io.fd, "LA", 2);
297 				write(pp->io.fd, COMMAND_START_BCAST, 2);
302 			write(pp->io.fd, "LO", 2);
308 			write(pp->io.fd, "LH", 2);
314 			write(pp->io.fd, "DB", 2);
325 			write(pp->io.fd, COMMAND_START_BCAST, 2);
345 	strlcpy(pp->a_lastcode, tbuf, sizeof(pp->a_lastcode));
346 	pp->a_lastcode[LENARB - 2] = up->qualchar;
347 	strlcat(pp->a_lastcode, up->status, sizeof(pp->a_lastcode));
348 	pp->lencode = strlen(pp->a_lastcode);
350 	if (sscanf(pp->a_lastcode, "%c%2d %3d %2d:%2d:%2d",
351 	    &syncchar, &pp->year, &pp->day, &pp->hour,
352 	    &pp->minute, &pp->second) != 6) {
354 		write(pp->io.fd, COMMAND_HALT_BCAST, 2);
365 		pp->disp = 1e-7;
366 		pp->lastref = pp->lastrec;
370 		pp->disp = 1e-6;
374 		pp->disp = 1e-5;
378 		pp->disp = 1e-4;
382 		pp->disp = .001;
386 		pp->disp = .01;
390 		pp->disp = .1;
394 		pp->disp = 1;
398 		pp->disp = 10;
402 		pp->disp = MAXDISPERSE;
404 		write(pp->io.fd, COMMAND_HALT_BCAST, 2);
408 		pp->disp = MAXDISPERSE;
410 		write(pp->io.fd, COMMAND_HALT_BCAST, 2);
414 		pp->leap = LEAP_NOTINSYNC;
416 		pp->leap = LEAP_NOWARNING;
422 	if (!refclock_process(pp))
428 	write(pp->io.fd, COMMAND_HALT_BCAST, 2);
443 	struct refclockproc *pp;
453 	pp = peer->procptr;
454 	up = pp->unitptr;
455 	pp->polls++;
457 	if (write(pp->io.fd, "TQ", 2) != 2)
464 	if (pp->coderecv == pp->codeproc) {
469 	record_clock_stats(&peer->srcadr, pp->a_lastcode);
473 		   pp->lencode, pp->a_lastcode);