diff options
Diffstat (limited to 'src')
-rw-r--r-- | src/Control/Concurrent/Lifted/Instrument.hs | 2 | ||||
-rw-r--r-- | src/Control/Concurrent/Tasks.hs | 2 | ||||
-rw-r--r-- | src/Network/Kademlia/Search.hs | 2 |
3 files changed, 3 insertions, 3 deletions
diff --git a/src/Control/Concurrent/Lifted/Instrument.hs b/src/Control/Concurrent/Lifted/Instrument.hs index 4aa9268f..91d4c0a4 100644 --- a/src/Control/Concurrent/Lifted/Instrument.hs +++ b/src/Control/Concurrent/Lifted/Instrument.hs | |||
@@ -43,7 +43,7 @@ globals = unsafePerformIO $ newMVar $ GlobalState | |||
43 | 43 | ||
44 | 44 | ||
45 | forkIO :: IO () -> IO ThreadId | 45 | forkIO :: IO () -> IO ThreadId |
46 | forkIO = fork | 46 | forkIO = GHC.forkIO |
47 | {-# INLINE forkIO #-} | 47 | {-# INLINE forkIO #-} |
48 | 48 | ||
49 | forkOS :: MonadBaseControl IO m => m () -> m ThreadId | 49 | forkOS :: MonadBaseControl IO m => m () -> m ThreadId |
diff --git a/src/Control/Concurrent/Tasks.hs b/src/Control/Concurrent/Tasks.hs index 287542ee..da2e589e 100644 --- a/src/Control/Concurrent/Tasks.hs +++ b/src/Control/Concurrent/Tasks.hs | |||
@@ -20,7 +20,7 @@ withTaskGroup :: String -> Int -> (TaskGroup -> IO ()) -> IO () | |||
20 | withTaskGroup glabel numslots action = do | 20 | withTaskGroup glabel numslots action = do |
21 | tg <- atomically $ newTChan | 21 | tg <- atomically $ newTChan |
22 | cnt <- atomically $ newTVar 0 | 22 | cnt <- atomically $ newTVar 0 |
23 | thread <- fork $ do | 23 | thread <- forkIO $ do |
24 | myThreadId >>= flip labelThread glabel | 24 | myThreadId >>= flip labelThread glabel |
25 | fix $ \again -> do | 25 | fix $ \again -> do |
26 | (slot, (lbl,task)) <- atomically $ do | 26 | (slot, (lbl,task)) <- atomically $ do |
diff --git a/src/Network/Kademlia/Search.hs b/src/Network/Kademlia/Search.hs index e13e0742..d3aaae28 100644 --- a/src/Network/Kademlia/Search.hs +++ b/src/Network/Kademlia/Search.hs | |||
@@ -199,7 +199,7 @@ search :: | |||
199 | search sch buckets target result = do | 199 | search sch buckets target result = do |
200 | let ns = R.kclosest (searchSpace sch) searchK target buckets | 200 | let ns = R.kclosest (searchSpace sch) searchK target buckets |
201 | st <- atomically $ newSearch sch target ns | 201 | st <- atomically $ newSearch sch target ns |
202 | fork $ searchLoop sch target result st | 202 | forkIO $ searchLoop sch target result st |
203 | return st | 203 | return st |
204 | 204 | ||
205 | searchLoop :: ( Ord addr, Ord nid, Ord ni, Show nid, Hashable nid, Hashable ni ) | 205 | searchLoop :: ( Ord addr, Ord nid, Ord ni, Show nid, Hashable nid, Hashable ni ) |