mirror of
https://github.com/webtorrent/bittorrent-tracker.git
synced 2025-01-18 20:21:36 +00:00
timeout might not be defined
This commit is contained in:
parent
954b3af78e
commit
0ff2c1917b
22
index.js
22
index.js
@ -181,7 +181,7 @@ Tracker.prototype._requestUdp = function (requestUrl, opts) {
|
|||||||
}, 15000)
|
}, 15000)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (timeout.unref) {
|
if (timeout && timeout.unref) {
|
||||||
timeout.unref()
|
timeout.unref()
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -236,7 +236,10 @@ Tracker.prototype._requestUdp = function (requestUrl, opts) {
|
|||||||
self.client.emit('peer', addr)
|
self.client.emit('peer', addr)
|
||||||
})
|
})
|
||||||
|
|
||||||
clearTimeout(timeout)
|
if (timeout) {
|
||||||
|
clearTimeout(timeout)
|
||||||
|
timeout = null
|
||||||
|
}
|
||||||
try { socket.close() } catch (err) {}
|
try { socket.close() } catch (err) {}
|
||||||
return
|
return
|
||||||
|
|
||||||
@ -252,7 +255,10 @@ Tracker.prototype._requestUdp = function (requestUrl, opts) {
|
|||||||
incomplete: msg.readUInt32BE(16)
|
incomplete: msg.readUInt32BE(16)
|
||||||
})
|
})
|
||||||
|
|
||||||
clearTimeout(timeout)
|
if (timeout) {
|
||||||
|
clearTimeout(timeout)
|
||||||
|
timeout = null
|
||||||
|
}
|
||||||
try { socket.close() } catch (err) {}
|
try { socket.close() } catch (err) {}
|
||||||
return
|
return
|
||||||
|
|
||||||
@ -263,7 +269,10 @@ Tracker.prototype._requestUdp = function (requestUrl, opts) {
|
|||||||
|
|
||||||
self.client.emit('error', new Error(msg.slice(8).toString()))
|
self.client.emit('error', new Error(msg.slice(8).toString()))
|
||||||
|
|
||||||
clearTimeout(timeout)
|
if (timeout) {
|
||||||
|
clearTimeout(timeout)
|
||||||
|
timeout = null
|
||||||
|
}
|
||||||
try { socket.close() } catch (err) {}
|
try { socket.close() } catch (err) {}
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@ -278,8 +287,11 @@ Tracker.prototype._requestUdp = function (requestUrl, opts) {
|
|||||||
|
|
||||||
function error (message) {
|
function error (message) {
|
||||||
self.client.emit('error', new Error(message + ' (connecting to tracker ' + requestUrl + ')'))
|
self.client.emit('error', new Error(message + ' (connecting to tracker ' + requestUrl + ')'))
|
||||||
|
if (timeout) {
|
||||||
|
clearTimeout(timeout)
|
||||||
|
timeout = null
|
||||||
|
}
|
||||||
try { socket.close() } catch (err) { }
|
try { socket.close() } catch (err) { }
|
||||||
clearTimeout(timeout)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
function genTransactionId () {
|
function genTransactionId () {
|
||||||
|
Loading…
Reference in New Issue
Block a user