sleep on connection retry loops of integration_tests_sv2::{MockDownstream,Sniffer,SnifferSV1}

Author: plebhash

integration-tests/lib/mock_roles.rs

@@ -30,7 +30,10 @@ impl MockDownstream {
             match TcpStream::connect(upstream_address).await {
                 Ok(stream) => break stream,
                 Err(_) => {
-                    println!("MockDownstream: unable to connect to upstream, retrying");
+                    tracing::warn!(
+                        "MockDownstream: unable to connect to upstream, retrying after 1 second"
+                    );
+                    tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
                 }
             }
         })

integration-tests/lib/sniffer.rs

@@ -95,10 +95,12 @@ impl<'a> Sniffer<'a> {
                 match TcpStream::connect(upstream_address).await {
                     Ok(stream) => break stream,
                     Err(_) => {
-                        println!(
-                            "Sniffer {}: unable to connect to upstream {}, retrying",
-                            identifier, upstream_address
+                        tracing::warn!(
+                            "Sniffer {}: unable to connect to upstream {}, retrying after 1 second",
+                            identifier,
+                            upstream_address
                         );
+                        tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
                     }
                 }
             })

integration-tests/lib/sv1_sniffer.rs

@@ -59,6 +59,10 @@ impl SnifferSV1 {
                 match TcpStream::connect(upstream_address).await {
                     Ok(s) => break s,
                     Err(_) => {
+                        tracing::warn!(
+                            "SnifferSV1: unable to connect to upstream, retrying after 1 second"
+                        );
+                        tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
                         continue;
                     }
                 }