git.iko.soy/distributed-process
on master help sign in
Simplify forkProcess
commit8b3370c882cce2e3770a2d866eb3c4095625247a authorNicolas Wu <nick@well-typed.com> dateSat 3 Dec 2011, 22:28 (15 years ago) parent7570710
1 file changed+2−2
distributed-process/src/Control/Distributed/Process.hs+2−2
distributed-process/src/Control/Distributed/Process.hs+2−2
@@ -120,12 +120,12 @@ forkProcess :: LocalNode -> Process () -> IO ProcessId
120120forkProcess node (Process action) = do
121121
122122 (sendAddr, chan) <- Trans.newConnection (ndTransport node)
123− sendEnd <- Trans.connectWith sendAddr Trans.SendHints
123+ sendEnd <- Trans.connect sendAddr
124124 processTable@(ProcessTable lpid _) <- takeMVar (ndProcessTable node)
125125 let pid = ProcessId sendEnd NodeId lpid
126126 forkIO $ do
127127 tid <- myThreadId
128− lpid <- putMVar (ndProcessTable node) (insertProcess tid processTable)
128+ putMVar (ndProcessTable node) (insertProcess tid processTable)
129129 queue <- newCQueue
130130 forkIO $ receiverPump chan queue
131131