added durations to checkOut events

Author: aditi-khare-mongoDB

src/cmap/connection.ts

@@ -191,7 +191,6 @@ export class Connection extends TypedEventEmitter<ConnectionEvents> {
 
   private lastUseTime: number;
   private clusterTime: Document | null = null;
-
   private error: Error | null = null;
   private dataEvents: AsyncGenerator<Buffer, void, void> | null = null;
 
@@ -230,7 +229,6 @@ export class Connection extends TypedEventEmitter<ConnectionEvents> {
     this.description = new StreamDescription(this.address, options);
     this.generation = options.generation;
     this.lastUseTime = now();
-    this.connectionCreatedEventTime = null;
 
     this.messageStream = this.socket
       .on('error', this.onError.bind(this))

src/cmap/connection_pool.ts

@@ -162,6 +162,7 @@ export class ConnectionPool extends TypedEventEmitter<ConnectionPoolEvents> {
   [kWaitQueue]: List<WaitQueueMember>;
   [kMetrics]: ConnectionPoolMetrics;
   [kProcessingWaitQueue]: boolean;
+  checkOutTime: undefined | number;
 
   /**
    * Emitted when the connection pool is created.
@@ -355,6 +356,7 @@ export class ConnectionPool extends TypedEventEmitter<ConnectionPoolEvents> {
    * explicitly destroyed by the new owner.
    */
   async checkOut(): Promise<Connection> {
+    this.checkOutTime = Date.now();
     this.emitAndLog(
       ConnectionPool.CONNECTION_CHECK_OUT_STARTED,
       new ConnectionCheckOutStartedEvent(this)

src/cmap/connection_pool_events.ts

@@ -229,7 +229,7 @@ export class ConnectionCheckOutFailedEvent extends ConnectionPoolMonitoringEvent
     error?: MongoError
   ) {
     super(pool);
-    this.durationMS = this.durationMS = Date.now() - (connection.connectionCreatedEventTime ?? Date.now());
+    this.durationMS = Date.now() - (pool.checkOutTime ?? 0);
     this.reason = reason;
     this.error = error;
   }
@@ -263,7 +263,7 @@ export class ConnectionCheckedOutEvent extends ConnectionPoolMonitoringEvent {
   /** @internal */
   constructor(pool: ConnectionPool, connection: Connection) {
     super(pool);
-    this.durationMS = 0;
+    this.durationMS = Date.now() - (pool.checkOutTime ?? 0);
     this.connectionId = connection.id;
   }
 }

test/integration/connection-monitoring-and-pooling/connection_monitoring_and_pooling.spec.test.ts

@@ -39,7 +39,7 @@ const INTERRUPT_IN_USE_SKIPPED_TESTS: SkipDescription[] = [
   }
 ];
 
-describe.only('Connection Monitoring and Pooling Spec Tests (Integration) - cmap-format', function () {
+describe('Connection Monitoring and Pooling Spec Tests (Integration) - cmap-format', function () {
   const tests: CmapTest[] = loadSpecTests('connection-monitoring-and-pooling', 'cmap-format');
 
   runCmapTestSuite(tests, {
@@ -57,7 +57,7 @@ describe.only('Connection Monitoring and Pooling Spec Tests (Integration) - cmap
   });
 });
 
-describe.only('Connection Monitoring and Pooling Spec Tests (Integration) - logging', function () {
+describe('Connection Monitoring and Pooling Spec Tests (Integration) - logging', function () {
   const tests = loadSpecTests('connection-monitoring-and-pooling', 'logging');
 
   runUnifiedSuite(tests, test => {