src/io/stats.rs

@@ -19,15 +19,15 @@ pub struct Stats {
 
 impl Stats {
     pub fn add_connection(&self) {
-        self.connections.fetch_add(1, Ordering::Relaxed);
+        self.connections.store(1, Ordering::Relaxed);
     }
 
     pub fn add_rx_bytes(&self, n: usize) {
-        self.rx.fetch_add(n, Ordering::Relaxed);
+        self.rx.store(n, Ordering::Relaxed);
     }
 
     pub fn add_tx_bytes(&self, n: usize) {
-        self.tx.fetch_add(n, Ordering::Relaxed);
+        self.tx.store(n, Ordering::Relaxed);
     }
 
     pub fn connections(&self) -> usize {
@@ -39,7 +39,7 @@ impl Stats {
     }
 
     pub fn set_failed(&self, failed: bool) {
-        self.failed.fetch_and(failed, Ordering::Relaxed);
+        self.failed.store(failed, Ordering::Relaxed);
     }
 
     pub fn rx(&self) -> Unit {

src/ssh/handler.rs

@@ -330,26 +330,6 @@ impl russh::server::Handler for Handler {
         Ok(session.channel_success(channel)?)
     }
 
-    async fn channel_close(
-        &mut self,
-        channel: ChannelId,
-        session: &mut Session,
-    ) -> Result<(), Self::Error> {
-        if let Some(pty_channel) = self.pty_channel
-            && pty_channel == channel
-        {
-            debug!("Pty channel closed");
-
-            session.disconnect(
-                russh::Disconnect::ByApplication,
-                "Remaining active connections have been closed",
-                "EN",
-            )?;
-        }
-
-        Ok(())
-    }
-
     async fn tcpip_forward(
         &mut self,
         address: &str,