git.iko.soy/distributed-process
on master help sign in
Split off distributed-process-simplelocalnet
8736f7dEdsko de Vries
distributed-process-simplelocalnet/LICENSEnew file+31
compare with master
unifiedsplit
@@ -0,0 +1,31 @@
1+Copyright Well-Typed LLP, 2011-2012
2+
3+All rights reserved.
4+
5+Redistribution and use in source and binary forms, with or without
6+modification, are permitted provided that the following conditions are met:
7+
8+ * Redistributions of source code must retain the above copyright
9+ notice, this list of conditions and the following disclaimer.
10+
11+ * Redistributions in binary form must reproduce the above
12+ copyright notice, this list of conditions and the following
13+ disclaimer in the documentation and/or other materials provided
14+ with the distribution.
15+
16+ * Neither the name of the owner nor the names of other
17+ contributors may be used to endorse or promote products derived
18+ from this software without specific prior written permission.
19+
20+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
21+"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
22+LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
23+A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
24+OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
25+SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
26+LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
27+DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
28+THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
29+(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
30+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
31+
distributed-process-simplelocalnet/Setup.hsnew file+2
@@ -0,0 +1,2 @@
1+import Distribution.Simple
2+main = defaultMain
distributed-process-simplelocalnet/distributed-process-simplelocalnet.cabalnew file+58
@@ -0,0 +1,58 @@
1+Name: distributed-process-simplelocalnet
2+Version: 0.2.0
3+Cabal-Version: >=1.8
4+Build-Type: Simple
5+License: BSD3
6+License-File: LICENSE
7+Copyright: Well-Typed LLP
8+Author: Duncan Coutts, Nicolas Wu, Edsko de Vries
9+Maintainer: edsko@well-typed.com, dcoutts@well-typed.com
10+Stability: experimental
11+Homepage: http://github.com/haskell-distributed/distributed-process
12+Bug-Reports: mailto:edsko@well-typed.com
13+Synopsis: Simple zero-configuration backend for Cloud Haskell
14+Description: Simple backend based on the TCP transport which offers node
15+ discovery based on UDP multicast. This is a zero-configuration
16+ backend designed to get you going with Cloud Haskell quickly
17+ without imposing any structure on your application.
18+Tested-With: GHC==7.2.2 GHC==7.4.1 GHC==7.4.2
19+Category: Control
20+
21+Library
22+ Build-Depends: base >= 4.4 && < 5,
23+ bytestring >= 0.9 && < 0.10,
24+ network >= 2.3 && < 2.4,
25+ network-multicast >= 0.0 && < 0.1,
26+ data-accessor >= 0.2 && < 0.3,
27+ binary >= 0.5 && < 0.6,
28+ containers >= 0.4 && < 0.5,
29+ transformers >= 0.2 && < 0.4,
30+ network-transport >= 0.2 && < 0.3,
31+ network-transport-tcp >= 0.2 && < 0.3,
32+ distributed-process >= 0.2 && < 0.3
33+ Exposed-modules: Control.Distributed.Process.Backend.SimpleLocalnet,
34+ Control.Distributed.Process.Backend.SimpleLocalnet.Internal.Multicast
35+ Extensions: RankNTypes,
36+ DeriveDataTypeable
37+ ghc-options: -Wall
38+ HS-Source-Dirs: src
39+
40+-- Not a proper test, but we want to use cabal to compile it
41+Test-Suite TestSimpleLocalnet
42+ Type: exitcode-stdio-1.0
43+ Main-Is: TestSimpleLocalnet.hs
44+ Build-Depends: base >= 4.4 && < 5,
45+ bytestring >= 0.9 && < 0.10,
46+ network >= 2.3 && < 2.4,
47+ network-multicast >= 0.0 && < 0.1,
48+ data-accessor >= 0.2 && < 0.3,
49+ binary >= 0.5 && < 0.6,
50+ containers >= 0.4 && < 0.5,
51+ transformers >= 0.2 && < 0.4,
52+ network-transport >= 0.2 && < 0.3,
53+ network-transport-tcp >= 0.2 && < 0.3,
54+ distributed-process >= 0.2 && < 0.3
55+ Extensions: RankNTypes,
56+ DeriveDataTypeable
57+ ghc-options: -Wall -threaded -rtsopts -with-rtsopts=-N -fno-warn-unused-do-bind
58+ HS-Source-Dirs: tests src
distributed-process/src/Control/Distributed/Process/Backend/Local.hs → distributed-process-simplelocalnet/src/Control/Distributed/Process/Backend/SimpleLocalnet.hsrenamed+19−19
@@ -15,7 +15,7 @@
15-- > import Control.Distributed.Process.Node (initRemoteTable)
15-- > import Control.Distributed.Process.Node (initRemoteTable)
16-- > import Control.Distributed.Process.Backend.Local
16-- > import Control.Distributed.Process.Backend.Local
17-- >
17-- >
18−-- > master :: LocalBackend -> [NodeId] -> Process ()
18+-- > master :: Backend -> [NodeId] -> Process ()
19-- > master backend slaves = do
19-- > master backend slaves = do
20-- > -- Do something interesting with the slaves
20-- > -- Do something interesting with the slaves
21-- > liftIO . putStrLn $ "Slaves: " ++ show slaves
21-- > liftIO . putStrLn $ "Slaves: " ++ show slaves
@@ -34,9 +34,9 @@
34-- > backend <- initializeBackend host port initRemoteTable
34-- > backend <- initializeBackend host port initRemoteTable
35-- > startSlave backend
35-- > startSlave backend
36{-# OPTIONS_GHC -fno-warn-orphans #-}
36{-# OPTIONS_GHC -fno-warn-orphans #-}
37−module Control.Distributed.Process.Backend.Local
37+module Control.Distributed.Process.Backend.SimpleLocalnet
38 ( -- * Initialization
38 ( -- * Initialization
39− LocalBackend(..)
39+ Backend(..)
40 , initializeBackend
40 , initializeBackend
41 -- * Slave nodes
41 -- * Slave nodes
42 , startSlave
42 , startSlave
@@ -89,10 +89,10 @@ import qualified Network.Transport.TCP as NT
89 )
89 )
90import qualified Network.Transport as NT (Transport)
90import qualified Network.Transport as NT (Transport)
91import qualified Network.Socket as N (HostName, ServiceName, SockAddr)
91import qualified Network.Socket as N (HostName, ServiceName, SockAddr)
92−import Control.Distributed.Process.Internal.Multicast (initMulticast)
92+import Control.Distributed.Process.Backend.SimpleLocalnet.Internal.Multicast (initMulticast)
93
93
94-- | Local backend
94-- | Local backend
95−data LocalBackend = LocalBackend {
95+data Backend = Backend {
96 -- | Create a new local node
96 -- | Create a new local node
97 newLocalNode :: IO Node.LocalNode
97 newLocalNode :: IO Node.LocalNode
98 -- | @findPeers t@ sends out a /who's there?/ request, waits 't' msec,
98 -- | @findPeers t@ sends out a /who's there?/ request, waits 't' msec,
@@ -103,19 +103,19 @@ data LocalBackend = LocalBackend {
103 , redirectLogsHere :: Process ()
103 , redirectLogsHere :: Process ()
104 }
104 }
105
105
106−data LocalBackendState = LocalBackendState {
106+data BackendState = BackendState {
107 _localNodes :: [Node.LocalNode]
107 _localNodes :: [Node.LocalNode]
108 , _peers :: Set NodeId
108 , _peers :: Set NodeId
109 , discoveryDaemon :: ThreadId
109 , discoveryDaemon :: ThreadId
110 }
110 }
111
111
112-- | Initialize the backend
112-- | Initialize the backend
113−initializeBackend :: N.HostName -> N.ServiceName -> RemoteTable -> IO LocalBackend
113+initializeBackend :: N.HostName -> N.ServiceName -> RemoteTable -> IO Backend
114initializeBackend host port rtable = do
114initializeBackend host port rtable = do
115 mTransport <- NT.createTransport host port NT.defaultTCPParameters
115 mTransport <- NT.createTransport host port NT.defaultTCPParameters
116 (recv, send) <- initMulticast "224.0.0.99" 9999 1024
116 (recv, send) <- initMulticast "224.0.0.99" 9999 1024
117 (_, backendState) <- fixIO $ \ ~(tid, _) -> do
117 (_, backendState) <- fixIO $ \ ~(tid, _) -> do
118− backendState <- newMVar LocalBackendState
118+ backendState <- newMVar BackendState
119 { _localNodes = []
119 { _localNodes = []
120 , _peers = Set.empty
120 , _peers = Set.empty
121 , discoveryDaemon = tid
121 , discoveryDaemon = tid
@@ -125,7 +125,7 @@ initializeBackend host port rtable = do
125 case mTransport of
125 case mTransport of
126 Left err -> throw err
126 Left err -> throw err
127 Right transport ->
127 Right transport ->
128− let backend = LocalBackend {
128+ let backend = Backend {
129 newLocalNode = apiNewLocalNode transport rtable backendState
129 newLocalNode = apiNewLocalNode transport rtable backendState
130 , findPeers = apiFindPeers send backendState
130 , findPeers = apiFindPeers send backendState
131 , redirectLogsHere = apiRedirectLogsHere backend
131 , redirectLogsHere = apiRedirectLogsHere backend
@@ -135,7 +135,7 @@ initializeBackend host port rtable = do
135-- | Create a new local node
135-- | Create a new local node
136apiNewLocalNode :: NT.Transport
136apiNewLocalNode :: NT.Transport
137 -> RemoteTable
137 -> RemoteTable
138− -> MVar LocalBackendState
138+ -> MVar BackendState
139 -> IO Node.LocalNode
139 -> IO Node.LocalNode
140apiNewLocalNode transport rtable backendState = do
140apiNewLocalNode transport rtable backendState = do
141 localNode <- Node.newLocalNode transport rtable
141 localNode <- Node.newLocalNode transport rtable
@@ -144,7 +144,7 @@ apiNewLocalNode transport rtable backendState = do
144
144
145-- | Peer discovery
145-- | Peer discovery
146apiFindPeers :: (PeerDiscoveryMsg -> IO ())
146apiFindPeers :: (PeerDiscoveryMsg -> IO ())
147− -> MVar LocalBackendState
147+ -> MVar BackendState
148 -> Int
148 -> Int
149 -> IO [NodeId]
149 -> IO [NodeId]
150apiFindPeers send backendState delay = do
150apiFindPeers send backendState delay = do
@@ -167,7 +167,7 @@ instance Binary PeerDiscoveryMsg where
167 _ -> fail "PeerDiscoveryMsg.get: invalid"
167 _ -> fail "PeerDiscoveryMsg.get: invalid"
168
168
169-- | Respond to peer discovery requests sent by other nodes
169-- | Respond to peer discovery requests sent by other nodes
170−peerDiscoveryDaemon :: MVar LocalBackendState
170+peerDiscoveryDaemon :: MVar BackendState
171 -> IO (PeerDiscoveryMsg, N.SockAddr)
171 -> IO (PeerDiscoveryMsg, N.SockAddr)
172 -> (PeerDiscoveryMsg -> IO ())
172 -> (PeerDiscoveryMsg -> IO ())
173 -> IO ()
173 -> IO ()
@@ -187,7 +187,7 @@ peerDiscoveryDaemon backendState recv send = forever go
187--------------------------------------------------------------------------------
187--------------------------------------------------------------------------------
188
188
189-- | Make sure that all log messages are printed by the logger on this node
189-- | Make sure that all log messages are printed by the logger on this node
190−apiRedirectLogsHere :: LocalBackend -> Process ()
190+apiRedirectLogsHere :: Backend -> Process ()
191apiRedirectLogsHere backend = do
191apiRedirectLogsHere backend = do
192 mLogger <- whereis "logger"
192 mLogger <- whereis "logger"
193 forM_ mLogger $ \logger -> do
193 forM_ mLogger $ \logger -> do
@@ -219,7 +219,7 @@ instance Binary SlaveControllerMsg where
219--
219--
220-- This function does not return. The only way to exit the slave is to CTRL-C
220-- This function does not return. The only way to exit the slave is to CTRL-C
221-- the process or call terminateSlave from another node.
221-- the process or call terminateSlave from another node.
222−startSlave :: LocalBackend -> IO ()
222+startSlave :: Backend -> IO ()
223startSlave backend = do
223startSlave backend = do
224 node <- newLocalNode backend
224 node <- newLocalNode backend
225 Node.runProcess node slaveController
225 Node.runProcess node slaveController
@@ -241,7 +241,7 @@ terminateSlave :: NodeId -> Process ()
241terminateSlave nid = nsendRemote nid "slaveController" SlaveTerminate
241terminateSlave nid = nsendRemote nid "slaveController" SlaveTerminate
242
242
243-- | Find slave nodes
243-- | Find slave nodes
244−findSlaves :: LocalBackend -> Process [NodeId]
244+findSlaves :: Backend -> Process [NodeId]
245findSlaves backend = do
245findSlaves backend = do
246 nodes <- liftIO $ findPeers backend 1000000
246 nodes <- liftIO $ findPeers backend 1000000
247 -- Fire of asynchronous requests for the slave controller
247 -- Fire of asynchronous requests for the slave controller
@@ -254,7 +254,7 @@ findSlaves backend = do
254 ])
254 ])
255
255
256-- | Terminate all slaves
256-- | Terminate all slaves
257−terminateAllSlaves :: LocalBackend -> Process ()
257+terminateAllSlaves :: Backend -> Process ()
258terminateAllSlaves backend = do
258terminateAllSlaves backend = do
259 slaves <- findSlaves backend
259 slaves <- findSlaves backend
260 forM_ slaves terminateSlave
260 forM_ slaves terminateSlave
@@ -272,7 +272,7 @@ terminateAllSlaves backend = do
272-- Terminates when the specified process terminates. If you want to terminate
272-- Terminates when the specified process terminates. If you want to terminate
273-- the slaves when the master terminates, you should manually call
273-- the slaves when the master terminates, you should manually call
274-- 'terminateAllSlaves'.
274-- 'terminateAllSlaves'.
275−startMaster :: LocalBackend -> ([NodeId] -> Process ()) -> IO ()
275+startMaster :: Backend -> ([NodeId] -> Process ()) -> IO ()
276startMaster backend proc = do
276startMaster backend proc = do
277 node <- newLocalNode backend
277 node <- newLocalNode backend
278 Node.runProcess node $ do
278 Node.runProcess node $ do
@@ -284,8 +284,8 @@ startMaster backend proc = do
284-- Accessors --
284-- Accessors --
285--------------------------------------------------------------------------------
285--------------------------------------------------------------------------------
286
286
287−localNodes :: Accessor LocalBackendState [Node.LocalNode]
287+localNodes :: Accessor BackendState [Node.LocalNode]
288localNodes = accessor _localNodes (\ns st -> st { _localNodes = ns })
288localNodes = accessor _localNodes (\ns st -> st { _localNodes = ns })
289
289
290−peers :: Accessor LocalBackendState (Set NodeId)
290+peers :: Accessor BackendState (Set NodeId)
291peers = accessor _peers (\ps st -> st { _peers = ps })
291peers = accessor _peers (\ps st -> st { _peers = ps })
distributed-process/src/Control/Distributed/Process/Internal/Multicast.hs → distributed-process-simplelocalnet/src/Control/Distributed/Process/Backend/SimpleLocalnet/Internal/Multicast.hsrenamed+7−5
@@ -1,6 +1,6 @@
1-- | Multicast utilities
1-- | Multicast utilities
2{-# OPTIONS_GHC -fno-warn-orphans #-}
2{-# OPTIONS_GHC -fno-warn-orphans #-}
3−module Control.Distributed.Process.Internal.Multicast (initMulticast) where
3+module Control.Distributed.Process.Backend.SimpleLocalnet.Internal.Multicast (initMulticast) where
4
4
5import Data.Function (on)
5import Data.Function (on)
6import Data.Map (Map)
6import Data.Map (Map)
@@ -35,12 +35,14 @@ import Network.Multicast (multicastSender, multicastReceiver)
35-- message size; if you do, all subsequent communication will probably fail.
35-- message size; if you do, all subsequent communication will probably fail.
36--
36--
37-- Returns a reader and a writer.
37-- Returns a reader and a writer.
38+--
39+-- NOTE: By rights the two functions should be "locally" polymorphic in 'a',
40+-- but this requires impredicative types.
41+initMulticast :: forall a. Binary a
38−initMulticast :: HostName -- ^ Multicast IP
42+ => HostName -- ^ Multicast IP
39 -> PortNumber -- ^ Port number
43 -> PortNumber -- ^ Port number
40 -> Int -- ^ Maximum message size
44 -> Int -- ^ Maximum message size
41− -> IO ( forall a. Binary a => IO (a, SockAddr)
45+ -> IO (IO (a, SockAddr), a -> IO ())
42− , forall a. Binary a => a -> IO ()
43− )
44initMulticast host port bufferSize = do
46initMulticast host port bufferSize = do
45 (sendSock, sendAddr) <- multicastSender host port
47 (sendSock, sendAddr) <- multicastSender host port
46 readSock <- multicastReceiver host port
48 readSock <- multicastReceiver host port
distributed-process/tests/TestLocalBackend.hs → distributed-process-simplelocalnet/tests/TestSimpleLocalnet.hsrenamed+2−2
@@ -1,9 +1,9 @@
1import System.Environment (getArgs, getProgName)
1import System.Environment (getArgs, getProgName)
2import Control.Distributed.Process (NodeId, Process, liftIO)
2import Control.Distributed.Process (NodeId, Process, liftIO)
3import Control.Distributed.Process.Node (initRemoteTable)
3import Control.Distributed.Process.Node (initRemoteTable)
4−import Control.Distributed.Process.Backend.Local
4+import Control.Distributed.Process.Backend.SimpleLocalnet
5
5
6−master :: LocalBackend -> [NodeId] -> Process ()
6+master :: Backend -> [NodeId] -> Process ()
7master backend slaves = do
7master backend slaves = do
8 liftIO . putStrLn $ "Slaves: " ++ show slaves
8 liftIO . putStrLn $ "Slaves: " ++ show slaves
9 terminateAllSlaves backend
9 terminateAllSlaves backend
distributed-process-simplelocalnet/tests/runTestSimpleLocalnet.hsnew file+11
@@ -0,0 +1,11 @@
1+#!/bin/bash
2+TestSimpleLocalnet=dist/build/TestSimpleLocalnet/TestSimpleLocalnet
3+$TestSimpleLocalnet slave 127.0.0.1 8080 &
4+sleep 1
5+$TestSimpleLocalnet slave 127.0.0.1 8081 &
6+sleep 1
7+$TestSimpleLocalnet slave 127.0.0.1 8082 &
8+sleep 1
9+$TestSimpleLocalnet slave 127.0.0.1 8083 &
10+sleep 1
11+$TestSimpleLocalnet master 127.0.0.1 8084
distributed-process/LICENSE+1−1
@@ -1,4 +1,4 @@
1−Copyright Well-Typed LLP, 2011
1+Copyright Well-Typed LLP, 2011-2012
2
2
3All rights reserved.
3All rights reserved.
4
4
distributed-process/distributed-process.cabal+111−83
@@ -1,102 +1,130 @@
1−Name: distributed-process
1+Name: distributed-process
2−Version: 0.1.0
2+Version: 0.2.0
3−Description: Distributed processes for message based concurrency.
3+Cabal-Version: >=1.8
4+Build-Type: Simple
4−License: BSD3
5+License: BSD3
5−License-file: LICENSE
6+License-File: LICENSE
7+Copyright: Well-Typed LLP
6−Author: Duncan Coutts, Nicolas Wu, Edsko de Vries
8+Author: Duncan Coutts, Nicolas Wu, Edsko de Vries
7−Maintainer: duncan@well-typed.com
9+Maintainer: edsko@well-typed.com, dcoutts@well-typed.com
10+Stability: experimental
8−Homepage: http://github.com/haskell-distributed/
11+Homepage: http://github.com/haskell-distributed/distributed-process
9−Build-Type: Simple
12+Bug-Reports: mailto:edsko@well-typed.com
10−Cabal-Version: >=1.2
13+Synopsis: Cloud Haskell: Erlang-style concurrency in Haskell
14+Description: This is an implementation of Cloud Haskell, as described in
15+ /Towards Haskell in the Cloud/ by Jeff Epstein, Andrew Black,
16+ and Simon Peyton Jones
17+ (<http://research.microsoft.com/en-us/um/people/simonpj/papers/parallel/>),
18+ although some of the details are different. The precise message
19+ passing semantics are based on /A unified semantics for future
20+ Erlang/ by Hans Svensson, Lars-Åke Fredlund and Clara Benac
21+ Earle.
22+
23+ You will probably also want to install a Cloud Haskell backend such
24+ as distributed-process-simplelocalnet.
25+Tested-With: GHC==7.2.2 GHC==7.4.1 GHC==7.4.2
26+Category: Control
11
27
12Library
28Library
13− Build-Depends: base >= 3 && < 5,
29+ Build-Depends: base >= 4.4 && < 5,
14− bytestring >= 0.9,
15− containers >= 0.4,
16− mtl >= 2.0,
17− binary,
30+ binary >= 0.5 && < 0.6,
31+ network-transport >= 0.2 && < 0.3,
32+ stm >= 2.4 && < 2.5,
18− transformers,
33+ transformers >= 0.2 && < 0.4,
34+ mtl >= 2.0 && < 2.2,
19− data-accessor,
35+ data-accessor >= 0.2 && < 0.3,
20− random,
36+ bytestring >= 0.9 && < 0.10,
37+ containers >= 0.4 && < 0.5,
38+ old-locale >= 1.0 && < 1.1,
39+ time >= 1.2 && < 1.3,
21− template-haskell,
40+ template-haskell >= 2.6 && < 2.7,
22− stm,
41+ random >= 1.0 && < 1.1,
23− ghc-prim,
42+ ghc-prim >= 0.2 && < 0.3
24− network,
25− network-multicast,
26− time,
27− old-locale,
28− network-transport >= 0.1
29 Exposed-modules: Control.Distributed.Process,
43 Exposed-modules: Control.Distributed.Process,
30 Control.Distributed.Process.Serializable,
44 Control.Distributed.Process.Serializable,
31 Control.Distributed.Process.Closure,
45 Control.Distributed.Process.Closure,
32− Control.Distributed.Process.Node
46+ Control.Distributed.Process.Node,
47+ Control.Distributed.Process.Internal.Primitives,
48+ Control.Distributed.Process.Internal.CQueue,
49+ Control.Distributed.Process.Internal.Dynamic,
33− Control.Distributed.Process.Backend.Local
50+ Control.Distributed.Process.Internal.Closure,
34− Extensions: ExplicitForAll, ScopedTypeVariables, GeneralizedNewtypeDeriving, FlexibleInstances, UndecidableInstances, MultiParamTypeClasses, DeriveDataTypeable, TemplateHaskell, ExistentialQuantification, RankNTypes, GADTs, ImpredicativeTypes
51+ Control.Distributed.Process.Internal.TypeRep,
52+ Control.Distributed.Process.Internal.MessageT,
53+ Control.Distributed.Process.Internal.Types,
54+ Control.Distributed.Process.Internal.Closure.BuiltIn,
55+ Control.Distributed.Process.Internal.Closure.Combinators,
56+ Control.Distributed.Process.Internal.Closure.TH,
57+ Control.Distributed.Process.Internal.Node
58+ Extensions: RankNTypes,
59+ ScopedTypeVariables,
60+ FlexibleInstances,
61+ UndecidableInstances,
62+ ExistentialQuantification,
63+ GADTs,
64+ GeneralizedNewtypeDeriving,
65+ DeriveDataTypeable,
66+ TemplateHaskell
35 ghc-options: -Wall
67 ghc-options: -Wall
36 HS-Source-Dirs: src
68 HS-Source-Dirs: src
37
69
38Test-Suite TestCH
70Test-Suite TestCH
39 Type: exitcode-stdio-1.0
71 Type: exitcode-stdio-1.0
40 Main-Is: TestCH.hs
72 Main-Is: TestCH.hs
41− Build-Depends: base,
73+ Build-Depends: base >= 4.4 && < 5,
42− bytestring,
43− containers,
44− mtl,
45− binary,
74+ binary >= 0.5 && < 0.6,
75+ network-transport >= 0.2 && < 0.3,
76+ network-transport-tcp >= 0.2 && < 0.3,
77+ stm >= 2.4 && < 2.5,
46− transformers,
78+ transformers >= 0.2 && < 0.4,
79+ mtl >= 2.0 && < 2.2,
47− data-accessor,
80+ data-accessor >= 0.2 && < 0.3,
48− random,
81+ bytestring >= 0.9 && < 0.10,
49− ansi-terminal,
82+ containers >= 0.4 && < 0.5,
83+ old-locale >= 1.0 && < 1.1,
84+ time >= 1.2 && < 1.3,
50− template-haskell,
85+ template-haskell >= 2.6 && < 2.7,
51− stm,
86+ random >= 1.0 && < 1.1,
52− ghc-prim,
87+ ghc-prim >= 0.2 && < 0.3,
53− time,
88+ ansi-terminal >= 0.5 && < 0.6
54− old-locale,
89+ Extensions: RankNTypes,
55− network-transport >= 0.1
90+ ScopedTypeVariables,
56− Extensions: ExplicitForAll, ScopedTypeVariables, GeneralizedNewtypeDeriving, FlexibleInstances, UndecidableInstances, MultiParamTypeClasses, DeriveDataTypeable, TemplateHaskell, ExistentialQuantification, RankNTypes, GADTs, ImpredicativeTypes
91+ FlexibleInstances,
92+ UndecidableInstances,
93+ ExistentialQuantification,
94+ GADTs,
95+ GeneralizedNewtypeDeriving,
96+ DeriveDataTypeable,
97+ TemplateHaskell
57 ghc-options: -Wall -threaded -rtsopts -with-rtsopts=-N -fno-warn-unused-do-bind
98 ghc-options: -Wall -threaded -rtsopts -with-rtsopts=-N -fno-warn-unused-do-bind
58 HS-Source-Dirs: tests src
99 HS-Source-Dirs: tests src
59
100
60−-- Separate test suite for tests that involve closures, as this will be replaced
61−-- once we have proper support for 'static'
62Test-Suite TestClosure
101Test-Suite TestClosure
63 Type: exitcode-stdio-1.0
102 Type: exitcode-stdio-1.0
64 Main-Is: TestClosure.hs
103 Main-Is: TestClosure.hs
65− Build-Depends: base,
104+ Build-Depends: base >= 4.4 && < 5,
66− bytestring,
105+ binary >= 0.5 && < 0.6,
67− containers,
106+ network-transport >= 0.2 && < 0.3,
68− mtl,
107+ network-transport-tcp >= 0.2 && < 0.3,
69− binary,
108+ stm >= 2.4 && < 2.5,
70− transformers,
109+ transformers >= 0.2 && < 0.4,
110+ mtl >= 2.0 && < 2.2,
71− data-accessor,
111+ data-accessor >= 0.2 && < 0.3,
72− random,
112+ bytestring >= 0.9 && < 0.10,
73− ansi-terminal,
113+ containers >= 0.4 && < 0.5,
74− template-haskell,
114+ old-locale >= 1.0 && < 1.1,
75− stm,
76− time,
115+ time >= 1.2 && < 1.3,
77− old-locale,
116+ template-haskell >= 2.6 && < 2.7,
78− network-transport >= 0.1
117+ random >= 1.0 && < 1.1,
79− Extensions: ExplicitForAll, ScopedTypeVariables, GeneralizedNewtypeDeriving, FlexibleInstances, UndecidableInstances, MultiParamTypeClasses, DeriveDataTypeable, TemplateHaskell, ExistentialQuantification, RankNTypes, GADTs, ImpredicativeTypes
118+ ghc-prim >= 0.2 && < 0.3,
80− ghc-options: -Wall -threaded -rtsopts -with-rtsopts=-N -fno-warn-unused-do-bind
119+ ansi-terminal >= 0.5 && < 0.6
81− HS-Source-Dirs: tests src
120+ Extensions: RankNTypes,
82−
121+ ScopedTypeVariables,
83−-- Not a proper test, but we want to use cabal to compile it
122+ FlexibleInstances,
84−Test-Suite TestLocalBackend
123+ UndecidableInstances,
85− Type: exitcode-stdio-1.0
124+ ExistentialQuantification,
86− Main-Is: TestLocalBackend.hs
125+ GADTs,
87− Build-Depends: base,
126+ GeneralizedNewtypeDeriving,
88− bytestring,
127+ DeriveDataTypeable,
89− containers,
128+ TemplateHaskell
90− mtl,
91− binary,
92− transformers,
93− data-accessor,
94− random,
95− ansi-terminal,
96− template-haskell,
97− stm,
98− old-locale,
99− network-transport >= 0.1
100− Extensions: ExplicitForAll, ScopedTypeVariables, GeneralizedNewtypeDeriving, FlexibleInstances, UndecidableInstances, MultiParamTypeClasses, DeriveDataTypeable, TemplateHaskell, ExistentialQuantification, RankNTypes, GADTs, ImpredicativeTypes
101 ghc-options: -Wall -threaded -rtsopts -with-rtsopts=-N -fno-warn-unused-do-bind
129 ghc-options: -Wall -threaded -rtsopts -with-rtsopts=-N -fno-warn-unused-do-bind
102 HS-Source-Dirs: tests src
130 HS-Source-Dirs: tests src
distributed-process/tests/runTestLocalBackend.hsdeleted−11
@@ -1,11 +0,0 @@
1−#!/bin/bash
2−TestLocalBackend=dist/build/TestLocalBackend/TestLocalBackend
3−$TestLocalBackend slave 127.0.0.1 8080 &
4−sleep 1
5−$TestLocalBackend slave 127.0.0.1 8081 &
6−sleep 1
7−$TestLocalBackend slave 127.0.0.1 8082 &
8−sleep 1
9−$TestLocalBackend slave 127.0.0.1 8083 &
10−sleep 1
11−$TestLocalBackend master 127.0.0.1 8084