aboutsummaryrefslogtreecommitdiff
path: root/src/server/session/agents/server_worker.ts
diff options
context:
space:
mode:
authorSam Wilkins <samwilkins333@gmail.com>2020-01-10 13:57:21 -0500
committerSam Wilkins <samwilkins333@gmail.com>2020-01-10 13:57:21 -0500
commit109abe78646c94903ef423aeb7db213087c4b92d (patch)
treef716582e9a5d30f2b11e4fd7ab40eeb7a0f0b2b5 /src/server/session/agents/server_worker.ts
parenta1760ecbb780dc17a7675bd60fb50aa1103fa961 (diff)
event emitter, streamlined initialization
Diffstat (limited to 'src/server/session/agents/server_worker.ts')
-rw-r--r--src/server/session/agents/server_worker.ts4
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) {