import System.IO (hSetBuffering, BufferMode ( NoBuffering ))
import FuncTorrent.Metainfo (Metainfo)
-import FuncTorrent.Peer (handlePeerMsgs, Peer(..))
+import FuncTorrent.Peer (handlePeerMsgs, Peer(..), PieceMap)
-- server is listening on any port from 6881 - 6889
-- return the port number used
sock <- listenOn $ PortNumber $ fromIntegral (head portnums)
return (sock, PortNumber $ head portnums)
-run :: Socket -> String -> Metainfo -> IO ()
-run listenSock peerid m = forever $ do
+run :: Socket -> String -> Metainfo -> PieceMap -> IO ()
+run listenSock peerid m pieceMap = forever $ do
(handle, ip, port) <- accept listenSock
let peer = Peer "" ip (fromIntegral port)
hSetBuffering handle NoBuffering
- forkIO $ handlePeerMsgs peer peerid m
+ forkIO $ handlePeerMsgs peer peerid m pieceMap