Fixed typos

Author: coot

ouroboros-consensus/ouroboros-consensus-test-infra/src/Test/ThreadNet/Network.hs

@@ -744,10 +744,10 @@ runThreadNetwork ThreadNetworkArgs
             , maxBlockSize           = NoOverride
             , mempoolCap             = NoMempoolCapacityBytesOverride
             , miniProtocolParameters = MiniProtocolParameters {
-                  chainSyncPipelineingHighMark = 4,
-                  chainSyncPipelineingLowMark  = 2,
-                  blockFetchPipelineingMax     = 10,
-                  txSubmissionMaxUnacked       = 1000 -- TODO ?
+                  chainSyncPipeliningHighMark = 4,
+                  chainSyncPipeliningLowMark  = 2,
+                  blockFetchPipeliningMax     = 10,
+                  txSubmissionMaxUnacked      = 1000 -- TODO ?
                 }
             }
 

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

@@ -220,7 +220,7 @@ initNodeKernel args@NodeArgs { registry, cfg, tracers, maxBlockSize
     blockFetchConfiguration = BlockFetchConfiguration
       { bfcMaxConcurrencyBulkSync = 1 -- Set to 1 for now, see #1526
       , bfcMaxConcurrencyDeadline = 1
-      , bfcMaxRequestsInflight    = blockFetchPipelineingMax miniProtocolParameters
+      , bfcMaxRequestsInflight    = blockFetchPipeliningMax miniProtocolParameters
       }
 
 {-------------------------------------------------------------------------------

ouroboros-consensus/src/Ouroboros/Consensus/NodeNetwork.hs

@@ -159,8 +159,8 @@ protocolHandlers NodeArgs {btime, cfg, maxClockSkew, tracers, miniProtocolParame
     ProtocolHandlers {
       phChainSyncClient =
         chainSyncClient
-          (pipelineDecisionLowHighMark (chainSyncPipelineingLowMark  miniProtocolParameters)
-                                       (chainSyncPipelineingHighMark miniProtocolParameters))
+          (pipelineDecisionLowHighMark (chainSyncPipeliningLowMark  miniProtocolParameters)
+                                       (chainSyncPipeliningHighMark miniProtocolParameters))
           (chainSyncClientTracer tracers)
           getTopLevelConfig
           btime

ouroboros-network/src/Ouroboros/Network/NodeToNode.hs

@@ -147,21 +147,21 @@ data NodeToNodeProtocols appType bytes m a b = NodeToNodeProtocols {
 
 
 data MiniProtocolParameters = MiniProtocolParameters {
-      chainSyncPipelineingHighMark :: !Word32,
+      chainSyncPipeliningHighMark :: !Word32,
       -- ^ high threshold for pipelining (we will never exceed that many
       -- messages pipelined).
 
-      chainSyncPipelineingLowMark  :: !Word32,
-      -- ^ low threshold: if we hit the 'chainSyncPipelineingHighMark' we will
+      chainSyncPipeliningLowMark  :: !Word32,
+      -- ^ low threshold: if we hit the 'chainSyncPipeliningHighMark' we will
       -- listen for responses until there are at most
-      -- 'chainSyncPipelineingLowMark' pipelined message
+      -- 'chainSyncPipeliningLowMark' pipelined message
       --
-      -- Must be smaller than 'chainSyncPipelineingHighMark'.
+      -- Must be smaller than 'chainSyncPipeliningHighMark'.
       --
-      -- Note: 'chainSyncPipelineingLowMark' and 'chainSyncPipelineingLowMark'
+      -- Note: 'chainSyncPipeliningLowMark' and 'chainSyncPipeliningLowMark'
       -- are passed to 'pipelineDecisionLowHighMark'.
 
-      blockFetchPipelineingMax     :: !Word,
+      blockFetchPipeliningMax     :: !Word,
       -- ^ maximal number of pipelined messages in 'block-fetch' mini-protocol.
 
       txSubmissionMaxUnacked       :: !Word16
@@ -171,9 +171,9 @@ data MiniProtocolParameters = MiniProtocolParameters {
 
 defaultMiniProtocolParameters :: MiniProtocolParameters
 defaultMiniProtocolParameters = MiniProtocolParameters {
-      chainSyncPipelineingLowMark  = 200
-    , chainSyncPipelineingHighMark = 300
-    , blockFetchPipelineingMax     = 100
+      chainSyncPipeliningLowMark  = 200
+    , chainSyncPipeliningHighMark = 300
+    , blockFetchPipeliningMax     = 100
     , txSubmissionMaxUnacked       = 10
   }
 
@@ -200,8 +200,8 @@ nodeToNodeProtocols
   -> NodeToNodeProtocols appType bytes m a b
   -> OuroborosApplication appType bytes m a b
 nodeToNodeProtocols MiniProtocolParameters {
-                        chainSyncPipelineingHighMark,
-                        blockFetchPipelineingMax,
+                        chainSyncPipeliningHighMark,
+                        blockFetchPipeliningMax,
                         txSubmissionMaxUnacked
                       }
                     NodeToNodeProtocols {
@@ -292,18 +292,18 @@ nodeToNodeProtocols MiniProtocolParameters {
           --   = 716
           --   ```
           --
-          -- Since chain sync can pipeline up to 'chainSyncPipelineingHighMark' of 'MsgRollForward'
+          -- Since chain sync can pipeline up to 'chainSyncPipeliningHighMark' of 'MsgRollForward'
           -- messages the maximal queue size can be
-          -- @chainSyncPipelineingHighMark * 716@.  The current value of
-          -- 'chainSyncPipelineingHighMark' is '300' thus the upper bound is
+          -- @chainSyncPipeliningHighMark * 716@.  The current value of
+          -- 'chainSyncPipeliningHighMark' is '300' thus the upper bound is
           -- `214.8Kb`)  We add 10% to that for safety.
           --
           maximumIngressQueue = addSafetyMargin $
-            fromIntegral chainSyncPipelineingHighMark * 716
+            fromIntegral chainSyncPipeliningHighMark * 716
         }
 
     blockFetchProtocolLimits = MiniProtocolLimits {
-        -- block-fetch client can pipeline at most 'blockFetchPipelineingMax'
+        -- block-fetch client can pipeline at most 'blockFetchPipeliningMax'
         -- blocks (currently '10').  This is currently hard coded in
         -- 'Ouroboros.Network.BlockFetch.blockFetchLogic' (where
         -- @maxInFlightReqsPerPeer = 10@ is specified).  In the future the
@@ -323,7 +323,7 @@ nodeToNodeProtocols MiniProtocolParameters {
         -- '20Mb'), we add 10% safety margin:
         --
         maximumIngressQueue = addSafetyMargin $
-          fromIntegral blockFetchPipelineingMax * 2_097_154
+          fromIntegral blockFetchPipeliningMax * 2_097_154
       }
 
     txSubmissionProtocolLimits = MiniProtocolLimits {