@@ -9,11 +9,11 @@ import Control.Concurrent.MVar ( newEmptyMVar
10 , readMVar
10 , readMVar
12−import Control.Exception (catch)
13import Control.Monad (replicateM_)
12import Control.Monad (replicateM_)
14import Control.Distributed.Process
13import Control.Distributed.Process
15import qualified Network.Transport as NT (Transport)
14import qualified Network.Transport as NT (Transport)
16import Network.Transport.TCP (createTransport, defaultTCPParameters)
15import Network.Transport.TCP (createTransport, defaultTCPParameters)
18newtype Ping = Ping ProcessId
18newtype Ping = Ping ProcessId
19 deriving (Typeable, Binary, Show)
19 deriving (Typeable, Binary, Show)
@@ -55,7 +55,6 @@ testPing transport = do
55 Ping _ <- expect
55 Ping _ <- expect
58− putStrLn $ "Client did " ++ show numPings ++ " pings"
59 putMVar clientDone ()
58 putMVar clientDone ()
@@ -113,6 +112,8 @@ testMonitor2 transport = do
113main :: IO ()
112main :: IO ()
115 Right transport <- createTransport "127.0.0.1" "8080" defaultTCPParameters
114 Right transport <- createTransport "127.0.0.1" "8080" defaultTCPParameters
116− -- testPing transport
116+ [ ("Ping", testPing transport)
117− testMonitor1 transport
117+ , ("Monitor1", testMonitor1 transport)
118− testMonitor2 transport
118+ , ("Monitor2", testMonitor2 transport)