Lines Matching full:peer
106 #define COMMAND_HALT_BCAST ( (peer->MODE % 2) ? "O0" : "B0" )
107 #define COMMAND_START_BCAST ( (peer->MODE % 2) ? "O5" : "B5" )
123 static int arb_start (int, struct peer *);
124 static void arb_shutdown (int, struct peer *);
126 static void arb_poll (int, struct peer *);
148 struct peer *peer in arb_start() argument
160 fd = refclock_open(&peer->srcadr, device, SPEED232, LDISC_CLK); in arb_start()
168 pp = peer->procptr; in arb_start()
170 pp->io.srcclock = peer; in arb_start()
184 peer->precision = PRECISION; in arb_start()
187 if (peer->MODE > 1) { in arb_start()
188 msyslog(LOG_NOTICE, "ARBITER: Invalid mode %d", peer->MODE); in arb_start()
195 if(debug) { printf("arbiter: mode = %d.\n", peer->MODE); } in arb_start()
197 refclock_write(peer, COMMAND_HALT_BCAST, 2, "HALT_BCAST"); in arb_start()
208 struct peer *peer in arb_shutdown() argument
214 pp = peer->procptr; in arb_shutdown()
233 struct peer *peer; in arb_receive() local
242 peer = rbufp->recv_peer; in arb_receive()
243 pp = peer->procptr; in arb_receive()
282 refclock_write(peer, "SR", 2, "SR"); in arb_receive()
289 refclock_write(peer, "LA", 2, "LA"); in arb_receive()
291 refclock_write(peer, COMMAND_START_BCAST, 2, in arb_receive()
297 refclock_write(peer, "LO", 2, "LO"); in arb_receive()
303 refclock_write(peer, "LH", 2, "LH"); in arb_receive()
309 refclock_write(peer, "DB", 2, "DB"); in arb_receive()
315 record_clock_stats(&peer->srcadr, up->latlon); in arb_receive()
320 refclock_write(peer, COMMAND_START_BCAST, 2, in arb_receive()
349 refclock_report(peer, CEVNT_BADREPLY); in arb_receive()
350 refclock_write(peer, COMMAND_HALT_BCAST, 2, COMMAND_HALT_BCAST); in arb_receive()
399 refclock_report(peer, CEVNT_FAULT); in arb_receive()
400 refclock_write(peer, COMMAND_HALT_BCAST, 2, in arb_receive()
406 refclock_report(peer, CEVNT_BADREPLY); in arb_receive()
407 refclock_write(peer, COMMAND_HALT_BCAST, 2, in arb_receive()
421 refclock_report(peer, CEVNT_BADTIME); in arb_receive()
422 else if (peer->disp > MAXDISTANCE) in arb_receive()
423 refclock_receive(peer); in arb_receive()
426 refclock_write(peer, COMMAND_HALT_BCAST, 2, COMMAND_HALT_BCAST); in arb_receive()
437 struct peer *peer in arb_poll() argument
451 pp = peer->procptr; in arb_poll()
455 if (refclock_write(peer, "TQ", 2, "TQ") != 2) in arb_poll()
456 refclock_report(peer, CEVNT_FAULT); in arb_poll()
463 refclock_report(peer, CEVNT_TIMEOUT); in arb_poll()
466 refclock_receive(peer); in arb_poll()
467 record_clock_stats(&peer->srcadr, pp->a_lastcode); in arb_poll()