Fields

• dtMuxTracer :: Tracer m (WithBearer (ConnectionId ntnAddr) Trace)

  Mux tracer

• dtHandshakeTracer :: Tracer m (HandshakeTr ntnAddr ntnVersion)

  Handshake protocol tracer

• dtLocalMuxTracer :: Tracer m (WithBearer (ConnectionId ntcAddr) Trace)

  Mux tracer for local clients

• dtLocalHandshakeTracer :: Tracer m (HandshakeTr ntcAddr ntcVersion)

  Handshake protocol tracer for local clients

• dtDiffusionTracer :: Tracer m (DiffusionTracer ntnAddr ntcAddr)

  Diffusion initialisation tracer

• dtTraceLocalRootPeersTracer :: Tracer m (TraceLocalRootPeers extraFlags ntnAddr resolverError)
   
• dtTracePublicRootPeersTracer :: Tracer m TracePublicRootPeers
   
• dtTraceLedgerPeersTracer :: Tracer m TraceLedgerPeers

  Ledger Peers tracer

• dtTracePeerSelectionTracer :: Tracer m (TracePeerSelection extraDebugState extraFlags extraPeers ntnAddr)
   
• dtDebugPeerSelectionInitiatorTracer :: Tracer m (DebugPeerSelection extraState extraFlags extraPeers ntnAddr)
   
• dtDebugPeerSelectionInitiatorResponderTracer :: Tracer m (DebugPeerSelection extraState extraFlags extraPeers ntnAddr)
   
• dtTracePeerSelectionCounters :: Tracer m (PeerSelectionCounters extraCounters)
   
• dtTraceChurnCounters :: Tracer m ChurnCounters
   
• dtPeerSelectionActionsTracer :: Tracer m (PeerSelectionActionsTrace ntnAddr ntnVersion)
   
• dtConnectionManagerTracer :: Tracer m (Trace ntnAddr (ConnectionHandlerTrace ntnVersion ntnVersionData))
   
• dtConnectionManagerTransitionTracer :: Tracer m (AbstractTransitionTrace ConnStateId)
   
• dtServerTracer :: Tracer m (Trace ntnAddr)
   
• dtInboundGovernorTracer :: Tracer m (Trace ntnAddr)
   
• dtInboundGovernorTransitionTracer :: Tracer m (RemoteTransitionTrace ntnAddr)
   
• dtLocalConnectionManagerTracer :: Tracer m (Trace ntcAddr (ConnectionHandlerTrace ntcVersion ntcVersionData))

  Connection manager tracer for local clients

• dtLocalServerTracer :: Tracer m (Trace ntcAddr)

  Server tracer for local clients

• dtLocalInboundGovernorTracer :: Tracer m (Trace ntcAddr)

  Inbound protocol governor tracer for local clients

Fields

• daIPv4Address :: Maybe (Either ntnFd ntnAddr)

  an IPv4 socket ready to accept connections or an IPv4 addresses

• daIPv6Address :: Maybe (Either ntnFd ntnAddr)

  an IPv6 socket ready to accept connections or an IPv6 addresses

• daLocalAddress :: Maybe (Either ntcFd ntcAddr)

  an AF_UNIX socket ready to accept connections or an AF_UNIX socket path

• daAcceptedConnectionsLimit :: AcceptedConnectionsLimit

  parameters for limiting number of accepted connections

• daMode :: DiffusionMode

  run in initiator only mode

• daPublicPeerSelectionVar :: StrictTVar m (PublicPeerSelectionState ntnAddr)

  public peer selection state

  It is created outside of diffusion, since it is needed to create some apps (e.g. peer sharing).

• daPeerSelectionTargets :: PeerSelectionTargets

  selection targets for the peer governor

• daReadLocalRootPeers :: STM m (Config extraFlags RelayAccessPoint)
   
• daReadPublicRootPeers :: STM m (Map RelayAccessPoint PeerAdvertise)
   
• daReadLedgerPeerSnapshot :: STM m (Maybe LedgerPeerSnapshot)

  Depending on configuration, node may provide us with a snapshot of big ledger peers taken at some slot on the chain. These peers may be selected by ledgerPeersThread when requested by the peer selection governor when the node is syncing up. This is especially useful for Genesis consensus mode.

• daOwnPeerSharing :: PeerSharing

  Peer's own PeerSharing value.

  This value comes from the node's configuration file and is static.

• daReadUseLedgerPeers :: STM m UseLedgerPeers
   
• daProtocolIdleTimeout :: DiffTime

  Timeout which starts once all responder protocols are idle. If the responders stay idle for duration of the timeout, the connection will be demoted, if it wasn't used by the p2p-governor it will be closed.

  Applies to Unidirectional as well as Duplex node-to-node connections.

  See serverProtocolIdleTimeout.

• daTimeWaitTimeout :: DiffTime

  Time for which node-to-node connections are kept in TerminatingState, it should correspond to the OS configured TCP TIME_WAIT timeout.

  This timeout will apply to after a connection has been closed, its purpose is to be resilient for delayed packets in the same way TCP is using TIME_WAIT.

• daDeadlineChurnInterval :: DiffTime

  Churn interval between churn events in deadline mode. A small fuzz is added (max 10 minutes) so that not all nodes churn at the same time.

  By default it is set to 3300 seconds.

• daBulkChurnInterval :: DiffTime

  Churn interval between churn events in bulk sync mode. A small fuzz is added (max 1 minute) so that not all nodes churn at the same time.

  By default it is set to 300 seconds.

• daEmptyExtraState :: extraState

  Extra State empty value

• daEmptyExtraCounters :: extraCounters

  Extra Counters empty value

• daExtraPeersAPI :: PublicExtraPeersAPI extraPeers ntnAddr

  Provide Public Extra Actions for extraPeers to be

• daPeerSelectionGovernorArgs :: forall (muxMode :: Mode) responderCtx ntnVersionData bytes a b. PeerSelectionGovernorArgs extraState extraDebugState extraFlags extraPeers extraAPI extraCounters ntnAddr (PeerConnectionHandle muxMode responderCtx ntnAddr ntnVersionData bytes m a b) exception m
   
• daPeerSelectionStateToExtraCounters :: forall (muxMode :: Mode) responderCtx ntnVersionData bytes a b. PeerSelectionState extraState extraFlags extraPeers ntnAddr (PeerConnectionHandle muxMode responderCtx ntnAddr ntnVersionData bytes m a b) -> extraCounters

  Function that computes extraCounters from PeerSelectionState

• daToExtraPeers :: Map ntnAddr PeerAdvertise -> extraPeers

  Function that constructs a extraPeers set from a map of dns lookup results.

• daRequestPublicRootPeers :: Maybe (PeerActionsDNS ntnAddr resolver resolverError m -> DNSSemaphore m -> (Map ntnAddr PeerAdvertise -> extraPeers) -> (NumberOfPeers -> LedgerPeersKind -> m (Maybe (Set ntnAddr, DiffTime))) -> LedgerPeersKind -> Int -> m (PublicRootPeers extraPeers ntnAddr, DiffTime))

  Request Public Root Peers.

  If no custom public root peers is provided (i.e. Nothing) just the default one from getPublicRootPeers

• daPeerChurnGovernor :: PeerChurnArgs m extraChurnArgs extraDebugState extraFlags extraPeers extraAPI extraCounters ntnAddr -> m Void

  Peer Churn Governor if no custom churn governor is required just use the default one from peerChurnGovernor

• daExtraChurnArgs :: extraChurnArgs

  Provide extraChurnArgs to be passed to churn governor

• daMuxForkPolicy :: ForkPolicy ntnAddr

  A fork policy for node-to-node mini-protocol threads spawn by mux.

• daLocalMuxForkPolicy :: ForkPolicy ntcAddr

  A fork policy for node-to-client mini-protocols threads spawn by mux.

Fields

• diNtnSnocket :: Snocket m ntnFd ntnAddr

  node-to-node snocket

• diNtnBearer :: MakeBearer m ntnFd

  node-to-node MakeBearer callback

• diNtnConfigureSocket :: ntnFd -> Maybe ntnAddr -> m ()

  node-to-node socket configuration

• diNtnConfigureSystemdSocket :: ntnFd -> ntnAddr -> m ()

  node-to-node systemd socket configuration

• diNtnHandshakeArguments :: HandshakeArguments (ConnectionId ntnAddr) ntnVersion ntnVersionData m

  node-to-node handshake configuration

• diNtnAddressType :: ntnAddr -> Maybe AddressType

  node-to-node address type

• diNtnDataFlow :: ntnVersionData -> DataFlow

  node-to-node data flow used by connection manager to classify negotiated connections

• diNtnPeerSharing :: ntnVersionData -> PeerSharing

  remote side peer sharing information used by peer selection governor to decide which peers are available for performing peer sharing

• diNtnToPeerAddr :: IP -> PortNumber -> ntnAddr

  node-to-node peer address

• diNtcSnocket :: Snocket m ntcFd ntcAddr

  node-to-client snocket

• diNtcBearer :: MakeBearer m ntcFd

  node-to-client MakeBearer callback

• diNtcHandshakeArguments :: HandshakeArguments (ConnectionId ntcAddr) ntcVersion ntcVersionData m

  node-to-client handshake configuration

• diNtcGetFileDescriptor :: ntcFd -> m FileDescriptor

  node-to-client file descriptor

• diRng :: StdGen

  diffusion pseudo random generator. It is split between various components that need randomness, e.g. inbound governor, peer selection, policies, etc.

• diInstallSigUSR1Handler :: forall (mode :: Mode) x y. NodeToNodeConnectionManager mode ntnFd ntnAddr ntnVersionData ntnVersion m x y -> StrictTVar m (PeerSelectionState extraState extraFlags extraPeers ntnAddr (NodeToNodePeerConnectionHandle mode ntnAddr ntnVersionData m x y)) -> PeerMetrics m ntnAddr -> m ()

  callback which is used to register SIGUSR1 signal handler.

• diDnsActions :: DNSLookupType -> DNSActions resolver resolverError m

  diffusion dns actions

• diUpdateVersionData :: ntnVersionData -> DiffusionMode -> ntnVersionData

  Update ntnVersionData for initiator-only local roots.

• diConnStateIdSupply :: ConnStateIdSupply m

  ConnStateIdSupply used by the connection-manager for this node.

  This is exposed for testing, where we use a global ConnStateIdSupply.