diff options
| author | Sam Wilkins <samwilkins333@gmail.com> | 2020-01-10 13:57:21 -0500 |
|---|---|---|
| committer | Sam Wilkins <samwilkins333@gmail.com> | 2020-01-10 13:57:21 -0500 |
| commit | 109abe78646c94903ef423aeb7db213087c4b92d (patch) | |
| tree | f716582e9a5d30f2b11e4fd7ab40eeb7a0f0b2b5 /src/server/session/agents/server_worker.ts | |
| parent | a1760ecbb780dc17a7675bd60fb50aa1103fa961 (diff) | |
event emitter, streamlined initialization
Diffstat (limited to 'src/server/session/agents/server_worker.ts')
| -rw-r--r-- | src/server/session/agents/server_worker.ts | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/server/session/agents/server_worker.ts b/src/server/session/agents/server_worker.ts index 6ed385151..e9fdaf923 100644 --- a/src/server/session/agents/server_worker.ts +++ b/src/server/session/agents/server_worker.ts @@ -3,6 +3,7 @@ import { isMaster } from "cluster"; import { IPC } from "../utilities/ipc"; import { red, green, white, yellow } from "colors"; import { get } from "request-promise"; +import { Monitor } from "./monitor"; /** * Effectively, each worker repairs the connection to the server by reintroducing a consistent state @@ -19,6 +20,7 @@ export class ServerWorker { private pollingFailureTolerance: number; private pollTarget: string; private serverPort: number; + private isInitialized = false; public static Create(work: Function) { if (isMaster) { @@ -136,6 +138,8 @@ export class ServerWorker { if (!this.shouldServerBeResponsive) { // notify monitor thread that the server is up and running this.lifecycleNotification(green(`listening on ${this.serverPort}...`)); + this.sendMonitorAction(Monitor.IntrinsicEvents.ServerRunning, { firstTime: !this.isInitialized }); + this.isInitialized = true; } this.shouldServerBeResponsive = true; } catch (error) { |
