format fix

aws · Jan 22, 2025 · cec0010 · cec0010
1 parent 9d3278d
commit cec0010
Show file tree

Hide file tree

Showing 5 changed files with 204 additions and 218 deletions.
diff --git a/common/lib/plugins/efm2/host_monitoring2_connection_plugin.ts b/common/lib/plugins/efm2/host_monitoring2_connection_plugin.ts
@@ -112,7 +112,7 @@ export class HostMonitoring2ConnectionPlugin extends AbstractConnectionPlugin im
       result = await methodFunc();
     } finally {
       if (monitorContext != null) {
-         await this.monitorService.stopMonitoring(monitorContext, this.pluginService.getCurrentClient().targetClient);
+        await this.monitorService.stopMonitoring(monitorContext, this.pluginService.getCurrentClient().targetClient);
 
         logger.debug(Messages.get("HostMonitoringConnectionPlugin.monitoringDeactivated", methodName));
       }

diff --git a/common/lib/plugins/efm2/monitor.ts b/common/lib/plugins/efm2/monitor.ts
@@ -99,13 +99,6 @@ export class MonitorImpl implements Monitor {
     return this.activeContexts.length === 0 && MonitorImpl.newContexts.size === 0;
   }
 
-  async close(): Promise<void> {
-    this.stopped = true;
-    // Waiting for 30s gives a task enough time to exit monitoring loop and close database connection.
-    await sleep(30000);
-    logger.debug(Messages.get("MonitorImpl.stopped", this.hostInfo.host));
-  }
-
   startMonitoring(context: MonitorConnectionContext): void {
     if (this.isStopped()) {
       logger.warn(Messages.get("MonitorImpl.monitorIsStopped", this.hostInfo.host));
@@ -116,7 +109,7 @@ export class MonitorImpl implements Monitor {
     const connectionQueue = MapUtils.computeIfAbsent(
       MonitorImpl.newContexts,
       startMonitorTimeNano,
-      (k) => new Array<WeakRef<MonitorConnectionContext>>()
+      () => new Array<WeakRef<MonitorConnectionContext>>()
     );
     connectionQueue.push(new WeakRef<MonitorConnectionContext>(context));
   }
@@ -260,10 +253,6 @@ export class MonitorImpl implements Monitor {
     });
   }
 
-  clearContexts(): void {
-    this.activeContexts.length = 0;
-  }
-
   isStopped(): boolean {
     return this.stopped;
   }
@@ -310,7 +299,6 @@ export class MonitorImpl implements Monitor {
 
   async endMonitoringClient() {
     if (this.monitoringClient) {
-
       await this.pluginService.abortTargetClient(this.monitoringClient);
       this.monitoringClient = null;
     }

diff --git a/common/lib/plugins/efm2/monitor_connection_context.ts b/common/lib/plugins/efm2/monitor_connection_context.ts
@@ -16,8 +16,6 @@
 
 import { uniqueId } from "../../../logutils";
 import { ClientWrapper } from "../../client_wrapper";
-import { sleep } from "../../utils/utils";
-import { AwsWrapperError } from "../../utils/errors";
 
 /**
  * Monitoring context for each connection. This contains each connection's criteria for whether a

diff --git a/common/lib/plugins/efm2/monitor_service.ts b/common/lib/plugins/efm2/monitor_service.ts
@@ -145,7 +145,7 @@ export class MonitorServiceImpl implements MonitorService {
     const cacheExpirationNanos = BigInt(WrapperProperties.MONITOR_DISPOSAL_TIME_MS.get(properties) * 1_000_000);
     return MonitorServiceImpl.monitors.computeIfAbsent(
       monitorKey,
-      (key) =>
+      () =>
         this.monitorSupplier(
           this.pluginService,
           hostInfo,