Safe Haskell	Safe-Inferred
Language	Haskell2010

Ouroboros.Network.Diffusion.Common

Synopsis

data DiffusionTracer ntnAddr ntcAddr
- = RunServer (NonEmpty ntnAddr)
- | RunLocalServer ntcAddr
- | UsingSystemdSocket ntcAddr
- | CreateSystemdSocketForSnocketPath ntcAddr
- | CreatedLocalSocket ntcAddr
- | ConfiguringLocalSocket ntcAddr FileDescriptor
- | ListeningLocalSocket ntcAddr FileDescriptor
- | LocalSocketUp ntcAddr FileDescriptor
- | CreatingServerSocket ntnAddr
- | ConfiguringServerSocket ntnAddr
- | ListeningServerSocket ntnAddr
- | ServerSocketUp ntnAddr
- | UnsupportedLocalSystemdSocket ntnAddr
- | UnsupportedReadySocketCase
- | DiffusionErrored SomeException
- | SystemdSocketConfiguration SystemdSocketTracer
data Failure where
- UnsupportedReadySocket ∷ Failure
- UnexpectedIPv4Address ∷ ∀ ntnAddr. (Show ntnAddr, Typeable ntnAddr) ⇒ ntnAddr → Failure
- UnexpectedIPv6Address ∷ ∀ ntnAddr. (Show ntnAddr, Typeable ntnAddr) ⇒ ntnAddr → Failure
- NoSocket ∷ Failure
- DiffusionError ∷ SomeException → Failure
data Tracers ntnAddr ntnVersion ntcAddr ntcVersion m = Tracers {
- dtMuxTracer ∷ Tracer m (WithMuxBearer (ConnectionId ntnAddr) MuxTrace)
- dtHandshakeTracer ∷ Tracer m (HandshakeTr ntnAddr ntnVersion)
- dtLocalMuxTracer ∷ Tracer m (WithMuxBearer (ConnectionId ntcAddr) MuxTrace)
- dtLocalHandshakeTracer ∷ Tracer m (HandshakeTr ntcAddr ntcVersion)
- dtDiffusionTracer ∷ Tracer m (DiffusionTracer ntnAddr ntcAddr)
}
nullTracers ∷ Applicative m ⇒ Tracers ntnAddr ntnVersion ntcAddr ntcVersion m
data Arguments m ntnFd ntnAddr ntcFd ntcAddr = Arguments {
- daIPv4Address ∷ Maybe (Either ntnFd ntnAddr)
- daIPv6Address ∷ Maybe (Either ntnFd ntnAddr)
- daLocalAddress ∷ Maybe (Either ntcFd ntcAddr)
- daAcceptedConnectionsLimit ∷ AcceptedConnectionsLimit
- daMode ∷ DiffusionMode
- daPublicPeerSelectionVar ∷ StrictTVar m (PublicPeerSelectionState ntnAddr)
}
data Applications ntnAddr ntnVersion ntnVersionData ntcAddr ntcVersion ntcVersionData m a = Applications {
- daApplicationInitiatorMode ∷ Versions ntnVersion ntnVersionData (OuroborosBundleWithExpandedCtx InitiatorMode ntnAddr ByteString m a Void)
- daApplicationInitiatorResponderMode ∷ Versions ntnVersion ntnVersionData (OuroborosBundleWithExpandedCtx InitiatorResponderMode ntnAddr ByteString m a ())
- daLocalResponderApplication ∷ Versions ntcVersion ntcVersionData (OuroborosApplicationWithMinimalCtx ResponderMode ntcAddr ByteString m Void ())
- daLedgerPeersCtx ∷ LedgerPeersConsensusInterface m
- daUpdateOutboundConnectionsState ∷ OutboundConnectionsState → STM m ()
}

Documentation

data DiffusionTracer ntnAddr ntcAddr Source #

The DiffusionTracer logs

diffusion initialisation messages
terminal errors thrown by diffusion

Constructors

RunServer (NonEmpty ntnAddr)
RunLocalServer ntcAddr
UsingSystemdSocket ntcAddr
CreateSystemdSocketForSnocketPath ntcAddr
CreatedLocalSocket ntcAddr
ConfiguringLocalSocket ntcAddr FileDescriptor
ListeningLocalSocket ntcAddr FileDescriptor
LocalSocketUp ntcAddr FileDescriptor
CreatingServerSocket ntnAddr
ConfiguringServerSocket ntnAddr
ListeningServerSocket ntnAddr
ServerSocketUp ntnAddr
UnsupportedLocalSystemdSocket ntnAddr
UnsupportedReadySocketCase
DiffusionErrored SomeException
SystemdSocketConfiguration SystemdSocketTracer

Instances

Instances details

(Show ntcAddr, Show ntnAddr) ⇒ Show (DiffusionTracer ntnAddr ntcAddr) Source #
Instance details Defined in Ouroboros.Network.Diffusion.Common Methods showsPrec ∷ Int → DiffusionTracer ntnAddr ntcAddr → ShowS # show ∷ DiffusionTracer ntnAddr ntcAddr → String # showList ∷ [DiffusionTracer ntnAddr ntcAddr] → ShowS #

data Failure where Source #

Constructors

UnsupportedReadySocket ∷ Failure
UnexpectedIPv4Address ∷ ∀ ntnAddr. (Show ntnAddr, Typeable ntnAddr) ⇒ ntnAddr → Failure
UnexpectedIPv6Address ∷ ∀ ntnAddr. (Show ntnAddr, Typeable ntnAddr) ⇒ ntnAddr → Failure
NoSocket ∷ Failure
DiffusionError ∷ SomeException → Failure

Instances

Instances details

Exception Failure Source #
Instance details Defined in Ouroboros.Network.Diffusion.Common Methods toException ∷ Failure → SomeException # fromException ∷ SomeException → Maybe Failure # displayException ∷ Failure → String #
Show Failure Source #
Instance details Defined in Ouroboros.Network.Diffusion.Common Methods showsPrec ∷ Int → Failure → ShowS # show ∷ Failure → String # showList ∷ [Failure] → ShowS #

data Tracers ntnAddr ntnVersion ntcAddr ntcVersion m Source #

Common DiffusionTracers interface between P2P and NonP2P

Constructors

Tracers

Fields

dtMuxTracer ∷ Tracer m (WithMuxBearer (ConnectionId ntnAddr) MuxTrace)
Mux tracer
dtHandshakeTracer ∷ Tracer m (HandshakeTr ntnAddr ntnVersion)
Handshake protocol tracer
dtLocalMuxTracer ∷ Tracer m (WithMuxBearer (ConnectionId ntcAddr) MuxTrace)
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

nullTracers ∷ Applicative m ⇒ Tracers ntnAddr ntnVersion ntcAddr ntcVersion m Source #

data Arguments m ntnFd ntnAddr ntcFd ntcAddr Source #

Common DiffusionArguments interface between P2P and NonP2P

Constructors

Arguments

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

data Applications ntnAddr ntnVersion ntnVersionData ntcAddr ntcVersion ntcVersionData m a Source #

Versioned mini-protocol bundles run on a negotiated connection.

Constructors

Applications

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.
Even in non-p2p mode we use p2p apps.
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.
daLedgerPeersCtx ∷ LedgerPeersConsensusInterface m
Interface used to get peers from the current ledger.
TODO: it should be in InterfaceExtra
daUpdateOutboundConnectionsState ∷ OutboundConnectionsState → STM m ()
Callback provided by consensus to inform it if the node is connected to only local roots or also some external peers.
This is useful in order for the Bootstrap State Machine to simply refuse to transition from TooOld to YoungEnough while it only has local peers.