Skip to content

HORIZON HASKELL Docs lts/ghc-9.14.xd82dee82026-10-12Search names, modules, packages, or :: a typeCtrl K

GHC 9.14.1 · lts/ghc-9.14.x · d82dee8 · 2026-10-12

Moduleouroboros-network-1.2.0.0

Ouroboros.Network.BlockFetch

12 types
6 values

Packageouroboros-network-1.2.0.0
Exports18
LicenceApache-2.0
SourceTrace.hs

valueblockFetchLogic

:: (HasHeader header, HasHeader block, HeaderHash header ~ HeaderHash block, MonadDelay m, MonadTimer m, Ord addr, Hashable addr)
=> Tracer m (TraceDecisionEvent addr header)
-> Tracer m (TraceLabelPeer addr (TraceFetchClientState header))
-> BlockFetchConsensusInterface addr header block m
-> FetchClientRegistry addr header block m
-> KeepAliveRegistry addr m
-> BlockFetchConfiguration
-> m Void

valuebracketFetchClient

:: (MonadFork m, MonadMask m, MonadTimer m, Ord peer)
=> FetchClientRegistry peer header block m
-> KeepAliveRegistry peer m
-> version
-> peer
-> FetchClientContext header block m -> m a
-> m a

valuebracketSyncWithFetchClient

:: (MonadSTM m, MonadFork m, MonadCatch m, Ord peer)
=> FetchClientRegistry peer header block m
-> peer
-> m a
-> m a

valuenewFetchClientRegistry :: MonadSTM m => m (FetchClientRegistry peer header block m)

valuebracketKeepAliveClient

:: (MonadSTM m, MonadFork m, MonadMask m, Ord peer)
=> KeepAliveRegistry peer m
-> peer
-> StrictTVar m (Map peer PeerGSV) -> m a
-> m a

valuenewKeepAliveRegistry :: MonadSTM m => m (KeepAliveRegistry peer m)

datadata TraceLabelPeer peerid a

A peer label for use in Tracers. This annotates tracer output as being associated with a given peer identifier.

Constructors

TraceLabelPeer peerid a

Instances4Bifunctor, Functor, Eq, Show

Bifunctor TraceLabelPeerDefined in network-mux-0.11.0.0 · Network.Mux.Trace
Functor (TraceLabelPeer peerid)Defined in network-mux-0.11.0.0 · Network.Mux.Trace
(Eq peerid, Eq a) => Eq (TraceLabelPeer peerid a)Defined in network-mux-0.11.0.0 · Network.Mux.Trace
(Show peerid, Show a) => Show (TraceLabelPeer peerid a)Defined in network-mux-0.11.0.0 · Network.Mux.Trace

datadata BlockFetchConfiguration

Constructors

BlockFetchConfiguration
- bfcMaxConcurrencyBulkSync :: !Word
- bfcMaxConcurrencyDeadline :: !Word
- bfcMaxRequestsInflight :: !Word
- bfcDecisionLoopIntervalGenesis :: !DiffTime
- bfcDecisionLoopIntervalPraos :: !DiffTime
- bfcSalt :: !Int
- bfcGenesisBFConfig :: !GenesisBlockFetchConfiguration

Instances1Show

Show BlockFetchConfigurationDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.BlockFetch

datadata GenesisBlockFetchConfiguration

Constructors

GenesisBlockFetchConfiguration
- gbfcGracePeriod :: !DiffTime

Instances4Eq, Show, Generic, Rep

Eq GenesisBlockFetchConfigurationDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.BlockFetch
Show GenesisBlockFetchConfigurationDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.BlockFetch
Generic GenesisBlockFetchConfigurationDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.BlockFetch
type Rep GenesisBlockFetchConfiguration = D1 ('MetaData "GenesisBlockFetchConfiguration" "Ouroboros.Network.BlockFetch" "ouroboros-network-1.2.0.0-B1caDgInx2QvMEOwyv0T" 'False) (C1 ('MetaCons "GenesisBlockFetchConfiguration" 'PrefixI 'True) (S1 ('MetaSel ('Just "gbfcGracePeriod") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 DiffTime)))Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.BlockFetch

datadata FetchClientRegistry peer header block (m :: Type -> Type)

datadata TraceFetchClientState header

Constructors

AddedFetchRequest (FetchRequest header) (PeerFetchInFlight header) PeerFetchInFlightLimits (PeerFetchStatus header)
AcknowledgedFetchRequest (FetchRequest header)
SendFetchRequest (AnchoredFragment header) PeerGSV
StartedFetchBatch (ChainRange (Point header)) (PeerFetchInFlight header) PeerFetchInFlightLimits (PeerFetchStatus header)
CompletedBlockFetch (Point header) (PeerFetchInFlight header) PeerFetchInFlightLimits (PeerFetchStatus header) NominalDiffTime SizeInBytes
CompletedFetchBatch (ChainRange (Point header)) (PeerFetchInFlight header) PeerFetchInFlightLimits (PeerFetchStatus header)
RejectedFetchBatch (ChainRange (Point header)) (PeerFetchInFlight header) PeerFetchInFlightLimits (PeerFetchStatus header)
ClientTerminating Int

Instances1Show

(StandardHash header, Show header) => Show (TraceFetchClientState header)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.BlockFetch.ClientState

typetype FetchDecision result = Either FetchDecline result

datadata KeepAliveRegistry peer (m :: Type -> Type)

datadata BlockFetchConsensusInterface peer header block (m :: Type -> Type)

Constructors

BlockFetchConsensusInterface
- readCandidateChains :: STM m (Map peer (AnchoredFragment header))
- readCurrentChain :: STM m (AnchoredFragment header)
- readFetchMode :: STM m FetchMode
- readFetchedBlocks :: STM m (Point block -> Bool)
- mkAddFetchedBlock :: STM m (Point block -> block -> m ())
- readFetchedMaxSlotNo :: STM m MaxSlotNo
- readChainComparison :: STM m (WithFingerprint (ChainComparison header))
- blockFetchSize :: header -> SizeInBytes
- blockMatchesHeader :: header -> block -> Bool
- headerForgeUTCTime :: header -> UTCTime
- readChainSelStarvation :: STM m ChainSelStarvation
- demoteChainSyncJumpingDynamo :: peer -> m ()

datadata ChainComparison header

Constructors

ChainComparison
- plausibleCandidateChain :: HasCallStack => AnchoredFragment header -> AnchoredFragment header -> Bool
- compareCandidateChains :: HasCallStack => AnchoredFragment header -> AnchoredFragment header -> Ordering

datadata FetchMode

Constructors

datadata PraosFetchMode

FetchModeBulkSync FetchModeDeadline

newtypenewtype SizeInBytes