better disconnect

sokra · sokra · commit 046021174268 · 2012-10-26T00:19:19.000+02:00
diff --git a/lib/Workers.js b/lib/Workers.js
@@ -4,6 +4,15 @@
 */
 var child_process = require("child_process");
 
+function disconnectWorker(worker) {
+	if(worker.disconnect)
+		worker.disconnect();
+	else if(worker.kill)
+		worker.kill();
+	else
+		worker.process.kill();
+}
+
 function Workers(moduleToFork, count) {
 	this.nextId = 1;
 	this.workers = [];
@@ -49,7 +58,7 @@ Workers.prototype.bindWorker = function(worker, idx) {
 				callback.apply(null, result);
 			}.bind(this));
 		} else {
-			worker.disconnect();
+			disconnectWorker(worker);
 			this.forkedWorkers.splice(idx, 1);
 		}
 	}.bind(this));
@@ -85,9 +94,7 @@ Workers.prototype.pushJob = function(worker) {
 }
 
 Workers.prototype.close = function() {
-	this.workers.forEach(function(worker) {
-		worker.disconnect();
-	});
+	this.workers.forEach(disconnectWorker);
 	this.workers.length = 0;
 	this.workersJobs.length = 0;
 	this.workersRegister.length = 0;
