summaryrefslogtreecommitdiff
path: root/src/Network/BitTorrent/Tracker.hs
diff options
context:
space:
mode:
Diffstat (limited to 'src/Network/BitTorrent/Tracker.hs')
-rw-r--r--src/Network/BitTorrent/Tracker.hs8
1 files changed, 1 insertions, 7 deletions
diff --git a/src/Network/BitTorrent/Tracker.hs b/src/Network/BitTorrent/Tracker.hs
index 6bf6de4b..179dae1d 100644
--- a/src/Network/BitTorrent/Tracker.hs
+++ b/src/Network/BitTorrent/Tracker.hs
@@ -170,7 +170,6 @@ sec = 1000 * 1000
170waitInterval :: TSession -> IO () 170waitInterval :: TSession -> IO ()
171waitInterval se @ TSession {..} = do 171waitInterval se @ TSession {..} = do
172 delay <- readIORef seInterval 172 delay <- readIORef seInterval
173 print delay
174 threadDelay (delay * sec) 173 threadDelay (delay * sec)
175 174
176withTracker :: Progress -> TConnection -> (TSession -> IO a) -> IO a 175withTracker :: Progress -> TConnection -> (TSession -> IO a) -> IO a
@@ -178,21 +177,17 @@ withTracker initProgress conn action = bracket start end (action . fst)
178 where 177 where
179 start = do 178 start = do
180 resp <- askTracker (startedReq conn initProgress) 179 resp <- askTracker (startedReq conn initProgress)
181 print resp
182 se <- newSession initProgress (respInterval resp) (respPeers resp) 180 se <- newSession initProgress (respInterval resp) (respPeers resp)
183 tid <- forkIO (return ()) -- (syncSession se) 181 tid <- forkIO (syncSession se)
184 return (se, tid) 182 return (se, tid)
185 183
186 syncSession se @ TSession {..} = forever $ do 184 syncSession se @ TSession {..} = forever $ do
187 waitInterval se 185 waitInterval se
188 pr <- getProgress se 186 pr <- getProgress se
189 print "tracker req"
190 resp <- tryJust isIOException $ do 187 resp <- tryJust isIOException $ do
191 askTracker (regularReq defaultNumWant conn pr) 188 askTracker (regularReq defaultNumWant conn pr)
192 print "tracker resp"
193 case resp of 189 case resp of
194 Right (ok @ OK {..}) -> do 190 Right (ok @ OK {..}) -> do
195 print ok
196 writeIORef seInterval respInterval 191 writeIORef seInterval respInterval
197 writeList2Chan sePeers respPeers 192 writeList2Chan sePeers respPeers
198 _ -> return () 193 _ -> return ()
@@ -203,7 +198,6 @@ withTracker initProgress conn action = bracket start end (action . fst)
203 end (se, tid) = do 198 end (se, tid) = do
204 killThread tid 199 killThread tid
205 pr <- getProgress se 200 pr <- getProgress se
206 print "stopping"
207 leaveTracker $ stoppedReq conn pr 201 leaveTracker $ stoppedReq conn pr
208 202
209 203