Mirror/bittorrent-tracker
1
0
Fork 0
mirror of https://github.com/webtorrent/bittorrent-tracker.git synced 2024-12-13 19:06:27 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

server: reuse udp socket for responses

Browse Source 
Reasons:
* Save file-descriptors
* Support clients behind NAT
This commit is contained in:
Astro 2014-12-12 17:27:03 +01:00
parent 79068a49cf
commit 80da7c50d0
1 changed files with 9 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
server.js
View File

@ -61,13 +61,13 @@ function Server (opts) {
// default to starting a udp server unless the user explicitly says no // default to starting a udp server unless the user explicitly says no
if (opts.udp !== false) { if (opts.udp !== false) {
self._udpServer = dgram.createSocket('udp4') self._udpSocket = dgram.createSocket('udp4')
self._udpServer.on('message', self._onUdpRequest.bind(self)) self._udpSocket.on('message', self._onUdpRequest.bind(self))
self._udpServer.on('error', self._onError.bind(self)) self._udpSocket.on('error', self._onError.bind(self))
self._udpServer.on('listening', onListening) self._udpSocket.on('listening', onListening)
} }
var num = !!self._httpServer + !!self._udpServer var num = !!self._httpServer + !!self._udpSocket
function onListening () { function onListening () {
num -= 1 num -= 1
if (num === 0) { if (num === 0) {
@ -95,7 +95,7 @@ Server.prototype.listen = function (port, onlistening) {
if (err) return self.emit('error', err) if (err) return self.emit('error', err)
self.port = port self.port = port
self._httpServer && self._httpServer.listen(port.http || port) self._httpServer && self._httpServer.listen(port.http || port)
self._udpServer && self._udpServer.bind(port.udp || port) self._udpSocket && self._udpSocket.bind(port.udp || port)
} }
if (port) onPort(null, port) if (port) onPort(null, port)
@ -105,8 +105,8 @@ Server.prototype.listen = function (port, onlistening) {
Server.prototype.close = function (cb) { Server.prototype.close = function (cb) {
var self = this var self = this
cb = cb || function () {} cb = cb || function () {}
if (self._udpServer) { if (self._udpSocket) {
self._udpServer.close() self._udpSocket.close()
} }
if (self._httpServer) { if (self._httpServer) {
self._httpServer.close(cb) self._httpServer.close(cb)
@ -177,11 +177,10 @@ Server.prototype._onUdpRequest = function (msg, rinfo) {
} }
} }
var socket = dgram.createSocket('udp4')
response.transactionId = params.transactionId response.transactionId = params.transactionId
response.connectionId = params.connectionId response.connectionId = params.connectionId
var buf = makeUdpPacket(response) var buf = makeUdpPacket(response)
socket.send(buf, 0, buf.length, rinfo.port, rinfo.address, function () { self._udpSocket.send(buf, 0, buf.length, rinfo.port, rinfo.address, function () {
try { try {
socket.close() socket.close()
} catch (err) {} } catch (err) {}