git.iko.soy/distributed-process
on master help sign in
tidy up some more compilation warnings
ab7368cTim Watson
src/Control/Distributed/Process/Node.hs+3−5
compare with master
unifiedsplit
@@ -31,7 +31,6 @@ import qualified Data.Map as Map
31 , delete
31 , delete
32 , toList
32 , toList
33 , fromList
33 , fromList
34− , filter
35 , insert
34 , insert
36 , lookup
35 , lookup
37 , partition
36 , partition
@@ -193,7 +192,6 @@ import Control.Distributed.Process.Management
193 , liftMX
192 , liftMX
194 , mxUpdateLocal
193 , mxUpdateLocal
195 , mxGetLocal
194 , mxGetLocal
196− , mxSetLocal
197 , mxReady
195 , mxReady
198 , MxEvent(..)
196 , MxEvent(..)
199 , MxAgentId(..)
197 , MxAgentId(..)
@@ -325,9 +323,6 @@ startDefaultTracer node' = do
325
323
326-- TODO: we need a better mechanism for defining and registering services
324-- TODO: we need a better mechanism for defining and registering services
327
325
328−registryMonitorAgentId :: MxAgentId
329−registryMonitorAgentId = MxAgentId "service.registry.monitoring"
330−
331{- note [registry monitoring agent]
326{- note [registry monitoring agent]
332 This agent listens for 'MxRegistered' and 'MxUnRegistered' events and tracks
327 This agent listens for 'MxRegistered' and 'MxUnRegistered' events and tracks
333 all labels for remote 'ProcessId's that are stored in the registry.
328 all labels for remote 'ProcessId's that are stored in the registry.
@@ -362,6 +357,9 @@ registryMonitorAgent = do
362 -- The framework simply discards any input you don't have a handler for.
357 -- The framework simply discards any input you don't have a handler for.
363 -- See Management.hs `runAgent` for details.
358 -- See Management.hs `runAgent` for details.
364 ]
359 ]
360+ where
361+ registryMonitorAgentId :: MxAgentId
362+ registryMonitorAgentId = MxAgentId "service.registry.monitoring"
365
363
366-- | Start and register the service processes on a node
364-- | Start and register the service processes on a node
367startServiceProcesses :: LocalNode -> IO ()
365startServiceProcesses :: LocalNode -> IO ()