Skip to content

Commit

Permalink
testnet: move Node module
Browse files Browse the repository at this point in the history
Also edit export lists so that we need fewer imports.
  • Loading branch information
coot committed Feb 12, 2025
1 parent 01f9bbf commit d0f1f93
Show file tree
Hide file tree
Showing 4 changed files with 21 additions and 20 deletions.
2 changes: 1 addition & 1 deletion ouroboros-network/ouroboros-network.cabal
Original file line number Diff line number Diff line change
Expand Up @@ -259,13 +259,13 @@ library sim-tests-lib
Ouroboros.Network.BlockFetch.Examples
Ouroboros.Network.MockNode
Test.Ouroboros.Network.BlockFetch
Test.Ouroboros.Network.Diffusion.Node
Test.Ouroboros.Network.Diffusion.Node.ChainDB
Test.Ouroboros.Network.Diffusion.Node.Kernel
Test.Ouroboros.Network.Diffusion.Node.MiniProtocols
Test.Ouroboros.Network.Diffusion.Policies
Test.Ouroboros.Network.Diffusion.Testnet.Cardano
Test.Ouroboros.Network.Diffusion.Testnet.Cardano.Simulation
Test.Ouroboros.Network.Diffusion.Testnet.Node
Test.Ouroboros.Network.KeepAlive
Test.Ouroboros.Network.LedgerPeers
Test.Ouroboros.Network.MockNode
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,25 +8,33 @@
{-# LANGUAGE TypeOperators #-}
{-# LANGUAGE UndecidableInstances #-}

module Test.Ouroboros.Network.Diffusion.Testnet.Node
module Test.Ouroboros.Network.Diffusion.Node
( -- * run a node
Node.BlockGeneratorArgs (..)
, Node.LimitsAndTimeouts (..)
, Interfaces (..)
Interfaces (..)
, Arguments (..)
, run
-- * node types
, NtNAddr
, NtNFD
, NtNVersion
, NtNVersionData
, NtCAddr
, NtCFD
, NtCVersion
, NtCVersionData
, Node.NtNAddr_ (..)
-- * extra types used by the node
, AcceptedConnectionsLimit (..)
, DiffusionMode (..)
, PeerAdvertise (..)
, PeerSelectionTargets (..)
-- * configuration constants
, config_REPROMOTE_DELAY
-- * re-exports
, Node.BlockGeneratorArgs (..)
, Node.LimitsAndTimeouts (..)
, Node.randomBlockGenerationArgs
, Node.ntnAddrToRelayAccessPoint
) where

import Control.Applicative (Alternative)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -94,9 +94,9 @@ import Test.Ouroboros.Network.Data.AbsBearerInfo
import Test.Ouroboros.Network.Data.Script
import Test.Ouroboros.Network.Data.Signal
import Test.Ouroboros.Network.Data.Signal qualified as Signal
import Test.Ouroboros.Network.Diffusion.Node (config_REPROMOTE_DELAY)
import Test.Ouroboros.Network.Diffusion.Node.Kernel
import Test.Ouroboros.Network.Diffusion.Testnet.Cardano.Simulation
import Test.Ouroboros.Network.Diffusion.Testnet.Node (config_REPROMOTE_DELAY)
import Test.Ouroboros.Network.InboundGovernor.Utils
import Test.Ouroboros.Network.LedgerPeers (LedgerPools (..))
import Test.Ouroboros.Network.Utils hiding (SmallDelay, debugTracer)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -109,14 +109,12 @@ import Ouroboros.Network.InboundGovernor (RemoteTransitionTrace)
import Ouroboros.Network.InboundGovernor qualified as IG
import Ouroboros.Network.Mock.ConcreteBlock (Block (..), BlockHeader (..))
import Ouroboros.Network.Mux (MiniProtocolLimits (..))
import Ouroboros.Network.NodeToNode.Version (DiffusionMode (..))
import Ouroboros.Network.PeerSelection.Governor (DebugPeerSelection (..),
PeerSelectionTargets (..), TracePeerSelection)
TracePeerSelection)
import Ouroboros.Network.PeerSelection.Governor qualified as PeerSelection
import Ouroboros.Network.PeerSelection.LedgerPeers (AfterSlot (..),
LedgerPeersConsensusInterface (..), TraceLedgerPeers,
UseLedgerPeers (..), accPoolStake)
import Ouroboros.Network.PeerSelection.PeerAdvertise (PeerAdvertise (..))
import Ouroboros.Network.PeerSelection.PeerSharing (PeerSharing)
import Ouroboros.Network.PeerSelection.PeerStateActions
(PeerSelectionActionsTrace)
Expand All @@ -138,19 +136,14 @@ import Ouroboros.Network.Protocol.KeepAlive.Codec (byteLimitsKeepAlive,
import Ouroboros.Network.Protocol.Limits (shortWait, smallByteLimit)
import Ouroboros.Network.Protocol.PeerSharing.Codec (byteLimitsPeerSharing,
timeLimitsPeerSharing)
import Ouroboros.Network.Server.RateLimiting (AcceptedConnectionsLimit (..))
import Ouroboros.Network.Server2 qualified as Server
import Ouroboros.Network.Snocket (Snocket, TestAddress (..))

import Simulation.Network.Snocket (BearerInfo (..), FD, SnocketTrace,
WithAddr (..), makeFDBearer, withSnocket)

import Test.Ouroboros.Network.Data.Script
import Test.Ouroboros.Network.Diffusion.Node.Kernel (BlockGeneratorArgs,
NtCAddr, NtCVersion, NtCVersionData, NtNAddr, NtNAddr_ (IPAddr),
NtNVersion, NtNVersionData, ntnAddrToRelayAccessPoint,
randomBlockGenerationArgs)
import Test.Ouroboros.Network.Diffusion.Testnet.Node qualified as Node
import Test.Ouroboros.Network.Diffusion.Node as Node
import Test.Ouroboros.Network.LedgerPeers (LedgerPools (..), genLedgerPoolsFrom)
import Test.Ouroboros.Network.PeerSelection.Cardano.Instances ()
import Test.Ouroboros.Network.PeerSelection.Instances qualified as PeerSelection
Expand Down Expand Up @@ -486,7 +479,7 @@ genNodeArgs relays minConnected localRootPeers relay = flip suchThat hasUpstream
hasUpstream NodeArgs { naAddr, naPublicRoots, naLocalRootPeers } =
not (Map.null $ naPublicRoots
`Map.withoutKeys`
Set.fromList (maybeToList (ntnAddrToRelayAccessPoint naAddr)))
Set.fromList (maybeToList (Node.ntnAddrToRelayAccessPoint naAddr)))
|| any id [ v > 0 && not (Map.null m)
| (HotValency v, _, m) <- naLocalRootPeers
]
Expand Down Expand Up @@ -1117,11 +1110,11 @@ diffusionSimulation
defaultMiniProtocolsLimit =
MiniProtocolLimits { maximumIngressQueue = 64000 }

blockGeneratorArgs :: BlockGeneratorArgs Block StdGen
blockGeneratorArgs :: Node.BlockGeneratorArgs Block StdGen
blockGeneratorArgs =
randomBlockGenerationArgs bgaSlotDuration
bgaRng
quota
Node.randomBlockGenerationArgs bgaSlotDuration
bgaRng
quota

stdChainSyncTimeout :: ChainSyncTimeout
stdChainSyncTimeout = do
Expand Down

0 comments on commit d0f1f93

Please sign in to comment.