Fix inverse contidion in open tunnel retain check

fvacek · fvacek · commit f618dc6ca69d · 2026-01-07T11:01:41.000+01:00
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -3,7 +3,7 @@ name = "shvcall"
 description = "CLI utility to invoke remote SHV RPC calls"
 license = "MIT"
 repository = "https://github.com/silicon-heaven/shvcall-rs"
-version = "3.9.11"
+version = "3.9.12"
 edition = "2024"
 
 [[bin]]
diff --git a/src/lib.rs b/src/lib.rs
@@ -671,18 +671,17 @@ async fn start_tunnel_server(
                                 break;
                             }
                         }
-                        tunnels.retain(|tunnel| tunnel.frame_sender.is_closed());
-                        // {
-                        //     if tunnel.frame_sender.is_closed() {
-                        //         debug!(target: "Tunnel", "Removing closed tunnel state {:?}", tunnel);
-                        //         false
-                        //     } else {
-                        //         true
-                        //     }
-                        // });
+                        tunnels.retain(|tunnel| {
+                            if tunnel.frame_sender.is_closed() {
+                                debug!(target: "Tunnel", "Removing closed tunnel state {:?}", tunnel);
+                                false
+                            } else {
+                                true
+                            }
+                        });
                     }
                     Err(e) => {
-                        error!("Get response receiver error: {e}");
+                        error!("Get response receiver error1: {e}");
                         break;
                     }
                 }

Original file line number	Diff line number	Diff line change
`@@ -671,18 +671,17 @@ async fn start_tunnel_server(`
`671`	`671`	`break;`
`672`	`672`	`}`
`673`	`673`	`}`
`674`		`- tunnels.retain(\|tunnel\| tunnel.frame_sender.is_closed());`
`675`		`- // {`
`676`		`- // if tunnel.frame_sender.is_closed() {`
`677`		`- // debug!(target: "Tunnel", "Removing closed tunnel state {:?}", tunnel);`
`678`		`- // false`
`679`		`- // } else {`
`680`		`- // true`
`681`		`- // }`
`682`		`- // });`
	`674`	`+ tunnels.retain(\|tunnel\| {`
	`675`	`+ if tunnel.frame_sender.is_closed() {`
	`676`	`+ debug!(target: "Tunnel", "Removing closed tunnel state {:?}", tunnel);`
	`677`	`+ false`
	`678`	`+ } else {`
	`679`	`+ true`
	`680`	`+ }`
	`681`	`+ });`
`683`	`682`	`}`
`684`	`683`	`Err(e) => {`
`685`		`- error!("Get response receiver error: {e}");`
	`684`	`+ error!("Get response receiver error1: {e}");`
`686`	`685`	`break;`
`687`	`686`	`}`
`688`	`687`	`}`