diff options
Diffstat (limited to 'src/Network/BitTorrent/Tracker.hs')
-rw-r--r-- | src/Network/BitTorrent/Tracker.hs | 8 |
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 | |||
170 | waitInterval :: TSession -> IO () | 170 | waitInterval :: TSession -> IO () |
171 | waitInterval se @ TSession {..} = do | 171 | waitInterval se @ TSession {..} = do |
172 | delay <- readIORef seInterval | 172 | delay <- readIORef seInterval |
173 | print delay | ||
174 | threadDelay (delay * sec) | 173 | threadDelay (delay * sec) |
175 | 174 | ||
176 | withTracker :: Progress -> TConnection -> (TSession -> IO a) -> IO a | 175 | withTracker :: 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 | ||