Fields

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

  Mux tracer

• dtChannelTracer :: Tracer m (WithBearer (ConnectionId ntnAddr) ChannelTrace)

  Mux's channel tracer

• dtBearerTracer :: Tracer m (WithBearer (ConnectionId ntnAddr) BearerTrace)

  Bearer tracer

• dtHandshakeTracer :: Tracer m (WithBearer (ConnectionId ntnAddr) (TraceSendRecv (Handshake ntnVersion Term)))

  Handshake protocol tracer

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

  Mux tracer for local clients

• dtLocalChannelTracer :: Tracer m (WithBearer (ConnectionId ntcAddr) ChannelTrace)

  Mux's channel tracer for local clients

• dtLocalBearerTracer :: Tracer m (WithBearer (ConnectionId ntcAddr) BearerTrace)

  Bearer tracer for local clients

• dtLocalHandshakeTracer :: Tracer m (WithBearer (ConnectionId ntcAddr) (TraceSendRecv (Handshake ntcVersion Term)))

  Handshake protocol tracer for local clients

• dtDiffusionTracer :: Tracer m (DiffusionTracer ntnAddr ntcAddr)

  Diffusion initialisation tracer

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

  Ledger Peers tracer

• dtTracePeerSelectionTracer :: Tracer m (TracePeerSelection extraDebugState extraFlags extraPeers extraTrace 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)
   
• dtDnsTracer :: Tracer m DNSTrace
   
• 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

• dcIPv4Address :: Maybe (Either ntnFd ntnAddr)

  an IPv4 socket ready to accept connections or an IPv4 addresses

• dcIPv6Address :: Maybe (Either ntnFd ntnAddr)

  an IPv6 socket ready to accept connections or an IPv6 addresses

• dcLocalAddress :: Maybe (Either ntcFd ntcAddr)

  an AF_UNIX socket ready to accept connections or an AF_UNIX socket path or name of `named-pipe` on Windows.

  Windows Named Pipes Names of named-pipes must follow https://learn.microsoft.com/en-us/windows/win32/ipc/pipe-names, in particular:

  • It must be well formed, e.g. \.pipePipeName
  • The pipe name string specified by PipeName can include any character other than a backslash, including numbers and special characters.
  • The entire pipe name string can be up to 256 characters long. Pipe names are not case-sensitive.
  • PipeName has to include an app name to avoid clashes with other applications, e.g. cardano-node-mainnet.
  • PipeName should be different for different parallel-installable instances, e.g. mainnet vs testnet.
  • default file permissions should be right: it will be accessible to the same user.
• dcAcceptedConnectionsLimit :: AcceptedConnectionsLimit

  parameters for limiting number of accepted connections

• dcMode :: DiffusionMode

  run in initiator only mode

• dcPublicPeerSelectionVar :: 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).

• dcPeerSelectionTargets :: PeerSelectionTargets

  selection targets for the peer governor

• dcReadLocalRootPeers :: STM m (Config extraFlags RelayAccessPoint)
   
• dcReadPublicRootPeers :: STM m (Map RelayAccessPoint PeerAdvertise)
   
• dcReadLedgerPeerSnapshot :: 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.

• dcReadUseLedgerPeers :: STM m UseLedgerPeers

  UseLedgerPeers from topology file.

• dcPeerSharing :: PeerSharing

  Peer's own PeerSharing value.

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

• dcProtocolIdleTimeout :: 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.

• dcTimeWaitTimeout :: 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.

• dcDeadlineChurnInterval :: 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.

• dcBulkChurnInterval :: 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.

• dcMuxForkPolicy :: ForkPolicy ntnAddr

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

• dcLocalMuxForkPolicy :: ForkPolicy ntcAddr

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

• dcEgressPollInterval :: DiffTime

  Mux egress queue's poll interval

Fields

• daApplicationInitiatorMode :: Versions ntnVersion ntnVersionData (OuroborosBundleWithExpandedCtx 'InitiatorMode ntnAddr ByteString m a Void)

  NodeToNode initiator applications for initiator only mode.

  TODO: we should accept one or the other, but not both: daApplicationInitiatorMode, daApplicationInitiatorResponderMode.

• daApplicationInitiatorResponderMode :: Versions ntnVersion ntnVersionData (OuroborosBundleWithExpandedCtx 'InitiatorResponderMode ntnAddr ByteString m a ())

  NodeToNode initiator & responder applications for bidirectional mode.

• daLocalResponderApplication :: Versions ntcVersion ntcVersionData (OuroborosApplicationWithMinimalCtx 'ResponderMode ntcAddr ByteString m Void ())

  NodeToClient responder application (server role)

  Because p2p mode does not infect local connections we we use non-p2p apps.

• daRethrowPolicy :: RethrowPolicy

  node-to-node rethrow policy.

  TODO: should it be part of ExitPolicy?

• daReturnPolicy :: ReturnPolicy a

  node-to-node return policy

  Internally packed into ExitPolicy record.

• daRepromoteErrorDelay :: RepromoteDelay

  node-to-node error delay.

  Internally packed into ExitPolicy record.

• daLocalRethrowPolicy :: RethrowPolicy

  node-to-client rethrow policy

• daPeerSelectionPolicy :: PeerSelectionPolicy ntnAddr m

  PeerSelectionPolicy used by the outbound governor to pick peers to promote/demote ((see simplePeerSelectionPolicy).

• daPeerSharingRegistry :: PeerSharingRegistry ntnAddr m

  Used for peer sharing protocol

Fields

• daNtnDataFlow :: ntnVersionData -> DataFlow

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

• daNtnPeerSharing :: ntnVersionData -> PeerSharing

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

• daUpdateVersionData :: ntnVersionData -> DiffusionMode -> ntnVersionData

  Update ntnVersionData for initiator-only local roots.

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

  node-to-node handshake configuration

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

  node-to-client handshake configuration

• daLedgerPeersCtx :: LedgerPeersConsensusInterface extraAPI m

  Interface used to get peers from the current ledger.

• daEmptyExtraState :: extraState

  Extra State empty value

• daEmptyExtraCounters :: extraCounters

  Extra Counters empty value

• daExtraPeersAPI :: PublicExtraPeersAPI extraPeers ntnAddr

  Provide Public Extra Actions for extraPeers to be

• daInstallSigUSR1Handler :: 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)) -> m ()

  callback which is used to register SIGUSR1 signal handler.

• daPeerSelectionGovernorArgs :: forall (muxMode :: Mode) responderCtx bytes a b. PeerSelectionGovernorArgs extraState extraDebugState extraFlags extraPeers extraAPI extraCounters extraTrace ntnAddr (PeerConnectionHandle muxMode responderCtx ntnAddr ntnVersionData bytes m a b) exception m
   
• daPeerSelectionStateToExtraCounters :: forall (muxMode :: Mode) responderCtx 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 m -> DNSSemaphore m -> (Map ntnAddr PeerAdvertise -> extraPeers) -> (NumberOfPeers -> LedgerPeersKind -> m (Maybe (Set ntnAddr, DiffTime))) -> LedgerPeersKind -> StdGen -> 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 extraTrace 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

• daSRVPrefix :: SRVPrefix

  SRV Prefix, as defined in CIP#0155

Fields

• diNtnSnocket :: Snocket m ntnFd ntnAddr

  node-to-node snocket

• diNtnBearer :: MakeBearer m ntnFd

  node-to-node MakeBearer callback

• diWithBuffer :: (Maybe (ReadBuffer m) -> m ()) -> m ()

  readbuffer

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

  node-to-node socket configuration

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

  node-to-node systemd socket configuration

• diNtnAddressType :: ntnAddr -> Maybe AddressType

  node-to-node address type

• 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

• 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.

• diDnsActions :: Tracer m DNSTrace -> DNSLookupType -> (IP -> PortNumber -> ntnAddr) -> DNSActions ntnAddr resolver m

  diffusion dns actions

• diConnStateIdSupply :: ConnStateIdSupply m

  ConnStateIdSupply used by the connection-manager for this node.

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