From 54a241ff71abc07a5dbdebce1b614f1024a767e6 Mon Sep 17 00:00:00 2001 From: Sam Wilkins Date: Sat, 11 Jan 2020 15:08:26 -0500 Subject: final session cleanup --- src/server/session/agents/server_worker.ts | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) (limited to 'src/server/session/agents/server_worker.ts') diff --git a/src/server/session/agents/server_worker.ts b/src/server/session/agents/server_worker.ts index 23ffb2650..705307030 100644 --- a/src/server/session/agents/server_worker.ts +++ b/src/server/session/agents/server_worker.ts @@ -1,6 +1,6 @@ import { ExitHandler } from "./applied_session_agent"; import { isMaster } from "cluster"; -import { PromisifiedIPCManager, Message, MessageHandler } from "../utilities/ipc"; +import { PromisifiedIPCManager } from "./promisified_ipc_manager"; import ProcessMessageRouter from "./process_message_router"; import { red, green, white, yellow } from "colors"; import { get } from "request-promise"; @@ -61,7 +61,7 @@ export class ServerWorker extends ProcessMessageRouter { private constructor(work: Function) { super(); - ServerWorker.IPCManager = new PromisifiedIPCManager(process); + ServerWorker.IPCManager = new PromisifiedIPCManager(process, this.route); this.lifecycleNotification(green(`initializing process... ${white(`[${process.execPath} ${process.execArgv.join(" ")}]`)}`)); const { pollingRoute, serverPort, pollingIntervalSeconds, pollingFailureTolerance } = process.env; @@ -80,12 +80,8 @@ export class ServerWorker extends ProcessMessageRouter { * server process. */ private configureProcess = () => { - ServerWorker.IPCManager.setRouter(this.route); // updates the local values of variables to the those sent from master - this.on("updatePollingInterval", ({ newPollingIntervalSeconds }) => { - this.pollingIntervalSeconds = newPollingIntervalSeconds; - return new Promise(resolve => setTimeout(resolve, 1000 * 10)); - }); + this.on("updatePollingInterval", ({ newPollingIntervalSeconds }) => this.pollingIntervalSeconds = newPollingIntervalSeconds); this.on("manualExit", async ({ isSessionEnd }) => { await this.executeExitHandlers(isSessionEnd); process.exit(0); -- cgit v1.2.3-70-g09d2