From b4bf12dd03cdac8c9930ddf5e19e36c87b3696e6 Mon Sep 17 00:00:00 2001
From: Sam Wilkins <samwilkins333@gmail.com>
Date: Sun, 29 Dec 2019 15:35:38 -0800
Subject: experimenting with process clustering

---
 src/server/session_manager/session_manager.ts | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

(limited to 'src/server/session_manager/session_manager.ts')

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)));
-- 
cgit v1.2.3-70-g09d2