@@ -120,12 +120,12 @@ forkProcess :: LocalNode -> Process () -> IO ProcessId
120forkProcess node (Process action) = do
120forkProcess node (Process action) = do
122 (sendAddr, chan) <- Trans.newConnection (ndTransport node)
122 (sendAddr, chan) <- Trans.newConnection (ndTransport node)
123− sendEnd <- Trans.connectWith sendAddr Trans.SendHints
123+ sendEnd <- Trans.connect sendAddr
124 processTable@(ProcessTable lpid _) <- takeMVar (ndProcessTable node)
124 processTable@(ProcessTable lpid _) <- takeMVar (ndProcessTable node)
125 let pid = ProcessId sendEnd NodeId lpid
125 let pid = ProcessId sendEnd NodeId lpid
126 forkIO $ do
126 forkIO $ do
127 tid <- myThreadId
127 tid <- myThreadId
128− lpid <- putMVar (ndProcessTable node) (insertProcess tid processTable)
128+ putMVar (ndProcessTable node) (insertProcess tid processTable)
129 queue <- newCQueue
129 queue <- newCQueue
130 forkIO $ receiverPump chan queue
130 forkIO $ receiverPump chan queue