Fields

• bfcMaxConcurrencyBulkSync :: !Word

  Maximum concurrent downloads during bulk syncing.

• bfcMaxConcurrencyDeadline :: !Word

  Maximum concurrent downloads during deadline syncing.

• bfcMaxRequestsInflight :: !Word

  Maximum requests in flight per each peer.

• bfcDecisionLoopIntervalGenesis :: !DiffTime

  Desired interval between calls to fetchLogicIteration in Genesis fetch mode

• bfcDecisionLoopIntervalPraos :: !DiffTime

  Desired interval between calls to fetchLogicIteration in Praos fetch modes

• bfcSalt :: !Int

  Salt used when comparing peers

• bfcGenesisBFConfig :: !GenesisBlockFetchConfiguration

  Genesis-specific parameters

Fields

• readCandidateChains :: STM m (Map peer (AnchoredFragment header))

  Read the K-suffixes of the candidate chains.

  Assumptions: * Their headers must be already validated. * They may contain fewer than K blocks. * Their anchor does not have to intersect with the current chain.

• readCurrentChain :: STM m (AnchoredFragment header)

  Read the K-suffix of the current chain.

  This must contain info on the last K blocks (unless we're near the chain genesis of course).

• readFetchMode :: STM m FetchMode

  Read the current fetch mode that the block fetch logic should use.

  The fetch mode is a dynamic part of the block fetch policy. In FetchModeBulkSync it follows a policy that optimises for expected bandwidth over latency to fetch any particular block, whereas in FetchModeDeadline it follows a policy optimises for the latency to fetch blocks, at the expense of wasting bandwidth.

  FetchModeGenesis should be used when the genesis node is syncing to ensure it isn't leashed.

  This mode should be set so that when the node's current chain is near to "now" it uses the deadline mode, and when it is far away it uses the bulk sync mode.

• readFetchedBlocks :: STM m (Point block -> Bool)

  Recent, only within last K

• mkAddFetchedBlock :: STM m (Point block -> block -> m ())

  This method allocates an addFetchedBlock function per client. That function and readFetchedBlocks are required to be linked. Upon successful completion of addFetchedBlock it must be the case that readFetchedBlocks reports the block.

• readFetchedMaxSlotNo :: STM m MaxSlotNo

  The highest stored/downloaded slot number.

  This is used to optimise the filtering of fragments in the block fetch logic: when removing already downloaded blocks from a fragment, the filtering (with a linear cost) is stopped as soon as a block has a slot number higher than this slot number, as it cannot have been downloaded anyway.

• plausibleCandidateChain :: HasCallStack => AnchoredFragment header -> AnchoredFragment header -> Bool

  Given the current chain, is the given chain plausible as a candidate chain. Classically for Ouroboros this would simply check if the candidate is strictly longer, but for Ouroboros with operational key certificates there are also cases where we would consider a chain of equal length to the current chain.

• compareCandidateChains :: HasCallStack => AnchoredFragment header -> AnchoredFragment header -> Ordering

  Compare two candidate chains and return a preference ordering. This is used as part of selecting which chains to prioritise for downloading block bodies.

• blockFetchSize :: header -> SizeInBytes

  Much of the logic for deciding which blocks to download from which peer depends on making estimates based on recent performance metrics. These estimates of course depend on the amount of data we will be downloading.

• blockMatchesHeader :: header -> block -> Bool

  Given a block header, validate the supposed corresponding block body.

• headerForgeUTCTime :: FromConsensus header -> STM m UTCTime

  Calculate when a header's block was forged.

  PRECONDITION: This function will succeed and give a _correct_ result when applied to headers obtained via this interface (ie via Consensus, ie via readCurrentChain or readCandidateChains).

  WARNING: This function may fail or, worse, __give an incorrect result (!!)__ if applied to headers obtained from sources outside of this interface. The FromConsensus newtype wrapper is intended to make it difficult to make that mistake, so please pay that syntactic price and consider its meaning at each call to this function. Relatedly, preserve that argument wrapper as much as possible when deriving ancillary functions/interfaces from this function.

• readChainSelStarvation :: STM m ChainSelStarvation

  Information on the ChainSel starvation status; whether it is ongoing or has ended recently. Needed by the bulk sync decision logic.

• demoteChainSyncJumpingDynamo :: peer -> m ()

  Action to inform CSJ (ChainSync Jumping) that the given peer has not been performing adequately with respect to BlockFetch, and that it should be demoted from the dynamo role. Can be set to const (pure ()) in all other scenarios.

Fields

• gbfcGracePeriod :: !DiffTime

  Grace period when starting to talk to a peer in genesis mode during which it is fine if the chain selection gets starved.

Fields

• unFromConsensus :: a