From c3af9eb007c96c7fe816cc428f1e37881241b48c Mon Sep 17 00:00:00 2001 From: Joe Crayne Date: Sat, 11 Jan 2020 21:27:43 -0500 Subject: WIP: efforts regarding tcp-mediated connections. --- dht/Announcer.hs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'dht/Announcer.hs') diff --git a/dht/Announcer.hs b/dht/Announcer.hs index e7c0bcd2..bdbf5ecc 100644 --- a/dht/Announcer.hs +++ b/dht/Announcer.hs @@ -176,7 +176,10 @@ listener announcer = relisten Just cmd -> return $ handleCommand cmd Nothing -> do writeTVar (scheduled announcer) (Schedule queue') - (fmap (>> relisten) (fmap fork (f announcer k now))) + io <- f announcer k now + return $ do + forkLabeled ("announcer:item:"++unpackAnnounceKey announcer k) io + relisten where modifyScheduled f = modifyTVar (scheduled announcer) (Schedule . f . unSchedule) declareInactive = writeTVar (announcerActive announcer) False -- cgit v1.2.3