diff --git a/lib/client/websocket-tracker.js b/lib/client/websocket-tracker.js index c389c92..e9944d0 100644 --- a/lib/client/websocket-tracker.js +++ b/lib/client/websocket-tracker.js @@ -89,6 +89,15 @@ WebSocketTracker.prototype.destroy = function (cb) { clearInterval(self.interval) clearTimeout(self.reconnectTimer) + // Destroy peers + for(var peerId in self.peers) { + var peer = self.peers[peerId] + clearTimeout(peer.trackerTimeout) + peer.destroy() + } + delete self.peers + + // Close socked if (socketPool[self.announceUrl]) socketPool[self.announceUrl].consumers-- self.socket.removeListener('connect', self._onSocketConnectBound)