Safe Haskell	None
Language	Haskell2010

Test.Ouroboros.Network.PeerSelection.Cardano.MockEnvironment

Synopsis

newtype PeerGraph = PeerGraph [(PeerAddr, [PeerAddr], PeerInfo)]
data GovernorMockEnvironment = GovernorMockEnvironment {
- peerGraph :: !PeerGraph
- localRootPeers :: !(LocalRootPeers PeerTrustable PeerAddr)
- publicRootPeers :: !(PublicRootPeers (ExtraPeers PeerAddr) PeerAddr)
- targets :: !(TimedScript (PeerSelectionTargets, PeerSelectionTargets))
- pickKnownPeersForPeerShare :: !(PickScript PeerAddr)
- pickColdPeersToPromote :: !(PickScript PeerAddr)
- pickWarmPeersToPromote :: !(PickScript PeerAddr)
- pickHotPeersToDemote :: !(PickScript PeerAddr)
- pickWarmPeersToDemote :: !(PickScript PeerAddr)
- pickColdPeersToForget :: !(PickScript PeerAddr)
- pickInboundPeers :: !(PickScript PeerAddr)
- peerSharingFlag :: !PeerSharing
- useBootstrapPeers :: !(TimedScript UseBootstrapPeers)
- consensusMode :: !ConsensusMode
- useLedgerPeers :: !(TimedScript UseLedgerPeers)
- ledgerStateJudgement :: !(TimedScript LedgerStateJudgement)
}
newtype GovernorPraosMockEnvironment = GovernorPraosMockEnvironment {
- getMockEnv :: GovernorMockEnvironment
}
newtype GovernorMockEnvironmentWithoutAsyncDemotion = GovernorMockEnvironmentWAD GovernorMockEnvironment
runGovernorInMockEnvironment :: GovernorMockEnvironment -> SimTrace Void
exploreGovernorInMockEnvironment :: Testable test => (ExplorationOptions -> ExplorationOptions) -> GovernorMockEnvironment -> (Maybe (SimTrace Void) -> SimTrace Void -> test) -> Property
data TraceMockEnv
- = TraceEnvAddPeers !PeerGraph
- | TraceEnvSetLocalRoots !(LocalRootPeers PeerTrustable PeerAddr)
- | TraceEnvRequestPublicRootPeers
- | TraceEnvRequestBigLedgerPeers
- | TraceEnvSetPublicRoots !(PublicRootPeers (ExtraPeers PeerAddr) PeerAddr)
- | TraceEnvPublicRootTTL
- | TraceEnvBigLedgerPeersTTL
- | TraceEnvPeerShareTTL !PeerAddr
- | TraceEnvSetTargets !PeerSelectionTargets
- | TraceEnvPeersDemote !AsyncDemotion !PeerAddr
- | TraceEnvEstablishConn !PeerAddr
- | TraceEnvActivatePeer !PeerAddr
- | TraceEnvDeactivatePeer !PeerAddr
- | TraceEnvCloseConn !PeerAddr
- | TraceEnvRootsResult ![PeerAddr]
- | TraceEnvBigLedgerPeersResult !(Set PeerAddr)
- | TraceEnvPeerShareRequest !PeerAddr !(Maybe ([PeerAddr], PeerShareTime))
- | TraceEnvPeerShareResult !PeerAddr ![PeerAddr]
- | TraceEnvPeersStatus !(Map PeerAddr PeerStatus)
- | TraceEnvSetUseBootstrapPeers !UseBootstrapPeers
- | TraceEnvSetLedgerStateJudgement !LedgerStateJudgement
- | TraceEnvUseLedgerPeers !UseLedgerPeers
- | TraceEnvGenesisLsjAndTargets !(LedgerStateJudgement, PeerSelectionTargets)
data TestTraceEvent extraState extraFlags extraPeers extraCounters
- = GovernorDebug !(DebugPeerSelection extraState extraFlags extraPeers PeerAddr)
- | GovernorEvent !(TracePeerSelection extraState extraFlags extraPeers PeerAddr)
- | GovernorCounters !(PeerSelectionCounters extraCounters)
- | GovernorAssociationMode !AssociationMode
- | MockEnvEvent !TraceMockEnv
selectGovernorEvents :: [(Time, TestTraceEvent extraState extraFlags extraPeers extraCounters)] -> [(Time, TracePeerSelection extraState extraFlags extraPeers PeerAddr)]
selectGovernorStateEvents :: [(Time, TestTraceEvent extraState extraFlags extraPeers extraCounters)] -> [(Time, DebugPeerSelection extraState extraFlags extraPeers PeerAddr)]
selectPeerSelectionTraceEvents :: (Typeable extraState, Typeable extraFlags, Typeable extraPeers, Typeable extraCounters) => SimTrace a -> [(Time, TestTraceEvent extraState extraFlags extraPeers extraCounters)]
selectPeerSelectionTraceEventsUntil :: (Typeable extraState, Typeable extraFlags, Typeable extraPeers, Typeable extraCounters) => Time -> SimTrace a -> [(Time, TestTraceEvent extraState extraFlags extraPeers extraCounters)]
peerShareReachablePeers :: PeerGraph -> Set PeerAddr -> Set PeerAddr
data ScriptDelay
- = NoDelay
- | ShortDelay
- | LongDelay
- | Delay DiffTime
newtype Script a = Script (NonEmpty a)
arbitraryPickScript :: Gen (Set peeraddr) -> Gen (PickScript peeraddr)
arbitraryScriptOf :: Int -> Gen a -> Gen (Script a)
initScript :: MonadSTM m => Script a -> m (TVar m (Script a))
initScript' :: MonadSTM m => Script a -> m (StrictTVar m (Script a))
interpretPickScript :: forall (m :: Type -> Type) peeraddr. (MonadSTM m, Ord peeraddr) => StrictTVar m (PickScript peeraddr) -> Set peeraddr -> Int -> STM m (Set peeraddr)
playTimedScript :: (MonadAsync m, MonadDelay m) => Tracer m a -> TimedScript a -> m (TVar m a)
prop_shrink_Script :: ShrinkCarefully (Script Int) -> Property
shrinkScriptWith :: (a -> [a]) -> Script a -> [Script a]
singletonScript :: a -> Script a
singletonTimedScript :: a -> TimedScript a
stepScript :: MonadSTM m => TVar m (Script a) -> m a
stepScriptSTM :: forall (m :: Type -> Type) a. MonadSTM m => TVar m (Script a) -> STM m a
stepScriptSTM' :: forall (m :: Type -> Type) a. MonadSTM m => StrictTVar m (Script a) -> STM m a
type PickScript peeraddr = Script (PickMembers peeraddr)
type TimedScript a = Script (a, ScriptDelay)
data PeerStatus
- = PeerCold
- | PeerCooling
- | PeerWarm
- | PeerHot
tests :: TestTree
prop_shrink_nonequal_GovernorMockEnvironment :: ShrinkCarefully GovernorMockEnvironment -> Property
config_REPROMOTE_DELAY :: RepromoteDelay

Documentation

newtype PeerGraph Source #

The peer graph is the graph of all the peers in the mock p2p network, in traditional adjacency representation.

Constructors

PeerGraph [(PeerAddr, [PeerAddr], PeerInfo)]

Instances

Instances details

Arbitrary PeerGraph Source #
Instance details Defined in Test.Ouroboros.Network.PeerSelection.PeerGraph Methods arbitrary :: Gen PeerGraph # shrink :: PeerGraph -> [PeerGraph] #
Show PeerGraph Source #
Instance details Defined in Test.Ouroboros.Network.PeerSelection.PeerGraph Methods showsPrec :: Int -> PeerGraph -> ShowS # show :: PeerGraph -> String # showList :: [PeerGraph] -> ShowS #
Eq PeerGraph Source #
Instance details Defined in Test.Ouroboros.Network.PeerSelection.PeerGraph Methods (==) :: PeerGraph -> PeerGraph -> Bool # (/=) :: PeerGraph -> PeerGraph -> Bool #

data GovernorMockEnvironment Source #

The data needed to execute the peer selection governor in a test with a mock network environment. It contains the data needed to provide the PeerSelectionActions and PeerSelectionPolicy to run the governor.

The representations are chosen to be easily shrinkable. See the Arbitrary instances.

Constructors

GovernorMockEnvironment

Fields

peerGraph :: !PeerGraph
localRootPeers :: !(LocalRootPeers PeerTrustable PeerAddr)
publicRootPeers :: !(PublicRootPeers (ExtraPeers PeerAddr) PeerAddr)
targets :: !(TimedScript (PeerSelectionTargets, PeerSelectionTargets))
pickKnownPeersForPeerShare :: !(PickScript PeerAddr)
pickColdPeersToPromote :: !(PickScript PeerAddr)
pickWarmPeersToPromote :: !(PickScript PeerAddr)
pickHotPeersToDemote :: !(PickScript PeerAddr)
pickWarmPeersToDemote :: !(PickScript PeerAddr)
pickColdPeersToForget :: !(PickScript PeerAddr)
pickInboundPeers :: !(PickScript PeerAddr)
peerSharingFlag :: !PeerSharing
useBootstrapPeers :: !(TimedScript UseBootstrapPeers)
consensusMode :: !ConsensusMode
useLedgerPeers :: !(TimedScript UseLedgerPeers)
ledgerStateJudgement :: !(TimedScript LedgerStateJudgement)

Instances

Instances details

Arbitrary GovernorMockEnvironment Source #
Instance details Defined in Test.Ouroboros.Network.PeerSelection.Cardano.MockEnvironment Methods arbitrary :: Gen GovernorMockEnvironment # shrink :: GovernorMockEnvironment -> [GovernorMockEnvironment] #
Show GovernorMockEnvironment Source #
Instance details Defined in Test.Ouroboros.Network.PeerSelection.Cardano.MockEnvironment Methods showsPrec :: Int -> GovernorMockEnvironment -> ShowS # show :: GovernorMockEnvironment -> String # showList :: [GovernorMockEnvironment] -> ShowS #
Eq GovernorMockEnvironment Source #
Instance details Defined in Test.Ouroboros.Network.PeerSelection.Cardano.MockEnvironment Methods (==) :: GovernorMockEnvironment -> GovernorMockEnvironment -> Bool # (/=) :: GovernorMockEnvironment -> GovernorMockEnvironment -> Bool #

newtype GovernorPraosMockEnvironment Source #

This instance is used to generate test cases for properties which rely on peer selection prior to introduction of Genesis

Constructors

GovernorPraosMockEnvironment
Fields getMockEnv :: GovernorMockEnvironment

Instances

Instances details

Arbitrary GovernorPraosMockEnvironment Source #
Instance details Defined in Test.Ouroboros.Network.PeerSelection.Cardano.MockEnvironment Methods arbitrary :: Gen GovernorPraosMockEnvironment # shrink :: GovernorPraosMockEnvironment -> [GovernorPraosMockEnvironment] #
Show GovernorPraosMockEnvironment Source #
Instance details Defined in Test.Ouroboros.Network.PeerSelection.Cardano.MockEnvironment Methods showsPrec :: Int -> GovernorPraosMockEnvironment -> ShowS # show :: GovernorPraosMockEnvironment -> String # showList :: [GovernorPraosMockEnvironment] -> ShowS #
Eq GovernorPraosMockEnvironment Source #
Instance details Defined in Test.Ouroboros.Network.PeerSelection.Cardano.MockEnvironment Methods (==) :: GovernorPraosMockEnvironment -> GovernorPraosMockEnvironment -> Bool # (/=) :: GovernorPraosMockEnvironment -> GovernorPraosMockEnvironment -> Bool #

newtype GovernorMockEnvironmentWithoutAsyncDemotion Source #

GovernorMockEnvironment which does not do any asynchronous demotions.

Constructors

GovernorMockEnvironmentWAD GovernorMockEnvironment

Instances

Instances details

Arbitrary GovernorMockEnvironmentWithoutAsyncDemotion Source #
Instance details Defined in Test.Ouroboros.Network.PeerSelection.Cardano.MockEnvironment Methods arbitrary :: Gen GovernorMockEnvironmentWithoutAsyncDemotion # shrink :: GovernorMockEnvironmentWithoutAsyncDemotion -> [GovernorMockEnvironmentWithoutAsyncDemotion] #
Show GovernorMockEnvironmentWithoutAsyncDemotion Source #
Instance details Defined in Test.Ouroboros.Network.PeerSelection.Cardano.MockEnvironment Methods showsPrec :: Int -> GovernorMockEnvironmentWithoutAsyncDemotion -> ShowS # show :: GovernorMockEnvironmentWithoutAsyncDemotion -> String # showList :: [GovernorMockEnvironmentWithoutAsyncDemotion] -> ShowS #

runGovernorInMockEnvironment :: GovernorMockEnvironment -> SimTrace Void Source #

Run the peerSelectionGovernor in the mock environment dictated by the data in the GovernorMockEnvironment.

The result is an execution trace.

exploreGovernorInMockEnvironment :: Testable test => (ExplorationOptions -> ExplorationOptions) -> GovernorMockEnvironment -> (Maybe (SimTrace Void) -> SimTrace Void -> test) -> Property Source #

data TraceMockEnv Source #

Constructors

TraceEnvAddPeers !PeerGraph
TraceEnvSetLocalRoots !(LocalRootPeers PeerTrustable PeerAddr)
TraceEnvRequestPublicRootPeers
TraceEnvRequestBigLedgerPeers
TraceEnvSetPublicRoots !(PublicRootPeers (ExtraPeers PeerAddr) PeerAddr)
TraceEnvPublicRootTTL
TraceEnvBigLedgerPeersTTL
TraceEnvPeerShareTTL !PeerAddr
TraceEnvSetTargets !PeerSelectionTargets
TraceEnvPeersDemote !AsyncDemotion !PeerAddr
TraceEnvEstablishConn !PeerAddr
TraceEnvActivatePeer !PeerAddr
TraceEnvDeactivatePeer !PeerAddr
TraceEnvCloseConn !PeerAddr
TraceEnvRootsResult ![PeerAddr]
TraceEnvBigLedgerPeersResult !(Set PeerAddr)
TraceEnvPeerShareRequest !PeerAddr !(Maybe ([PeerAddr], PeerShareTime))
TraceEnvPeerShareResult !PeerAddr ![PeerAddr]
TraceEnvPeersStatus !(Map PeerAddr PeerStatus)
TraceEnvSetUseBootstrapPeers !UseBootstrapPeers
TraceEnvSetLedgerStateJudgement !LedgerStateJudgement
TraceEnvUseLedgerPeers !UseLedgerPeers
TraceEnvGenesisLsjAndTargets !(LedgerStateJudgement, PeerSelectionTargets)

Instances

Instances details

Show TraceMockEnv Source #
Instance details Defined in Test.Ouroboros.Network.PeerSelection.Cardano.MockEnvironment Methods showsPrec :: Int -> TraceMockEnv -> ShowS # show :: TraceMockEnv -> String # showList :: [TraceMockEnv] -> ShowS #

data TestTraceEvent extraState extraFlags extraPeers extraCounters Source #

Constructors

GovernorDebug !(DebugPeerSelection extraState extraFlags extraPeers PeerAddr)
GovernorEvent !(TracePeerSelection extraState extraFlags extraPeers PeerAddr)
GovernorCounters !(PeerSelectionCounters extraCounters)
GovernorAssociationMode !AssociationMode
MockEnvEvent !TraceMockEnv

Instances

Instances details

(Show extraState, Show extraFlags, Show extraPeers, Show extraCounters) => Show (TestTraceEvent extraState extraFlags extraPeers extraCounters) Source #
Instance details Defined in Test.Ouroboros.Network.PeerSelection.Cardano.MockEnvironment Methods showsPrec :: Int -> TestTraceEvent extraState extraFlags extraPeers extraCounters -> ShowS # show :: TestTraceEvent extraState extraFlags extraPeers extraCounters -> String # showList :: [TestTraceEvent extraState extraFlags extraPeers extraCounters] -> ShowS #

selectGovernorEvents :: [(Time, TestTraceEvent extraState extraFlags extraPeers extraCounters)] -> [(Time, TracePeerSelection extraState extraFlags extraPeers PeerAddr)] Source #

selectGovernorStateEvents :: [(Time, TestTraceEvent extraState extraFlags extraPeers extraCounters)] -> [(Time, DebugPeerSelection extraState extraFlags extraPeers PeerAddr)] Source #

selectPeerSelectionTraceEvents :: (Typeable extraState, Typeable extraFlags, Typeable extraPeers, Typeable extraCounters) => SimTrace a -> [(Time, TestTraceEvent extraState extraFlags extraPeers extraCounters)] Source #

selectPeerSelectionTraceEventsUntil :: (Typeable extraState, Typeable extraFlags, Typeable extraPeers, Typeable extraCounters) => Time -> SimTrace a -> [(Time, TestTraceEvent extraState extraFlags extraPeers extraCounters)] Source #

peerShareReachablePeers :: PeerGraph -> Set PeerAddr -> Set PeerAddr Source #

data ScriptDelay #

Constructors

NoDelay
ShortDelay
LongDelay
Delay DiffTime

Instances

Instances details

Arbitrary ScriptDelay
Instance details Defined in Test.Ouroboros.Network.Data.Script Methods arbitrary :: Gen ScriptDelay # shrink :: ScriptDelay -> [ScriptDelay] #
Show ScriptDelay
Instance details Defined in Test.Ouroboros.Network.Data.Script Methods showsPrec :: Int -> ScriptDelay -> ShowS # show :: ScriptDelay -> String # showList :: [ScriptDelay] -> ShowS #
Eq ScriptDelay
Instance details Defined in Test.Ouroboros.Network.Data.Script Methods (==) :: ScriptDelay -> ScriptDelay -> Bool # (/=) :: ScriptDelay -> ScriptDelay -> Bool #

newtype Script a #

Constructors

Script (NonEmpty a)

Instances

Instances details

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

arbitraryPickScript :: Gen (Set peeraddr) -> Gen (PickScript peeraddr) #

arbitraryScriptOf :: Int -> Gen a -> Gen (Script a) #

initScript :: MonadSTM m => Script a -> m (TVar m (Script a)) #

initScript' :: MonadSTM m => Script a -> m (StrictTVar m (Script a)) #

interpretPickScript :: forall (m :: Type -> Type) peeraddr. (MonadSTM m, Ord peeraddr) => StrictTVar m (PickScript peeraddr) -> Set peeraddr -> Int -> STM m (Set peeraddr) #

playTimedScript :: (MonadAsync m, MonadDelay m) => Tracer m a -> TimedScript a -> m (TVar m a) #

prop_shrink_Script :: ShrinkCarefully (Script Int) -> Property #

shrinkScriptWith :: (a -> [a]) -> Script a -> [Script a] #

singletonScript :: a -> Script a #

singletonTimedScript :: a -> TimedScript a #

Timed script which consists of a single element.

stepScript :: MonadSTM m => TVar m (Script a) -> m a #

stepScriptSTM :: forall (m :: Type -> Type) a. MonadSTM m => TVar m (Script a) -> STM m a #

stepScriptSTM' :: forall (m :: Type -> Type) a. MonadSTM m => StrictTVar m (Script a) -> STM m a #

type PickScript peeraddr = Script (PickMembers peeraddr) #

A pick script is used to interpret the policyPickKnownPeersForPeerShare and the policyPickColdPeersToForget. It selects elements from the given choices by their index (modulo the number of choices). This representation was chosen because it allows easy shrinking.

type TimedScript a = Script (a, ScriptDelay) #

data PeerStatus #

Constructors

PeerCold	Peer is in true cold which means no connection to exists and the outbound governor is safe to promote it.
PeerCooling	Peer is in cold state but its connection still lingers. I.e. it is still in progress to be fully demoted. Note: The `PeerCooling -> PeerCold` state transition is an `outbound-governor` reflection of the connection-manager's `TerminatingSt -> TerminatedSt` state transition (our version of tcp's `TimeWait`). It is only triggered in case of a clean connection shutdown, not in the case of errors.
PeerWarm
PeerHot

Instances

Instances details

Show PeerStatus
Instance details Defined in Ouroboros.Network.PeerSelection.Types Methods showsPrec :: Int -> PeerStatus -> ShowS # show :: PeerStatus -> String # showList :: [PeerStatus] -> ShowS #
Eq PeerStatus
Instance details Defined in Ouroboros.Network.PeerSelection.Types Methods (==) :: PeerStatus -> PeerStatus -> Bool # (/=) :: PeerStatus -> PeerStatus -> Bool #
Ord PeerStatus
Instance details Defined in Ouroboros.Network.PeerSelection.Types Methods compare :: PeerStatus -> PeerStatus -> Ordering # (<) :: PeerStatus -> PeerStatus -> Bool # (<=) :: PeerStatus -> PeerStatus -> Bool # (>) :: PeerStatus -> PeerStatus -> Bool # (>=) :: PeerStatus -> PeerStatus -> Bool # max :: PeerStatus -> PeerStatus -> PeerStatus # min :: PeerStatus -> PeerStatus -> PeerStatus #

tests :: TestTree Source #

prop_shrink_nonequal_GovernorMockEnvironment :: ShrinkCarefully GovernorMockEnvironment -> Property Source #

config_REPROMOTE_DELAY :: RepromoteDelay Source #