Skip to content

Commit 5253563

Browse files
Niolsneilmayhew
Niols
authored and
neilmayhew
committed
Accomodate for changes to BlockFetch
* Addition of ChainSyncClientHandleCollection, grace period, and starvation event in BlockFetch * Plug `rotateDynamo` into `BlockFetchConsensusInterface` * Removal of `bfcMaxConcurrencyBulkSync` * Changes in blockfetch decision tracing
1 parent b4adc16 commit 5253563

File tree

10 files changed

+59
-61
lines changed

10 files changed

+59
-61
lines changed

‎ouroboros-consensus-diffusion/src/ouroboros-consensus-diffusion/Ouroboros/Consensus/Node.hs‎

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -321,8 +321,7 @@ nonImmutableDbPath (MultipleDbPaths _ vol) = vol
321321
--
322322
-- See 'stdLowLevelRunNodeArgsIO'.
323323
data StdRunNodeArgs m blk (p2p :: Diffusion.P2P) = StdRunNodeArgs
324-
{ srnBfcMaxConcurrencyBulkSync :: Maybe Word
325-
, srnBfcMaxConcurrencyDeadline :: Maybe Word
324+
{ srnBfcMaxConcurrencyDeadline :: Maybe Word
326325
, srnChainDbValidateOverride :: Bool
327326
-- ^ If @True@, validate the ChainDB on init no matter what
328327
, srnDiskPolicyArgs :: DiskPolicyArgs
@@ -986,9 +985,6 @@ stdLowLevelRunNodeArgsIO RunNodeArgs{ rnProtocolInfo
986985
maybe id
987986
(\mc bfc -> bfc { bfcMaxConcurrencyDeadline = mc })
988987
srnBfcMaxConcurrencyDeadline
989-
. maybe id
990-
(\mc bfc -> bfc { bfcMaxConcurrencyBulkSync = mc })
991-
srnBfcMaxConcurrencyBulkSync
992988
modifyMempoolCapacityOverride =
993989
maybe id
994990
(\mc nka -> nka { mempoolCapacityOverride = mc })

‎ouroboros-consensus-diffusion/src/ouroboros-consensus-diffusion/Ouroboros/Consensus/Node/Tracers.hs‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -38,8 +38,10 @@ import Ouroboros.Consensus.MiniProtocol.LocalTxSubmission.Server
3838
(TraceLocalTxSubmissionServerEvent (..))
3939
import Ouroboros.Consensus.Node.GSM (TraceGsmEvent)
4040
import Ouroboros.Network.Block (Tip)
41-
import Ouroboros.Network.BlockFetch (FetchDecision,
42-
TraceFetchClientState, TraceLabelPeer)
41+
import Ouroboros.Network.BlockFetch (TraceFetchClientState,
42+
TraceLabelPeer)
43+
import Ouroboros.Network.BlockFetch.Decision.Trace
44+
(TraceDecisionEvent)
4345
import Ouroboros.Network.KeepAlive (TraceKeepAliveClient)
4446
import Ouroboros.Network.TxSubmission.Inbound
4547
(TraceTxSubmissionInbound)
@@ -54,7 +56,7 @@ data Tracers' remotePeer localPeer blk f = Tracers
5456
{ chainSyncClientTracer :: f (TraceLabelPeer remotePeer (TraceChainSyncClientEvent blk))
5557
, chainSyncServerHeaderTracer :: f (TraceLabelPeer remotePeer (TraceChainSyncServerEvent blk))
5658
, chainSyncServerBlockTracer :: f (TraceChainSyncServerEvent blk)
57-
, blockFetchDecisionTracer :: f [TraceLabelPeer remotePeer (FetchDecision [Point (Header blk)])]
59+
, blockFetchDecisionTracer :: f (TraceDecisionEvent remotePeer (Header blk))
5860
, blockFetchClientTracer :: f (TraceLabelPeer remotePeer (TraceFetchClientState (Header blk)))
5961
, blockFetchServerTracer :: f (TraceLabelPeer remotePeer (TraceBlockFetchServerEvent blk))
6062
, txInboundTracer :: f (TraceLabelPeer remotePeer (TraceTxSubmissionInbound (GenTxId blk) (GenTx blk)))

‎ouroboros-consensus-diffusion/src/ouroboros-consensus-diffusion/Ouroboros/Consensus/NodeKernel.hs‎

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,6 @@ import Data.Function (on)
4242
import Data.Functor ((<&>))
4343
import Data.Hashable (Hashable)
4444
import Data.List.NonEmpty (NonEmpty)
45-
import Data.Map.Strict (Map)
4645
import Data.Maybe (isJust, mapMaybe)
4746
import Data.Proxy
4847
import qualified Data.Text as Text
@@ -64,7 +63,7 @@ import qualified Ouroboros.Consensus.MiniProtocol.BlockFetch.ClientInterface as
6463
import Ouroboros.Consensus.MiniProtocol.ChainSync.Client
6564
(ChainSyncClientHandle (..),
6665
ChainSyncClientHandleCollection (..), ChainSyncState (..),
67-
newChainSyncClientHandleCollection, viewChainSyncState)
66+
newChainSyncClientHandleCollection)
6867
import Ouroboros.Consensus.MiniProtocol.ChainSync.Client.HistoricityCheck
6968
(HistoricityCheck)
7069
import Ouroboros.Consensus.MiniProtocol.ChainSync.Client.InFutureCheck
@@ -395,9 +394,6 @@ initInternalState NodeKernelArgs { tracers, chainDB, registry, cfg
395394

396395
fetchClientRegistry <- newFetchClientRegistry
397396

398-
let getCandidates :: STM m (Map (ConnectionId addrNTN) (AnchoredFragment (Header blk)))
399-
getCandidates = viewChainSyncState (cschcMap varChainSyncHandles) csCandidate
400-
401397
slotForgeTimeOracle <- BlockFetchClientInterface.initSlotForgeTimeOracle cfg chainDB
402398
let readFetchMode = BlockFetchClientInterface.readFetchModeDefault
403399
btime
@@ -408,7 +404,7 @@ initInternalState NodeKernelArgs { tracers, chainDB, registry, cfg
408404
blockFetchInterface = BlockFetchClientInterface.mkBlockFetchConsensusInterface
409405
(configBlock cfg)
410406
(BlockFetchClientInterface.defaultChainDbView chainDB)
411-
getCandidates
407+
varChainSyncHandles
412408
blockFetchSize
413409
slotForgeTimeOracle
414410
readFetchMode

‎ouroboros-consensus-diffusion/src/unstable-diffusion-testlib/Test/ThreadNet/Network.hs‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1013,8 +1013,7 @@ runThreadNetwork systemTime ThreadNetworkArgs
10131013
txSubmissionMaxUnacked = 1000 -- TODO ?
10141014
}
10151015
, blockFetchConfiguration = BlockFetchConfiguration {
1016-
bfcMaxConcurrencyBulkSync = 1
1017-
, bfcMaxConcurrencyDeadline = 2
1016+
bfcMaxConcurrencyDeadline = 2
10181017
, bfcMaxRequestsInflight = 10
10191018
, bfcDecisionLoopInterval = 0.0 -- Mock testsuite can use sub-second slot
10201019
-- interval which doesn't play nice with

‎ouroboros-consensus-diffusion/test/consensus-test/Test/Consensus/PeerSimulator/BlockFetch.hs‎

Lines changed: 7 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -17,28 +17,25 @@ module Test.Consensus.PeerSimulator.BlockFetch (
1717
, startKeepAliveThread
1818
) where
1919

20-
import Control.Exception (SomeException)
2120
import Control.Monad (void)
2221
import Control.Monad.Class.MonadTime
2322
import Control.Monad.Class.MonadTimer.SI (MonadTimer)
2423
import Control.ResourceRegistry
2524
import Control.Tracer (Tracer, nullTracer, traceWith)
2625
import Data.Functor.Contravariant ((>$<))
27-
import Data.Map.Strict (Map)
2826
import Network.TypedProtocol.Codec (ActiveState, AnyMessage,
2927
StateToken, notActiveState)
3028
import Ouroboros.Consensus.Block (HasHeader)
3129
import Ouroboros.Consensus.Block.Abstract (Header, Point (..))
3230
import Ouroboros.Consensus.Config
3331
import qualified Ouroboros.Consensus.MiniProtocol.BlockFetch.ClientInterface as BlockFetchClientInterface
32+
import Ouroboros.Consensus.MiniProtocol.ChainSync.Client
33+
(ChainSyncClientHandleCollection)
3434
import Ouroboros.Consensus.Node.ProtocolInfo
3535
(NumCoreNodes (NumCoreNodes))
3636
import Ouroboros.Consensus.Storage.ChainDB.API
3737
import Ouroboros.Consensus.Util (ShowProxy)
38-
import Ouroboros.Consensus.Util.IOLike (DiffTime,
39-
Exception (fromException), IOLike, STM, atomically, retry,
40-
try)
41-
import Ouroboros.Network.AnchoredFragment (AnchoredFragment)
38+
import Ouroboros.Consensus.Util.IOLike
4239
import Ouroboros.Network.BlockFetch (BlockFetchConfiguration (..),
4340
FetchClientRegistry, FetchMode (..), blockFetchLogic,
4441
bracketFetchClient, bracketKeepAliveClient)
@@ -78,17 +75,17 @@ startBlockFetchLogic ::
7875
-> Tracer m (TraceEvent TestBlock)
7976
-> ChainDB m TestBlock
8077
-> FetchClientRegistry PeerId (Header TestBlock) TestBlock m
81-
-> STM m (Map PeerId (AnchoredFragment (Header TestBlock)))
78+
-> ChainSyncClientHandleCollection PeerId m TestBlock
8279
-> m ()
83-
startBlockFetchLogic registry tracer chainDb fetchClientRegistry getCandidates = do
80+
startBlockFetchLogic registry tracer chainDb fetchClientRegistry csHandlesCol = do
8481
let slotForgeTime :: BlockFetchClientInterface.SlotForgeTimeOracle m blk
8582
slotForgeTime _ = pure dawnOfTime
8683

8784
blockFetchConsensusInterface =
8885
BlockFetchClientInterface.mkBlockFetchConsensusInterface
8986
(TestBlockConfig $ NumCoreNodes 0) -- Only needed when minting blocks
9087
(BlockFetchClientInterface.defaultChainDbView chainDb)
91-
getCandidates
88+
csHandlesCol
9289
-- The size of headers in bytes is irrelevant because our tests
9390
-- do not serialize the blocks.
9491
(\_hdr -> 1000)
@@ -103,17 +100,7 @@ startBlockFetchLogic registry tracer chainDb fetchClientRegistry getCandidates =
103100
-- Values taken from
104101
-- ouroboros-consensus-diffusion/src/unstable-diffusion-testlib/Test/ThreadNet/Network.hs
105102
blockFetchCfg = BlockFetchConfiguration
106-
{ -- We set a higher value here to allow downloading blocks from all
107-
-- peers.
108-
--
109-
-- If the value is too low, block downloads from a peer may prevent
110-
-- blocks from being downloaded from other peers. This can be
111-
-- problematic, since the batch download of a simulated BlockFetch
112-
-- server can last serveral ticks if the block pointer is not
113-
-- advanced to allow completion of the batch.
114-
--
115-
bfcMaxConcurrencyBulkSync = 50
116-
, bfcMaxConcurrencyDeadline = 50
103+
{ bfcMaxConcurrencyDeadline = 50 -- unused because of @pure FetchModeBulkSync@ above
117104
, bfcMaxRequestsInflight = 10
118105
, bfcDecisionLoopInterval = 0
119106
, bfcSalt = 0

‎ouroboros-consensus-diffusion/test/consensus-test/Test/Consensus/PeerSimulator/Run.hs‎

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -336,9 +336,7 @@ startNode ::
336336
LiveInterval TestBlock m ->
337337
m ()
338338
startNode schedulerConfig genesisTest interval = do
339-
let
340-
handles = psrHandles lrPeerSim
341-
getCandidates = viewChainSyncState (cschcMap handles) CSClient.csCandidate
339+
let handles = psrHandles lrPeerSim
342340
fetchClientRegistry <- newFetchClientRegistry
343341
let chainDbView = CSClient.defaultChainDbView lnChainDb
344342
activePeers = Map.toList $ Map.restrictKeys (psrPeers lrPeerSim) (lirActive liveResult)
@@ -385,7 +383,7 @@ startNode schedulerConfig genesisTest interval = do
385383
-- The block fetch logic needs to be started after the block fetch clients
386384
-- otherwise, an internal assertion fails because getCandidates yields more
387385
-- peer fragments than registered clients.
388-
BlockFetch.startBlockFetchLogic lrRegistry lrTracer lnChainDb fetchClientRegistry getCandidates
386+
BlockFetch.startBlockFetchLogic lrRegistry lrTracer lnChainDb fetchClientRegistry handles
389387

390388
for_ lrLoEVar $ \ var -> do
391389
forkLinkedWatcher lrRegistry "LoE updater background" $

‎ouroboros-consensus/src/ouroboros-consensus/Ouroboros/Consensus/MiniProtocol/BlockFetch/ClientInterface.hs‎

Lines changed: 14 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,10 @@ import qualified Ouroboros.Consensus.HardFork.Abstract as History
2626
import qualified Ouroboros.Consensus.HardFork.History as History
2727
import Ouroboros.Consensus.Ledger.Abstract
2828
import Ouroboros.Consensus.Ledger.Extended
29+
import Ouroboros.Consensus.Ledger.SupportsProtocol
30+
(LedgerSupportsProtocol)
31+
import qualified Ouroboros.Consensus.MiniProtocol.ChainSync.Client as CSClient
32+
import qualified Ouroboros.Consensus.MiniProtocol.ChainSync.Client.Jumping as Jumping
2933
import Ouroboros.Consensus.Storage.ChainDB.API (ChainDB)
3034
import qualified Ouroboros.Consensus.Storage.ChainDB.API as ChainDB
3135
import Ouroboros.Consensus.Storage.ChainDB.API.Types.InvalidBlockPunishment
@@ -169,11 +173,12 @@ mkBlockFetchConsensusInterface ::
169173
forall m peer blk.
170174
( IOLike m
171175
, BlockSupportsDiffusionPipelining blk
172-
, BlockSupportsProtocol blk
176+
, Ord peer
177+
, LedgerSupportsProtocol blk
173178
)
174179
=> BlockConfig blk
175180
-> ChainDbView m blk
176-
-> STM m (Map peer (AnchoredFragment (Header blk)))
181+
-> CSClient.ChainSyncClientHandleCollection peer m blk
177182
-> (Header blk -> SizeInBytes)
178183
-> SlotForgeTimeOracle m blk
179184
-- ^ Slot forge time, see 'headerForgeUTCTime' and 'blockForgeUTCTime'.
@@ -182,9 +187,12 @@ mkBlockFetchConsensusInterface ::
182187
-> DiffusionPipeliningSupport
183188
-> BlockFetchConsensusInterface peer (Header blk) blk m
184189
mkBlockFetchConsensusInterface
185-
bcfg chainDB getCandidates blockFetchSize slotForgeTime readFetchMode pipelining =
190+
bcfg chainDB csHandlesCol blockFetchSize slotForgeTime readFetchMode pipelining =
186191
BlockFetchConsensusInterface {..}
187192
where
193+
getCandidates :: STM m (Map peer (AnchoredFragment (Header blk)))
194+
getCandidates = CSClient.viewChainSyncState (CSClient.cschcMap csHandlesCol) CSClient.csCandidate
195+
188196
blockMatchesHeader :: Header blk -> blk -> Bool
189197
blockMatchesHeader = Block.blockMatchesHeader
190198

@@ -329,3 +337,6 @@ mkBlockFetchConsensusInterface
329337

330338
headerForgeUTCTime = slotForgeTime . headerRealPoint . unFromConsensus
331339
blockForgeUTCTime = slotForgeTime . blockRealPoint . unFromConsensus
340+
341+
demoteCSJDynamo :: peer -> m ()
342+
demoteCSJDynamo = void . atomically . Jumping.rotateDynamo csHandlesCol

‎ouroboros-consensus/test/consensus-test/Test/Consensus/MiniProtocol/BlockFetch/Client.hs‎

Lines changed: 14 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88
{-# LANGUAGE RecordWildCards #-}
99
{-# LANGUAGE ScopedTypeVariables #-}
1010
{-# LANGUAGE TupleSections #-}
11+
{-# LANGUAGE TypeApplications #-}
1112

1213
-- | A test for the consensus-specific parts of the BlockFetch client.
1314
--
@@ -51,7 +52,7 @@ import Ouroboros.Consensus.Util.STM (blockUntilJust,
5152
import Ouroboros.Network.AnchoredFragment (AnchoredFragment)
5253
import qualified Ouroboros.Network.AnchoredFragment as AF
5354
import Ouroboros.Network.BlockFetch (BlockFetchConfiguration (..),
54-
BlockFetchConsensusInterface, FetchMode (..),
55+
BlockFetchConsensusInterface (..), FetchMode (..),
5556
blockFetchLogic, bracketFetchClient,
5657
bracketKeepAliveClient, bracketSyncWithFetchClient,
5758
newFetchClientRegistry)
@@ -254,10 +255,11 @@ runBlockFetchTest BlockFetchClientTestSetup{..} = withRegistry \registry -> do
254255

255256
let -- Always return the empty chain such that the BlockFetch logic
256257
-- downloads all chains.
257-
getCurrentChain = pure $ AF.Empty AF.AnchorGenesis
258-
getIsFetched = ChainDB.getIsFetched chainDB
259-
getMaxSlotNo = ChainDB.getMaxSlotNo chainDB
260-
addBlockWaitWrittenToDisk = ChainDB.addBlockWaitWrittenToDisk chainDB
258+
getCurrentChain = pure $ AF.Empty AF.AnchorGenesis
259+
getIsFetched = ChainDB.getIsFetched chainDB
260+
getMaxSlotNo = ChainDB.getMaxSlotNo chainDB
261+
addBlockAsync = ChainDB.addBlockAsync chainDB
262+
getChainSelStarvation = ChainDB.getChainSelStarvation chainDB
261263
pure BlockFetchClientInterface.ChainDbView {..}
262264
where
263265
-- Needs to be larger than any chain length in this test, to ensure that
@@ -276,14 +278,17 @@ runBlockFetchTest BlockFetchClientTestSetup{..} = withRegistry \registry -> do
276278
-> BlockFetchClientInterface.ChainDbView m TestBlock
277279
-> BlockFetchConsensusInterface PeerId (Header TestBlock) TestBlock m
278280
mkTestBlockFetchConsensusInterface getCandidates chainDbView =
279-
BlockFetchClientInterface.mkBlockFetchConsensusInterface
281+
(BlockFetchClientInterface.mkBlockFetchConsensusInterface @m @PeerId
280282
(TestBlockConfig numCoreNodes)
281283
chainDbView
282-
getCandidates
284+
(error "ChainSyncClientHandleCollection not provided to mkBlockFetchConsensusInterface")
283285
(\_hdr -> 1000) -- header size, only used for peer prioritization
284286
slotForgeTime
285287
(pure blockFetchMode)
286-
blockFetchPipelining
288+
blockFetchPipelining)
289+
{ readCandidateChains = getCandidates
290+
, demoteChainSyncJumpingDynamo = const (pure ())
291+
}
287292
where
288293
-- Bogus implementation; this is fine as this is only used for
289294
-- enriching tracing information ATM.
@@ -362,6 +367,7 @@ instance Arbitrary BlockFetchClientTestSetup where
362367
-- logic iterations in case the monitored state vars change too
363368
-- fast, which we don't have to worry about in this test.
364369
bfcDecisionLoopInterval = 0
370+
bfcBulkSyncGracePeriod = 10
365371
bfcMaxRequestsInflight <- chooseEnum (2, 10)
366372
bfcSalt <- arbitrary
367373
pure BlockFetchConfiguration {..}

‎ouroboros-consensus/test/consensus-test/Test/Consensus/MiniProtocol/ChainSync/Client.hs‎

Lines changed: 12 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -81,12 +81,14 @@ import Ouroboros.Consensus.Ledger.Abstract
8181
import Ouroboros.Consensus.Ledger.Extended hiding (ledgerState)
8282
import Ouroboros.Consensus.MiniProtocol.ChainSync.Client
8383
(CSJConfig (..), ChainDbView (..),
84-
ChainSyncClientException, ChainSyncClientResult (..),
85-
ChainSyncLoPBucketConfig (..), ChainSyncState (..),
86-
ChainSyncStateView (..), ConfigEnv (..), Consensus,
87-
DynamicEnv (..), Our (..), Their (..),
88-
TraceChainSyncClientEvent (..), bracketChainSyncClient,
89-
chainSyncClient, chainSyncStateFor, viewChainSyncState)
84+
ChainSyncClientException,
85+
ChainSyncClientHandleCollection (..),
86+
ChainSyncClientResult (..), ChainSyncLoPBucketConfig (..),
87+
ChainSyncState (..), ChainSyncStateView (..),
88+
ConfigEnv (..), Consensus, DynamicEnv (..), Our (..),
89+
Their (..), TraceChainSyncClientEvent (..),
90+
bracketChainSyncClient, chainSyncClient, chainSyncStateFor,
91+
newChainSyncClientHandleCollection, viewChainSyncState)
9092
import Ouroboros.Consensus.MiniProtocol.ChainSync.Client.HistoricityCheck
9193
(HistoricityCheck, HistoricityCutoff (..))
9294
import qualified Ouroboros.Consensus.MiniProtocol.ChainSync.Client.HistoricityCheck as HistoricityCheck
@@ -353,7 +355,7 @@ runChainSync skew securityParam (ClientUpdates clientUpdates)
353355
-- separate map too, one that isn't emptied. We can use this map to look
354356
-- at the final state of each candidate.
355357
varFinalCandidates <- uncheckedNewTVarM Map.empty
356-
varHandles <- uncheckedNewTVarM Map.empty
358+
cschCol <- atomically newChainSyncClientHandleCollection
357359

358360
(tracer, getTrace) <- do
359361
(tracer', getTrace) <- recordingTracerTVar
@@ -506,7 +508,7 @@ runChainSync skew securityParam (ClientUpdates clientUpdates)
506508
bracketChainSyncClient
507509
chainSyncTracer
508510
chainDbView
509-
varHandles
511+
cschCol
510512
-- 'Syncing' only ever impacts the LoP, which is disabled in
511513
-- this test, so any value would do.
512514
(pure Syncing)
@@ -517,7 +519,7 @@ runChainSync skew securityParam (ClientUpdates clientUpdates)
517519
diffusionPipelining
518520
$ \csState -> do
519521
atomically $ do
520-
handles <- readTVar varHandles
522+
handles <- cschcMap cschCol
521523
modifyTVar varFinalCandidates $ Map.insert serverId (handles Map.! serverId)
522524
(result, _) <-
523525
runPipelinedPeer protocolTracer codecChainSyncId clientChannel $
@@ -538,7 +540,7 @@ runChainSync skew securityParam (ClientUpdates clientUpdates)
538540
let checkTipTime :: m ()
539541
checkTipTime = do
540542
now <- systemTimeCurrent clientSystemTime
541-
candidates <- atomically $ viewChainSyncState varHandles csCandidate
543+
candidates <- atomically $ viewChainSyncState (cschcMap cschCol) csCandidate
542544
forM_ candidates $ \candidate -> do
543545
let p = castPoint $ AF.headPoint candidate :: Point TestBlock
544546
case pointSlot p of

‎ouroboros-consensus/test/storage-test/Test/Ouroboros/Storage/ChainDB/StateMachine.hs‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1635,6 +1635,7 @@ traceEventName = \case
16351635
TraceImmutableDBEvent ev -> "ImmutableDB." <> constrName ev
16361636
TraceVolatileDBEvent ev -> "VolatileDB." <> constrName ev
16371637
TraceLastShutdownUnclean -> "LastShutdownUnclean"
1638+
TraceChainSelStarvationEvent _ -> "TraceChainSelStarvationEvent"
16381639

16391640
mkArgs :: IOLike m
16401641
=> TopLevelConfig Blk

0 commit comments

Comments
 (0)