aboutsummaryrefslogtreecommitdiff
path: root/src/server/session_manager/session_manager.ts
diff options
context:
space:
mode:
authorSam Wilkins <samwilkins333@gmail.com>2019-12-29 15:35:38 -0800
committerSam Wilkins <samwilkins333@gmail.com>2019-12-29 15:35:38 -0800
commitb4bf12dd03cdac8c9930ddf5e19e36c87b3696e6 (patch)
tree6c71a85034267bd1d471113ac4c7114034fe79fc /src/server/session_manager/session_manager.ts
parentac1f91082abee583384f50b95d6a1a5e7386ca07 (diff)
experimenting with process clustering
Diffstat (limited to 'src/server/session_manager/session_manager.ts')
-rw-r--r--src/server/session_manager/session_manager.ts7
1 files changed, 6 insertions, 1 deletions
diff --git a/src/server/session_manager/session_manager.ts b/src/server/session_manager/session_manager.ts
index 6084d9a77..97c2ab214 100644
--- a/src/server/session_manager/session_manager.ts
+++ b/src/server/session_manager/session_manager.ts
@@ -9,13 +9,18 @@ import { ChildProcess, exec, execSync } from "child_process";
import InputManager from "./input_manager";
import { identifier, logPath, crashPath, onWindows, pid, ports, heartbeat, recipient, latency, SessionState } from "./config";
const killport = require("kill-port");
+import * as io from "socket.io";
process.on('SIGINT', endPrevious);
let state: SessionState = SessionState.STARTING;
const is = (...reference: SessionState[]) => reference.includes(state);
const set = (reference: SessionState) => state = reference;
+const endpoint = io();
+endpoint.on("connection", socket => {
+});
+endpoint.listen(process.env.PORT);
const { registerCommand } = new InputManager({ identifier });
@@ -116,7 +121,7 @@ function timestamp() {
async function endPrevious() {
identifiedLog(yellow("Cleaning up previous connections..."));
- current_backup?.kill("SIGKILL");
+ current_backup?.kill();
await Promise.all(ports.map(port => {
const task = killport(port, 'tcp');
return task.catch((error: any) => identifiedLog(red(error)));