X-Git-Url: https://git.rkrishnan.org/?a=blobdiff_plain;f=src%2FFuncTorrent%2FPeer.hs;h=c833c061bd4285be88f3754e62e5b83774c1d806;hb=08f3238a8162039a1b77f4fb8825a56a34203c02;hp=5d987e815bcac57b36f1d3be85d10ead30422256;hpb=f47d266fbb7ed6ebd00b444a9b69feb60e67d615;p=functorrent.git diff --git a/src/FuncTorrent/Peer.hs b/src/FuncTorrent/Peer.hs index 5d987e8..c833c06 100644 --- a/src/FuncTorrent/Peer.hs +++ b/src/FuncTorrent/Peer.hs @@ -20,8 +20,7 @@ {-# LANGUAGE OverloadedStrings #-} module FuncTorrent.Peer - (Peer(..), - PieceMap, + (PieceMap, handlePeerMsgs ) where @@ -53,7 +52,7 @@ havePiece pm index = dlstate (pm ! index) == Have connectToPeer :: Peer -> IO Handle -connectToPeer (Peer _ ip port) = do +connectToPeer (Peer ip port) = do h <- connectTo ip (PortNumber (fromIntegral port)) hSetBuffering h LineBuffering return h @@ -167,7 +166,7 @@ msgLoop pieceStatus msgchannel = do NotInterestedMsg -> do modify (\st' -> st' {heInterested = False}) msgLoop pieceStatus msgchannel - CancelMsg _ _ _ -> -- check if valid index, begin, length + CancelMsg {} -> -- check if valid index, begin, length msgLoop pieceStatus msgchannel PortMsg _ -> msgLoop pieceStatus msgchannel @@ -176,7 +175,7 @@ msgLoop pieceStatus msgchannel = do let pieceStatus' = updatePieceAvailability pieceStatus p [idx] msgLoop pieceStatus' msgchannel _ -> do - liftIO $ putStrLn $ ".. not doing anything with the msg" + liftIO $ putStrLn ".. not doing anything with the msg" msgLoop pieceStatus msgchannel -- No need to handle PieceMsg and RequestMsg here.