X-Git-Url: https://git.rkrishnan.org/?p=functorrent.git;a=blobdiff_plain;f=src%2FFuncTorrent%2FServer.hs;h=3827aa2bc35673110f379901ac139090e2fd3bcf;hp=4c3ab948dbe6004d622c018fe23819f21bba6d06;hb=9beb0fb9814b33725f6adfa5adabb3225a54277b;hpb=2ddd7237e3615d4a55460ca86de22a669c90232c diff --git a/src/FuncTorrent/Server.hs b/src/FuncTorrent/Server.hs index 4c3ab94..3827aa2 100644 --- a/src/FuncTorrent/Server.hs +++ b/src/FuncTorrent/Server.hs @@ -27,7 +27,8 @@ import Network (withSocketsDo, listenOn, accept, Socket, PortID ( PortNumber )) import System.IO (hSetBuffering, BufferMode ( NoBuffering )) import FuncTorrent.Metainfo (Metainfo) -import FuncTorrent.Peer (handlePeerMsgs, Peer(..), PieceMap) +import FuncTorrent.Peer (handlePeerMsgs, PieceMap) +import FuncTorrent.PeerMsgs (Peer(..)) import qualified FuncTorrent.FileSystem as FS (MsgChannel) -- server is listening on any port from 6881 - 6889 @@ -41,6 +42,6 @@ start = withSocketsDo $ do run :: Socket -> String -> Metainfo -> PieceMap -> FS.MsgChannel -> IO () run listenSock peerid m pieceMap c = forever $ do (handle, ip, port) <- accept listenSock - let peer = Peer "" ip (fromIntegral port) + let peer = Peer ip (fromIntegral port) hSetBuffering handle NoBuffering forkIO $ handlePeerMsgs peer peerid m pieceMap False c