Skip to content

HORIZON HASKELL Docs lts/ghc-9.14.x99ffbb82026-10-19Search packagesCtrl K

Theme: |

GHC 9.14.1 · lts/ghc-9.14.x · 99ffbb8 · 2026-10-19

Moduleouroboros-network-1.2.0.0

Ouroboros.Network.TxSubmission.Inbound.V2.State

Synopsis

value applyPeerEvents
value currentPeerScore
value drainPeerScore
value handleReceivedTxIds
value handleReceivedTxs
value handleSubmittedTxs
value markSubmittingTxs
value nextPeerAction
value nextPeerActionPipelined
value peerClaimDelay
value sweepSharedState

Packageouroboros-network-1.2.0.0
Exports11
LicenceApache-2.0

valueapplyPeerEvents

:: TxDecisionPolicy
-> Time
-> Int
-> Int
-> PeerTxLocalState tx
-> (Double, PeerTxLocalState tx)

valuecurrentPeerScore :: TxDecisionPolicy -> Time -> PeerScore -> Double

valuedrainPeerScore

valuehandleReceivedTxIds

:: HasRawTxId txid
=> txid -> Bool
-> Time
-> TxDecisionPolicy
-> NumTxIdsToReq
-> [(txid, SizeInBytes)]
-> PeerTxLocalState tx
-> PeerTxInFlight
-> SharedTxState peeraddr txid
-> (PeerTxLocalState tx, PeerTxInFlight, SharedTxState peeraddr txid)

valuehandleReceivedTxs

:: (HasCallStack, Eq peeraddr, Show peeraddr, HasRawTxId txid)
=> txid -> Bool
-> Time
-> TxDecisionPolicy
-> peeraddr
-> [(txid, tx)]
-> PeerTxLocalState tx
-> PeerTxInFlight
-> SharedTxState peeraddr txid
-> (Int, Int, PeerTxLocalState tx, PeerTxInFlight, SharedTxState peeraddr txid)

valuehandleSubmittedTxs

:: Eq peeraddr
=> Time
-> TxDecisionPolicy
-> peeraddr
-> [TxKey]
-> [TxKey]
-> PeerTxLocalState tx
-> PeerTxInFlight
-> SharedTxState peeraddr txid
-> (PeerTxLocalState tx, PeerTxInFlight, SharedTxState peeraddr txid)

valuemarkSubmittingTxs

:: [TxKey]
-> SharedTxState peeraddr txid
-> SharedTxState peeraddr txid

valuenextPeerAction

:: Ord peeraddr
=> Time
-> TxDecisionPolicy
-> peeraddr
-> PeerTxLocalState tx
-> PeerTxInFlight
-> SharedTxState peeraddr txid
-> (PeerAction, PeerTxLocalState tx, PeerTxInFlight, SharedTxState peeraddr txid)

valuenextPeerActionPipelined

:: Ord peeraddr
=> Time
-> TxDecisionPolicy
-> peeraddr
-> PeerTxLocalState tx
-> PeerTxInFlight
-> SharedTxState peeraddr txid
-> (PeerAction, PeerTxLocalState tx, PeerTxInFlight, SharedTxState peeraddr txid)

valuepeerClaimDelay :: TxDecisionPolicy -> Time -> PeerScore -> DiffTime

valuesweepSharedState

:: HasRawTxId txid
=> Time
-> IntSet
-> SharedTxState peeraddr txid
-> SharedTxState peeraddr txid