mirrors/IHaskell
1
0
Fork 0
mirror of https://github.com/IHaskell/IHaskell.git synced 2025-04-15 19:06:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixing context GC'd bug.

Browse Source
This commit is contained in:
Andrew Gibiansky 2013-09-28 21:07:50 -07:00
parent 78940c2d65
commit 842f281628
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
IHaskell/ZeroMQ.hs
View File

@ -49,10 +49,10 @@ serveProfile profile = do
-- withContext or withSocket complete, the context or socket become invalid.
forkIO $ withContext $ \context -> do
-- Serve on all sockets.
serveSocket context Rep (hbPort profile) $ heartbeat channels
serveSocket context Router (controlPort profile) $ control channels
serveSocket context Router (shellPort profile) $ shell channels
serveSocket context Router (stdinPort profile) $ stdin channels
forkIO $ serveSocket context Rep (hbPort profile) $ heartbeat channels
forkIO $ serveSocket context Router (controlPort profile) $ control channels
forkIO $ serveSocket context Router (shellPort profile) $ shell channels
forkIO $ serveSocket context Router (stdinPort profile) $ stdin channels
serveSocket context Pub (iopubPort profile) $ iopub channels
-- Wait forever
@ -64,11 +64,10 @@ serveProfile profile = do
-- | given context and then loop the provided action, which should listen
-- | on the socket and respond to any events.
serveSocket :: SocketType a => Context -> a -> Port -> (Socket a -> IO b) -> IO ()
serveSocket context socketType port action = void . forkIO $ do
serveSocket context socketType port action = void $
withSocket context socketType $ \socket -> do
bind socket $ textToString $ "tcp://127.0.0.1:" ++ show port
forever $ action socket
newEmptyMVar >>= takeMVar
-- | Listener on the heartbeat port. Echoes back any data it was sent.
heartbeat :: ZeroMQInterface -> Socket Rep -> IO ()