[Git][NTPsec/ntpsec][master] ntpd/refclock_arbiter.c: remove tabs, Single line /* comments to //
Hal Murray (@hal.murray)
gitlab at mg.gitlab.com
Thu Aug 6 19:56:54 UTC 2026
Hal Murray pushed to branch master at NTPsec / ntpsec
Commits:
5f3a525e by Gary E. Miller at 2026-08-06T12:52:55-07:00
ntpd/refclock_arbiter.c: remove tabs, Single line /* comments to //
- - - - -
1 changed file:
- ntpd/refclock_arbiter.c
Changes:
=====================================
ntpd/refclock_arbiter.c
=====================================
@@ -1,6 +1,6 @@
/*
* refclock_arbiter - clock driver for Arbiter 1088A/B Satellite
- * Controlled Clock
+ * Controlled Clock
*/
#include "config.h"
@@ -35,13 +35,13 @@
*
* <cr><lf>i yy ddd hh:mm:ss.000bbb
*
- * on-time = <cr>
- * i = synchronization flag (' ' = locked, '?' = unlocked)
- * yy = year of century
- * ddd = day of year
- * hh:mm:ss = hours, minutes, seconds
- * .000 = fraction of second (not used)
- * bbb = tailing spaces for fill
+ * on-time = <cr>
+ * i = synchronization flag (' ' = locked, '?' = unlocked)
+ * yy = year of century
+ * ddd = day of year
+ * hh:mm:ss = hours, minutes, seconds
+ * .000 = fraction of second (not used)
+ * bbb = tailing spaces for fill
*
* The alarm condition is indicated by a '?' at i, which indicates the
* receiver is not synchronized. In normal operation, a line consisting
@@ -51,28 +51,28 @@
*
* Format TQ (IEEE P1344 estimated worst-case time quality)
*
- * 0 clock locked, maximum accuracy
- * F clock failure, time not reliable
- * 4 clock unlocked, accuracy < 1 us
- * 5 clock unlocked, accuracy < 10 us
- * 6 clock unlocked, accuracy < 100 us
- * 7 clock unlocked, accuracy < 1 ms
- * 8 clock unlocked, accuracy < 10 ms
- * 9 clock unlocked, accuracy < 100 ms
- * A clock unlocked, accuracy < 1 s
- * B clock unlocked, accuracy < 10 s
+ * 0 clock locked, maximum accuracy
+ * F clock failure, time not reliable
+ * 4 clock unlocked, accuracy < 1 us
+ * 5 clock unlocked, accuracy < 10 us
+ * 6 clock unlocked, accuracy < 100 us
+ * 7 clock unlocked, accuracy < 1 ms
+ * 8 clock unlocked, accuracy < 10 ms
+ * 9 clock unlocked, accuracy < 100 ms
+ * A clock unlocked, accuracy < 1 s
+ * B clock unlocked, accuracy < 10 s
*
* The status string is encoded as follows:
*
* Format SR (25 ASCII printing characters)
*
- * V=vv S=ss T=t P=pdop E=ee
+ * V=vv S=ss T=t P=pdop E=ee
*
- * vv = satellites visible
- * ss = relative signal strength
- * t = satellites tracked
- * pdop = position dilution of precision (meters)
- * ee = hardware errors
+ * vv = satellites visible
+ * ss = relative signal strength
+ * t = satellites tracked
+ * pdop = position dilution of precision (meters)
+ * ee = hardware errors
*
* If flag4 is set, an additional line consisting of the receiver
* latitude (LA), longitude (LO), elevation (LH) (meters), and data
@@ -87,15 +87,15 @@
/*
* Interface definitions
*/
-#define DEVICE "/dev/gps%d" /* device name and unit */
-#define SPEED232 B9600 /* uart speed (9600 baud) */
-#define PRECISION (-20) /* precision assumed (about 1 us) */
-#define REFID "GPS " /* reference ID */
-#define NAME "ARBITER" /* shortname */
-#define DESCRIPTION "Arbiter 1088A/B GPS Receiver" /* WRU */
-#define LENARB 24 /* format B5 timecode length */
-#define MAXSTA 40 /* max length of status string */
-#define MAXPOS 80 /* max length of position string */
+#define DEVICE "/dev/gps%d" // device name and unit
+#define SPEED232 B9600 // uart speed (9600 baud)
+#define PRECISION (-20) // precision assumed (about 1 us)
+#define REFID "GPS " // reference ID
+#define NAME "ARBITER" // shortname
+#define DESCRIPTION "Arbiter 1088A/B GPS Receiver" // WRU
+#define LENARB 24 // format B5 timecode length
+#define MAXSTA 40 // max length of status string
+#define MAXPOS 80 // max length of position string
#define COMMAND_HALT_BCAST ( (peer->cfg.mode % 2) ? "O0" : "B0" )
#define COMMAND_START_BCAST ( (peer->cfg.mode % 2) ? "O5" : "B5" )
@@ -104,31 +104,31 @@
* ARB unit control structure
*/
struct arbunit {
- l_fp laststamp; /* last receive timestamp */
- int tcswitch; /* timecode switch/counter */
- char qualchar; /* IEEE P1344 quality (TQ command) */
- char status[MAXSTA]; /* receiver status (SR command) */
- char latlon[MAXPOS]; /* receiver position (lat/lon/alt) */
+ l_fp laststamp; // last receive timestamp
+ int tcswitch; // timecode switch/counter
+ char qualchar; // IEEE P1344 quality (TQ command)
+ char status[MAXSTA]; // receiver status (SR command)
+ char latlon[MAXPOS]; // receiver position (lat/lon/alt)
};
/*
* Function prototypes
*/
-static bool arb_start (int, struct peer *);
-static void arb_receive (struct recvbuf *);
-static void arb_poll (int, struct peer *);
+static bool arb_start (int, struct peer *);
+static void arb_receive (struct recvbuf *);
+static void arb_poll (int, struct peer *);
/*
* Transfer vector
*/
-struct refclock refclock_arbiter = {
- NAME, /* basename of driver */
- arb_start, /* start up driver */
- NULL, /* shut down driver in standard way */
- arb_poll, /* transmit poll message */
- NULL, /* not used (old arb_control) */
- NULL, /* initialize driver (not used) */
- NULL /* timer - not used */
+struct refclock refclock_arbiter = {
+ NAME, // basename of driver
+ arb_start, // start up driver
+ NULL, // shut down driver in standard way
+ arb_poll, // transmit poll message
+ NULL, // not used (old arb_control)
+ NULL, // initialize driver (not used)
+ NULL // timer - not used
};
@@ -137,60 +137,60 @@ struct refclock refclock_arbiter = {
*/
static bool
arb_start(
- int unit,
- struct peer *peer
- )
+ int unit,
+ struct peer *peer
+ )
{
- struct arbunit *up;
- struct refclockproc *pp;
- int fd;
- char device[20];
-
- /*
- * Open serial port. Use CLK line discipline, if available.
- */
- snprintf(device, sizeof(device), DEVICE, unit);
- fd = refclock_open(peer->cfg.path ? peer->cfg.path : device,
- peer->cfg.baud ? peer->cfg.baud : SPEED232, LDISC_STD);
- if (fd <= 0)
- /* coverity[leaked_handle] */
- return false;
-
- /*
- * Allocate and initialize unit structure
- */
- up = emalloc_zero(sizeof(*up));
- pp = peer->procptr;
- pp->io.clock_recv = arb_receive;
- pp->io.srcclock = peer;
- pp->io.datalen = 0;
- pp->io.fd = fd;
- if (!io_addclock(&pp->io)) {
- close(fd);
- pp->io.fd = -1;
- free(up);
- return false;
- }
- pp->unitptr = up;
-
- /*
- * Initialize miscellaneous variables
- */
- peer->precision = PRECISION;
- pp->clockname = NAME;
- pp->clockdesc = DESCRIPTION;
- memcpy((char *)&pp->refid, REFID, REFIDLEN);
- peer->sstclktype = CTL_SST_TS_UHF;
- if (peer->cfg.mode > 1) {
- msyslog(LOG_NOTICE, "REFCLOCK ARBITER: Invalid mode %u", peer->cfg.mode);
- close(fd);
- pp->io.fd = -1;
- free(up);
- return false;
- }
- DPRINT(1, ("arbiter: mode = %u.\n", peer->cfg.mode));
- IGNORE(write(pp->io.fd, COMMAND_HALT_BCAST, 2));
- return true;
+ struct arbunit *up;
+ struct refclockproc *pp;
+ int fd;
+ char device[20];
+
+ /*
+ * Open serial port. Use CLK line discipline, if available.
+ */
+ snprintf(device, sizeof(device), DEVICE, unit);
+ fd = refclock_open(peer->cfg.path ? peer->cfg.path : device,
+ peer->cfg.baud ? peer->cfg.baud : SPEED232, LDISC_STD);
+ if (fd <= 0)
+ // coverity[leaked_handle]
+ return false;
+
+ /*
+ * Allocate and initialize unit structure
+ */
+ up = emalloc_zero(sizeof(*up));
+ pp = peer->procptr;
+ pp->io.clock_recv = arb_receive;
+ pp->io.srcclock = peer;
+ pp->io.datalen = 0;
+ pp->io.fd = fd;
+ if (!io_addclock(&pp->io)) {
+ close(fd);
+ pp->io.fd = -1;
+ free(up);
+ return false;
+ }
+ pp->unitptr = up;
+
+ /*
+ * Initialize miscellaneous variables
+ */
+ peer->precision = PRECISION;
+ pp->clockname = NAME;
+ pp->clockdesc = DESCRIPTION;
+ memcpy((char *)&pp->refid, REFID, REFIDLEN);
+ peer->sstclktype = CTL_SST_TS_UHF;
+ if (peer->cfg.mode > 1) {
+ msyslog(LOG_NOTICE, "REFCLOCK ARBITER: Invalid mode %u", peer->cfg.mode);
+ close(fd);
+ pp->io.fd = -1;
+ free(up);
+ return false;
+ }
+ DPRINT(1, ("arbiter: mode = %u.\n", peer->cfg.mode));
+ IGNORE(write(pp->io.fd, COMMAND_HALT_BCAST, 2));
+ return true;
}
@@ -199,204 +199,204 @@ arb_start(
*/
static void
arb_receive(
- struct recvbuf *rbufp
- )
+ struct recvbuf *rbufp
+ )
{
- struct arbunit *up;
- struct refclockproc *pp;
- struct peer *peer;
- l_fp trtmp;
- int temp;
- uint8_t syncchar; /* synch indicator */
- char tbuf[BMAX]; /* temp buffer */
-
- /*
- * Initialize pointers and read the timecode and timestamp
- */
- peer = rbufp->recv_peer;
- pp = peer->procptr;
- up = pp->unitptr;
- temp = refclock_gtlin(rbufp, tbuf, sizeof(tbuf), &trtmp);
-
- /*
- * Note we get a buffer and timestamp for both a <cr> and <lf>,
- * but only the <cr> timestamp is retained. The program first
- * sends a TQ and expects the echo followed by the time quality
- * character. It then sends a B5 starting the timecode broadcast
- * and expects the echo followed some time later by the on-time
- * character <cr> and then the <lf> beginning the timecode
- * itself. Finally, at the <cr> beginning the next timecode at
- * the next second, the program sends a B0 shutting down the
- * timecode broadcast.
- *
- * If flag4 is set, the program snatches the latitude, longitude
- * and elevation and writes it to the clockstats file.
- */
- if (temp == 0) {
- return;
- }
-
- pp->lastrec = up->laststamp;
- up->laststamp = trtmp;
- if (temp < 3) {
- return;
- }
-
- if (up->tcswitch == 0) {
-
- /*
- * Collect statistics. If nothing is recognized, just
- * ignore; sometimes the clock doesn't stop spewing
- * timecodes for awhile after the B0 command.
- *
- * If flag4 is not set, send TQ, SR, B5. If flag4 is
- * sset, send TQ, SR, LA, LO, LH, DB, B5. When the
- * median filter is full, send B0.
- */
- if (!strncmp(tbuf, "TQ", 2)) {
- up->qualchar = tbuf[2];
- IGNORE(write(pp->io.fd, "SR", 2));
- return;
-
- } else if (!strncmp(tbuf, "SR", 2)) {
- strlcpy(up->status, tbuf + 2,
- sizeof(up->status));
- if (pp->sloppyclockflag & CLK_FLAG4)
- IGNORE(write(pp->io.fd, "LA", 2));
- else
- IGNORE(write(pp->io.fd, COMMAND_START_BCAST, 2));
- return;
-
- } else if (!strncmp(tbuf, "LA", 2)) {
- strlcpy(up->latlon, tbuf + 2, sizeof(up->latlon));
- IGNORE(write(pp->io.fd, "LO", 2));
- return;
-
- } else if (!strncmp(tbuf, "LO", 2)) {
- strlcat(up->latlon, " ", sizeof(up->latlon));
- strlcat(up->latlon, tbuf + 2, sizeof(up->latlon));
- IGNORE(write(pp->io.fd, "LH", 2));
- return;
-
- } else if (!strncmp(tbuf, "LH", 2)) {
- strlcat(up->latlon, " ", sizeof(up->latlon));
- strlcat(up->latlon, tbuf + 2, sizeof(up->latlon));
- IGNORE(write(pp->io.fd, "DB", 2));
- return;
-
- } else if (!strncmp(tbuf, "DB", 2)) {
- strlcat(up->latlon, " ", sizeof(up->latlon));
- strlcat(up->latlon, tbuf + 2, sizeof(up->latlon));
- record_clock_stats(peer, up->latlon);
- DPRINT(1, ("arbiter: %s\n", up->latlon));
- IGNORE(write(pp->io.fd, COMMAND_START_BCAST, 2));
- }
- }
-
- /*
- * We get down to business, check the timecode format and decode
- * its contents. If the timecode has valid length, but not in
- * proper format, we declare bad format and exit. If the
- * timecode has invalid length, which sometimes occurs when the
- * B0 amputates the broadcast, we just quietly steal away. Note
- * that the time quality character and receiver status string is
- * tacked on the end for clockstats display.
- */
- up->tcswitch++;
- if (up->tcswitch <= 1 || temp < LENARB) {
- return;
- }
-
- /*
- * Timecode format B5: "i yy ddd hh:mm:ss.000 "
- */
- strlcpy(pp->a_lastcode, tbuf, sizeof(pp->a_lastcode));
- pp->a_lastcode[LENARB - 2] = up->qualchar;
- strlcat(pp->a_lastcode, up->status, sizeof(pp->a_lastcode));
- pp->lencode = (int)strlen(pp->a_lastcode);
- syncchar = ' ';
- if (sscanf(pp->a_lastcode, "%c%2d %3d %2d:%2d:%2d",
- &syncchar, &pp->year, &pp->yday, &pp->hour,
- &pp->minute, &pp->second) != 6) {
- refclock_report(peer, CEVNT_BADREPLY);
- IGNORE(write(pp->io.fd, COMMAND_HALT_BCAST, 2));
- return;
- }
-
- /*
- * We decode the clock dispersion from the time quality
- * character.
- */
- switch (up->qualchar) {
-
- case '0': /* locked, max accuracy */
- pp->disp = 1e-7;
- pp->lastref = pp->lastrec;
- break;
-
- case '4': /* unlock accuracy < 1 us */
- pp->disp = S_PER_US;
- break;
-
- case '5': /* unlock accuracy < 10 us */
- pp->disp = 1e-5;
- break;
-
- case '6': /* unlock accuracy < 100 us */
- pp->disp = 1e-4;
- break;
-
- case '7': /* unlock accuracy < 1 ms */
- pp->disp = S_PER_MS;
- break;
-
- case '8': /* unlock accuracy < 10 ms */
- pp->disp = .01;
- break;
-
- case '9': /* unlock accuracy < 100 ms */
- pp->disp = .1;
- break;
-
- case 'A': /* unlock accuracy < 1 s */
- pp->disp = 1;
- break;
-
- case 'B': /* unlock accuracy < 10 s */
- pp->disp = 10;
- break;
-
- case 'F': /* clock failure */
- pp->disp = sys_maxdisp;
- refclock_report(peer, CEVNT_FAULT);
- IGNORE(write(pp->io.fd, COMMAND_HALT_BCAST, 2));
- return;
-
- default:
- pp->disp = sys_maxdisp;
- refclock_report(peer, CEVNT_BADREPLY);
- IGNORE(write(pp->io.fd, COMMAND_HALT_BCAST, 2));
- return;
- }
- if (syncchar != ' ') {
- pp->leap = LEAP_NOTINSYNC;
- } else {
- pp->leap = LEAP_NOWARNING;
- }
-
- /*
- * Process the new sample in the median filter and determine the
- * timecode timestamp.
- */
- if (!refclock_process(pp)) {
- refclock_report(peer, CEVNT_BADTIME);
- } else if (peer->disp > MAXDISTANCE) {
- refclock_receive(peer);
- }
-
- /* if (up->tcswitch >= MAXSTAGE) { */
- IGNORE(write(pp->io.fd, COMMAND_HALT_BCAST, 2));
- /* } */
+ struct arbunit *up;
+ struct refclockproc *pp;
+ struct peer *peer;
+ l_fp trtmp;
+ int temp;
+ uint8_t syncchar; // synch indicator
+ char tbuf[BMAX]; // temp buffer
+
+ /*
+ * Initialize pointers and read the timecode and timestamp
+ */
+ peer = rbufp->recv_peer;
+ pp = peer->procptr;
+ up = pp->unitptr;
+ temp = refclock_gtlin(rbufp, tbuf, sizeof(tbuf), &trtmp);
+
+ /*
+ * Note we get a buffer and timestamp for both a <cr> and <lf>,
+ * but only the <cr> timestamp is retained. The program first
+ * sends a TQ and expects the echo followed by the time quality
+ * character. It then sends a B5 starting the timecode broadcast
+ * and expects the echo followed some time later by the on-time
+ * character <cr> and then the <lf> beginning the timecode
+ * itself. Finally, at the <cr> beginning the next timecode at
+ * the next second, the program sends a B0 shutting down the
+ * timecode broadcast.
+ *
+ * If flag4 is set, the program snatches the latitude, longitude
+ * and elevation and writes it to the clockstats file.
+ */
+ if (temp == 0) {
+ return;
+ }
+
+ pp->lastrec = up->laststamp;
+ up->laststamp = trtmp;
+ if (temp < 3) {
+ return;
+ }
+
+ if (up->tcswitch == 0) {
+
+ /*
+ * Collect statistics. If nothing is recognized, just
+ * ignore; sometimes the clock doesn't stop spewing
+ * timecodes for awhile after the B0 command.
+ *
+ * If flag4 is not set, send TQ, SR, B5. If flag4 is
+ * sset, send TQ, SR, LA, LO, LH, DB, B5. When the
+ * median filter is full, send B0.
+ */
+ if (!strncmp(tbuf, "TQ", 2)) {
+ up->qualchar = tbuf[2];
+ IGNORE(write(pp->io.fd, "SR", 2));
+ return;
+
+ } else if (!strncmp(tbuf, "SR", 2)) {
+ strlcpy(up->status, tbuf + 2,
+ sizeof(up->status));
+ if (pp->sloppyclockflag & CLK_FLAG4)
+ IGNORE(write(pp->io.fd, "LA", 2));
+ else
+ IGNORE(write(pp->io.fd, COMMAND_START_BCAST, 2));
+ return;
+
+ } else if (!strncmp(tbuf, "LA", 2)) {
+ strlcpy(up->latlon, tbuf + 2, sizeof(up->latlon));
+ IGNORE(write(pp->io.fd, "LO", 2));
+ return;
+
+ } else if (!strncmp(tbuf, "LO", 2)) {
+ strlcat(up->latlon, " ", sizeof(up->latlon));
+ strlcat(up->latlon, tbuf + 2, sizeof(up->latlon));
+ IGNORE(write(pp->io.fd, "LH", 2));
+ return;
+
+ } else if (!strncmp(tbuf, "LH", 2)) {
+ strlcat(up->latlon, " ", sizeof(up->latlon));
+ strlcat(up->latlon, tbuf + 2, sizeof(up->latlon));
+ IGNORE(write(pp->io.fd, "DB", 2));
+ return;
+
+ } else if (!strncmp(tbuf, "DB", 2)) {
+ strlcat(up->latlon, " ", sizeof(up->latlon));
+ strlcat(up->latlon, tbuf + 2, sizeof(up->latlon));
+ record_clock_stats(peer, up->latlon);
+ DPRINT(1, ("arbiter: %s\n", up->latlon));
+ IGNORE(write(pp->io.fd, COMMAND_START_BCAST, 2));
+ }
+ }
+
+ /*
+ * We get down to business, check the timecode format and decode
+ * its contents. If the timecode has valid length, but not in
+ * proper format, we declare bad format and exit. If the
+ * timecode has invalid length, which sometimes occurs when the
+ * B0 amputates the broadcast, we just quietly steal away. Note
+ * that the time quality character and receiver status string is
+ * tacked on the end for clockstats display.
+ */
+ up->tcswitch++;
+ if (up->tcswitch <= 1 || temp < LENARB) {
+ return;
+ }
+
+ /*
+ * Timecode format B5: "i yy ddd hh:mm:ss.000 "
+ */
+ strlcpy(pp->a_lastcode, tbuf, sizeof(pp->a_lastcode));
+ pp->a_lastcode[LENARB - 2] = up->qualchar;
+ strlcat(pp->a_lastcode, up->status, sizeof(pp->a_lastcode));
+ pp->lencode = (int)strlen(pp->a_lastcode);
+ syncchar = ' ';
+ if (sscanf(pp->a_lastcode, "%c%2d %3d %2d:%2d:%2d",
+ &syncchar, &pp->year, &pp->yday, &pp->hour,
+ &pp->minute, &pp->second) != 6) {
+ refclock_report(peer, CEVNT_BADREPLY);
+ IGNORE(write(pp->io.fd, COMMAND_HALT_BCAST, 2));
+ return;
+ }
+
+ /*
+ * We decode the clock dispersion from the time quality
+ * character.
+ */
+ switch (up->qualchar) {
+
+ case '0': // locked, max accuracy
+ pp->disp = 1e-7;
+ pp->lastref = pp->lastrec;
+ break;
+
+ case '4': // unlock accuracy < 1 us
+ pp->disp = S_PER_US;
+ break;
+
+ case '5': // unlock accuracy < 10 us
+ pp->disp = 1e-5;
+ break;
+
+ case '6': // unlock accuracy < 100 us
+ pp->disp = 1e-4;
+ break;
+
+ case '7': // unlock accuracy < 1 ms
+ pp->disp = S_PER_MS;
+ break;
+
+ case '8': // unlock accuracy < 10 ms
+ pp->disp = .01;
+ break;
+
+ case '9': // unlock accuracy < 100 ms
+ pp->disp = .1;
+ break;
+
+ case 'A': // unlock accuracy < 1 s
+ pp->disp = 1;
+ break;
+
+ case 'B': // unlock accuracy < 10 s
+ pp->disp = 10;
+ break;
+
+ case 'F': // clock failure
+ pp->disp = sys_maxdisp;
+ refclock_report(peer, CEVNT_FAULT);
+ IGNORE(write(pp->io.fd, COMMAND_HALT_BCAST, 2));
+ return;
+
+ default:
+ pp->disp = sys_maxdisp;
+ refclock_report(peer, CEVNT_BADREPLY);
+ IGNORE(write(pp->io.fd, COMMAND_HALT_BCAST, 2));
+ return;
+ }
+ if (syncchar != ' ') {
+ pp->leap = LEAP_NOTINSYNC;
+ } else {
+ pp->leap = LEAP_NOWARNING;
+ }
+
+ /*
+ * Process the new sample in the median filter and determine the
+ * timecode timestamp.
+ */
+ if (!refclock_process(pp)) {
+ refclock_report(peer, CEVNT_BADTIME);
+ } else if (peer->disp > MAXDISTANCE) {
+ refclock_receive(peer);
+ }
+
+ // if (up->tcswitch >= MAXSTAGE) {
+ IGNORE(write(pp->io.fd, COMMAND_HALT_BCAST, 2));
+ // }
}
@@ -405,41 +405,41 @@ arb_receive(
*/
static void
arb_poll(
- int unit,
- struct peer *peer
- )
+ int unit,
+ struct peer *peer
+ )
{
- struct arbunit *up;
- struct refclockproc *pp;
-
- UNUSED_ARG(unit);
-
- /*
- * Time to poll the clock. The Arbiter clock responds to a "B5"
- * by returning a timecode in the format specified above.
- * Transmission occurs once per second, unless turned off by a
- * "B0". Note there is no checking on state, since this may not
- * be the only customer reading the clock. Only one customer
- * need poll the clock; all others just listen in.
- */
- pp = peer->procptr;
- up = pp->unitptr;
- pp->polls++;
- up->tcswitch = 0;
- if (write(pp->io.fd, "TQ", 2) != 2)
- refclock_report(peer, CEVNT_FAULT);
-
- /*
- * Process median filter samples. If none received, declare a
- * timeout and keep going.
- */
- if (pp->coderecv == pp->codeproc) {
- refclock_report(peer, CEVNT_TIMEOUT);
- return;
- }
- refclock_receive(peer);
- record_clock_stats(peer, pp->a_lastcode);
- DPRINT(1, ("arbiter: timecode %d %s\n",
- pp->lencode, pp->a_lastcode));
+ struct arbunit *up;
+ struct refclockproc *pp;
+
+ UNUSED_ARG(unit);
+
+ /*
+ * Time to poll the clock. The Arbiter clock responds to a "B5"
+ * by returning a timecode in the format specified above.
+ * Transmission occurs once per second, unless turned off by a
+ * "B0". Note there is no checking on state, since this may not
+ * be the only customer reading the clock. Only one customer
+ * need poll the clock; all others just listen in.
+ */
+ pp = peer->procptr;
+ up = pp->unitptr;
+ pp->polls++;
+ up->tcswitch = 0;
+ if (write(pp->io.fd, "TQ", 2) != 2)
+ refclock_report(peer, CEVNT_FAULT);
+
+ /*
+ * Process median filter samples. If none received, declare a
+ * timeout and keep going.
+ */
+ if (pp->coderecv == pp->codeproc) {
+ refclock_report(peer, CEVNT_TIMEOUT);
+ return;
+ }
+ refclock_receive(peer);
+ record_clock_stats(peer, pp->a_lastcode);
+ DPRINT(1, ("arbiter: timecode %d %s\n",
+ pp->lencode, pp->a_lastcode));
}
View it on GitLab: https://gitlab.com/NTPsec/ntpsec/-/commit/5f3a525ee895cc4d862bdf2435e0f4c854d3e39b
--
View it on GitLab: https://gitlab.com/NTPsec/ntpsec/-/commit/5f3a525ee895cc4d862bdf2435e0f4c854d3e39b
You're receiving this email because of your account on gitlab.com. Manage all notifications: https://gitlab.com/-/profile/notifications | Help: https://gitlab.com/help
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.ntpsec.org/pipermail/vc/attachments/20260806/5577d672/attachment-0001.htm>
More information about the vc
mailing list