temp

Author: nihohit

redis/tests/support/cluster.rs

@@ -204,35 +204,37 @@ impl RedisCluster {
             ));
         }
 
+        sleep(Duration::from_millis(100));
+
         for server in servers.iter_mut() {
             let process = &mut server.process;
-            sleep(Duration::from_millis(50));
-                        match process.try_wait() {
-                            Ok(Some(status)) => {                                
-                                    let contents = std::fs::read_to_string(server.log_file.clone()).unwrap();
-                                    panic!("redis server creation failed with status {status:?}.\nlogfile: {contents}");
-                            }
-                            Ok(None) => {
-                                // wait for 10 seconds for the server to be available.
-                                let max_attempts = 200;
-                                let mut cur_attempts = 0;
-                                let addr = &server.addr;
-                                loop {
-                                    if cur_attempts == max_attempts {
-                                        panic!("redis server creation failed: Port {} closed", &addr)
-                                    }
-                                    if port_in_use(&addr.to_string()) {
-                                        continue;
-                                    }
-                                    eprintln!("Waiting for redis process to initialize");
-                                    sleep(Duration::from_millis(50));
-                                    cur_attempts += 1;
-                                }
-                            }
-                            Err(e) => {
-                                panic!("Unexpected error in redis server creation {e}");
-                            }
+            match process.try_wait() {
+                Ok(Some(status)) => {                                
+                        let contents = std::fs::read_to_string(server.log_file.clone()).unwrap();
+                        panic!("redis server creation failed with status {status:?}.\nlogfile: {contents}");
+                }
+                Ok(None) => {
+                    // wait for 10 seconds for the server to be available.
+                    let max_attempts = 200;
+                    let mut cur_attempts = 0;
+                    let addr = &server.addr;
+                    loop {
+                        if cur_attempts == max_attempts {
+                            panic!("redis server creation failed: Port {} closed", &addr)
                         }
+                        if port_in_use(&addr.to_string()) {
+                            break;
+                        }
+                        eprintln!("Waiting for redis process to initialize");
+                        sleep(Duration::from_millis(50));
+                        cur_attempts += 1;
+                    }
+                    continue;
+                }
+                Err(e) => {
+                    panic!("Unexpected error in redis server creation {e}");
+                }
+            }
         }
 
         let mut cmd = process::Command::new("redis-cli");