Merge pull request #40 from razvancurcudel/master

set and get for nMaxWorkersCount

Author: oxygen

package.json

@@ -1,7 +1,7 @@
 {
   "name": "jsonrpc-bidirectional",
   "description": "Bidirectional JSONRPC over web sockets or HTTP with extensive plugin support.",
-  "version": "6.5.0",
+  "version": "6.5.1",
   "scripts": {
     "build": "node build.js",
     "test": "node --expose-gc --max-old-space-size=1024 tests/main.js",
@@ -81,4 +81,4 @@
     "node_modules/es6-promise/dist/es6-promise.auto.min.js",
     "node_modules/es6-promise/dist/es6-promise.auto.min.js.map"
   ]
-}
+}

src/NodeClusterBase/MasterEndpoint.js

@@ -70,6 +70,26 @@ class MasterEndpoint extends JSONRPC.EndpointBase
 	}
 
 
+	/**
+	 * @param {number} nWorkersCount
+	 */
+	set maxWorkersCount(nWorkersCount)
+	{
+		assert(typeof nWorkersCount === "number", `Invalid property type for nWorkersCount in MasterEndpoint. Expected "number", but got ${typeof nWorkersCount}.`);
+
+		this._nMaxWorkersCount = nWorkersCount;
+	}
+
+
+	/**
+	 * @returns {number}
+	 */
+	get maxWorkersCount()
+	{
+		return this._nMaxWorkersCount;
+	}
+
+
 	/**
 	 * This overridable function is called and awaited inside startWorker().
 	 * 
@@ -187,7 +207,7 @@ class MasterEndpoint extends JSONRPC.EndpointBase
 
 		await this._startServices();
 
-		for (let i = 0; i < Math.min(Math.max(os.cpus().length, 1), this._nMaxWorkersCount); i++)
+		for (let i = 0; i < Math.min(Math.max(os.cpus().length, 1), this.maxWorkersCount); i++)
 		{
 			cluster.fork();
 		}