Safe Haskell	None
Language	Haskell2010

Simulation.Network.Snocket

Contents

Simulated Snocket

Description

This module provides simulation environment and a snocket implementation suitable for IOSim .

Though this module is designed for simulation / testing, it lives in the library, since it is needed in `ouroboros-network-framework:test` and `ouroboros-network:test' components.

TODO: Create a snocket package, in order to avoid having to have ouroboros-network-testing as a dependency for this cabal library.

Synopsis

withSnocket :: forall m peerAddr a. ( MonadCatch m, MonadLabelledSTM m, MonadMask m, MonadTime m, MonadTimer m, MonadThrow ( STM m), GlobalAddressScheme peerAddr, Ord peerAddr, Typeable peerAddr, Show peerAddr) => Tracer m (WithAddr ( TestAddress peerAddr) ( SnocketTrace m ( TestAddress peerAddr))) -> BearerInfo -> Map (NormalisedId ( TestAddress peerAddr)) ( Script BearerInfo ) -> ( Snocket m ( FD m ( TestAddress peerAddr)) ( TestAddress peerAddr) -> m ( ObservableNetworkState ( TestAddress peerAddr)) -> m a) -> m a
newtype ObservableNetworkState addr = ObservableNetworkState {
- onsConnections :: Map (NormalisedId addr) addr
}
data ResourceException addr
- = NotReleasedListeningSockets [addr] ( Maybe SomeException )
- | NotReleasedConnections ( Map (NormalisedId addr) ConnectionState) ( Maybe SomeException )
data SDUSize
newtype Script a = Script ( NonEmpty a)
type Size = Int64
data SnocketTrace m addr
- = STConnecting (FD_ m addr) addr
- | STConnected (FD_ m addr) OpenType
- | STBearerInfo BearerInfo
- | STConnectError (FD_ m addr) addr IOError
- | STConnectTimeout TimeoutDetail
- | STBindError (FD_ m addr) addr IOError
- | STClosing SockType ( Wedge ( ConnectionId addr) [addr])
- | STClosed SockType ( Maybe ( Maybe ConnectionState))
- | STClosingQueue Bool
- | STClosedQueue Bool
- | STAcceptFailure SockType SomeException
- | STAccepting
- | STAccepted addr
- | STBearer (FD_ m addr)
- | STAttenuatedChannelTrace ( ConnectionId addr) AttenuatedChannelTrace
data SockType
- = ListeningSock
- | ConnectionSock
- | UnknownType
data OpenType
- = SimOpen
- | NormalOpen
normaliseId :: Ord addr => ConnectionId addr -> NormalisedId addr
data BearerInfo = BearerInfo {
- biConnectionDelay :: ! DiffTime
- biInboundAttenuation :: Time -> Size -> ( DiffTime , SuccessOrFailure )
- biOutboundAttenuation :: Time -> Size -> ( DiffTime , SuccessOrFailure )
- biInboundWriteFailure :: !( Maybe Int )
- biOutboundWriteFailure :: !( Maybe Int )
- biAcceptFailures :: !( Maybe ( DiffTime , IOErrType ))
- biSDUSize :: ! SDUSize
}
data IOErrType
- = IOErrConnectionAborted
- | IOErrResourceExhausted
data SuccessOrFailure
- = Success
- | Failure
data TimeoutDetail
- = WaitingToConnect
- | WaitingToBeAccepted
noAttenuation :: BearerInfo
data FD m peerAddr
class GlobalAddressScheme addr where
- getAddressType :: TestAddress addr -> AddressType
- ephemeralAddress :: AddressType -> Natural -> TestAddress addr
data AddressType
- = IPv4Address
- | IPv6Address

Simulated Snocket

withSnocket :: forall m peerAddr a. ( MonadCatch m, MonadLabelledSTM m, MonadMask m, MonadTime m, MonadTimer m, MonadThrow ( STM m), GlobalAddressScheme peerAddr, Ord peerAddr, Typeable peerAddr, Show peerAddr) => Tracer m (WithAddr ( TestAddress peerAddr) ( SnocketTrace m ( TestAddress peerAddr))) -> BearerInfo -> Map (NormalisedId ( TestAddress peerAddr)) ( Script BearerInfo ) -> ( Snocket m ( FD m ( TestAddress peerAddr)) ( TestAddress peerAddr) -> m ( ObservableNetworkState ( TestAddress peerAddr)) -> m a) -> m a Source #

A bracket which runs a network simulation. When the simulation terminates it verifies that all listening sockets and all connections are closed. It might throw ResourceException .

newtype ObservableNetworkState addr Source #

Simulation accessible network environment consumed by simSnocket .

Constructors

ObservableNetworkState
Fields onsConnections :: Map (NormalisedId addr) addr Registry of active connections and respective provider

Instances

Instances details

Show addr => Show ( ObservableNetworkState addr) Source #
Instance details Defined in Simulation.Network.Snocket Methods showsPrec :: Int -> ObservableNetworkState addr -> ShowS Source # show :: ObservableNetworkState addr -> String Source # showList :: [ ObservableNetworkState addr] -> ShowS Source #

data ResourceException addr Source #

Constructors

NotReleasedListeningSockets [addr] ( Maybe SomeException )
NotReleasedConnections ( Map (NormalisedId addr) ConnectionState) ( Maybe SomeException )

Instances

Instances details

Show addr => Show ( ResourceException addr) Source #
Instance details Defined in Simulation.Network.Snocket Methods showsPrec :: Int -> ResourceException addr -> ShowS Source # show :: ResourceException addr -> String Source # showList :: [ ResourceException addr] -> ShowS Source #
( Typeable addr, Show addr) => Exception ( ResourceException addr) Source #
Instance details Defined in Simulation.Network.Snocket Methods toException :: ResourceException addr -> SomeException Source # fromException :: SomeException -> Maybe ( ResourceException addr) Source # displayException :: ResourceException addr -> String Source #

data SDUSize Source #

Instances

Instances details

Show SDUSize
Instance details Defined in Network.Mux.Types Methods showsPrec :: Int -> SDUSize -> ShowS Source # show :: SDUSize -> String Source # showList :: [ SDUSize ] -> ShowS Source #
Generic SDUSize
Instance details Defined in Network.Mux.Types Associated Types type Rep SDUSize :: Type -> Type Source # Methods from :: SDUSize -> Rep SDUSize x Source # to :: Rep SDUSize x -> SDUSize Source #
type Rep SDUSize
Instance details Defined in Network.Mux.Types type Rep SDUSize = D1 (' MetaData "SDUSize" "Network.Mux.Types" "network-mux-0.1.0.1-7ZKx91o48G8EWFMuCmTsQc" ' True ) ( C1 (' MetaCons "SDUSize" ' PrefixI ' True ) ( S1 (' MetaSel (' Just "getSDUSize") ' NoSourceUnpackedness ' NoSourceStrictness ' DecidedLazy ) ( Rec0 Word16 )))

newtype Script a Source #

Constructors

Script ( NonEmpty a)

Instances

Instances details

Functor Script
Instance details Defined in Ouroboros.Network.Testing.Data.Script Methods fmap :: (a -> b) -> Script a -> Script b Source # (<$) :: a -> Script b -> Script a Source #
Foldable Script
Instance details Defined in Ouroboros.Network.Testing.Data.Script Methods fold :: Monoid m => Script m -> m Source # foldMap :: Monoid m => (a -> m) -> Script a -> m Source # foldMap' :: Monoid m => (a -> m) -> Script a -> m Source # foldr :: (a -> b -> b) -> b -> Script a -> b Source # foldr' :: (a -> b -> b) -> b -> Script a -> b Source # foldl :: (b -> a -> b) -> b -> Script a -> b Source # foldl' :: (b -> a -> b) -> b -> Script a -> b Source # foldr1 :: (a -> a -> a) -> Script a -> a Source # foldl1 :: (a -> a -> a) -> Script a -> a Source # toList :: Script a -> [a] Source # null :: Script a -> Bool Source # length :: Script a -> Int Source # elem :: Eq a => a -> Script a -> Bool Source # maximum :: Ord a => Script a -> a Source # minimum :: Ord a => Script a -> a Source # sum :: Num a => Script a -> a Source # product :: Num a => Script a -> a Source #
Traversable Script
Instance details Defined in Ouroboros.Network.Testing.Data.Script Methods traverse :: Applicative f => (a -> f b) -> Script a -> f ( Script b) Source # sequenceA :: Applicative f => Script (f a) -> f ( Script a) Source # mapM :: Monad m => (a -> m b) -> Script a -> m ( Script b) Source # sequence :: Monad m => Script (m a) -> m ( Script a) Source #
Eq a => Eq ( Script a)
Instance details Defined in Ouroboros.Network.Testing.Data.Script Methods (==) :: Script a -> Script a -> Bool Source # (/=) :: Script a -> Script a -> Bool Source #
Show a => Show ( Script a)
Instance details Defined in Ouroboros.Network.Testing.Data.Script Methods showsPrec :: Int -> Script a -> ShowS Source # show :: Script a -> String Source # showList :: [ Script a] -> ShowS Source #
Arbitrary a => Arbitrary ( Script a)
Instance details Defined in Ouroboros.Network.Testing.Data.Script Methods arbitrary :: Gen ( Script a) Source # shrink :: Script a -> [ Script a] Source #

type Size = Int64 Source #

data SnocketTrace m addr Source #

Constructors

STConnecting (FD_ m addr) addr
STConnected (FD_ m addr) OpenType
STBearerInfo BearerInfo
STConnectError (FD_ m addr) addr IOError
STConnectTimeout TimeoutDetail
STBindError (FD_ m addr) addr IOError
STClosing SockType ( Wedge ( ConnectionId addr) [addr])
STClosed SockType ( Maybe ( Maybe ConnectionState))	TODO: Document meaning of 'Maybe (Maybe OpenState)'
STClosingQueue Bool
STClosedQueue Bool
STAcceptFailure SockType SomeException
STAccepting
STAccepted addr
STBearer (FD_ m addr)
STAttenuatedChannelTrace ( ConnectionId addr) AttenuatedChannelTrace

Instances

Instances details

Show addr => Show ( SnocketTrace m addr) Source #
Instance details Defined in Simulation.Network.Snocket Methods showsPrec :: Int -> SnocketTrace m addr -> ShowS Source # show :: SnocketTrace m addr -> String Source # showList :: [ SnocketTrace m addr] -> ShowS Source #

data SockType Source #

Constructors

ListeningSock
ConnectionSock
UnknownType

Instances

Instances details

Show SockType Source #
Instance details Defined in Simulation.Network.Snocket Methods showsPrec :: Int -> SockType -> ShowS Source # show :: SockType -> String Source # showList :: [ SockType ] -> ShowS Source #

data OpenType Source #

Either simultaneous open or normal open. Unlike in TCP, only one side will will know that it is doing simultaneous open.

Constructors

SimOpen	Simultaneous open
NormalOpen	Normal open

Instances

Instances details

Show OpenType Source #
Instance details Defined in Simulation.Network.Snocket Methods showsPrec :: Int -> OpenType -> ShowS Source # show :: OpenType -> String Source # showList :: [ OpenType ] -> ShowS Source #

normaliseId :: Ord addr => ConnectionId addr -> NormalisedId addr Source #

Safe constructor of NormalisedId

data BearerInfo Source #

Each bearer info describes outbound and inbound side of a point to point bearer.

Constructors

BearerInfo

Fields

biConnectionDelay :: ! DiffTime

How long it take to create a connection
biInboundAttenuation :: Time -> Size -> ( DiffTime , SuccessOrFailure )

attenuation of inbound side of the bearer, i.e. attenuation used by bearers that were accept ed.
biOutboundAttenuation :: Time -> Size -> ( DiffTime , SuccessOrFailure )

attenuation of outbound side of the bearer, i.e. the attenuation used by bearers that were created with connect call.
biInboundWriteFailure :: !( Maybe Int )

Maximum number of successful writes for an inbound bearer.
biOutboundWriteFailure :: !( Maybe Int )

Maximum number of successful writes for an outbound bearer.
biAcceptFailures :: !( Maybe ( DiffTime , IOErrType ))

Time after which accept will throw an exception.

Currently it only supports two kinds of exceptions, ones that are caught and rethrown by the server (ECONNABORTED), and an exception which would be caught, and delivered to the application via AcceptFailure .
biSDUSize :: ! SDUSize

SDU size of the bearer; it will be shared between outbound and inbound sides.

Note: shrinking SDUSize means make it larger, as this allows to send fewer chunks through the bearer.

Instances

Instances details

Show BearerInfo Source #
Instance details Defined in Simulation.Network.Snocket Methods showsPrec :: Int -> BearerInfo -> ShowS Source # show :: BearerInfo -> String Source # showList :: [ BearerInfo ] -> ShowS Source #

data IOErrType Source #

Error types.

Constructors

IOErrConnectionAborted
IOErrResourceExhausted

Instances

Instances details

Eq IOErrType Source #
Instance details Defined in Simulation.Network.Snocket Methods (==) :: IOErrType -> IOErrType -> Bool Source # (/=) :: IOErrType -> IOErrType -> Bool Source #
Show IOErrType Source #
Instance details Defined in Simulation.Network.Snocket Methods showsPrec :: Int -> IOErrType -> ShowS Source # show :: IOErrType -> String Source # showList :: [ IOErrType ] -> ShowS Source #

data SuccessOrFailure Source #

Constructors

Success
Failure

data TimeoutDetail Source #

Constructors

WaitingToConnect
WaitingToBeAccepted

Instances

Instances details

Show TimeoutDetail Source #
Instance details Defined in Simulation.Network.Snocket Methods showsPrec :: Int -> TimeoutDetail -> ShowS Source # show :: TimeoutDetail -> String Source # showList :: [ TimeoutDetail ] -> ShowS Source #

noAttenuation :: BearerInfo Source #

BearerInfo without attenuation and instantaneous connect delay. It also using the production value of SDUSize .

data FD m peerAddr Source #

File descriptor type.

class GlobalAddressScheme addr where Source #

A type class for global IP address scheme. Every node in the simulation has an ephemeral address. Every node in the simulation has an implicit ipv4 and ipv6 address (if one is not bound by explicitly).

Methods

getAddressType :: TestAddress addr -> AddressType Source #

ephemeralAddress :: AddressType -> Natural -> TestAddress addr Source #

Instances

Instances details

GlobalAddressScheme Int Source #	All negative addresses are ephemeral. Even address are IPv4, while odd ones are IPv6.
Instance details Defined in Simulation.Network.Snocket Methods getAddressType :: TestAddress Int -> AddressType Source # ephemeralAddress :: AddressType -> Natural -> TestAddress Int Source #

data AddressType Source #

Connection manager supports IPv4 and IPv6 addresses.

Constructors

IPv4Address
IPv6Address

Instances

Instances details

Show AddressType Source #
Instance details Defined in Ouroboros.Network.ConnectionManager.Types Methods showsPrec :: Int -> AddressType -> ShowS Source # show :: AddressType -> String Source # showList :: [ AddressType ] -> ShowS Source #