Skip to content

Commit

Permalink
ouroboros-network-framework: make runMiniProtocolCb & ExpandedInitiat…
Browse files Browse the repository at this point in the history
…orContext strict
  • Loading branch information
coot committed Jun 2, 2023
1 parent 5db6560 commit eb63cda
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 6 deletions.
6 changes: 3 additions & 3 deletions ouroboros-network-framework/src/Ouroboros/Network/Context.hs
Expand Up @@ -19,9 +19,9 @@ import Ouroboros.Network.ControlMessage
-- | Context passed to initiator mini-protocol execution.
--
data ExpandedInitiatorContext addr m = ExpandedInitiatorContext {
eicConnectionId :: ConnectionId addr,
eicControlMessage :: ControlMessageSTM m,
eicIsBigLedgerPeer :: IsBigLedgerPeer
eicConnectionId :: !(ConnectionId addr),
eicControlMessage :: !(ControlMessageSTM m),
eicIsBigLedgerPeer :: !IsBigLedgerPeer
}

-- | A context passed to initiator mini-protocol execution for non-p2p
Expand Down
7 changes: 4 additions & 3 deletions ouroboros-network-framework/src/Ouroboros/Network/Mux.hs
@@ -1,3 +1,4 @@
{-# LANGUAGE BangPatterns #-}
{-# LANGUAGE DataKinds #-}
{-# LANGUAGE DeriveFoldable #-}
{-# LANGUAGE DeriveFunctor #-}
Expand Down Expand Up @@ -412,9 +413,9 @@ runMiniProtocolCb :: ( MonadAsync m
-> ctx
-> Mux.Channel m
-> m (a, Maybe LBS.ByteString)
runMiniProtocolCb (MiniProtocolCb run) ctx = run ctx . fromChannel
runMiniProtocolCb (MuxPeer fn) ctx = runMiniProtocolCb (mkMiniProtocolCbFromPeer fn) ctx
runMiniProtocolCb (MuxPeerPipelined fn) ctx = runMiniProtocolCb (mkMiniProtocolCbFromPeerPipelined fn) ctx
runMiniProtocolCb (MiniProtocolCb run) !ctx = run ctx . fromChannel
runMiniProtocolCb (MuxPeer fn) !ctx = runMiniProtocolCb (mkMiniProtocolCbFromPeer fn) ctx
runMiniProtocolCb (MuxPeerPipelined fn) !ctx = runMiniProtocolCb (mkMiniProtocolCbFromPeerPipelined fn) ctx

contramapMiniProtocolCbCtx :: (ctx -> ctx')
-> MiniProtocolCb ctx' bytes m a
Expand Down

0 comments on commit eb63cda

Please sign in to comment.