diff options
Diffstat (limited to 'src/Network/BitTorrent/DHT/Session.hs')
-rw-r--r-- | src/Network/BitTorrent/DHT/Session.hs | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/Network/BitTorrent/DHT/Session.hs b/src/Network/BitTorrent/DHT/Session.hs index 755985fc..e770b1d3 100644 --- a/src/Network/BitTorrent/DHT/Session.hs +++ b/src/Network/BitTorrent/DHT/Session.hs | |||
@@ -434,15 +434,20 @@ insertNode info = fork $ do | |||
434 | 434 | ||
435 | -- TODO limit dht peer store in size (probably by removing oldest peers) | 435 | -- TODO limit dht peer store in size (probably by removing oldest peers) |
436 | 436 | ||
437 | refreshContacts :: DHT ip () | ||
438 | refreshContacts = undefined | ||
439 | |||
437 | -- | Insert peer to peer store. Used to handle announce requests. | 440 | -- | Insert peer to peer store. Used to handle announce requests. |
438 | insertPeer :: Eq ip => InfoHash -> PeerAddr ip -> DHT ip () | 441 | insertPeer :: Eq ip => InfoHash -> PeerAddr ip -> DHT ip () |
439 | insertPeer ih addr = do | 442 | insertPeer ih addr = do |
443 | refreshContacts | ||
440 | var <- asks contactInfo | 444 | var <- asks contactInfo |
441 | liftIO $ atomically $ modifyTVar' var (P.insert ih addr) | 445 | liftIO $ atomically $ modifyTVar' var (P.insert ih addr) |
442 | 446 | ||
443 | -- | Get peer set for specific swarm. | 447 | -- | Get peer set for specific swarm. |
444 | lookupPeers :: InfoHash -> DHT ip [PeerAddr ip] | 448 | lookupPeers :: InfoHash -> DHT ip [PeerAddr ip] |
445 | lookupPeers ih = do | 449 | lookupPeers ih = do |
450 | refreshContacts | ||
446 | var <- asks contactInfo | 451 | var <- asks contactInfo |
447 | liftIO $ P.lookup ih <$> readTVarIO var | 452 | liftIO $ P.lookup ih <$> readTVarIO var |
448 | 453 | ||