feat: add portsPerGroup property

Author: maxeljkin

README.md

@@ -112,8 +112,11 @@ module.exports = {
         port : 8080,
 
         // number of workers' groups; each group will
-        // have its own port number (port + group number)
-        groups : 2
+        // have its own port number (port + group number * ports per group..port + (group number + 1) * ports per group - 1)
+        groups : 2,
+
+        // number of ports per worker group; default 1
+        portsPerGroup: 2,
     },
 
     // extensions to load

examples/simple_server/luster.conf.json

@@ -11,7 +11,7 @@
     },
 
     "server" : {
-        "port" : 10080,
+        "port" : 8080,
         "groups" : 3
     }
 }

examples/simple_server/worker.js

@@ -1,9 +1,7 @@
 const http = require('http'),
     worker = require('luster');
 
-if (worker.wid === 1 || worker.wid === 0) {
-    console.log('try to open http://localhost:%s', process.env.port);
-}
+console.log('Worker #%s: try to open http://localhost:%s', worker.wid, process.env.port);
 
 http
     .createServer((req, res) => {

lib/configuration/check.js

@@ -34,6 +34,8 @@ const CHECKS = {
     'server.port': { type: ['number', 'string'] },
     // increase port for every group
     'server.groups': { type: 'number' },
+    // number of ports for each group
+    'server.portsPerGroup': { type: 'number' },
     // hash of extensions; keys – modules' names, values – extensions' configs
     'extensions': { type: 'object' },
     // path to node_modules directory which contains extensions

lib/master.js

@@ -221,6 +221,7 @@ class Master extends ClusterProcess {
             count = this.config.get('workers', os.cpus().length),
             isServerPortSet = this.config.has('server.port'),
             groups = this.config.get('server.groups', 1),
+            portsPerGroup = this.config.get('server.portsPerGroup', 1),
             workersPerGroup = Math.floor(count / groups);
 
         let port,
@@ -240,7 +241,7 @@ class Master extends ClusterProcess {
                 stopTimeout,
                 exitThreshold,
                 allowedSequentialDeaths,
-                port: isServerPortSet ? port.next(group) : 0,
+                port: isServerPortSet ? port.next(group * portsPerGroup) : 0,
                 maxListeners: this.getMaxListeners(),
             }));