torrent: cancelBlocks on wire 'close'

webtorrent · astro · Jan 22, 2015 · Jan 22, 2015 · 4643ec3b8952ef4c304d722ae04d2f7387fbbf1b
commit 4643ec3b8952ef4c304d722ae04d2f7387fbbf1b
diff --git a/lib/torrent.js b/lib/torrent.js
@@ -514,6 +514,9 @@ Torrent.prototype._onWireWithMetadata = function (wire) {
 
   wire.on('close', function () {
     clearTimeout(timeoutId)
+    wire.requests.forEach(function (req) {
+      self.storage.cancelBlock(req.piece, req.offset)
+    })
   })
 
   wire.on('choke', function () {