X-Git-Url: https://git.rkrishnan.org/?a=blobdiff_plain;f=src%2FFuncTorrent%2FPeer.hs;h=c833c061bd4285be88f3754e62e5b83774c1d806;hb=08f3238a8162039a1b77f4fb8825a56a34203c02;hp=0df0abd7cf56352fbb1d67138716c92970a5a8c3;hpb=53d6f1e577880946a0f17d192b4c19691e486c50;p=functorrent.git diff --git a/src/FuncTorrent/Peer.hs b/src/FuncTorrent/Peer.hs index 0df0abd..c833c06 100644 --- a/src/FuncTorrent/Peer.hs +++ b/src/FuncTorrent/Peer.hs @@ -1,26 +1,26 @@ -{-# LANGUAGE OverloadedStrings #-} {- -Copyright (C) 2015-2016 Ramakrishnan Muthukrishnan - -This file is part of FuncTorrent. - -FuncTorrent is free software; you can redistribute it and/or modify -it under the terms of the GNU General Public License as published by -the Free Software Foundation; either version 3 of the License, or -(at your option) any later version. + - Copyright (C) 2015-2016 Ramakrishnan Muthukrishnan + - + - This file is part of FuncTorrent. + - + - FuncTorrent is free software; you can redistribute it and/or modify + - it under the terms of the GNU General Public License as published by + - the Free Software Foundation; either version 3 of the License, or + - (at your option) any later version. + - + - FuncTorrent is distributed in the hope that it will be useful, + - but WITHOUT ANY WARRANTY; without even the implied warranty of + - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + - GNU General Public License for more details. + - + - You should have received a copy of the GNU General Public License + - along with FuncTorrent; if not, see + -} -FuncTorrent is distributed in the hope that it will be useful, -but WITHOUT ANY WARRANTY; without even the implied warranty of -MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -GNU General Public License for more details. - -You should have received a copy of the GNU General Public License -along with FuncTorrent; if not, see --} +{-# LANGUAGE OverloadedStrings #-} module FuncTorrent.Peer - (Peer(..), - PieceMap, + (PieceMap, handlePeerMsgs ) where @@ -52,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 @@ -166,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 @@ -175,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.