Mirror/bittorrent-tracker
1
0
Fork 0
mirror of https://github.com/webtorrent/bittorrent-tracker.git synced 2025-01-18 20:21:36 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Merge pull request #23 from jhiesey/master

Browse Source 
Time out and clean up udp stopped messages
This commit is contained in:
Feross Aboukhadijeh 2014-06-05 00:10:10 -07:00
commit 8aebeb7898
1 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
index.js
View File

@ -172,15 +172,16 @@ Tracker.prototype._requestUdp = function (requestUrl, opts) {
var socket = dgram.createSocket('udp4')
var transactionId = new Buffer(hat(32), 'hex')
if (opts.event !== 'stopped') {
// if we're sending a stopped message, we don't really care if it arrives, so don't
// set a timer
var timeout = setTimeout(function () {
timeout = null
cleanup()
var stopped = opts.event === 'stopped'
// if we're sending a stopped message, we don't really care if it arrives, so set
// a short timer and don't call error
var timeout = setTimeout(function () {
timeout = null
cleanup()
if (!stopped) {
error('tracker request timed out')
}, 15000)
}
}
}, stopped ? 1500 : 15000)
if (timeout && timeout.unref) {
timeout.unref()
@ -264,7 +265,7 @@ Tracker.prototype._requestUdp = function (requestUrl, opts) {
function send (message) {
if (!parsedUrl.port) {
parsedUrl.port = 80;
parsedUrl.port = 80
}
socket.send(message, 0, message.length, parsedUrl.port, parsedUrl.hostname)
}
@ -334,7 +335,7 @@ Tracker.prototype._handleResponse = function (requestUrl, data) {
var warning = data['warning message']
if (warning) {
self.client.emit('warning', warning);
self.client.emit('warning', warning)
}
if (requestUrl === self._announceUrl) {