Remove debugging code

scramjetorg · Feb 21, 2024 · d7707d3 · d7707d3
1 parent 2a73c90
commit d7707d3
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/packages/runner/src/runner.ts b/packages/runner/src/runner.ts
@@ -300,7 +300,7 @@ export class Runner<X extends AppConfig> implements IComponent {
 
         if (timeout) {
             this.monitoringMessageReplyTimeout = setTimeout(async () => {
-                this.logger.warn("Monitoring Reply Timeout. Connected");
+                this.logger.warn("Monitoring Reply Timeout");
 
                 await this.handleDisconnect();
             }, timeout);
@@ -324,7 +324,7 @@ export class Runner<X extends AppConfig> implements IComponent {
 
         try {
             await this.hostClient.disconnect(!this.connected);
-            await defer(5000);
+            await defer(10000);
         } catch (e) {
             this.logger.error("Disconnect failed");
         }
@@ -405,18 +405,18 @@ export class Runner<X extends AppConfig> implements IComponent {
 
         try {
             this.logger.debug("connecting...");
-            await promiseTimeout(this.hostClient.init(this.instanceId), 5000);
+            await promiseTimeout(this.hostClient.init(this.instanceId), 10000);
             this.logger.debug("connected");
             this.connected = true;
 
-            this.hostClient.inputStream.pipe(this.logFile!);
+            //this.hostClient.inputStream.pipe(this.logFile!);
 
             await this.handleMonitoringRequest({ monitoringRate: 1 });
         } catch (e) {
             this.connected = false;
             this.logger.warn("Can't connect to Host", e);
 
-            await defer(5000);
+            await defer(10000);
 
             return await this.premain();
         }