Skip to content

Commit d4c34c3

Browse files
yciabaudfeross
authored andcommitted
Destroy peers and tracker timeouts on destroy
1 parent 3252070 commit d4c34c3

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

lib/client/websocket-tracker.js

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -89,6 +89,15 @@ WebSocketTracker.prototype.destroy = function (cb) {
8989
clearInterval(self.interval)
9090
clearTimeout(self.reconnectTimer)
9191

92+
// Destroy peers
93+
for(var peerId in self.peers) {
94+
var peer = self.peers[peerId]
95+
clearTimeout(peer.trackerTimeout)
96+
peer.destroy()
97+
}
98+
delete self.peers
99+
100+
// Close socked
92101
if (socketPool[self.announceUrl]) socketPool[self.announceUrl].consumers--
93102

94103
self.socket.removeListener('connect', self._onSocketConnectBound)

0 commit comments

Comments
 (0)