Skip to content

Commit f6c9525

Browse files
committed
[WIP 2] refactor internals of ObjectDiffusion protocol
1 parent 802ad82 commit f6c9525

File tree

6 files changed

+405
-405
lines changed
  • ouroboros-consensus-diffusion/src/ouroboros-consensus-diffusion/Ouroboros/Consensus/Network
  • ouroboros-consensus

6 files changed

+405
-405
lines changed

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

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -309,14 +309,16 @@ mkHandlers
309309
, hPerasCertDiffusionInbound = \version peer ->
310310
objectDiffusionInbound
311311
(contramap (TraceLabelPeer peer) (Node.certDiffusionInboundTracer tracers))
312-
(certDiffusionMaxUnacked miniProtocolParameters)
313-
(makePerasCertPoolReaderFromChainDB $ getChainDB)
312+
( perasCertDiffusionMaxFifoLength miniProtocolParameters
313+
, 10 -- TODO: change this to a sensible value
314+
, 10 -- TODO: change this to a sensible value
315+
)
314316
(makePerasCertPoolWriterFromChainDB $ getChainDB)
315317
version
316318
, hPerasCertDiffusionOutbound = \version controlMessageSTM peer ->
317319
objectDiffusionOutbound
318320
(contramap (TraceLabelPeer peer) (Node.certDiffusionOutboundTracer tracers))
319-
(certDiffusionMaxUnacked miniProtocolParameters)
321+
(perasCertDiffusionMaxFifoLength miniProtocolParameters)
320322
(makePerasCertPoolReaderFromChainDB $ getChainDB)
321323
version
322324
controlMessageSTM

0 commit comments

Comments
 (0)