diff options
author | James Crayne <jim.crayne@gmail.com> | 2019-10-18 10:13:55 +0000 |
---|---|---|
committer | Joe Crayne <joe@jerkface.net> | 2020-01-01 19:53:31 -0500 |
commit | c479c2dd58c12d159c05040a08da6c4c7730c407 (patch) | |
tree | 8f675cba6fc0fcb318078863589a083d2146caf4 /dht/examples | |
parent | c25b96d0665f9bd6c28245c811cbc7c57d0b9694 (diff) |
convert forkIO to forkLabeled (wip)
Diffstat (limited to 'dht/examples')
-rw-r--r-- | dht/examples/dhtd.hs | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/dht/examples/dhtd.hs b/dht/examples/dhtd.hs index eb41c598..c7fd4f06 100644 --- a/dht/examples/dhtd.hs +++ b/dht/examples/dhtd.hs | |||
@@ -54,12 +54,7 @@ import System.Posix.Process | |||
54 | import Text.PrettyPrint.HughesPJClass | 54 | import Text.PrettyPrint.HughesPJClass |
55 | import Text.Printf | 55 | import Text.Printf |
56 | import Text.Read | 56 | import Text.Read |
57 | #ifdef THREAD_DEBUG | 57 | import Control.Concurrent.ThreadUtil |
58 | import Control.Concurrent.Lifted.Instrument | ||
59 | #else | ||
60 | import Control.Concurrent.Lifted | ||
61 | import GHC.Conc (labelThread) | ||
62 | #endif | ||
63 | import qualified Data.HashMap.Strict as HashMap | 58 | import qualified Data.HashMap.Strict as HashMap |
64 | import qualified Data.Text as T | 59 | import qualified Data.Text as T |
65 | import qualified Data.Text.Encoding as T | 60 | import qualified Data.Text.Encoding as T |
@@ -1826,8 +1821,7 @@ main = do | |||
1826 | bootstrap btSaved fallbackNodes | 1821 | bootstrap btSaved fallbackNodes |
1827 | return () | 1822 | return () |
1828 | 1823 | ||
1829 | forkIO $ do | 1824 | forkLabeled "XMPP.stanzas" $ do |
1830 | myThreadId >>= flip labelThread "XMPP.stanzas" | ||
1831 | let console = cwPresenceChan <$> (mstate >>= consoleWriter) | 1825 | let console = cwPresenceChan <$> (mstate >>= consoleWriter) |
1832 | fix $ \loop -> do | 1826 | fix $ \loop -> do |
1833 | what <- atomically | 1827 | what <- atomically |