Skip to content

Commit c625852

Browse files
dnadalesnfrisby
dnadales
authored and
nfrisby
committed
fully squashed HeaderWithTime PR, from 3ea291c 
1 parent e717d56 commit c625852

File tree

40 files changed

+695
-211
lines changed

40 files changed

+695
-211
lines changed

‎ouroboros-consensus-cardano/src/ouroboros-consensus-cardano/Ouroboros/Consensus/Cardano/ByronHFC.hs

+4-2
Original file line numberDiff line numberDiff line change
@@ -30,9 +30,11 @@ type ByronBlockHFC = HardForkBlock '[ByronBlock]
3030
NoHardForks instance
3131
-------------------------------------------------------------------------------}
3232

33-
instance NoHardForks ByronBlock where
34-
getEraParams cfg =
33+
instance ImmutableEraParams ByronBlock where
34+
immutableEraParams cfg =
3535
byronEraParamsNeverHardForks (byronGenesisConfig (configBlock cfg))
36+
37+
instance NoHardForks ByronBlock where
3638
toPartialLedgerConfig _ cfg = ByronPartialLedgerConfig {
3739
byronLedgerConfig = cfg
3840
, byronTriggerHardFork = TriggerHardForkNotDuringThisExecution

‎ouroboros-consensus-cardano/src/shelley/Ouroboros/Consensus/Shelley/ShelleyHFC.hs

+7-3
Original file line numberDiff line numberDiff line change
@@ -79,12 +79,16 @@ type ShelleyBlockHFC proto era = HardForkBlock '[ShelleyBlock proto era]
7979

8080
instance ( ShelleyCompatible proto era
8181
, LedgerSupportsProtocol (ShelleyBlock proto era)
82-
, TxLimits (ShelleyBlock proto era)
83-
) => NoHardForks (ShelleyBlock proto era) where
84-
getEraParams =
82+
) => ImmutableEraParams (ShelleyBlock proto era) where
83+
immutableEraParams =
8584
shelleyEraParamsNeverHardForks
8685
. shelleyLedgerGenesis
8786
. configLedger
87+
88+
instance ( ShelleyCompatible proto era
89+
, LedgerSupportsProtocol (ShelleyBlock proto era)
90+
, TxLimits (ShelleyBlock proto era)
91+
) => NoHardForks (ShelleyBlock proto era) where
8892
toPartialLedgerConfig _ cfg = ShelleyPartialLedgerConfig {
8993
shelleyLedgerConfig = cfg
9094
, shelleyTriggerHardFork = TriggerHardForkNotDuringThisExecution

‎ouroboros-consensus-diffusion/src/ouroboros-consensus-diffusion/Ouroboros/Consensus/Network/NodeToNode.hs

+2-1
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,7 @@ import Data.Void (Void)
5555
import Network.TypedProtocol.Codec
5656
import Ouroboros.Consensus.Block
5757
import Ouroboros.Consensus.Config (DiffusionPipeliningSupport (..))
58+
import Ouroboros.Consensus.HeaderValidation (HeaderWithTime)
5859
import Ouroboros.Consensus.Ledger.SupportsMempool
5960
import Ouroboros.Consensus.Ledger.SupportsProtocol
6061
import Ouroboros.Consensus.MiniProtocol.BlockFetch.Server
@@ -152,7 +153,7 @@ data Handlers m addr blk = Handlers {
152153
:: NodeToNodeVersion
153154
-> ControlMessageSTM m
154155
-> FetchedMetricsTracer m
155-
-> BlockFetchClient (Header blk) blk m ()
156+
-> BlockFetchClient (HeaderWithTime blk) blk m ()
156157

157158
, hBlockFetchServer
158159
:: ConnectionId addr

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

+5-3
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,9 @@ module Ouroboros.Consensus.Node.Genesis (
1919

2020
import Control.Monad (join)
2121
import Data.Traversable (for)
22+
import Data.Typeable (Typeable)
2223
import Ouroboros.Consensus.Block
24+
import Ouroboros.Consensus.HeaderValidation (HeaderWithTime (..))
2325
import Ouroboros.Consensus.MiniProtocol.ChainSync.Client
2426
(CSJConfig (..), CSJEnabledConfig (..),
2527
ChainSyncLoPBucketConfig (..),
@@ -89,7 +91,7 @@ data GenesisNodeKernelArgs m blk = GenesisNodeKernelArgs {
8991
-- 'ChainDB.GetLoEFragment' that will be replaced via 'setGetLoEFragment') and a
9092
-- function to update the 'ChainDbArgs' accordingly.
9193
mkGenesisNodeKernelArgs ::
92-
forall m blk. (IOLike m, GetHeader blk)
94+
forall m blk. (IOLike m, GetHeader blk, Typeable blk)
9395
=> GenesisConfig
9496
-> m ( GenesisNodeKernelArgs m blk
9597
, Complete ChainDbArgs m blk -> Complete ChainDbArgs m blk
@@ -113,9 +115,9 @@ mkGenesisNodeKernelArgs gcfg = do
113115
-- | Set 'gnkaGetLoEFragment' to the actual logic for determining the current
114116
-- LoE fragment.
115117
setGetLoEFragment ::
116-
forall m blk. (IOLike m, GetHeader blk)
118+
forall m blk. (IOLike m, GetHeader blk, Typeable blk)
117119
=> STM m GSM.GsmState
118-
-> STM m (AnchoredFragment (Header blk))
120+
-> STM m (AnchoredFragment (HeaderWithTime blk))
119121
-- ^ The LoE fragment.
120122
-> StrictTVar m (ChainDB.GetLoEFragment m blk)
121123
-> m ()

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

+51-9
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
{-# LANGUAGE ScopedTypeVariables #-}
1212
{-# LANGUAGE TypeApplications #-}
1313
{-# LANGUAGE TypeFamilies #-}
14+
{-# LANGUAGE TypeOperators #-}
1415

1516
module Ouroboros.Consensus.NodeKernel (
1617
-- * Node kernel
@@ -45,6 +46,7 @@ import Data.List.NonEmpty (NonEmpty)
4546
import Data.Map.Strict (Map)
4647
import Data.Maybe (isJust, mapMaybe)
4748
import Data.Proxy
49+
import qualified Data.Set as Set
4850
import qualified Data.Text as Text
4951
import Data.Void (Void)
5052
import Ouroboros.Consensus.Block hiding (blockMatchesHeader)
@@ -94,6 +96,7 @@ import Ouroboros.Network.AnchoredFragment (AnchoredFragment,
9496
import qualified Ouroboros.Network.AnchoredFragment as AF
9597
import Ouroboros.Network.Block (castTip, tipFromHeader)
9698
import Ouroboros.Network.BlockFetch
99+
import qualified Ouroboros.Network.BlockFetch.ClientState as BF
97100
import Ouroboros.Network.Diffusion (PublicPeerSelectionState)
98101
import Ouroboros.Network.NodeToNode (ConnectionId,
99102
MiniProtocolParameters (..))
@@ -131,7 +134,7 @@ data NodeKernel m addrNTN addrNTC blk = NodeKernel {
131134
, getTopLevelConfig :: TopLevelConfig blk
132135

133136
-- | The fetch client registry, used for the block fetch clients.
134-
, getFetchClientRegistry :: FetchClientRegistry (ConnectionId addrNTN) (Header blk) blk m
137+
, getFetchClientRegistry :: FetchClientRegistry (ConnectionId addrNTN) (HeaderWithTime blk) blk m
135138

136139
-- | The fetch mode, used by diffusion.
137140
--
@@ -254,8 +257,8 @@ initNodeKernel args@NodeKernelArgs { registry, cfg, tracers
254257
, GSM.equivalent = (==) `on` (AF.headPoint . fst)
255258
, GSM.getChainSyncStates = fmap cschState <$> readTVar varChainSyncHandles
256259
, GSM.getCurrentSelection = do
257-
headers <- ChainDB.getCurrentChain chainDB
258-
extLedgerState <- ChainDB.getCurrentLedger chainDB
260+
headers <- ChainDB.getCurrentChainWithTime chainDB
261+
extLedgerState <- ChainDB.getCurrentLedger chainDB
259262
return (headers, ledgerState extLedgerState)
260263
, GSM.minCaughtUpDuration = gsmMinCaughtUpDuration
261264
, GSM.setCaughtUpPersistentMark = \upd ->
@@ -309,8 +312,8 @@ initNodeKernel args@NodeKernelArgs { registry, cfg, tracers
309312
-- 'addFetchedBlock' whenever a new block is downloaded.
310313
void $ forkLinkedThread registry "NodeKernel.blockFetchLogic" $
311314
blockFetchLogic
312-
(blockFetchDecisionTracer tracers)
313-
(blockFetchClientTracer tracers)
315+
(contramap (map (fmap (fmap (map castPoint)))) $ blockFetchDecisionTracer tracers)
316+
(contramap (fmap castTraceFetchClientState) $ blockFetchClientTracer tracers)
314317
blockFetchInterface
315318
fetchClientRegistry
316319
blockFetchConfiguration
@@ -344,6 +347,45 @@ initNodeKernel args@NodeKernelArgs { registry, cfg, tracers
344347
blockForging' <- traverse (forkBlockForging st) blockForging
345348
go blockForging'
346349

350+
castTraceFetchClientState ::
351+
forall blk. HasHeader (Header blk)
352+
=> TraceFetchClientState (HeaderWithTime blk) -> TraceFetchClientState (Header blk)
353+
castTraceFetchClientState = mapTraceFetchClientState hwtHeader
354+
355+
mapTraceFetchClientState ::
356+
(HeaderHash h1 ~ HeaderHash h2, HasHeader h2)
357+
=> (h1 -> h2) -> TraceFetchClientState h1 -> TraceFetchClientState h2
358+
mapTraceFetchClientState fheader = \case
359+
AddedFetchRequest request inflight inflightLimits status -> AddedFetchRequest (frequest request) (finflight inflight) inflightLimits (fstatus status)
360+
361+
AcknowledgedFetchRequest request -> AcknowledgedFetchRequest (frequest request)
362+
363+
SendFetchRequest headers gsv -> SendFetchRequest (AF.mapAnchoredFragment fheader headers) gsv
364+
365+
StartedFetchBatch range inflight inflightLimits status -> StartedFetchBatch (frange range) (finflight inflight) inflightLimits (fstatus status)
366+
CompletedBlockFetch point inflight inflightLimits status time size -> CompletedBlockFetch (fpoint point) (finflight inflight) inflightLimits (fstatus status) time size
367+
CompletedFetchBatch range inflight inflightLimits status -> CompletedFetchBatch (frange range) (finflight inflight) inflightLimits (fstatus status)
368+
RejectedFetchBatch range inflight inflightLimits status -> RejectedFetchBatch (frange range) (finflight inflight) inflightLimits (fstatus status)
369+
370+
ClientTerminating i -> ClientTerminating i
371+
where
372+
frequest (BF.FetchRequest headers) = BF.FetchRequest $ map (AF.mapAnchoredFragment fheader) headers
373+
374+
finflight inflight = inflight { BF.peerFetchBlocksInFlight = fpoints (BF.peerFetchBlocksInFlight inflight) }
375+
376+
fstatus = \case
377+
BF.PeerFetchStatusShutdown -> BF.PeerFetchStatusShutdown
378+
BF.PeerFetchStatusStarting -> BF.PeerFetchStatusStarting
379+
BF.PeerFetchStatusAberrant -> BF.PeerFetchStatusAberrant
380+
BF.PeerFetchStatusBusy -> BF.PeerFetchStatusBusy
381+
BF.PeerFetchStatusReady points idle -> BF.PeerFetchStatusReady (fpoints points) idle
382+
383+
fpoints = Set.mapMonotonic fpoint
384+
385+
frange (BF.ChainRange p1 p2) = BF.ChainRange (fpoint p1) (fpoint p2)
386+
387+
fpoint = castPoint
388+
347389
{-------------------------------------------------------------------------------
348390
Internal node components
349391
-------------------------------------------------------------------------------}
@@ -354,8 +396,8 @@ data InternalState m addrNTN addrNTC blk = IS {
354396
, registry :: ResourceRegistry m
355397
, btime :: BlockchainTime m
356398
, chainDB :: ChainDB m blk
357-
, blockFetchInterface :: BlockFetchConsensusInterface (ConnectionId addrNTN) (Header blk) blk m
358-
, fetchClientRegistry :: FetchClientRegistry (ConnectionId addrNTN) (Header blk) blk m
399+
, blockFetchInterface :: BlockFetchConsensusInterface (ConnectionId addrNTN) (HeaderWithTime blk) blk m
400+
, fetchClientRegistry :: FetchClientRegistry (ConnectionId addrNTN) (HeaderWithTime blk) blk m
359401
, varChainSyncHandles :: StrictTVar m (Map (ConnectionId addrNTN) (ChainSyncClientHandle m blk))
360402
, varGsmState :: StrictTVar m GSM.GsmState
361403
, mempool :: Mempool m blk
@@ -394,7 +436,7 @@ initInternalState NodeKernelArgs { tracers, chainDB, registry, cfg
394436

395437
fetchClientRegistry <- newFetchClientRegistry
396438

397-
let getCandidates :: STM m (Map (ConnectionId addrNTN) (AnchoredFragment (Header blk)))
439+
let getCandidates :: STM m (Map (ConnectionId addrNTN) (AnchoredFragment (HeaderWithTime blk)))
398440
getCandidates = viewChainSyncState varChainSyncHandles csCandidate
399441

400442
slotForgeTimeOracle <- BlockFetchClientInterface.initSlotForgeTimeOracle cfg chainDB
@@ -403,7 +445,7 @@ initInternalState NodeKernelArgs { tracers, chainDB, registry, cfg
403445
(ChainDB.getCurrentChain chainDB)
404446
getUseBootstrapPeers
405447
(GSM.gsmStateToLedgerJudgement <$> readTVar varGsmState)
406-
blockFetchInterface :: BlockFetchConsensusInterface (ConnectionId addrNTN) (Header blk) blk m
448+
blockFetchInterface :: BlockFetchConsensusInterface (ConnectionId addrNTN) (HeaderWithTime blk) blk m
407449
blockFetchInterface = BlockFetchClientInterface.mkBlockFetchConsensusInterface
408450
(configBlock cfg)
409451
(BlockFetchClientInterface.defaultChainDbView chainDB)

‎ouroboros-consensus-diffusion/src/unstable-mock-testlib/Test/ThreadNet/Util/SimpleBlock.hs

+1-1
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
module Test.ThreadNet.Util.SimpleBlock (prop_validSimpleBlock) where
44

5-
import Data.Typeable
5+
import Data.Typeable (Typeable)
66
import Ouroboros.Consensus.Block
77
import Ouroboros.Consensus.Mock.Ledger
88
import Ouroboros.Consensus.Util.Condense (condense)

‎ouroboros-consensus-diffusion/test/consensus-test/Test/Consensus/Genesis/Tests/DensityDisconnect.hs

+34-12
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ import Ouroboros.Consensus.Config.SecurityParam
3030
(SecurityParam (SecurityParam), maxRollbacks)
3131
import Ouroboros.Consensus.Genesis.Governor (DensityBounds,
3232
densityDisconnect, sharedCandidatePrefix)
33+
import Ouroboros.Consensus.HeaderValidation (HeaderWithTime)
3334
import Ouroboros.Consensus.MiniProtocol.ChainSync.Client
3435
(ChainSyncClientException (DensityTooLow),
3536
ChainSyncState (..))
@@ -59,13 +60,16 @@ import Test.QuickCheck
5960
import Test.QuickCheck.Extras (unsafeMapSuchThatJust)
6061
import Test.Tasty
6162
import Test.Tasty.QuickCheck
63+
import Test.Util.HeaderValidation (attachSlotTimeToFragment)
6264
import Test.Util.Orphans.IOLike ()
6365
import Test.Util.PartialAccessors
64-
import Test.Util.TersePrinting (terseHFragment, terseHeader)
65-
import Test.Util.TestBlock (TestBlock)
66+
import Test.Util.TersePrinting (terseHFragment, terseHWTFragment,
67+
terseHeader)
68+
import Test.Util.TestBlock (TestBlock, singleNodeTestConfig)
6669
import Test.Util.TestEnv (adjustQuickCheckMaxSize,
6770
adjustQuickCheckTests)
6871

72+
6973
tests :: TestTree
7074
tests =
7175
adjustQuickCheckTests (* 4) $
@@ -87,9 +91,9 @@ data StaticCandidates =
8791
StaticCandidates {
8892
k :: SecurityParam,
8993
sgen :: GenesisWindow,
90-
suffixes :: [(PeerId, AnchoredFragment (Header TestBlock))],
94+
suffixes :: [(PeerId, AnchoredFragment (HeaderWithTime TestBlock))],
9195
tips :: Map PeerId (Tip TestBlock),
92-
loeFrag :: AnchoredFragment (Header TestBlock)
96+
loeFrag :: AnchoredFragment (HeaderWithTime TestBlock)
9397
}
9498
deriving Show
9599

@@ -112,7 +116,11 @@ staticCandidates GenesisTest {gtSecurityParam, gtGenesisWindow, gtBlockTree} =
112116
}
113117
where
114118
(loeFrag, suffixes) =
115-
sharedCandidatePrefix curChain (second toHeaders <$> candidates)
119+
sharedCandidatePrefix
120+
curChain
121+
(second (attachTimeUsingTestConfig . toHeaders)
122+
<$> candidates
123+
)
116124

117125
selections = selection <$> branches
118126

@@ -128,6 +136,15 @@ staticCandidates GenesisTest {gtSecurityParam, gtGenesisWindow, gtBlockTree} =
128136

129137
branches = btBranches gtBlockTree
130138

139+
-- | Attach a relative slot time to a fragment of headers using the
140+
-- 'singleNodeTestConfig'. Since 'k' is not used for time conversions,
141+
-- it is safe to use this configuration even if other 'k' values are
142+
-- used in the tests that call this function.
143+
attachTimeUsingTestConfig ::
144+
AnchoredFragment (Header TestBlock) ->
145+
AnchoredFragment (HeaderWithTime TestBlock)
146+
attachTimeUsingTestConfig = attachSlotTimeToFragment singleNodeTestConfig
147+
131148
-- | Check that the GDD disconnects from some peers for each full Genesis window starting at any of a block tree's
132149
-- intersections, and that it's not the honest peer.
133150
prop_densityDisconnectStatic :: Property
@@ -139,7 +156,7 @@ prop_densityDisconnectStatic =
139156
counterexample "it should not disconnect the honest peers"
140157
(not $ any isHonestPeerId disconnect)
141158
where
142-
mkState :: AnchoredFragment (Header TestBlock) -> ChainSyncState TestBlock
159+
mkState :: AnchoredFragment (HeaderWithTime TestBlock) -> ChainSyncState TestBlock
143160
mkState frag =
144161
ChainSyncState {
145162
csCandidate = frag,
@@ -167,7 +184,7 @@ data EvolvingPeers =
167184
k :: SecurityParam,
168185
sgen :: GenesisWindow,
169186
peers :: Peers EvolvingPeer,
170-
loeFrag :: AnchoredFragment (Header TestBlock),
187+
loeFrag :: AnchoredFragment (HeaderWithTime TestBlock),
171188
fullTree :: BlockTree TestBlock
172189
}
173190
deriving Show
@@ -227,7 +244,7 @@ data UpdateEvent = UpdateEvent {
227244
, bounds :: [(PeerId, DensityBounds TestBlock)]
228245
-- | The current chains
229246
, tree :: BlockTree (Header TestBlock)
230-
, loeFrag :: AnchoredFragment (Header TestBlock)
247+
, loeFrag :: AnchoredFragment (HeaderWithTime TestBlock)
231248
, curChain :: AnchoredFragment (Header TestBlock)
232249
}
233250

@@ -240,7 +257,7 @@ prettyUpdateEvent UpdateEvent {target, added, killed, bounds, tree, loeFrag, cur
240257
[
241258
"Extended " ++ condense target ++ " with " ++ terseHeader added,
242259
" disconnect: " ++ show killed,
243-
" LoE frag: " ++ terseHFragment loeFrag,
260+
" LoE frag: " ++ terseHWTFragment loeFrag,
244261
" selection: " ++ terseHFragment curChain
245262
]
246263
++ prettyDensityBounds bounds
@@ -377,12 +394,17 @@ evolveBranches EvolvingPeers {k, sgen, peers = initialPeers, fullTree} =
377394
states =
378395
candidates <&> \ csCandidate ->
379396
ChainSyncState {
380-
csCandidate,
397+
csCandidate = attachTimeUsingTestConfig csCandidate,
381398
csIdling = False,
382399
csLatestSlot = SJust (AF.headSlot csCandidate)
383400
}
384401
-- Run GDD.
385-
(loeFrag, suffixes) = sharedCandidatePrefix curChain (Map.toList candidates)
402+
(loeFrag, suffixes) =
403+
sharedCandidatePrefix
404+
curChain
405+
(Map.toList $
406+
fmap attachTimeUsingTestConfig candidates
407+
)
386408
(killedNow, bounds) = first Set.fromList $ densityDisconnect sgen k states suffixes loeFrag
387409
event = UpdateEvent {
388410
target,
@@ -415,7 +437,7 @@ peerInfo EvolvingPeers {k = SecurityParam k, sgen = GenesisWindow sgen, loeFrag}
415437
[
416438
"k: " <> show k,
417439
"sgen: " <> show sgen,
418-
"loeFrag: " <> terseHFragment loeFrag
440+
"loeFrag: " <> terseHWTFragment loeFrag
419441
]
420442

421443
-- | Tests that when GDD disconnects a peer, it continues to disconnect it when

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

+6-5
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ import Network.TypedProtocol.Codec (ActiveState, AnyMessage,
3030
import Ouroboros.Consensus.Block (HasHeader)
3131
import Ouroboros.Consensus.Block.Abstract (Header, Point (..))
3232
import Ouroboros.Consensus.Config
33+
import Ouroboros.Consensus.HeaderValidation (HeaderWithTime (..))
3334
import qualified Ouroboros.Consensus.MiniProtocol.BlockFetch.ClientInterface as BlockFetchClientInterface
3435
import Ouroboros.Consensus.Node.ProtocolInfo
3536
(NumCoreNodes (NumCoreNodes))
@@ -77,8 +78,8 @@ startBlockFetchLogic ::
7778
=> ResourceRegistry m
7879
-> Tracer m (TraceEvent TestBlock)
7980
-> ChainDB m TestBlock
80-
-> FetchClientRegistry PeerId (Header TestBlock) TestBlock m
81-
-> STM m (Map PeerId (AnchoredFragment (Header TestBlock)))
81+
-> FetchClientRegistry PeerId (HeaderWithTime TestBlock) TestBlock m
82+
-> STM m (Map PeerId (AnchoredFragment (HeaderWithTime TestBlock)))
8283
-> m ()
8384
startBlockFetchLogic registry tracer chainDb fetchClientRegistry getCandidates = do
8485
let slotForgeTime :: BlockFetchClientInterface.SlotForgeTimeOracle m blk
@@ -130,10 +131,10 @@ startBlockFetchLogic registry tracer chainDb fetchClientRegistry getCandidates =
130131
decisionTracer = TraceOther . ("BlockFetchLogic | " ++) . show >$< tracer
131132

132133
startKeepAliveThread ::
133-
forall m peer blk.
134+
forall m peer blk hdr.
134135
(Ord peer, IOLike m)
135136
=> ResourceRegistry m
136-
-> FetchClientRegistry peer (Header blk) blk m
137+
-> FetchClientRegistry peer hdr blk m
137138
-> peer
138139
-> m ()
139140
startKeepAliveThread registry fetchClientRegistry peerId =
@@ -147,7 +148,7 @@ runBlockFetchClient ::
147148
-> PeerId
148149
-> BlockFetchTimeout
149150
-> StateViewTracers blk m
150-
-> FetchClientRegistry PeerId (Header blk) blk m
151+
-> FetchClientRegistry PeerId (HeaderWithTime blk) blk m
151152
-> ControlMessageSTM m
152153
-> Channel m (AnyMessage (BlockFetch blk (Point blk)))
153154
-- ^ Send and receive message via the given 'Channel'.

0 commit comments

Comments
 (0)