Safe Haskell	Safe-Inferred
Language	Haskell2010

Ouroboros.Network.ConnectionManager.InformationChannel

Synopsis

data InformationChannel a m = InformationChannel {
- readMessage ∷ STM m a
- writeMessage ∷ a → STM m ()
}
type InboundGovernorInfoChannel (muxMode ∷ MuxMode) initiatorCtx peerAddr versionData bytes m a b = InformationChannel (NewConnectionInfo peerAddr (Handle muxMode initiatorCtx (ResponderContext peerAddr) versionData bytes m a b)) m
type OutboundGovernorInfoChannel peerAddr m = InformationChannel (peerAddr, PeerSharing) m
newInformationChannel ∷ ∀ a m. MonadLabelledSTM m ⇒ m (InformationChannel a m)
cc_QUEUE_BOUND ∷ Natural

Documentation

data InformationChannel a m Source #

Information channel.

Constructors

InformationChannel
Fields readMessage ∷ STM m a Read a single value from the channel. writeMessage ∷ a → STM m () Write a value to the channel.

type InboundGovernorInfoChannel (muxMode ∷ MuxMode) initiatorCtx peerAddr versionData bytes m a b = InformationChannel (NewConnectionInfo peerAddr (Handle muxMode initiatorCtx (ResponderContext peerAddr) versionData bytes m a b)) m Source #

A Server control channel which instantiates to NewConnection and Handle.

It allows to pass STM transactions which will resolve to NewConnection. Server's monitoring thread is the consumer of these messages; there are two producers: accept loop and connection handler for outbound connections.

type OutboundGovernorInfoChannel peerAddr m = InformationChannel (peerAddr, PeerSharing) m Source #

Control Channel between Server and Outbound Governor.

Control channel that is meant to share inbound connections with the Peer Selection Governor. So the consumer is the Governor and Producer is the Server.

newInformationChannel ∷ ∀ a m. MonadLabelledSTM m ⇒ m (InformationChannel a m) Source #

cc_QUEUE_BOUND ∷ Natural Source #

The InformationChannels TBQueue depth.