Mirror/bittorrent-tracker
1
0
Fork 0
mirror of https://github.com/webtorrent/bittorrent-tracker.git synced 2025-02-22 21:29:07 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

udp client: unify error handling

Browse Source
This commit is contained in:
Feross Aboukhadijeh 2014-03-27 21:29:23 -07:00
parent b406d4ec5e
commit 1721eed413
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
index.js
View File

@ -147,31 +147,37 @@ Client.prototype._requestUdp = function (announceUrl, opts) {
var transactionId = new Buffer(hat(32), 'hex') var transactionId = new Buffer(hat(32), 'hex')
var timeout = setTimeout(function () { var timeout = setTimeout(function () {
error('tracker request timed out')
}, 15000)
function error (message) {
self.emit('error', new Error(message))
socket.close() socket.close()
}, 5000) clearTimeout(timeout)
}
socket.on('error', function (err) { socket.on('error', function (err) {
self.emit('error', err) error(err)
}) })
socket.on('message', function (message, rinfo) { socket.on('message', function (message, rinfo) {
if (message.length < 8 || message.readUInt32BE(4) !== transactionId.readUInt32BE(0)) { if (message.length < 8 || message.readUInt32BE(4) !== transactionId.readUInt32BE(0)) {
return self.emit('error', new Error('tracker sent back invalid transaction id')) return error(new Error('tracker sent back invalid transaction id'))
} }
var action = message.readUInt32BE(0) var action = message.readUInt32BE(0)
switch (action) { switch (action) {
case 0: case 0:
if (message.length < 16) { if (message.length < 16) {
return self.emit('error', new Error('invalid udp handshake')) return error(new Error('invalid udp handshake'))
} }
announce(message.slice(8, 16), opts) announce(message.slice(8, 16), opts)
return return
case 1: case 1:
if (message.length < 20) { if (message.length < 20) {
return self.emit('error', new Error('invalid announce message')) return error(new Error('invalid announce message'))
} }
// TODO: this should be stored per tracker, not globally for all trackers // TODO: this should be stored per tracker, not globally for all trackers