DorianNiemiecSVRJS/svrjs
Archived
1
0
Fork 0
forked from svrjs/svrjs
Code Pull requests Activity

Add addListenersToWorker() function

Browse source
This commit is contained in:
Dorian Niemiec 2024-08-25 19:35:58 +02:00
parent a92616b0a4
commit 4f565d1550
1 changed files with 19 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
src/index.js
View file

@ -377,6 +377,10 @@ if (typeof process.serverConfig.sport === "string") {
const serverconsole = require("./utils/serverconsole.js"); const serverconsole = require("./utils/serverconsole.js");
function addListenersToWorker(worker) {
process.messageEventListeners.forEach((messageEventListener) => worker.on("message", messageEventListener(worker, serverconsole)));
}
let inspectorURL = undefined; let inspectorURL = undefined;
try { try {
if (inspector) { if (inspector) {
@ -1113,7 +1117,7 @@ function SVRJSFork() {
) { ) {
threadLimitWarned = true; threadLimitWarned = true;
serverconsole.locwarnmessage( serverconsole.locwarnmessage(
"SVR.JS limited the number of workers to one, because of startup problems in Bun 1.0 and newer with shimmed (not native) clustering module. Reliability may suffer.", name + " limited the number of workers to one, because of startup problems in Bun 1.0 and newer with shimmed (not native) clustering module. Reliability may suffer.",
); );
} }
if ( if (
@ -1129,7 +1133,7 @@ function SVRJSFork() {
} else { } else {
if (SVRJSInitialized) if (SVRJSInitialized)
serverconsole.locwarnmessage( serverconsole.locwarnmessage(
"SVR.JS limited the number of workers to one, because of startup problems in Bun 1.0 and newer with shimmed (not native) clustering module. Reliability may suffer.", name + " limited the number of workers to one, because of startup problems in Bun 1.0 and newer with shimmed (not native) clustering module. Reliability may suffer.",
); );
} }
} catch (err) { } catch (err) {
@ -1145,7 +1149,7 @@ function SVRJSFork() {
) { ) {
threadLimitWarned = true; threadLimitWarned = true;
serverconsole.locwarnmessage( serverconsole.locwarnmessage(
"SVR.JS limited the number of workers to one, because of startup problems in Bun 1.0 and newer with shimmed (not native) clustering module. Reliability may suffer.", name + " limited the number of workers to one, because of startup problems in Bun 1.0 and newer with shimmed (not native) clustering module. Reliability may suffer.",
); );
} }
if ( if (
@ -1161,7 +1165,7 @@ function SVRJSFork() {
} else { } else {
if (SVRJSInitialized) if (SVRJSInitialized)
serverconsole.locwarnmessage( serverconsole.locwarnmessage(
"SVR.JS limited the number of workers to one, because of startup problems in Bun 1.0 and newer with shimmed (not native) clustering module. Reliability may suffer.", name + " limited the number of workers to one, because of startup problems in Bun 1.0 and newer with shimmed (not native) clustering module. Reliability may suffer.",
); );
} }
} else { } else {
@ -1187,9 +1191,17 @@ function SVRJSFork() {
// TODO: add listeners to workers // TODO: add listeners to workers
// newWorker.on("message", bruteForceListenerWrapper(newWorker)); // newWorker.on("message", bruteForceListenerWrapper(newWorker));
// newWorker.on("message", listenConnListener); // newWorker.on("message", listenConnListener);
addListenersToWorker(newWorker);
} }
} }
// TODO: main message event listener
process.messageEventListeners.push((worker, serverconsole) => {
return (message) => {
console.log("Message received from worker: " + message);
}
});
// Starting function // Starting function
function start(init) { function start(init) {
init = Boolean(init); init = Boolean(init);
@ -1506,12 +1518,12 @@ function start(init) {
*/ */
if (init) { if (init) {
var workersToFork = 1; let workersToFork = 1;
const getWorkerCountToFork = () => { const getWorkerCountToFork = () => {
var workersToFork = os.availableParallelism ? os.availableParallelism() : os.cpus().length; let workersToFork = os.availableParallelism ? os.availableParallelism() : os.cpus().length;
try { try {
var useAvailableCores = Math.round((os.freemem()) / 50000000) - 1; // 1 core deleted for safety... const useAvailableCores = Math.round((os.freemem()) / 50000000) - 1; // 1 core deleted for safety...
if (workersToFork > useAvailableCores) workersToFork = useAvailableCores; if (workersToFork > useAvailableCores) workersToFork = useAvailableCores;
} catch (err) { } catch (err) {
// Nevermind... Don't want SVR.JS to fail starting, because os.freemem function is not working. // Nevermind... Don't want SVR.JS to fail starting, because os.freemem function is not working.