don't clear the queue when load balanced

Author: abr-egn

src/cmap/worker.rs

@@ -513,11 +513,13 @@ impl ConnectionPoolWorker {
                 handler.handle_pool_cleared_event(event);
             });
 
-            for request in self.wait_queue.drain(..) {
-                // an error means the other end hung up already, which is okay because we were
-                // returning an error anyways
-                let _: std::result::Result<_, _> =
-                    request.fulfill(ConnectionRequestResult::PoolCleared(cause.clone()));
+            if !matches!(self.generation, PoolGeneration::LoadBalanced(_)) {
+                for request in self.wait_queue.drain(..) {
+                    // an error means the other end hung up already, which is okay because we were
+                    // returning an error anyways
+                    let _: std::result::Result<_, _> =
+                        request.fulfill(ConnectionRequestResult::PoolCleared(cause.clone()));
+                }
             }
         }
     }

src/test/spec/retryable_reads.rs

@@ -91,6 +91,10 @@ async fn retry_read_pool_cleared() {
         println!("skipping retry_read_pool_cleared due to blockConnection not being supported");
         return;
     }
+    if client.is_load_balanced() {
+        println!("skipping retry_read_pool_cleared due to load-balanced topology");
+        return;
+    }
 
     let collection = client
         .database("retry_read_pool_cleared")

src/test/spec/retryable_writes/mod.rs

@@ -422,6 +422,11 @@ async fn retry_write_pool_cleared() {
         return;
     }
 
+    if client.is_load_balanced() {
+        println!("skipping retry_write_pool_cleared due to load-balanced topology");
+        return;
+    }
+
     let collection = client
         .database("retry_write_pool_cleared")
         .collection("retry_write_pool_cleared");