Added multi-processor support for cube servers

bin/collector.js

@@ -1,9 +1,23 @@
-var options = require("./collector-config"),
+var cluster = require('cluster'),
+    options = require("./collector-config"),
     cube = require("../"),
     server = cube.server(options);
 
-server.register = function(db, endpoints) {
-  cube.collector.register(db, endpoints);
-};
+var numCPUs = options.workers || require('os').cpus().length;
 
-server.start();
+if (cluster.isMaster) {
+  for (var i = 0; i < numCPUs; i++) {
+    cluster.fork();
+  }
+
+  cluster.on('exit', function(worker, code, signal) {
+    console.log('worker ' + worker.process.pid + ' died');
+    cluster.fork();
+  });
+} else {
+  server.register = function(db, endpoints) {
+    cube.collector.register(db, endpoints);
+  };
+
+  server.start();
+}

bin/evaluator.js

@@ -1,9 +1,23 @@
-var options = require("./evaluator-config"),
+var cluster = require('cluster'),
+    options = require("./evaluator-config"),
     cube = require("../"),
     server = cube.server(options);
 
-server.register = function(db, endpoints) {
-  cube.evaluator.register(db, endpoints);
-};
+var numCPUs = options.workers || require('os').cpus().length;
 
-server.start();
+if (cluster.isMaster) {
+  for (var i = 0; i < numCPUs; i++) {
+    cluster.fork();
+  }
+
+  cluster.on('exit', function(worker, code, signal) {
+    console.log('worker ' + worker.process.pid + ' died');
+    cluster.fork();
+  });
+} else {
+  server.register = function(db, endpoints) {
+    cube.evaluator.register(db, endpoints);
+  };
+
+  server.start();
+}