Remove debugging logs

Author: JamieTsai1024

.evergreen/run-tests.sh

@@ -33,7 +33,7 @@ if [ "Windows_NT" == "$OS" ]; then
   export SSL_CERT_DIR=$(cygpath /etc/ssl/certs --windows)
 fi
 
-cargo_test "test::spec::retryable_reads::retry_read_different_mongos"
+cargo_test ""
 
 # cargo-nextest doesn't support doc tests
 RUST_BACKTRACE=1 cargo test --doc $(cargo_test_options)

src/client/executor.rs

@@ -318,11 +318,6 @@ impl Client {
                 .and_then(|s| s.transaction.pinned_mongos())
                 .or_else(|| op.selection_criteria());
 
-            if op.name() == "insert" || op.name() == "find" {
-                let first_server = retry.as_ref().map(|r| &r.first_server);
-                dbg!("deprioritized: {}", &first_server);
-            }
-
             let (server, effective_criteria) = match self
                 .select_server(
                     selection_criteria,

src/sdam/description/topology/server_selection.rs

@@ -62,33 +62,16 @@ pub(crate) fn attempt_to_select_server<'a>(
     deprioritized: Option<&ServerAddress>,
 ) -> Result<Option<SelectedServer>> {
     let mut in_window = topology_description.suitable_servers_in_latency_window(criteria)?;
-    dbg!("length of in_window before filter: {}", in_window.len());
-    for server_desc in in_window.clone() {
-        if let Some(server) = servers.get(&server_desc.address) {
-            dbg!("[Before filter] Server address: {}", &server.address);
-        }
-    }
     if let Some(addr) = deprioritized {
         if in_window.len() > 1 {
             in_window.retain(|d| &d.address != addr);
         }
     }
-    dbg!("length of in_window after filter: {}", in_window.len());
-    for server_desc in in_window.clone() {
-        if let Some(server) = servers.get(&server_desc.address) {
-            dbg!("[After filter] Server address: {}", &server.address);
-        }
-    }
     let in_window_servers = in_window
         .into_iter()
         .flat_map(|desc| servers.get(&desc.address))
         .collect();
     let selected = select_server_in_latency_window(in_window_servers);
-    if let Some(server) = selected.clone() {
-        dbg!("Selected server address: {}", &server.address);
-    } else {
-        dbg!("No server was selected.");
-    }
     Ok(selected.map(SelectedServer::new))
 }
 
@@ -150,18 +133,8 @@ impl TopologyDescription {
                 .collect(),
         };
 
-        dbg!(
-            "suitable servers before latency window filter: {}",
-            suitable_servers.len()
-        );
-
         self.retain_servers_within_latency_window(&mut suitable_servers);
 
-        dbg!(
-            "suitable servers after latency window filter: {}",
-            suitable_servers.len()
-        );
-
         Ok(suitable_servers)
     }
 

src/test/spec/retryable_reads.rs

@@ -174,7 +174,6 @@ async fn retry_read_different_mongos() {
     }
     client_options.hosts.drain(2..);
     client_options.retry_reads = Some(true);
-    dbg!("\nstart retry_read_different_mongos");
 
     let hosts = client_options.hosts.clone();
     let client = Client::for_test()
@@ -221,7 +220,6 @@ async fn retry_read_different_mongos() {
         first_address, second_address,
         "Failed commands did not occur on two different mongos instances"
     );
-    dbg!("end retry_read_different_mongos\n");
 
     drop(guards); // enforce lifetime
 }
@@ -237,7 +235,6 @@ async fn retry_read_same_mongos() {
         log_uncaptured("skipping retry_read_same_mongos: requires sharded cluster");
         return;
     }
-    dbg!("\nstart retry_read_same_mongos");
 
     let mut client_options = get_client_options().await.clone();
     client_options.hosts.drain(1..);
@@ -285,7 +282,5 @@ async fn retry_read_same_mongos() {
         "Failed command and retry did not occur on the same mongos instance",
     );
 
-    dbg!("end retry_read_same_mongos\n");
-
     drop(fp_guard); // enforce lifetime
 }

src/test/spec/retryable_writes.rs

@@ -320,7 +320,6 @@ async fn retry_write_different_mongos() {
     client_options.hosts.drain(2..);
     client_options.retry_writes = Some(true);
     let hosts = client_options.hosts.clone();
-    dbg!("\nstart retry_write_different_mongos");
     let client = Client::for_test()
         .options(client_options)
         .monitor_events()
@@ -366,7 +365,6 @@ async fn retry_write_different_mongos() {
         first_address, second_address,
         "Failed commands did not occur on two different mongos instances"
     );
-    dbg!("end retry_write_different_mongos\n");
 
     drop(guards); // enforce lifetime
 }
@@ -383,7 +381,6 @@ async fn retry_write_same_mongos() {
         return;
     }
 
-    dbg!("\nstart retry_write_same_mongos");
     let mut client_options = get_client_options().await.clone();
     client_options.hosts.drain(1..);
     client_options.retry_writes = Some(true);
@@ -431,7 +428,6 @@ async fn retry_write_same_mongos() {
         first_address, second_address,
         "Failed commands did not occur on the same mongos instance",
     );
-    dbg!("end retry_write_same_mongos\n");
 
     drop(fp_guard); // enforce lifetime
 }