Updated torrent.js

lib/torrent.js

@@ -1055,17 +1055,19 @@ Torrent.prototype._request = function (wire, index, hotswap) {
   var self = this
   var numRequests = wire.requests.length
 
+  var webPeer = wire.remotePort === 80 || wire.remotePort === 443
+
   if (self.bitfield.get(index)) return false
 
   var maxOutstandingRequests = getPipelineLength(wire, PIPELINE_MAX_DURATION)
   if (numRequests >= maxOutstandingRequests) return false
   // var endGame = (wire.requests.length === 0 && self.store.numMissing < 30)
 
   var piece = self.pieces[index]
-  var reservation = piece.reserve()
+  var reservation = webPeer ? piece.reserveRemaining() : piece.reserve()
 
   if (reservation === -1 && hotswap && self._hotswap(wire, index)) {
-    reservation = piece.reserve()
+    reservation = webPeer ? piece.reserveRemaining() : piece.reserve()
   }
   if (reservation === -1) return false
 
@@ -1076,7 +1078,7 @@ Torrent.prototype._request = function (wire, index, hotswap) {
   r[i] = wire
 
   var chunkOffset = piece.chunkOffset(reservation)
-  var chunkLength = piece.chunkLength(reservation)
+  var chunkLength = webPeer ? piece.chunkLengthRemaining(reservation) : piece.chunkLength(reservation)
 
   wire.request(index, chunkOffset, chunkLength, function onChunk (err, chunk) {
     // TODO: what is this for?
@@ -1092,7 +1094,7 @@ Torrent.prototype._request = function (wire, index, hotswap) {
         index, chunkOffset, chunkLength, wire.remoteAddress + ':' + wire.remotePort,
         err.message
       )
-      piece.cancel(reservation)
+      webPeer ? piece.cancelRemaining(reservation) : piece.cancel(reservation)
       onUpdateTick()
       return
     }