git.iko.soy/distributed-process
on master help sign in
Fix compilation warnings.
commit05797267eeb0b9056cd3c233f754e60baa3244ee authorAlexander Vershilov <alexander.vershilov@gmail.com> dateFri 11 Mar 2016, 02:15 (11 years ago) parent96fa6c3
5 files changed+15−25
compare with master
unifiedsplit
src/Control/Distributed/Process/Debug.hs+3−7 src/Control/Distributed/Process/Management.hs+3−2 src/Control/Distributed/Process/Management/Internal/Agent.hs+2−1 src/Control/Distributed/Process/Management/Internal/Trace/Primitives.hs+2−1 src/Control/Distributed/Process/Node.hs+5−14
src/Control/Distributed/Process/Debug.hs+3−7
@@ -141,17 +141,14 @@ module Control.Distributed.Process.Debug
141141 )
142142 where
143143
144−import Control.Applicative ((<$>))
144+import Control.Applicative
145145import Control.Distributed.Process.Internal.Primitives
146146 ( proxy
147− , finally
148147 , die
149148 , whereis
150149 , send
151150 , receiveWait
152151 , matchIf
153− , finally
154− , try
155152 , monitor
156153 )
157154import Control.Distributed.Process.Internal.Types
@@ -196,12 +193,11 @@ import Control.Exception (SomeException)
196193
197194import Control.Monad.IO.Class (liftIO)
198195import Control.Monad.Reader (ask)
196+import Control.Monad.Catch (finally, try)
199197
200198import Data.Binary()
201199
202−#if ! MIN_VERSION_base(4,6,0)
203−import Prelude hiding (catch)
204−#endif
200+import Prelude
205201
206202--------------------------------------------------------------------------------
207203-- Debugging/Tracing API --
src/Control/Distributed/Process/Management.hs+3−2
@@ -273,7 +273,7 @@ module Control.Distributed.Process.Management
273273 , mxDropTable
274274 ) where
275275
276−import Control.Applicative ((<$>))
276+import Control.Applicative
277277import Control.Concurrent.STM (atomically)
278278import Control.Concurrent.STM.TChan
279279 ( readTChan
@@ -288,7 +288,6 @@ import Control.Distributed.Process.Internal.Primitives
288288 , matchAny
289289 , matchSTM
290290 , unwrapMessage
291− , onException
292291 , register
293292 , whereis
294293 , die
@@ -317,12 +316,14 @@ import Control.Distributed.Process.Management.Internal.Types
317316import Control.Distributed.Process.Serializable (Serializable)
318317import Control.Monad.IO.Class (liftIO)
319318import Control.Monad.Reader (ask)
319+import Control.Monad.Catch (onException)
320320import qualified Control.Monad.State as ST
321321 ( get
322322 , modify
323323 , lift
324324 , runStateT
325325 )
326+import Prelude
326327
327328-- | Publishes an arbitrary @Serializable@ message to the management event bus.
328329-- Note that /no attempt is made to force the argument/, therefore it is very
src/Control/Distributed/Process/Management/Internal/Agent.hs+2−1
@@ -3,7 +3,7 @@
33
44module Control.Distributed.Process.Management.Internal.Agent where
55
6−import Control.Applicative ((<$>))
6+import Control.Applicative
77import Control.Concurrent (forkIO)
88import Control.Concurrent.MVar (MVar, newEmptyMVar, putMVar, takeMVar)
99import Control.Concurrent.STM (atomically)
@@ -44,6 +44,7 @@ import Control.Monad (void)
4444import Control.Monad.IO.Class (liftIO)
4545import Control.Monad.Reader (ask)
4646import GHC.Weak (Weak, deRefWeak)
47+import Prelude
4748
4849--------------------------------------------------------------------------------
4950-- Agent Controller Implementation --
src/Control/Distributed/Process/Management/Internal/Trace/Primitives.hs+2−1
@@ -28,7 +28,7 @@ module Control.Distributed.Process.Management.Internal.Trace.Primitives
2828 , withRegisteredTracer
2929 ) where
3030
31−import Control.Applicative ((<$>))
31+import Control.Applicative
3232import Control.Distributed.Process.Internal.Primitives
3333 ( whereis
3434 , newChan
@@ -67,6 +67,7 @@ import Control.Monad.IO.Class (liftIO)
6767import Control.Monad.Reader (ask)
6868
6969import qualified Data.Set as Set (fromList)
70+import Prelude
7071
7172--------------------------------------------------------------------------------
7273-- Main API --
src/Control/Distributed/Process/Node.hs+5−14
@@ -20,10 +20,6 @@ module Control.Distributed.Process.Node
2020
2121-- TODO: Calls to 'sendBinary' and co (by the NC) may stall the node controller.
2222
23−#if ! MIN_VERSION_base(4,6,0)
24−import Prelude hiding (catch)
25−#endif
26−
2723import System.IO (fixIO, hPutStrLn, stderr)
2824import System.Mem.Weak (Weak, deRefWeak)
2925import qualified Data.ByteString.Lazy as BSL (fromChunks)
@@ -52,7 +48,7 @@ import Data.Foldable (forM_)
5248import Data.Maybe (isJust, fromJust, isNothing, catMaybes)
5349import Data.Typeable (Typeable)
5450import Control.Category ((>>>))
55−import Control.Applicative (Applicative, (<$>))
51+import Control.Applicative
5652import Control.Monad (void, when, join)
5753import Control.Monad.IO.Class (MonadIO, liftIO)
5854import Control.Monad.State.Strict (MonadState, StateT, evalStateT, gets)
@@ -60,7 +56,6 @@ import qualified Control.Monad.State.Strict as StateT (get, put)
6056import Control.Monad.Reader (MonadReader, ReaderT, runReaderT, ask)
6157import Control.Exception
6258 ( throwIO
63− , AsyncException(ThreadKilled)
6459 , SomeException
6560 , Exception
6661 , throwTo
@@ -72,12 +67,11 @@ import qualified Control.Exception as Exception
7267 , catches
7368 , finally
7469 )
75−import Control.Concurrent (forkIO, forkIOWithUnmask, killThread, myThreadId)
70+import Control.Concurrent (forkIO, forkIOWithUnmask, killThread)
7671import Control.Distributed.Process.Internal.StrictMVar
7772 ( newMVar
7873 , withMVar
7974 , modifyMVarMasked
80− , modifyMVar_
8175 , modifyMVar
8276 , newEmptyMVar
8377 , putMVar
@@ -167,12 +161,11 @@ import Control.Distributed.Process.Internal.Types
167161 , RegisterReply(..)
168162 , WhereIsReply(..)
169163 , payloadToMessage
170− , messageToPayload
171164 , createUnencodedMessage
172165 , unsafeCreateUnencodedMessage
173166 , runLocalProcess
174167 , firstNonReservedProcessId
175− , ImplicitReconnect(WithImplicitReconnect,NoImplicitReconnect)
168+ , ImplicitReconnect(WithImplicitReconnect)
176169 )
177170import Control.Distributed.Process.Management.Internal.Agent
178171 ( mxAgentController
@@ -199,7 +192,6 @@ import Control.Distributed.Process.Management.Internal.Types
199192import Control.Distributed.Process.Serializable (Serializable)
200193import Control.Distributed.Process.Internal.Messaging
201194 ( sendBinary
202− , sendPayload
203195 , closeImplicitReconnections
204196 , impliesDeathOf
205197 )
@@ -208,7 +200,6 @@ import Control.Distributed.Process.Internal.Primitives
208200 , receiveWait
209201 , match
210202 , sendChan
211− , try
212203 , unwrapMessage
213204 )
214205import Control.Distributed.Process.Internal.Types (SendPort, Tracer(..))
@@ -218,7 +209,9 @@ import qualified Control.Distributed.Process.Internal.StrictContainerAccessors a
218209 ( mapMaybe
219210 , mapDefault
220211 )
212+import Control.Monad.Catch (try)
221213import Unsafe.Coerce
214+import Prelude
222215
223216--------------------------------------------------------------------------------
224217-- Initialization --
@@ -314,8 +307,6 @@ startServiceProcesses node = do
314307 -- process which uses 'send' or other primitives which are traced.
315308 register "trace.logger" logger
316309 where
317− fork = forkProcess node
318−
319310 loop = do
320311 receiveWait
321312 [ match $ \((time, pid, string) ::(String, ProcessId, String)) -> do