summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/Network/BitTorrent/DHT/Session.hs16
1 files changed, 11 insertions, 5 deletions
diff --git a/src/Network/BitTorrent/DHT/Session.hs b/src/Network/BitTorrent/DHT/Session.hs
index b3688a37..9455c465 100644
--- a/src/Network/BitTorrent/DHT/Session.hs
+++ b/src/Network/BitTorrent/DHT/Session.hs
@@ -17,6 +17,7 @@ module Network.BitTorrent.DHT.Session
17 -- * Session 17 -- * Session
18 , DHT 18 , DHT
19 , runDHT 19 , runDHT
20 , askOption
20 21
21 -- * Tokens 22 -- * Tokens
22 , grantToken 23 , grantToken
@@ -295,6 +296,11 @@ runDHT hs opts naddr action = runResourceT $ do
295 <*> pure logger 296 <*> pure logger
296 runReaderT (unDHT (listen >> action)) node 297 runReaderT (unDHT (listen >> action)) node
297 298
299
300askOption :: (Options -> a) -> DHT ip a
301askOption f = asks (f . options)
302{-# INLINE askOption #-}
303
298{----------------------------------------------------------------------- 304{-----------------------------------------------------------------------
299-- Routing 305-- Routing
300-----------------------------------------------------------------------} 306-----------------------------------------------------------------------}
@@ -435,11 +441,6 @@ deleteTopic ih p = do
435 var <- asks announceInfo 441 var <- asks announceInfo
436 liftIO $ atomically $ modifyTVar' var (S.delete (ih, p)) 442 liftIO $ atomically $ modifyTVar' var (S.delete (ih, p))
437 443
438republish :: DHT ip ThreadId
439republish = fork $ do
440 i <- asks (optReannounce . options)
441 error "DHT.republish: not implemented"
442
443{----------------------------------------------------------------------- 444{-----------------------------------------------------------------------
444-- Messaging 445-- Messaging
445-----------------------------------------------------------------------} 446-----------------------------------------------------------------------}
@@ -541,6 +542,11 @@ publish ih p = do
541 _ <- sourceList [nodes] $= search ih (announceQ ih p) $$ C.take r 542 _ <- sourceList [nodes] $= search ih (announceQ ih p) $$ C.take r
542 return () 543 return ()
543 544
545republish :: DHT ip ThreadId
546republish = fork $ do
547 i <- askOption optReannounce
548 error "DHT.republish: not implemented"
549
544{----------------------------------------------------------------------- 550{-----------------------------------------------------------------------
545-- Handlers 551-- Handlers
546-----------------------------------------------------------------------} 552-----------------------------------------------------------------------}