cloudi 2.0.1 → 2.0.2
raw patch · 3 files changed
+23/−16 lines, 3 filesPVP ok
version bump matches the API change (PVP)
API changes (from Hackage documentation)
+ Foreign.CloudI: priorityDefault :: T s -> Int
Files
- LICENSE +1/−1
- cloudi.cabal +2/−2
- src/Foreign/CloudI.hs +20/−13
LICENSE view
@@ -1,6 +1,6 @@ MIT License -Copyright (c) 2017-2020 Michael Truog <mjtruog at protonmail dot com> +Copyright (c) 2017-2021 Michael Truog <mjtruog at protonmail dot com> Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"),
cloudi.cabal view
@@ -1,5 +1,5 @@ name: cloudi-version: 2.0.1+version: 2.0.2 synopsis: Haskell CloudI API description: Haskell CloudI API (see https://cloudi.org for more details) homepage: https://github.com/CloudI/cloudi_api_haskell@@ -7,7 +7,7 @@ license-file: LICENSE author: Michael Truog maintainer: mjtruog at protonmail dot com-copyright: 2017-2020 Michael Truog+copyright: 2017-2021 Michael Truog category: Foreign stability: provisional build-type: Simple
src/Foreign/CloudI.hs view
@@ -5,7 +5,7 @@ MIT License - Copyright (c) 2017-2020 Michael Truog <mjtruog at protonmail dot com>+ Copyright (c) 2017-2021 Michael Truog <mjtruog at protonmail dot com> Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"),@@ -68,6 +68,7 @@ , timeoutAsync , timeoutSync , timeoutTerminate+ , priorityDefault , poll , shutdown , threadCreate@@ -310,11 +311,11 @@ sendAsync api0@Instance.T{ Instance.terminateException = terminateException , Instance.timeoutAsync = timeoutAsync'- , Instance.priorityDefault = priorityDefault}+ , Instance.priorityDefault = priorityDefault'} name request timeoutOpt requestInfoOpt priorityOpt = let timeout = fromMaybe timeoutAsync' timeoutOpt requestInfo = fromMaybe ByteString.empty requestInfoOpt- priority = fromMaybe priorityDefault priorityOpt+ priority = fromMaybe priorityDefault' priorityOpt sendAsyncTerms = Erlang.OtpErlangTuple [ Erlang.OtpErlangAtom (Char8.pack "send_async") , Erlang.OtpErlangString name@@ -345,11 +346,11 @@ sendSync api0@Instance.T{ Instance.terminateException = terminateException , Instance.timeoutSync = timeoutSync'- , Instance.priorityDefault = priorityDefault}+ , Instance.priorityDefault = priorityDefault'} name request timeoutOpt requestInfoOpt priorityOpt = let timeout = fromMaybe timeoutSync' timeoutOpt requestInfo = fromMaybe ByteString.empty requestInfoOpt- priority = fromMaybe priorityDefault priorityOpt+ priority = fromMaybe priorityDefault' priorityOpt sendSyncTerms = Erlang.OtpErlangTuple [ Erlang.OtpErlangAtom (Char8.pack "send_sync") , Erlang.OtpErlangString name@@ -384,11 +385,11 @@ mcastAsync api0@Instance.T{ Instance.terminateException = terminateException , Instance.timeoutAsync = timeoutAsync'- , Instance.priorityDefault = priorityDefault}+ , Instance.priorityDefault = priorityDefault'} name request timeoutOpt requestInfoOpt priorityOpt = let timeout = fromMaybe timeoutAsync' timeoutOpt requestInfo = fromMaybe ByteString.empty requestInfoOpt- priority = fromMaybe priorityDefault priorityOpt+ priority = fromMaybe priorityDefault' priorityOpt mcastAsyncTerms = Erlang.OtpErlangTuple [ Erlang.OtpErlangAtom (Char8.pack "mcast_async") , Erlang.OtpErlangString name@@ -646,6 +647,12 @@ timeoutTerminate Instance.T{Instance.timeoutTerminate = timeoutTerminate'} = timeoutTerminate' +-- | returns the default service request send priority+-- from the service configuration+priorityDefault :: Instance.T s -> Int+priorityDefault Instance.T{Instance.priorityDefault = priorityDefault'} =+ priorityDefault'+ nullResponse :: RequestType -> ByteString -> ByteString -> ByteString -> ByteString -> Int -> Int -> ByteString -> Source -> s -> Instance.T s -> IO (Instance.Response s)@@ -800,12 +807,12 @@ processCount' <- Get.getWord32host timeoutAsync' <- Get.getWord32host timeoutSync' <- Get.getWord32host- priorityDefault <- Get.getInt8+ priorityDefault' <- Get.getInt8 let api1 = Instance.reinit api0 processCount' timeoutAsync' timeoutSync'- priorityDefault+ priorityDefault' empty <- Get.isEmpty if not empty then handleEvents messages api1 external 0@@ -838,7 +845,7 @@ timeoutAsync' <- Get.getWord32host timeoutSync' <- Get.getWord32host timeoutTerminate' <- Get.getWord32host- priorityDefault <- Get.getInt8+ priorityDefault' <- Get.getInt8 let api1 = Instance.init api0 processIndex' processCount'@@ -849,7 +856,7 @@ timeoutAsync' timeoutSync' timeoutTerminate'- priorityDefault+ priorityDefault' empty <- Get.isEmpty if not empty then handleEvents messages api1 external 0@@ -942,12 +949,12 @@ processCount' <- Get.getWord32host timeoutAsync' <- Get.getWord32host timeoutSync' <- Get.getWord32host- priorityDefault <- Get.getInt8+ priorityDefault' <- Get.getInt8 let api1 = Instance.reinit api0 processCount' timeoutAsync' timeoutSync'- priorityDefault+ priorityDefault' empty <- Get.isEmpty if not empty then pollRequestDataGet messages api1 external