Comparing version 0.2.0 to 0.2.1
@@ -1,3 +0,2 @@ | ||
var fs = require('fs'), | ||
os = require('os'), | ||
var os = require('os'), | ||
cluster = require('cluster'), | ||
@@ -83,3 +82,3 @@ ClusterProcess = require('./cluster_process'), | ||
port.unlink(function(err) { | ||
if(err) { | ||
if (err) { | ||
self.emit('error', err); | ||
@@ -86,0 +85,0 @@ } |
@@ -30,3 +30,3 @@ var fs = require('fs'), | ||
get : function() { | ||
return isUnixSocket(this.value) ? Port.UNIX : Port.INET | ||
return isUnixSocket(this.value) ? Port.UNIX : Port.INET; | ||
} | ||
@@ -85,4 +85,4 @@ }); | ||
/** | ||
* @param [err] | ||
* @param cb | ||
* @param {Error} [err] | ||
* @param {Function} cb | ||
*/ | ||
@@ -109,3 +109,3 @@ Port.prototype.unlink = function(err, cb) { | ||
fs.unlink(this.value, function(err) { | ||
if(err && err.code !== 'ENOENT') { | ||
if (err && err.code !== 'ENOENT') { | ||
cb(LusterPortError | ||
@@ -112,0 +112,0 @@ .createError(LusterPortError.CODES.CAN_NOT_UNLINK_UNIX_SOCKET, err) |
@@ -478,3 +478,6 @@ var cluster = require('cluster'), | ||
legacy.setImmediate(function() { | ||
self._worker.disconnect(); | ||
// state can be changed before fucntion call | ||
if (self.isRunning()) { | ||
self._worker.disconnect(); | ||
} | ||
}); | ||
@@ -481,0 +484,0 @@ |
{ | ||
"name" : "luster", | ||
"version" : "0.2.0", | ||
"version" : "0.2.1", | ||
"description" : "Node.js cluster wrapper", | ||
@@ -5,0 +5,0 @@ "main" : "./lib/luster.js", |
Sorry, the diff of this file is not supported yet
97517
1797
10