address comments

Author: baileympearson

src/cmap/connection_pool.ts

@@ -415,7 +415,6 @@ export class ConnectionPool extends TypedEventEmitter<ConnectionPoolEvents> {
    */
   clear(options: { serviceId?: ObjectId; interruptInUseConnections?: boolean } = {}): void {
     const { serviceId } = options;
-    const interruptInUseConnections = options.interruptInUseConnections ?? false;
     if (this.closed) {
       return;
     }
@@ -438,10 +437,9 @@ export class ConnectionPool extends TypedEventEmitter<ConnectionPoolEvents> {
       );
       return;
     }
-
-    const oldGeneration = this[kGeneration];
-
     // handle non load-balanced case
+    const interruptInUseConnections = options.interruptInUseConnections ?? false;
+    const oldGeneration = this[kGeneration];
     this[kGeneration] += 1;
     const alreadyPaused = this[kPoolState] === PoolState.paused;
     this[kPoolState] = PoolState.paused;
@@ -455,7 +453,7 @@ export class ConnectionPool extends TypedEventEmitter<ConnectionPoolEvents> {
     }
 
     process.nextTick(() =>
-      this.pruneConnections({ minGeneration: oldGeneration, interruptInUseConnections })
+      this.interruptInUseConnections({ interruptInUseConnections, minGeneration: oldGeneration })
     );
 
     this.processWaitQueue();
@@ -468,41 +466,29 @@ export class ConnectionPool extends TypedEventEmitter<ConnectionPoolEvents> {
    * Only connections where `connection.generation <= minGeneration` are killed.  Connections are closed with a
    * resumable PoolClearedOnNetworkTimeoutError.
    */
-  private pruneConnections({
+  private interruptInUseConnections({
     interruptInUseConnections,
     minGeneration
   }: {
     interruptInUseConnections: boolean;
     minGeneration: number;
   }) {
-    this[kConnections].prune(connection => {
+    if (!interruptInUseConnections) {
+      return;
+    }
+    for (const connection of this[kCheckedOut]) {
       if (connection.generation <= minGeneration) {
+        this[kCheckedOut].delete(connection);
         connection.onError(new PoolClearedOnNetworkError(this));
         this.emit(
           ConnectionPool.CONNECTION_CLOSED,
           new ConnectionClosedEvent(this, connection, 'stale')
         );
-
-        return true;
       }
-      return false;
-    });
-
-    if (interruptInUseConnections) {
-      for (const connection of this[kCheckedOut]) {
-        if (connection.generation <= minGeneration) {
-          this[kCheckedOut].delete(connection);
-          connection.onError(new PoolClearedOnNetworkError(this));
-          this.emit(
-            ConnectionPool.CONNECTION_CLOSED,
-            new ConnectionClosedEvent(this, connection, 'stale')
-          );
-        }
-      }
-
-      // TODO(NODE-4784): track pending connections and cancel
-      // this[kCancellationToken].emit('cancel');
     }
+
+    // TODO(NODE-4784): track pending connections and cancel
+    // this[kCancellationToken].emit('cancel');
   }
 
   /** Close the pool */

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

@@ -24,6 +24,13 @@ const INTERRUPT_IN_USE_SKIPPED_TESTS: SkipDescription[] = [
     description: 'clear with interruptInUseConnections = true closes pending connections',
     skipIfCondition: 'always',
     skipReason: 'TODO(NODE-4784): track and kill pending connections'
+  },
+  {
+    description:
+      'Pool clear SHOULD schedule the next background thread run immediately (interruptInUseConnections: false)',
+    skipIfCondition: 'always',
+    skipReason: `NodeJS does not have a background thread responsible for managing connections, and so already checked in connections are not
+    pruned when in-use connections are interrupted.`
   }
 ];