findTimecardPCIAddrs resolves the PCI addresses of all time cards by following the "device" symlink under each /sys/class/timecard/ocp<n>.

formNewDest generates new ip address using the rack prefix /64 of DestinationAddress by adding :face:face:0:$i to the ipv6

headerMarshalBinaryTo is not a Header.MarshalBinaryTo to prevent all packets from having default (and incomplete) MarshalBinaryTo implementation throu

couple of helpers to log nice lines about happening communication

--- detectGNSSSerialFromGlob (PCI BDF resolver) --- makeFakeTimecardSysfs creates a sysfs-shaped layout under root mimicking sys/bus/pci/devices/<bdf>

marshalUint16s encodes a sequence of 16-bit integers in network byte order.

parseBannerLine returns a populated StatusInfo if line matches the cfgtool receiver-detection banner, or (nil, false) otherwise.

putCRC computes the CRC-24Q over all but the last three bytes of frame and writes the checksum into them.

refID converts ip into ReFID format and prints it on stdout

socketControlMessageTimestamp is a very optimised version of ParseSocketControlMessage https://github.com/golang/go/blob/2ebe77a2fda1ee9ff6fd9a3e08933

sourceHandshake sends the NTRIP v1 SOURCE request and streams raw RTCM data after the headers. The request uses a bare mountpoint (no leading slash) p

toMap converts struct to a map

bytes unmarshalHeader is not a Header.UnmarshalBinary to prevent all packets from having default (and incomplete) UnmarshalBinary implementation throu

AddrToSockaddr converts netip.Addr + port into a socket address

CalnexName returns Calnex Name like "PTP slave" or "NTP client"

ChannelFromInt returns channel from int

ChannelFromString returns channel from string

Connect establishes a connection to the NTRIP caster. If a proxy is configured, it first establishes an HTTP CONNECT tunnel through the proxy with TLS

Delta is a difference between receiver's RX timestamp and our TX timestamp

Drain consumes pending bytes on the port without blocking, then restores the normal read timeout. Call before Cmd / Get to clear stale or asynchronous

Drain traffic

EXPECT returns an object that allows the caller to indicate expected use.

EnableSWTimestamps enables SW timestamps (TX and RX) on the socket

FetchChannelProbe returns monitored protocol of the channel

FetchChannelTarget returns the measure target of the server monitored on the channel

FetchCounters returns counters map fetched from the url

nolint:revive // underscore in name mirrors the mathematical notation 2^16 FloatAsUint32 stores float as multiplier of 2**16

FrequencyPPB reads device frequency in PPB

Get queries a single named parameter via "{get,<param>}" and returns the parsed value. Device errors ("[!N]") are surfaced as errors wrapping ErrDevic

GetMode gets int mode from Version+Mode 8bit word

GetPeerStatus returns parsed PeerStatusWord struct if present

GetVersion gets int version from Version+Mode 8bit word

Good check if the test passed

Holders returns the PIDs of processes whose open file descriptors point at device. Both the literal path and any symlink target are matched. Per-pid r

IfaceHasIP checks if selected IP is on interface

IncRXSignalingCancel atomically add 1 to the counter

IncSequenceID adds 1 to a sequence id

IncTXTSMissing atomically increments the counter when all retries to get latest TX timestamp exceeded

IncTXTSMissing atomically increments the counter when all retries to get latest TX timestamp exceeded

IoctlGetEthtoolTsInfo is not supported on non-linux.

IsResponse returns true if packet is a response

LeapFile returns the current default leap second file path

Name returns the name of the check

NewActivityPacket creates new packet to request 'activity' information

NewClientAccessesByIndexPacket creates new packet to request 'clients' information: a page of up to MaxClientAccessesByIndex per-client entries starti

--- Constructor helpers, one per record type --- Critical-bit defaults follow the spec for a client building a request: types 0-3 MUST set it; types 4

NewJSONStats returns a new JSONStats

NewLoggingPort returns a SerialReadWriter that tees TX and RX bytes into l. l must not be nil; callers that don't want logging should not wrap.

NewNTPPeerStats constructs NTPStats from NTPCheckResult

NewRingBuffer creates new RingBuffer of a defined size

NewSPTPHTTPTester initializes a Tester

NewSelectDataPacket creates new packet to request 'selectdata' information

NewUDPConnTS initialises a new struct UDPConnTS

ParseAuthenticatorBody decodes the body of an NTS Authenticator EF. Trailing bytes past the declared nonce + ciphertext are silently accepted: RFC 89

ParseValue extracts the value from a "[=value]" response. "[!N]" replies are surfaced as errors wrapping ErrDeviceError with the numeric code.

Preflight refuses to proceed if another process is holding the device. A scan failure is fatal: returning the error lets the caller bail rather than c

Prepare will prepare all math expressions

PrepareConfig prepares final version of config based on defaults, CLI flags and on-disk config, and validates resulting config

ReadConfig reads config from the file

ReadConfig reads config and unmarshals it from yaml into Config

ReadFlashStatusWord returns list of flashers (as strings) decoded from flash status word

ReadPacketWithRXTimestampBuf writes byte packet into provide buffer buf, and returns number of bytes copied to the buffer, client ip and HW RX timesta

ReadPeerStatusWord transforms PeerStatus 16bit word into usable struct

ReadStatus talks to oscillatord via monitoring port connection and reads reported Status

Run config generation once

Run the utcoffset calculation

Run executes the check

RunCheck is a simple wrapper to connect to address and run NTPCheck.Run()

RunListener starts a listener, must be run before any client-server interactions happen

RunOnce produces one client-server exchange

SeqIDSocketControlMessage encodes the SequenceID into a socket control message and specifies SCM_TS_OPT_ID as the Control Message Header type

SetClockAccuracy atomically sets the clock accuracy

SetClockClass atomically sets the clock class

SetConnected sets connection status (1=connected, 0=disconnected).

SetMaxFreq is to adjust frequency range supported by PHC

SetMaxTXTSAttempts atomically sets number of retries for get latest TX timestamp

Start runs http server and initializes maps

String returns joined list of checks

Time returns time we got from network card

TimeAndOffsetFromDevice returns time we got from phc device + offset