distributed-process-client-server 0.2.7.1 → 0.2.8.0
raw patch · 8 files changed
+23/−40 lines, 8 filesdep +tastydep +tasty-hunitdep −HUnitdep −ansi-terminaldep −ghc-primdep ~containersdep ~deepseqdep ~fingertreePVP: major bump suggested
API removals or changes: PVP suggests a major version bump
Dependencies added: tasty, tasty-hunit
Dependencies removed: HUnit, ansi-terminal, ghc-prim, hashable, network, test-framework, test-framework-hunit, time, transformers, unordered-containers
Dependency ranges changed: containers, deepseq, fingertree
API changes (from Hackage documentation)
- Control.Distributed.Process.ManagedProcess: act :: GenProcess s () -> Action s
+ Control.Distributed.Process.ManagedProcess: act :: forall s. GenProcess s () -> Action s
- Control.Distributed.Process.ManagedProcess: push :: Message -> GenProcess s ()
+ Control.Distributed.Process.ManagedProcess: push :: forall s. Message -> GenProcess s ()
- Control.Distributed.Process.ManagedProcess: type Action s = Process ProcessAction s
+ Control.Distributed.Process.ManagedProcess: type Action s = Process (ProcessAction s)
- Control.Distributed.Process.ManagedProcess: type InitHandler a s = a -> Process InitResult s
+ Control.Distributed.Process.ManagedProcess: type InitHandler a s = a -> Process (InitResult s)
- Control.Distributed.Process.ManagedProcess: type Reply b s = Process ProcessReply b s
+ Control.Distributed.Process.ManagedProcess: type Reply b s = Process (ProcessReply b s)
- Control.Distributed.Process.ManagedProcess: type StatelessHandler s a = a -> s -> Action s
+ Control.Distributed.Process.ManagedProcess: type StatelessHandler s a = a -> (s -> Action s)
- Control.Distributed.Process.ManagedProcess.Client: call :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process b
+ Control.Distributed.Process.ManagedProcess.Client: call :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process b
- Control.Distributed.Process.ManagedProcess.Client: callAsync :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Async b)
+ Control.Distributed.Process.ManagedProcess.Client: callAsync :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Async b)
- Control.Distributed.Process.ManagedProcess.Client: callChan :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process (ReceivePort b)
+ Control.Distributed.Process.ManagedProcess.Client: callChan :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process (ReceivePort b)
- Control.Distributed.Process.ManagedProcess.Client: callSTM :: Addressable s => s -> (a -> STM ()) -> STM b -> a -> Process (Either ExitReason b)
+ Control.Distributed.Process.ManagedProcess.Client: callSTM :: forall s a b. Addressable s => s -> (a -> STM ()) -> STM b -> a -> Process (Either ExitReason b)
- Control.Distributed.Process.ManagedProcess.Client: callTimeout :: (Addressable s, Serializable a, Serializable b) => s -> a -> TimeInterval -> Process (Maybe b)
+ Control.Distributed.Process.ManagedProcess.Client: callTimeout :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> TimeInterval -> Process (Maybe b)
- Control.Distributed.Process.ManagedProcess.Client: cast :: (Addressable a, Serializable m) => a -> m -> Process ()
+ Control.Distributed.Process.ManagedProcess.Client: cast :: forall a m. (Addressable a, Serializable m) => a -> m -> Process ()
- Control.Distributed.Process.ManagedProcess.Client: flushPendingCalls :: Serializable b => TimeInterval -> (b -> Process b) -> Process (Maybe b)
+ Control.Distributed.Process.ManagedProcess.Client: flushPendingCalls :: forall b. Serializable b => TimeInterval -> (b -> Process b) -> Process (Maybe b)
- Control.Distributed.Process.ManagedProcess.Client: safeCall :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Either ExitReason b)
+ Control.Distributed.Process.ManagedProcess.Client: safeCall :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Either ExitReason b)
- Control.Distributed.Process.ManagedProcess.Client: syncCallChan :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process b
+ Control.Distributed.Process.ManagedProcess.Client: syncCallChan :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process b
- Control.Distributed.Process.ManagedProcess.Client: syncSafeCallChan :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Either ExitReason b)
+ Control.Distributed.Process.ManagedProcess.Client: syncSafeCallChan :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Either ExitReason b)
- Control.Distributed.Process.ManagedProcess.Client: tryCall :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Maybe b)
+ Control.Distributed.Process.ManagedProcess.Client: tryCall :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Maybe b)
- Control.Distributed.Process.ManagedProcess.Internal.GenProcess: act :: GenProcess s () -> Action s
+ Control.Distributed.Process.ManagedProcess.Internal.GenProcess: act :: forall s. GenProcess s () -> Action s
- Control.Distributed.Process.ManagedProcess.Internal.GenProcess: enqueue :: Message -> GenProcess s ()
+ Control.Distributed.Process.ManagedProcess.Internal.GenProcess: enqueue :: forall s. Message -> GenProcess s ()
- Control.Distributed.Process.ManagedProcess.Internal.GenProcess: eval :: GenProcess s (ProcessAction s) -> Action s
+ Control.Distributed.Process.ManagedProcess.Internal.GenProcess: eval :: forall s. GenProcess s (ProcessAction s) -> Action s
- Control.Distributed.Process.ManagedProcess.Internal.GenProcess: gets :: (ProcessState s -> a) -> GenProcess s a
+ Control.Distributed.Process.ManagedProcess.Internal.GenProcess: gets :: forall s a. (ProcessState s -> a) -> GenProcess s a
- Control.Distributed.Process.ManagedProcess.Internal.GenProcess: push :: Message -> GenProcess s ()
+ Control.Distributed.Process.ManagedProcess.Internal.GenProcess: push :: forall s. Message -> GenProcess s ()
- Control.Distributed.Process.ManagedProcess.Internal.Types: DispatchSTM :: STM a -> (s -> a -> Process (ProcessAction s)) -> Match Message -> (forall m. () => (Message -> m) -> Match m) -> ExternDispatcher s
+ Control.Distributed.Process.ManagedProcess.Internal.Types: DispatchSTM :: STM a -> (s -> a -> Process (ProcessAction s)) -> Match Message -> (forall m. (Message -> m) -> Match m) -> ExternDispatcher s
- Control.Distributed.Process.ManagedProcess.Internal.Types: [matchAnyStm] :: ExternDispatcher s -> forall m. () => (Message -> m) -> Match m
+ Control.Distributed.Process.ManagedProcess.Internal.Types: [matchAnyStm] :: ExternDispatcher s -> forall m. (Message -> m) -> Match m
- Control.Distributed.Process.ManagedProcess.Internal.Types: caller :: Message a b -> Maybe Recipient
+ Control.Distributed.Process.ManagedProcess.Internal.Types: caller :: forall a b. Message a b -> Maybe Recipient
- Control.Distributed.Process.ManagedProcess.Internal.Types: class ExternMatcher (d :: Type -> Type)
+ Control.Distributed.Process.ManagedProcess.Internal.Types: class ExternMatcher d
- Control.Distributed.Process.ManagedProcess.Internal.Types: class MessageMatcher (d :: Type -> Type)
+ Control.Distributed.Process.ManagedProcess.Internal.Types: class MessageMatcher d
- Control.Distributed.Process.ManagedProcess.Internal.Types: initCall :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process (CallRef b)
+ Control.Distributed.Process.ManagedProcess.Internal.Types: initCall :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process (CallRef b)
- Control.Distributed.Process.ManagedProcess.Internal.Types: rejectToCaller :: Message a b -> String -> Process ()
+ Control.Distributed.Process.ManagedProcess.Internal.Types: rejectToCaller :: forall a b. Message a b -> String -> Process ()
- Control.Distributed.Process.ManagedProcess.Internal.Types: type Action s = Process ProcessAction s
+ Control.Distributed.Process.ManagedProcess.Internal.Types: type Action s = Process (ProcessAction s)
- Control.Distributed.Process.ManagedProcess.Internal.Types: type InitHandler a s = a -> Process InitResult s
+ Control.Distributed.Process.ManagedProcess.Internal.Types: type InitHandler a s = a -> Process (InitResult s)
- Control.Distributed.Process.ManagedProcess.Internal.Types: type Reply b s = Process ProcessReply b s
+ Control.Distributed.Process.ManagedProcess.Internal.Types: type Reply b s = Process (ProcessReply b s)
- Control.Distributed.Process.ManagedProcess.Internal.Types: type State s = IORef ProcessState s
+ Control.Distributed.Process.ManagedProcess.Internal.Types: type State s = IORef (ProcessState s)
- Control.Distributed.Process.ManagedProcess.Internal.Types: type StatelessHandler s a = a -> s -> Action s
+ Control.Distributed.Process.ManagedProcess.Internal.Types: type StatelessHandler s a = a -> (s -> Action s)
- Control.Distributed.Process.ManagedProcess.Internal.Types: unsafeInitCall :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (CallRef b)
+ Control.Distributed.Process.ManagedProcess.Internal.Types: unsafeInitCall :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (CallRef b)
- Control.Distributed.Process.ManagedProcess.Internal.Types: waitResponse :: Serializable b => Maybe TimeInterval -> CallRef b -> Process (Maybe (Either ExitReason b))
+ Control.Distributed.Process.ManagedProcess.Internal.Types: waitResponse :: forall b. Serializable b => Maybe TimeInterval -> CallRef b -> Process (Maybe (Either ExitReason b))
- Control.Distributed.Process.ManagedProcess.Server: become :: ProcessDefinition s -> s -> Action s
+ Control.Distributed.Process.ManagedProcess.Server: become :: forall s. ProcessDefinition s -> s -> Action s
- Control.Distributed.Process.ManagedProcess.Server: condition :: (Serializable a, Serializable b) => (a -> b -> Bool) -> Condition a b
+ Control.Distributed.Process.ManagedProcess.Server: condition :: forall a b. (Serializable a, Serializable b) => (a -> b -> Bool) -> Condition a b
- Control.Distributed.Process.ManagedProcess.Server: handleRaw :: ActionHandler s Message -> DeferredDispatcher s
+ Control.Distributed.Process.ManagedProcess.Server: handleRaw :: forall s. ActionHandler s Message -> DeferredDispatcher s
- Control.Distributed.Process.ManagedProcess.Server.Gen: act :: GenProcess s () -> Action s
+ Control.Distributed.Process.ManagedProcess.Server.Gen: act :: forall s. GenProcess s () -> Action s
- Control.Distributed.Process.ManagedProcess.Server.Gen: become :: ProcessDefinition s -> GenProcess s (ProcessAction s)
+ Control.Distributed.Process.ManagedProcess.Server.Gen: become :: forall s. ProcessDefinition s -> GenProcess s (ProcessAction s)
- Control.Distributed.Process.ManagedProcess.Server.Gen: enqueue :: Message -> GenProcess s ()
+ Control.Distributed.Process.ManagedProcess.Server.Gen: enqueue :: forall s. Message -> GenProcess s ()
- Control.Distributed.Process.ManagedProcess.Server.Gen: eval :: GenProcess s (ProcessAction s) -> Action s
+ Control.Distributed.Process.ManagedProcess.Server.Gen: eval :: forall s. GenProcess s (ProcessAction s) -> Action s
- Control.Distributed.Process.ManagedProcess.Server.Gen: gets :: (ProcessState s -> a) -> GenProcess s a
+ Control.Distributed.Process.ManagedProcess.Server.Gen: gets :: forall s a. (ProcessState s -> a) -> GenProcess s a
- Control.Distributed.Process.ManagedProcess.Server.Gen: push :: Message -> GenProcess s ()
+ Control.Distributed.Process.ManagedProcess.Server.Gen: push :: forall s. Message -> GenProcess s ()
- Control.Distributed.Process.ManagedProcess.Server.Gen: reply :: Serializable r => r -> GenProcess s (ProcessReply r s)
+ Control.Distributed.Process.ManagedProcess.Server.Gen: reply :: forall r s. Serializable r => r -> GenProcess s (ProcessReply r s)
- Control.Distributed.Process.ManagedProcess.Server.Gen: replyWith :: Serializable r => r -> ProcessAction s -> GenProcess s (ProcessReply r s)
+ Control.Distributed.Process.ManagedProcess.Server.Gen: replyWith :: forall r s. Serializable r => r -> ProcessAction s -> GenProcess s (ProcessReply r s)
- Control.Distributed.Process.ManagedProcess.Server.Priority: act :: GenProcess s () -> Action s
+ Control.Distributed.Process.ManagedProcess.Server.Priority: act :: forall s. GenProcess s () -> Action s
- Control.Distributed.Process.ManagedProcess.Server.Priority: api_ :: (Serializable m, Serializable b) => (m -> Process Bool) -> (s -> Message m b -> Process (Filter s)) -> FilterHandler s
+ Control.Distributed.Process.ManagedProcess.Server.Priority: api_ :: forall m b s. (Serializable m, Serializable b) => (m -> Process Bool) -> (s -> Message m b -> Process (Filter s)) -> FilterHandler s
- Control.Distributed.Process.ManagedProcess.Server.Priority: check :: FilterHandler s -> DispatchFilter s
+ Control.Distributed.Process.ManagedProcess.Server.Priority: check :: forall s. FilterHandler s -> DispatchFilter s
- Control.Distributed.Process.ManagedProcess.Server.Priority: crash :: s -> ExitReason -> Process (Filter s)
+ Control.Distributed.Process.ManagedProcess.Server.Priority: crash :: forall s. s -> ExitReason -> Process (Filter s)
- Control.Distributed.Process.ManagedProcess.Server.Priority: ensure :: (s -> Bool) -> DispatchFilter s
+ Control.Distributed.Process.ManagedProcess.Server.Priority: ensure :: forall s. (s -> Bool) -> DispatchFilter s
- Control.Distributed.Process.ManagedProcess.Server.Priority: push :: Message -> GenProcess s ()
+ Control.Distributed.Process.ManagedProcess.Server.Priority: push :: forall s. Message -> GenProcess s ()
- Control.Distributed.Process.ManagedProcess.Server.Priority: raw :: (s -> Message -> Process Bool) -> (s -> Message -> Process (Maybe (Filter s))) -> FilterHandler s
+ Control.Distributed.Process.ManagedProcess.Server.Priority: raw :: forall s. (s -> Message -> Process Bool) -> (s -> Message -> Process (Maybe (Filter s))) -> FilterHandler s
- Control.Distributed.Process.ManagedProcess.Server.Priority: raw_ :: (Message -> Process Bool) -> (s -> Message -> Process (Maybe (Filter s))) -> FilterHandler s
+ Control.Distributed.Process.ManagedProcess.Server.Priority: raw_ :: forall s. (Message -> Process Bool) -> (s -> Message -> Process (Maybe (Filter s))) -> FilterHandler s
- Control.Distributed.Process.ManagedProcess.Server.Priority: safely :: (s -> Message -> Bool) -> DispatchFilter s
+ Control.Distributed.Process.ManagedProcess.Server.Priority: safely :: forall s. (s -> Message -> Bool) -> DispatchFilter s
- Control.Distributed.Process.ManagedProcess.Server.Restricted: continue :: RestrictedProcess s RestrictedAction
+ Control.Distributed.Process.ManagedProcess.Server.Restricted: continue :: forall s. RestrictedProcess s RestrictedAction
- Control.Distributed.Process.ManagedProcess.Server.Restricted: handleTimeout :: (Delay -> RestrictedProcess s RestrictedAction) -> TimeoutHandler s
+ Control.Distributed.Process.ManagedProcess.Server.Restricted: handleTimeout :: forall s. (Delay -> RestrictedProcess s RestrictedAction) -> TimeoutHandler s
- Control.Distributed.Process.ManagedProcess.Server.Restricted: hibernate :: TimeInterval -> RestrictedProcess s RestrictedAction
+ Control.Distributed.Process.ManagedProcess.Server.Restricted: hibernate :: forall s. TimeInterval -> RestrictedProcess s RestrictedAction
- Control.Distributed.Process.ManagedProcess.Server.Restricted: stop :: ExitReason -> RestrictedProcess s RestrictedAction
+ Control.Distributed.Process.ManagedProcess.Server.Restricted: stop :: forall s. ExitReason -> RestrictedProcess s RestrictedAction
- Control.Distributed.Process.ManagedProcess.Server.Restricted: timeoutAfter :: Delay -> RestrictedProcess s RestrictedAction
+ Control.Distributed.Process.ManagedProcess.Server.Restricted: timeoutAfter :: forall s. Delay -> RestrictedProcess s RestrictedAction
- Control.Distributed.Process.ManagedProcess.UnsafeClient: call :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process b
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: call :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process b
- Control.Distributed.Process.ManagedProcess.UnsafeClient: callAsync :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Async b)
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: callAsync :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Async b)
- Control.Distributed.Process.ManagedProcess.UnsafeClient: callChan :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (ReceivePort b)
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: callChan :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (ReceivePort b)
- Control.Distributed.Process.ManagedProcess.UnsafeClient: callTimeout :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> TimeInterval -> Process (Maybe b)
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: callTimeout :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> TimeInterval -> Process (Maybe b)
- Control.Distributed.Process.ManagedProcess.UnsafeClient: cast :: (Addressable a, NFSerializable m) => a -> m -> Process ()
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: cast :: forall a m. (Addressable a, NFSerializable m) => a -> m -> Process ()
- Control.Distributed.Process.ManagedProcess.UnsafeClient: flushPendingCalls :: NFSerializable b => TimeInterval -> (b -> Process b) -> Process (Maybe b)
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: flushPendingCalls :: forall b. NFSerializable b => TimeInterval -> (b -> Process b) -> Process (Maybe b)
- Control.Distributed.Process.ManagedProcess.UnsafeClient: safeCall :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Either ExitReason b)
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: safeCall :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Either ExitReason b)
- Control.Distributed.Process.ManagedProcess.UnsafeClient: syncCallChan :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process b
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: syncCallChan :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process b
- Control.Distributed.Process.ManagedProcess.UnsafeClient: syncSafeCallChan :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Either ExitReason b)
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: syncSafeCallChan :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Either ExitReason b)
- Control.Distributed.Process.ManagedProcess.UnsafeClient: tryCall :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Maybe b)
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: tryCall :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Maybe b)
Files
- CHANGELOG.md +5/−0
- distributed-process-client-server.cabal +7/−27
- src/Control/Distributed/Process/ManagedProcess.hs +0/−1
- src/Control/Distributed/Process/ManagedProcess/Server/Gen.hs +0/−1
- src/Control/Distributed/Process/ManagedProcess/Timer.hs +0/−1
- tests/TestManagedProcess.hs +5/−4
- tests/TestPrioritisedProcess.hs +4/−4
- tests/TestUtils.hs +2/−2
CHANGELOG.md view
@@ -1,5 +1,10 @@ # Change Log +2025-02-04 Laurent P. René de Cotret <laurent.decotret@outlook.com> 0.2.8.0++* Ported test suite to use `tasty` rather than `test-framework`.+* Removed unused dependencies and addressed some warnings (#467).+ 2024-10-30 David Simmons-Duffin <dsd@caltech.edu> 0.2.7.1 * Bump dependency bound for ansi-terminal
distributed-process-client-server.cabal view
@@ -1,6 +1,6 @@ cabal-version: 3.0 name: distributed-process-client-server-version: 0.2.7.1+version: 0.2.8.0 build-type: Simple license: BSD-3-Clause license-file: LICENCE@@ -16,7 +16,7 @@ development into a set of modules and standards designed to help you build concurrent, distributed applications with relative ease. category: Control-tested-with: GHC==8.10.7 GHC==9.0.2 GHC==9.2.8 GHC==9.4.5 GHC==9.6.4 GHC==9.8.2 GHC==9.10.1+tested-with: GHC==8.10.7 GHC==9.0.2 GHC==9.2.8 GHC==9.4.5 GHC==9.6.4 GHC==9.8.2 GHC==9.10.1 GHC==9.12.1 extra-doc-files: CHANGELOG.md source-repository head@@ -33,6 +33,7 @@ -Wredundant-constraints -fhide-source-paths -Wpartial-fields+ -Wunused-packages library import: warnings@@ -45,12 +46,8 @@ deepseq >= 1.4 && < 1.7, mtl, containers >= 0.6 && < 0.8,- hashable >= 1.2.0.5 && < 1.6,- unordered-containers >= 0.2.3.0 && < 0.3, fingertree < 0.2, stm >= 2.4 && < 2.6,- time > 1.4 && < 1.15,- transformers, exceptions >= 0.10 && < 0.11 hs-source-dirs: src exposed-modules:@@ -73,26 +70,17 @@ x-uses-tf: true build-depends: base >= 4.14 && < 5,- ansi-terminal >= 0.5 && < 1.2,- containers, distributed-process, distributed-process-extras, distributed-process-async, distributed-process-client-server, distributed-process-systest ^>= 0.4, network-transport >= 0.4 && < 0.7,- mtl,- fingertree, network-transport-tcp >= 0.6 && < 0.9, binary >= 0.8 && < 0.9,- deepseq,- network >= 2.3 && < 3.3,- HUnit >= 1.2 && < 2, stm,- test-framework >= 0.6 && < 0.9,- test-framework-hunit,- transformers,- ghc-prim,+ tasty >= 1.5 && <1.6,+ tasty-hunit >=0.10 && <0.11, exceptions other-modules: Counter, ManagedProcessCommon,@@ -111,26 +99,18 @@ x-uses-tf: true build-depends: base >= 4.14 && < 5,- ansi-terminal,- containers, distributed-process, distributed-process-extras, distributed-process-async, distributed-process-client-server, distributed-process-systest ^>= 0.4, network-transport,- mtl,- fingertree, network-transport-tcp, binary, deepseq,- network,- HUnit, stm,- test-framework,- test-framework-hunit,- transformers,- ghc-prim,+ tasty >= 1.5 && <1.6,+ tasty-hunit >=0.10 && <0.11, exceptions other-modules: ManagedProcessCommon, TestUtils
src/Control/Distributed/Process/ManagedProcess.hs view
@@ -651,7 +651,6 @@ import Control.Distributed.Process hiding (call, Message) import Control.Distributed.Process.ManagedProcess.Client import Control.Distributed.Process.ManagedProcess.Server-import qualified Control.Distributed.Process.ManagedProcess.Server.Restricted as R import qualified Control.Distributed.Process.ManagedProcess.Server.Priority as P hiding (reject) import qualified Control.Distributed.Process.ManagedProcess.Internal.GenProcess as Gen import Control.Distributed.Process.ManagedProcess.Internal.GenProcess
src/Control/Distributed/Process/ManagedProcess/Server/Gen.hs view
@@ -97,7 +97,6 @@ , modifyState , setUserTimeout , setProcessState- , GenProcess , peek , push , enqueue
src/Control/Distributed/Process/ManagedProcess/Timer.hs view
@@ -67,7 +67,6 @@ import Data.Binary (Binary) import Data.Maybe (isJust, fromJust) import Data.Typeable (Typeable)-import GHC.Conc (registerDelay) import GHC.Generics --------------------------------------------------------------------------------
tests/TestManagedProcess.hs view
@@ -26,8 +26,8 @@ import Counter import qualified SafeCounter as SafeCounter -import Test.Framework (Test, testGroup)-import Test.Framework.Providers.HUnit (testCase)+import Test.Tasty (TestTree, testGroup)+import Test.Tasty.HUnit (testCase) import TestUtils import ManagedProcessCommon @@ -210,13 +210,14 @@ ] stash result (r /= DiedNormal) -tests :: NT.Transport -> IO [Test]+tests :: NT.Transport -> IO TestTree tests transport = do localNode <- newLocalNode transport initRemoteTable scpid <- newEmptyMVar _ <- forkProcess localNode $ SafeCounter.startCounter 5 >>= stash scpid safeCounter <- takeMVar scpid- return [+ return $ + testGroup "" [ testGroup "Basic Client/Server Functionality" [ testCase "basic call with explicit server reply" (delayedAssertion
tests/TestPrioritisedProcess.hs view
@@ -38,8 +38,8 @@ import Data.Maybe (isNothing, isJust) import Data.Typeable (Typeable) -import Test.Framework (Test, testGroup)-import Test.Framework.Providers.HUnit (testCase)+import Test.Tasty (TestTree, testGroup)+import Test.Tasty.HUnit (testCase) import TestUtils import ManagedProcessCommon @@ -534,10 +534,10 @@ let ms = rights st stash result $ ms == ["we do prioritise", "the longest", "commands", "first"] -tests :: NT.Transport -> IO [Test]+tests :: NT.Transport -> IO TestTree tests transport = do localNode <- newLocalNode transport initRemoteTable- return [+ return $ testGroup "" [ testGroup "basic server functionality matches un-prioritised processes" [ testCase "basic call with explicit server reply" (delayedAssertion
tests/TestUtils.hs view
@@ -18,7 +18,7 @@ import Control.Distributed.Process.Extras import Control.Distributed.Process.Extras.Time import Control.Distributed.Process.Extras.Timer-import Test.Framework (Test, defaultMain)+import Test.Tasty (TestTree, defaultMain) import Network.Transport.TCP import qualified Network.Transport as NT@@ -41,7 +41,7 @@ newLocalNode transport1 initRemoteTable -- | Given a @builder@ function, make and run a test suite on a single transport-testMain :: (NT.Transport -> IO [Test]) -> IO ()+testMain :: (NT.Transport -> IO TestTree) -> IO () testMain builder = do Right (transport, _) <- createTransportExposeInternals (defaultTCPAddr "127.0.0.1" "0") defaultTCPParameters testData <- builder transport