cluster-requiem
Advanced tools
Comparing version 1.1.3 to 1.2.0
@@ -22,5 +22,3 @@ var util = require('util'); | ||
this.options = {}; | ||
this.sockets = new LinkedList(); | ||
this.trackers = new LinkedList(); | ||
}; | ||
@@ -49,11 +47,2 @@ | ||
Requiem.prototype.trackSocket = function(socket) { | ||
var self = this; | ||
var item = this.sockets.push(socket); | ||
socket.once('close', function() { | ||
self.sockets.remove(item); | ||
}); | ||
}; | ||
Requiem.prototype.createTracker = function() { | ||
@@ -102,10 +91,3 @@ var self = this; | ||
// Grab the violin, the requiem is starting! | ||
async.series([ | ||
function(cb) { | ||
self._closeAllSockets(cb); | ||
}, | ||
function(cb) { | ||
self._waitAllTrackers(cb); | ||
} | ||
], function() { | ||
this._waitAllTrackers(function() { | ||
self.state = 'dead'; | ||
@@ -149,10 +131,2 @@ self.emit('dead'); | ||
Requiem.prototype._closeAllSockets = function(cb) { | ||
this.sockets.iterateAsync(function(socket, cb) { | ||
socket.data.close(function() { | ||
cb(); | ||
}); | ||
}, cb); | ||
}; | ||
Requiem.prototype._waitAllTrackers = function(cb) { | ||
@@ -159,0 +133,0 @@ this.trackers.iterateAsync(function(tracker, cb) { |
{ | ||
"name": "cluster-requiem", | ||
"version": "1.1.3", | ||
"version": "1.2.0", | ||
"description": "high availability enhacements for clustering", | ||
@@ -5,0 +5,0 @@ "main": "lib/index.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
7515
166