Safe Haskell	None
Language	Haskell2010

Ouroboros.Network.InboundGovernor.State

Contents

Internals

Synopsis

data PublicInboundGovernorState peerAddr versionData = PublicInboundGovernorState {
- inboundDuplexPeers :: !(Map peerAddr versionData)
- remoteStateMap :: Map (ConnectionId peerAddr) RemoteSt
}
mkPublicInboundGovernorState :: forall (muxMode :: MuxMode) initatorCtx versionData peerAddr (m :: Type -> Type) a b. InboundGovernorState muxMode initatorCtx peerAddr versionData m a b -> PublicInboundGovernorState peerAddr versionData
data InboundGovernorState (muxMode :: MuxMode) initiatorCtx peerAddr versionData (m :: Type -> Type) a b = InboundGovernorState {
- igsConnections :: !(Map (ConnectionId peerAddr) (ConnectionState muxMode initiatorCtx peerAddr versionData m a b))
- igsMatureDuplexPeers :: !(Map peerAddr versionData)
- igsFreshDuplexPeers :: !(OrdPSQ peerAddr Time versionData)
- igsCountersCache :: !(Cache InboundGovernorCounters)
}
data ConnectionState (muxMode :: MuxMode) initiatorCtx peerAddr versionData (m :: Type -> Type) a b = ConnectionState {
- csMux :: !(Mux muxMode m)
- csDataFlow :: !DataFlow
- csVersionData :: !versionData
- csMiniProtocolMap :: !(Map MiniProtocolNum (MiniProtocolData muxMode initiatorCtx peerAddr m a b))
- csCompletionMap :: !(Map MiniProtocolNum (STM m (Either SomeException b)))
- csRemoteState :: !(RemoteState m)
}
data InboundGovernorCounters = InboundGovernorCounters {
- coldPeersRemote :: !Int
- idlePeersRemote :: !Int
- warmPeersRemote :: !Int
- hotPeersRemote :: !Int
}
inboundGovernorCounters :: forall (muxMode :: MuxMode) initiatorCtx peerAddr versionData (m :: Type -> Type) a b. InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b -> InboundGovernorCounters
unregisterConnection :: forall peerAddr (muxMode :: MuxMode) initiatorCtx versionData (m :: Type -> Type) a b. Ord peerAddr => ConnectionId peerAddr -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b
updateMiniProtocol :: forall peerAddr (m :: Type -> Type) b (muxMode :: MuxMode) initiatorCtx versionData a. Ord peerAddr => ConnectionId peerAddr -> MiniProtocolNum -> STM m (Either SomeException b) -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b
data RemoteState (m :: Type -> Type) where
- RemoteWarm
- RemoteHot
- RemoteIdle !(STM m ())
- RemoteCold
- pattern RemoteEstablished :: RemoteState m
data RemoteSt
- = RemoteWarmSt
- | RemoteHotSt
- | RemoteIdleSt
- | RemoteColdSt
mkRemoteSt :: forall (m :: Type -> Type). RemoteState m -> RemoteSt
updateRemoteState :: forall peerAddr (m :: Type -> Type) (muxMode :: MuxMode) initiatorCtx versionData a b. Ord peerAddr => ConnectionId peerAddr -> RemoteState m -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b
mapRemoteState :: forall peerAddr (m :: Type -> Type) (muxMode :: MuxMode) initiatorCtx versionData a b. Ord peerAddr => ConnectionId peerAddr -> (RemoteState m -> RemoteState m) -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b
data MiniProtocolData (muxMode :: MuxMode) initiatorCtx peerAddr (m :: Type -> Type) a b = MiniProtocolData {
- mpdMiniProtocol :: !(MiniProtocol muxMode initiatorCtx (ResponderContext peerAddr) ByteString m a b)
- mpdResponderContext :: !(ResponderContext peerAddr)
- mpdMiniProtocolTemp :: !ProtocolTemperature
}

Documentation

data PublicInboundGovernorState peerAddr versionData Source #

Public inbound governor state.

Constructors

PublicInboundGovernorState
Fields inboundDuplexPeers :: !(Map peerAddr versionData) A map of mature inbound duplex connections. These peers are used for light peer sharing (e.g. bootstrapping peer sharing). remoteStateMap :: Map (ConnectionId peerAddr) RemoteSt Map of `RemoteSt`. It is lazy on purpose. It is created from `igsConnections`, so it should not point to any thunks that should be GC-ed leading to a memory leak.

Internals

mkPublicInboundGovernorState :: forall (muxMode :: MuxMode) initatorCtx versionData peerAddr (m :: Type -> Type) a b. InboundGovernorState muxMode initatorCtx peerAddr versionData m a b -> PublicInboundGovernorState peerAddr versionData Source #

Smart constructor for PublicInboundGovernorState.

NOTE: we assume that all inbound connections share the same address. This is true in P2P mode since all outbound connections (which also can end up in the InboundGovernorState) bind the server address. This allows us to use mapKeysMonotonic.

data InboundGovernorState (muxMode :: MuxMode) initiatorCtx peerAddr versionData (m :: Type -> Type) a b Source #

InboundGovernorState, which consist of pure part, and a mutable part. The mutable part can be observable from outside. Future version could contain additional statistics on the peers.

Constructors

InboundGovernorState

Fields

igsConnections :: !(Map (ConnectionId peerAddr) (ConnectionState muxMode initiatorCtx peerAddr versionData m a b))
Map of connections state. Modifying igsConnections outside of inboundGovernorLoop is not safe.
igsMatureDuplexPeers :: !(Map peerAddr versionData)
Map of mature duplex peers.
We don't add new duplex connections immediately, but only after a 15mins delay (defined in inboundMaturePeerDelay.
igsFreshDuplexPeers :: !(OrdPSQ peerAddr Time versionData)
Queue of fresh duplex connections ordered by time of arrival. Only connections younger than than 15mins are kept in this data structure.
igsCountersCache :: !(Cache InboundGovernorCounters)
InboundGovernorCounters counters cache. Allows to only trace values when necessary.

data ConnectionState (muxMode :: MuxMode) initiatorCtx peerAddr versionData (m :: Type -> Type) a b Source #

Per connection state tracked by inbound protocol governor.

Constructors

ConnectionState

Fields

csMux :: !(Mux muxMode m)
Mux interface.
csDataFlow :: !DataFlow
Connection data flow.
TODO: once we will be able able to compute DataFlow from versionData, e.g. the oldest supported version is greater than NodeToNodeV_10, we will no longer need this field.
csVersionData :: !versionData
version data negotiated on the connection.
csMiniProtocolMap :: !(Map MiniProtocolNum (MiniProtocolData muxMode initiatorCtx peerAddr m a b))
All supported mini-protocols and respective ProtocolTemperature
csCompletionMap :: !(Map MiniProtocolNum (STM m (Either SomeException b)))
Map of all running mini-protocol completion STM actions.
csRemoteState :: !(RemoteState m)
State of the connection.

data InboundGovernorCounters Source #

Counters for tracing and analysis purposes

Constructors

InboundGovernorCounters

Fields

coldPeersRemote :: !Int
the number of remote peers which are in RemoteCold state
idlePeersRemote :: !Int
the number of remote peers which are in RemoteIdle state
warmPeersRemote :: !Int
the number of remote peers which are in RemoteWarm state (a close approximation of peers that have the node as a warm peer)
hotPeersRemote :: !Int
the number of remote peers which are in RemoteHot state (a close approximation of peers that have the node as a hot peer)

Instances

Instances details

Monoid InboundGovernorCounters Source #
Instance details Defined in Ouroboros.Network.InboundGovernor.State Methods mempty :: InboundGovernorCounters # mappend :: InboundGovernorCounters -> InboundGovernorCounters -> InboundGovernorCounters # mconcat :: [InboundGovernorCounters] -> InboundGovernorCounters #
Semigroup InboundGovernorCounters Source #
Instance details Defined in Ouroboros.Network.InboundGovernor.State Methods (<>) :: InboundGovernorCounters -> InboundGovernorCounters -> InboundGovernorCounters # sconcat :: NonEmpty InboundGovernorCounters -> InboundGovernorCounters # stimes :: Integral b => b -> InboundGovernorCounters -> InboundGovernorCounters #
Show InboundGovernorCounters Source #
Instance details Defined in Ouroboros.Network.InboundGovernor.State Methods showsPrec :: Int -> InboundGovernorCounters -> ShowS # show :: InboundGovernorCounters -> String # showList :: [InboundGovernorCounters] -> ShowS #
Eq InboundGovernorCounters Source #
Instance details Defined in Ouroboros.Network.InboundGovernor.State Methods (==) :: InboundGovernorCounters -> InboundGovernorCounters -> Bool # (/=) :: InboundGovernorCounters -> InboundGovernorCounters -> Bool #
Ord InboundGovernorCounters Source #
Instance details Defined in Ouroboros.Network.InboundGovernor.State Methods compare :: InboundGovernorCounters -> InboundGovernorCounters -> Ordering # (<) :: InboundGovernorCounters -> InboundGovernorCounters -> Bool # (<=) :: InboundGovernorCounters -> InboundGovernorCounters -> Bool # (>) :: InboundGovernorCounters -> InboundGovernorCounters -> Bool # (>=) :: InboundGovernorCounters -> InboundGovernorCounters -> Bool # max :: InboundGovernorCounters -> InboundGovernorCounters -> InboundGovernorCounters # min :: InboundGovernorCounters -> InboundGovernorCounters -> InboundGovernorCounters #

inboundGovernorCounters :: forall (muxMode :: MuxMode) initiatorCtx peerAddr versionData (m :: Type -> Type) a b. InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b -> InboundGovernorCounters Source #

unregisterConnection :: forall peerAddr (muxMode :: MuxMode) initiatorCtx versionData (m :: Type -> Type) a b. Ord peerAddr => ConnectionId peerAddr -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b Source #

Remove connection from InboundGovernorState.

updateMiniProtocol :: forall peerAddr (m :: Type -> Type) b (muxMode :: MuxMode) initiatorCtx versionData a. Ord peerAddr => ConnectionId peerAddr -> MiniProtocolNum -> STM m (Either SomeException b) -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b Source #

Update a mini-protocol in ConnectionState. Once a mini-protocol was restarted we put the new completion action into csCompletionMap.

data RemoteState (m :: Type -> Type) Source #

Each inbound connection is either in RemoteIdle, RemoteCold or RemoteEstablished state. We only need to support PromotedToWarm^{Duplex}_{Remote}, DemotedToCold^{Duplex}_{Remote} and DemotedToCold^{Unidirectional}_{Remote} transitions.

Constructors

RemoteWarm	After `PromotedToWarm^{dataFlow}_{Remote}` a connection is in `RemoteWarm` state.
RemoteHot	In this state all established and hot mini-protocols are running and none of the warm mini-protocols is running.
RemoteIdle !(STM m ())	After `DemotedToCold^{dataFlow}_{Remote}` is detected. This state corresponds to `InboundIdleState`. In this state we are checking if the responder protocols are idle during protocol idle timeout (represented by an `STM` action) `RemoteIdle` is the initial state of an accepted a connection.
RemoteCold	The `RemoteCold` state for `Duplex` connections allows us to have responders started using the on-demand strategy. This assures that once the remote peer start using the connection the local side will be ready to serve it. For a `Duplex` connection: a `RemoteIdle` connection transitions to `RemoteCold` state after all responders being idle for `protocolIdleTimeout`. This triggers `unregisterInboundConnection`. For a `Unidreictional` connection: after all responders terminated.

Bundled Patterns

pattern RemoteEstablished :: RemoteState m

data RemoteSt Source #

Remote connection state tracked by inbound protocol governor.

This type is used for tracing.

Constructors

RemoteWarmSt
RemoteHotSt
RemoteIdleSt
RemoteColdSt

Instances

Instances details

Show RemoteSt Source #
Instance details Defined in Ouroboros.Network.InboundGovernor.State Methods showsPrec :: Int -> RemoteSt -> ShowS # show :: RemoteSt -> String # showList :: [RemoteSt] -> ShowS #
Eq RemoteSt Source #
Instance details Defined in Ouroboros.Network.InboundGovernor.State Methods (==) :: RemoteSt -> RemoteSt -> Bool # (/=) :: RemoteSt -> RemoteSt -> Bool #

mkRemoteSt :: forall (m :: Type -> Type). RemoteState m -> RemoteSt Source #

updateRemoteState :: forall peerAddr (m :: Type -> Type) (muxMode :: MuxMode) initiatorCtx versionData a b. Ord peerAddr => ConnectionId peerAddr -> RemoteState m -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b Source #

Set csRemoteState for a given connection.

mapRemoteState :: forall peerAddr (m :: Type -> Type) (muxMode :: MuxMode) initiatorCtx versionData a b. Ord peerAddr => ConnectionId peerAddr -> (RemoteState m -> RemoteState m) -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b -> InboundGovernorState muxMode initiatorCtx peerAddr versionData m a b Source #

data MiniProtocolData (muxMode :: MuxMode) initiatorCtx peerAddr (m :: Type -> Type) a b Source #

Constructors

MiniProtocolData
Fields mpdMiniProtocol :: !(MiniProtocol muxMode initiatorCtx (ResponderContext peerAddr) ByteString m a b) Static `MiniProtocol` description. mpdResponderContext :: !(ResponderContext peerAddr) mpdMiniProtocolTemp :: !ProtocolTemperature Static mini-protocol temperature.