Send a message to the client.

Add a board registration.

Compute a final channel value with scaling, gamma, and brightness baked in.

Get the total number of values in the range. Returns `u64::MAX` if the range spans the entire u64 space (the true count would be 2^64 which doesn't f

Create an iterator over this range.

Check if value bits fit within this mask

Receive a message the client wrote.

Get the underlying target (lossless). Use this for actual share validation (comparing against block hashes).

Check if the range is empty.

Record work from a share at the given timestamp.

Send a register write command, converting the sink error to anyhow.

Helper: create a Work value from a u64 hash count.

Cancel the animation and return the LED. Stops a running task immediately. Returns at once if the task has already completed.

Convert to little-endian bytes.

Wait for the animation to reach a natural stopping point. For looping animations, waits until the end of the current cycle. For one-shot animations,

Split the stream into reader, writer, and control handles. This allows concurrent reading and writing while maintaining the ability to reconfigure th

Suggest difficulty for the latest hashrate, subject to the deadband and the cooldown. A material change during the cooldown is held; `flush_suggest`

Update the alarm with the current condition. Returns an [`AlarmStatus`] describing what happened: | Previous state | condition | Result | |---------

Get difficulty as f64. Exact to 12 significant digits for any difficulty a source would reasonably assign. Only difficulties above 2^53 (~9.0P) lose

Get the message ID if present.

Return the next backoff delay (with jitter) and advance the state. The nominal delay (1s, 2s, 4s, ...) is scaled by a jitter factor in [0.5, 1.0] to

Get the voltage value as f32

Helper to create a broadcast write command

Convert f32 to Linear16 format using cached VOUT_MODE

Turn the LED off, stopping any animation.

Helper to create a minimal client for testing notification handlers.

Apply serial configuration to a file descriptor. This helper function configures termios settings for a serial port, including baud rate, data bits,

Compute breathing brightness for a position in the cycle. `cycle_fraction` ranges from 0.0 (start) to 1.0 (end). Values outside this range wrap via m

Virtual serial port pair for integration tests using pty

Extract 5-bit two's complement exponent from PMBus format

Handle mining.set_difficulty notification.

Load configuration from the default location.

Count a newly-registered thread.

Count a thread's first report.

Helper to create a StratumV1Source with protocol state for testing.

Apply these bits to a base version to produce the final version. Shifts these bits left 13 positions and ORs with the base version. # Example ``` u

Compute merkle root for a task (called once when task is assigned).

Convert Linear16 format to f32 using cached VOUT_MODE

Get the source name.

Read the current temperature.

Record the enumeration-complete signal.

Send a raw packet and wait for response.

Find a virtual board descriptor by device type.

Flash the LED with a color for a fixed duration. Spawns a task that sets the color and sleeps for the duration. The handle can be awaited via [`Anima

Handle mining.set_version_mask notification.

Initialize the TPS546

Returns true if the hashrate is zero.

Update shared status.

Snapshot all connected boards. Removes boards whose sender has been dropped (board disconnected) and returns the current state of each.

Start a breathe animation with the default period. Takes ownership of the LED and fades it in a sinusoidal cycle. Cancel or interrupt via the returne

Extranonce1 (pool-assigned) as used in this block

Hashrate estimate at the given timestamp. Divides total work by the span from the oldest sample to `now`. This gives an accurate estimate as soon as

Convert Stratum JobNotification to JobTemplate.

Create a board registration with the given name, returning the state sender so the test can update or drop it.

Reset the alarm to idle, regardless of current state. Use when an external event invalidates the condition (e.g., hashrate changed, difficulty change

Run the source (main event loop). Defers pool connection until the scheduler reports a positive hashrate via `UpdateHashRate`---no point fetching job

Send a request and wait for its response. Sends the request and then loops reading messages from the connection, handling notifications along the way

Update the LED to reflect a new board status.

Create a StratumV1Source wired to a mock transport channel. Returns (source, event_rx, command_tx, mock_tx, shutdown).

Get statistics about the serial port.

Common integration test logic for pool connections. # Test Strategy This test validates that the client can successfully connect to a pool and maint

Convert to Stratum hex string format for transmission. Converts Bitcoin types back to the hex strings expected by the pool.

Encode ticket mask to wire format bytes

Calculate PLL configuration for a specific frequency

Coinbase transaction prefix (coinbase1 in Stratum v1) Everything before the extranonce space: version + witness flag + input count + prev output + pr

Coinbase transaction suffix (coinbase2 in Stratum v1) Everything after the extranonce space: rest of scriptsig + sequence + outputs + witness + lockt

Compute merkle root for the given extranonce2. Returns an error if this is a fixed merkle root (header-only job) or if merkle computation fails.

Convert Linear16 value using this VOUT_MODE

Encode packet to bytes

Encode to Linear16 using this VOUT_MODE

Calculate expected time between shares at given difficulty and hashrate. Returns the average time to find a share. Actual time varies due to randomne

Get the 5-bit exponent (bits 4:0)

Extranonce2 (miner-chosen) as used in this block

Helper to convert extranonce2 bytes to Extranonce2 type.