aboutsummaryrefslogtreecommitdiff
path: root/src/server/session_manager/session_manager_cluster.ts
diff options
context:
space:
mode:
authorSam Wilkins <samwilkins333@gmail.com>2020-01-01 21:32:30 -0800
committerSam Wilkins <samwilkins333@gmail.com>2020-01-01 21:32:30 -0800
commit7d9dc9e647542b0a2fdb9a98cb02e3c9ffc5ff12 (patch)
treedb64744cc3a330de2d89957e48936003777df2d7 /src/server/session_manager/session_manager_cluster.ts
parent6a3167f80e5801763a88add8b3a8cfce2ac7b467 (diff)
session manager improvements
Diffstat (limited to 'src/server/session_manager/session_manager_cluster.ts')
-rw-r--r--src/server/session_manager/session_manager_cluster.ts11
1 files changed, 10 insertions, 1 deletions
diff --git a/src/server/session_manager/session_manager_cluster.ts b/src/server/session_manager/session_manager_cluster.ts
index bfe6187c3..546465c03 100644
--- a/src/server/session_manager/session_manager_cluster.ts
+++ b/src/server/session_manager/session_manager_cluster.ts
@@ -4,19 +4,28 @@ import { createServer } from "http";
const capacity = cpus().length;
+let thrown = false;
+
if (isMaster) {
console.log(capacity);
for (let i = 0; i < capacity; i++) {
fork();
}
on("exit", (worker, code, signal) => {
- console.log(`worker ${worker.process.pid} died`);
+ console.log(`worker ${worker.process.pid} died with code ${code} and signal ${signal}`);
+ fork();
});
} else {
const port = 1234;
createServer().listen(port, () => {
console.log('process id local', process.pid);
console.log(`http server started at port ${port}`);
+ if (!thrown) {
+ thrown = true;
+ setTimeout(() => {
+ throw new Error("Hey I'm a fake error!");
+ }, 1000);
+ }
});
}