remove uncessary info

Author: zhboner

src/relay.rs

@@ -6,8 +6,6 @@ use std::net::{IpAddr, SocketAddr};
 use std::sync::mpsc;
 use std::sync::{Arc, RwLock};
 use std::thread;
-use std::thread::sleep;
-use std::time::Duration;
 use tokio;
 use tokio::io;
 use tokio::net;
@@ -24,15 +22,12 @@ pub async fn start_relay(configs: Vec<RelayConfig>) {
 
     let mut remote_ips: Vec<Arc<RwLock<std::net::IpAddr>>> = Vec::new();
     for _ in 0..remote_addrs.len() {
-        remote_ips.push(
-            Arc::new(RwLock::new(default_ip.clone()))
-        )
+        remote_ips.push(Arc::new(RwLock::new(default_ip.clone())))
     }
     let cloned_remote_ips = remote_ips.clone();
 
     thread::spawn(move || resolver::resolve(remote_addrs, cloned_remote_ips));
 
-    // sleep(Duration::from_secs(3));
     resolver::print_ips(&remote_ips);
 
     let mut iter = configs.into_iter().zip(remote_ips);
@@ -62,14 +57,6 @@ pub async fn run(config: RelayConfig, remote_ip: Arc<RwLock<IpAddr>>) {
     thread::spawn(move || udp_transfer(client_socket.clone(), remote_socket.port(), udp_remote_ip));
 
     // Start TCP connection
-    println!(
-        "[success] Started {}:{} -> {}:{}",
-        config.listening_address,
-        config.listening_port,
-        &(remote_ip.read().unwrap()),
-        config.remote_port
-    );
-
     while let Ok((inbound, _)) = tcp_listener.accept().await {
         remote_socket = format!("{}:{}", &(remote_ip.read().unwrap()), config.remote_port)
             .parse()
@@ -151,4 +138,3 @@ async fn transfer_tcp(
 
     Ok(())
 }
-

src/resolver.rs

@@ -38,21 +38,18 @@ pub fn resolve(addr_list: Vec<String>, ip_list: Vec<Arc<RwLock<net::IpAddr>>>) {
     loop {
         for (i, addr) in addr_list.iter().enumerate() {
             if let Some(new_ip) = resolve_single(&resolver, addr) {
-                println!("Resolving {}", i);
                 if new_ip != cache_list[i] {
                     cache_list[i] = new_ip;
                     let mut w = ip_list[i].write().unwrap();
                     *w = new_ip;
                     drop(w);
                     println!("Resolved {}: {}", addr, new_ip);
-                    // println!("ip_list[{}]: {}", i, *w);
-                    print_ips(&ip_list);
                 }
             } else {
                 println!("Cannot resolve address {}", addr);
             }
         }
-        
+
         sleep(Duration::from_secs(60));
     }
 }