diff options
author | Sam Wilkins <samwilkins333@gmail.com> | 2020-01-01 21:32:30 -0800 |
---|---|---|
committer | Sam Wilkins <samwilkins333@gmail.com> | 2020-01-01 21:32:30 -0800 |
commit | 7d9dc9e647542b0a2fdb9a98cb02e3c9ffc5ff12 (patch) | |
tree | db64744cc3a330de2d89957e48936003777df2d7 /src/server/session_manager/session_manager_cluster.ts | |
parent | 6a3167f80e5801763a88add8b3a8cfce2ac7b467 (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.ts | 11 |
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); + } }); } |