Reduce log for test

netfetch/src/ca.rs

@@ -514,7 +514,7 @@ impl CaConnSet {
                 }
             };
         }
-        err::todoval()
+        Ok(())
     }
 
     pub async fn add_channel_to_addr(
@@ -526,6 +526,7 @@ impl CaConnSet {
         let g = self.ca_conn_ress.lock().await;
         match g.get(&addr) {
             Some(ca_conn) => {
+                //info!("try to add to existing... {addr} {channel_name}");
                 let (cmd, rx) = ConnCommand::channel_add(channel_name);
                 ca_conn.sender.send(cmd).await.err_conv()?;
                 let a = rx.recv().await.err_conv()?;
@@ -536,6 +537,8 @@ impl CaConnSet {
                 }
             }
             None => {
+                //info!("create new {addr} {channel_name}");
+                drop(g);
                 let addr = if let SocketAddr::V4(x) = addr {
                     x
                 } else {

netfetch/src/ca/conn.rs

@@ -394,7 +394,7 @@ impl CaConn {
             array_truncate,
             stats: Arc::new(CaConnStats::new()),
             insert_queue_max,
-            insert_ivl_min_mus: 1000 * 1000 * 6,
+            insert_ivl_min_mus: 1000 * 6,
             ts_channel_alive_check_last: Instant::now(),
             conn_command_tx: cq_tx,
             conn_command_rx: cq_rx,