Ouroboros.Network.BlockFetch.Decision · ouroboros-network-1.2.0.0

valuefetchDecisions

:: (Ord peer, Hashable peer, HasHeader header, HeaderHash header ~ HeaderHash block)
=> FetchDecisionPolicy header
-> ChainComparison header
-> PraosFetchMode
-> AnchoredFragment header
-> Point block -> Bool
-> MaxSlotNo
-> [(AnchoredFragment header, PeerInfo header peer extra)]
-> [(FetchDecision (FetchRequest header), PeerInfo header peer extra)]

#

valuefetchRequestDecision

:: HasHeader header
=> FetchDecisionPolicy header
-> PraosFetchMode
-> Word
-> PeerFetchInFlightLimits
-> PeerFetchInFlight header
-> PeerFetchStatus header
-> FetchDecision [AnchoredFragment header]
-> FetchDecision (FetchRequest header)

#

valuefetchRequestDecisions

:: (Hashable peer, HasHeader header, Ord peer)
=> FetchDecisionPolicy header
-> PraosFetchMode
-> [(FetchDecision [AnchoredFragment header], PeerFetchStatus header, PeerFetchInFlight header, PeerGSV, peer, extra)]
-> [(FetchDecision (FetchRequest header), extra)]

#

valuefilterNotAlreadyFetched

:: (HasHeader header, HeaderHash header ~ HeaderHash block)
=> Point block -> Bool
-> MaxSlotNo
-> [(FetchDecision (ChainSuffix header), peerinfo)]
-> [(FetchDecision (CandidateFragments header), peerinfo)]

#

valuefilterNotAlreadyInFlightWithOtherPeers

:: HasHeader header
=> PraosFetchMode
-> [(FetchDecision [AnchoredFragment header], PeerFetchStatus header, PeerFetchInFlight header, peerinfo)]
-> [(FetchDecision [AnchoredFragment header], peerinfo)]

#

valuefilterNotAlreadyInFlightWithPeer

:: HasHeader header
=> [(FetchDecision (CandidateFragments header), PeerFetchInFlight header, peerinfo)]
-> [(FetchDecision (CandidateFragments header), peerinfo)]

#

valuefilterPlausibleCandidates

:: AnchoredFragment block -> AnchoredFragment header -> Bool
-> AnchoredFragment block
-> [(AnchoredFragment header, peerinfo)]
-> [(FetchDecision (AnchoredFragment header), peerinfo)]

#

valuefilterWithMaxSlotNo

:: HasHeader header
=> header -> Bool
-> MaxSlotNo
-> AnchoredFragment header
-> [AnchoredFragment header]

#

valuepeerInfoPeer :: PeerInfo header peer extra -> peer

#

valueprioritisePeerChains

:: (HasHeader header, Hashable peer, Ord peer)
=> PraosFetchMode
-> Int
-> AnchoredFragment header -> AnchoredFragment header -> Ordering
-> header -> SizeInBytes
-> [(FetchDecision (CandidateFragments header), PeerFetchInFlight header, PeerGSV, peer, extra)]
-> [(FetchDecision [AnchoredFragment header], extra)]

#

valueselectForkSuffixes

:: HasHeader header
=> AnchoredFragment header
-> [(FetchDecision (AnchoredFragment header), peerinfo)]
-> [(FetchDecision (ChainSuffix header), peerinfo)]

#

typetype CandidateFragments header = (ChainSuffix header, [AnchoredFragment header])

#

datadata ChainSuffix header

#

Constructors

ChainSuffix
- getChainSuffix :: !AnchoredFragment header
- getFullCandidate :: !AnchoredFragment header

typetype FetchDecision result = Either FetchDecline result

#

datadata FetchDecisionPolicy header

#

Constructors

FetchDecisionPolicy
- maxInFlightReqsPerPeer :: Word
- maxConcurrencyBulkSync :: Word
- maxConcurrencyDeadline :: Word
- decisionLoopIntervalGenesis :: DiffTime
- decisionLoopIntervalPraos :: DiffTime
- peerSalt :: Int
- bulkSyncGracePeriod :: DiffTime
- blockFetchSize :: header -> SizeInBytes

datadata FetchDecline

#

Instances2Eq, Show

Eq FetchDeclineDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.BlockFetch.Decision
Show FetchDeclineDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.BlockFetch.Decision

typetype PeerInfo header peer extra = (PeerFetchStatus header, PeerFetchInFlight header, PeerGSV, peer, extra)

#

datadata PraosFetchMode

#

FetchModeBulkSync FetchModeDeadline