git.iko.soy/distributed-process
on master help sign in
Placate hlint and remove reconnectNode
96fb8c3Edsko de Vries
distributed-process/src/Control/Distributed/Process.hs+3−5
compare with master
unifiedsplit
@@ -101,7 +101,6 @@ module Control.Distributed.Process
101 , spawnChannelLocal
101 , spawnChannelLocal
102 -- * Reconnecting
102 -- * Reconnecting
103 , reconnect
103 , reconnect
104− , reconnectNode
105 , reconnectPort
104 , reconnectPort
106 ) where
105 ) where
107
106
@@ -118,6 +117,8 @@ import Control.Distributed.Static
118 , closure
117 , closure
119 , Static
118 , Static
120 , RemoteTable
119 , RemoteTable
120+ , closureCompose
121+ , staticClosure
121 )
122 )
122import Control.Distributed.Process.Internal.Types
123import Control.Distributed.Process.Internal.Types
123 ( NodeId(..)
124 ( NodeId(..)
@@ -139,7 +140,7 @@ import Control.Distributed.Process.Internal.Types
139 , WhereIsReply(..)
140 , WhereIsReply(..)
140 , LocalProcess(processNode)
141 , LocalProcess(processNode)
141 )
142 )
142−import Control.Distributed.Process.Serializable (SerializableDict)
143+import Control.Distributed.Process.Serializable (Serializable, SerializableDict)
143import Control.Distributed.Process.Internal.Closure.BuiltIn
144import Control.Distributed.Process.Internal.Closure.BuiltIn
144 ( sdictUnit
145 ( sdictUnit
145 , sdictSendPort
146 , sdictSendPort
@@ -154,7 +155,6 @@ import Control.Distributed.Process.Internal.Closure.BuiltIn
154 , cpSend
155 , cpSend
155 , cpNewChan
156 , cpNewChan
156 )
157 )
157−import Control.Distributed.Static (closureCompose, staticClosure)
158import Control.Distributed.Process.Internal.Primitives
158import Control.Distributed.Process.Internal.Primitives
159 ( -- Basic messaging
159 ( -- Basic messaging
160 send
160 send
@@ -214,10 +214,8 @@ import Control.Distributed.Process.Internal.Primitives
214 , spawnAsync
214 , spawnAsync
215 -- Reconnecting
215 -- Reconnecting
216 , reconnect
216 , reconnect
217− , reconnectNode
218 , reconnectPort
217 , reconnectPort
219 )
218 )
220−import Control.Distributed.Process.Serializable (Serializable)
221import Control.Distributed.Process.Node (forkProcess)
219import Control.Distributed.Process.Node (forkProcess)
222
220
223-- INTERNAL NOTES
221-- INTERNAL NOTES
distributed-process/src/Control/Distributed/Process/Internal/Primitives.hs−6
@@ -61,7 +61,6 @@ module Control.Distributed.Process.Internal.Primitives
61 , monitorPort
61 , monitorPort
62 -- * Reconnecting
62 -- * Reconnecting
63 , reconnect
63 , reconnect
64− , reconnectNode
65 , reconnectPort
64 , reconnectPort
66 ) where
65 ) where
67
66
@@ -538,11 +537,6 @@ reconnect :: ProcessId -> Process ()
538reconnect =
537reconnect =
539 sendCtrlMsg Nothing . Reconnect . ProcessIdentifier
538 sendCtrlMsg Nothing . Reconnect . ProcessIdentifier
540
539
541−-- | Reconnect to a node. See 'reconnect' for more information.
542−reconnectNode :: NodeId -> Process ()
543−reconnectNode =
544− sendCtrlMsg Nothing . Reconnect . NodeIdentifier
545−
546-- | Reconnect to a sendport. See 'reconnect' for more information.
540-- | Reconnect to a sendport. See 'reconnect' for more information.
547reconnectPort :: SendPort a -> Process ()
541reconnectPort :: SendPort a -> Process ()
548reconnectPort =
542reconnectPort =