Documentation

Shared STM handle for V2 coordination state.

Registry of every live peer's coordination TVars: its in-flight contributions and its private counters cell.

withPeer adds the pair on bracket-enter and removes it on bracket-exit (after scrubbing any contributions the peer still has to shared state and flushing its counters into the retired accumulator). snapshotLiveReferences reads the in-flight vars to compute the liveAdvertised union; snapshotCounters reads the counter cells to aggregate for emission.

Peer-facing coordination API.

The peer thread keeps its local protocol state in a local variable. Registry helpers operate only on the shared STM state and the per-peer PeerTxInFlight TVar (closure-captured); any helper that needs peer-local state should take it explicitly as an argument.

STM handle for V2 monotonic counters. Used both for each peer's private counters cell and for the shared retired-peers accumulator (see withPeer and txCountersThreadV2).

Central bookkeeping thread for V2.

Wakes every bufferedTxsMinLifetime policy / 4 seconds (capped between 100 ms and 1 s) to run sweepSharedState on the shared tx state. The sweep needs the union of every live peer's pifAdvertised to decide which entries are still wanted; the registry is read inside the same STM transaction as the sweep so the snapshot is coherent. On a slower cadence (every countersInterval seconds of elapsed time) it also emits the aggregated counters -- the retired-peers accumulator plus every live peer's cell -- when they differ from the last emission, and a TraceSharedTxState snapshot when sharedRevision or sharedGeneration has moved since the last emission.

A bracket function which registers / de-registers a new peer in SharedTxStateVar, which exposes PeerTxStateAPI. PeerTxStateAPI is only safe inside the withPeer scope.