Fields

• sharedTxTable :: !(IntMap (TxEntry peeraddr))

  Active unresolved txs that still participate in leasing, buffering, submission and advertiser tracking.

• sharedRetainedTxs :: !RetainedTxs

  Accepted txs retained locally for a bounded time so later txid advertisements can be acked without re-requesting the body.

• sharedTxIdToKey :: !(Map (RawTxId txid) TxKey)

  Forward txid interning table: maps a raw txid to its compact TxKey. Inverse of sharedKeyToTxId.

• sharedKeyToTxId :: !(IntMap txid)

  Reverse interning table: maps a TxKey back to its txid. Inverse of sharedTxIdToKey.

• sharedNextTxKey :: !Int

  Next fresh TxKey to allocate; stays strictly greater than every live key.

• sharedGeneration :: !Word64

  Wake counter. Bumped on transitions that may grant other peers a new option (lease release, new entry accepted into the mempool, cap bump, ...). Parked peers watch this via awaitSharedChange.

• sharedRevision :: !Word64

  Structural dirty bit. Bumped on most structural changes; used by writeSharedStateIfChanged (paired with sharedGeneration) to skip redundant TVar writes. A change to either counter triggers a write.

Fields

• ptxcAccepted :: Int

  Just accepted this many transactions.

• ptxcRejected :: Int

  Just rejected this many transactions.

• ptxcScore :: Double
   

Fields

• txId :: tx -> txid

  Compute the transaction id from a transaction.

  This is used in the protocol handler to verify a full transaction matches a previously given transaction id.

• mempoolAddTxs :: [tx] -> m ([txid], [(txid, err)])

  Supply a batch of transactions to the mempool. They are either accepted or rejected individually, but in the order supplied.

  Return list of valid tx's added to the mempool and a list of invalid tx's with the corresponding error.

Fields

• txIdMessagesSent :: !Word64

  Number of txid request messages sent (MsgRequestTxIds, blocking or pipelined).

• txIdsRequested :: !Word64

  Total number of txids requested across all txid request messages (sum of NumTxIdsToReq values).

• txIdRepliesReceived :: !Word64

  Number of txid reply messages received (MsgReplyTxIds).

• txIdsReceived :: !Word64

  Total number of txid-size pairs received across all txid replies.

• txMessagesSent :: !Word64

  Number of tx body request messages sent (MsgRequestTxs).

• txsRequested :: !Word64

  Total number of tx bodies requested across all body request messages.

• txRepliesReceived :: !Word64

  Number of tx body reply messages received (MsgReplyTxs).

• txsReceived :: !Word64

  Total number of tx bodies received across all body replies.

• txsOmitted :: !Word64

  Number of requested tx bodies the peer omitted from its reply.

• lateBodies :: !Word64

  Number of tx bodies received after the local state had already resolved them (txid was found in the mempool before the body arrived).

• txsAccepted :: !Word64

  Tx bodies resolved into the mempool (includes txs found already present before attempting submission).

• txsRejected :: !Word64

  Tx bodies rejected by the mempool.

• txIdBlockingReqsSent :: !Word64

  Txid request messages sent as blocking requests.

• txIdPipelinedReqsSent :: !Word64

  Txid request messages sent as pipelined (non-blocking) requests.

• txIdBlockingWaitMs :: !Word64

  Cumulative milliseconds spent waiting for replies to blocking txid requests. High values indicate the system is mostly idle (no new transactions available from peers).

• txPipelineWaitMs :: !Word64

  Cumulative milliseconds the pipeline was active, measured from the first MsgRequestTxs send until all pipelined requests (both body and txid) have been replied to and the pipeline fully drains. Proxy for the "loading" state where the peer is actively downloading transactions.

• txSubmissionWaitMs :: !Word64

  Cumulative milliseconds spent inside mempoolAddTxs. Covers both normal submission latency and time blocked due to a full mempool. High values relative to the other duration fields indicate mempool backpressure.

Fields

• requestedTxBatchSet :: !IntSet

  The set of transaction keys requested in this batch.

• requestedTxBatchSize :: !SizeInBytes

  Total expected size in bytes for all tx bodies in this batch.

Fields

• txLease :: !(TxLease peeraddr)

  Current owner lease for downloading the tx body. When TxClaimable, the embedded Time also doubles as the last-activity stamp used by the orphan sweep.

  Invariant: while TxLeased to a registered peer, that peer's pifLeased contains this key (stale leases left behind by inflight-cap theft are tolerated).

• txAttempt :: !Int

  Number of peers currently attempting the body (claimed lease and/or buffered locally). Incremented on claim, decremented on omit lease release PeerSubmitTxs transition (the submitting peer no longer counts as an attempter).

  Invariant: equals the number of registered peers whose pifAttempting contains this key.

• txInSubmission :: !Bool

  At least one peer is currently inside mempoolAddTxs for this body. Other peers skip PeerSubmitTxs for the key while it is set. STM serialisation guarantees at most one peer is the submitter at any moment.

  Invariant: true iff some registered peer's pifSubmitting contains this key.

• currentMaxInflightMultiplicity :: !Int

  Effective per-tx inflight multiplicity cap.

  Initialised from txInflightMultiplicity of the policy when the entry is created, and bumped by one when a peer's attempt sits past inflightTimeout without reaching submission, allowing another peer to attempt in parallel.

Fields

• peerScoreValue :: !Double
   
• peerScoreTs :: !Time
   

Fields

• peerPhase :: !PeerPhase

  Coarse phase of this peer's worker thread. Updated by nextPeerAction / nextPeerActionPipelined when an action is chosen and inspected in serverIdle to decide whether to skip awaitSharedChange on an Active->Idle transition.

• peerUnacknowledgedTxIds :: !(StrictSeq TxKey)

  Unacknowledged txids in the order advertised by the peer.

• peerAvailableTxIds :: !(IntMap SizeInBytes)

  Txids this peer currently advertises and that may be requested from it if the peer becomes the owner.

• peerRequestedTxs :: !IntSet

  Requested txids that have not yet been replied to.

• peerRequestedTxBatches :: !(StrictSeq RequestedTxBatch)

  Outstanding tx-body request batches, in request order. Their requestedTxBatchSets union to peerRequestedTxs and their requestedTxBatchSizes sum to peerRequestedTxsSize.

• peerRequestedTxsSize :: !SizeInBytes

  Total serialized size of all outstanding requested tx bodies.

• peerRequestedTxIds :: !NumTxIdsToReq

  Number of txids requested from this peer but not yet replied to (the in-flight txid-request window).

• peerDownloadedTxs :: !(IntMap tx)

  Tx bodies downloaded from this peer and buffered locally until they are either submitted to the mempool or superseded by shared-state resolution.

• peerDownloadStartTime :: !(Maybe Time)

  Time at which the first outstanding body-request batch was sent in the current download episode.

• peerScore :: !PeerScore

  Usefulness score for this peer, tracking rejection penalties and time-based decay.

• peerLastTxIdReplyWasEmpty :: !Bool

  Set on a txid reply that returned zero new txids; cleared on a non-empty txid reply or when the mempool accepts at least one tx delivered by this peer.

Fields

• pifAdvertised :: !IntSet

  Keys this peer currently has in its advertised window. Used by the orphan sweep to know the entry is still wanted, and by nextWakeDelay to scan for the earliest claim wake.

  Invariant: a subset of the live keys (active sharedTxTable union retained sharedRetainedTxs).

• pifLeased :: !IntSet

  Keys this peer currently holds TxLeased on. Cleared on omit, accept, reject, lease-loss and bracket exit.

• pifAttempting :: !IntSet

  Keys this peer currently counts toward txAttempt. Spans the claim -> download -> buffer phases; the key moves to pifSubmitting on the submit transition.

• pifSubmitting :: !IntSet

  Keys this peer currently counts toward txInSubmission. Set on PeerSubmitTxs / markSubmittingTxs, cleared on accept or reject.

• pifAcksPending :: !IntSet

  Keys this peer holds in peerUnacknowledgedTxIds. A superset of pifAdvertised: also tracks keys the peer learned about via the retained-or-mempool path of handleReceivedTxIds that are not advertised for fetch but still pending an ack. Used by the sweep to know whether the txid lookup tables can be reclaimed.

Fields

• unTxKey :: Int