Implement Debug for some items

Author: mkj

embassy/src/embassy_sunset.rs

@@ -31,6 +31,7 @@ pub type SunsetRawMutex = NoopRawMutex;
 
 pub type SunsetMutex<T> = Mutex<SunsetRawMutex, T>;
 
+#[derive(Debug)]
 struct Wakers {
     chan_read: [WakerRegistration; MAX_CHANNELS],
 
@@ -109,6 +110,18 @@ pub(crate) struct EmbassySunset<'a> {
     chan_refcounts: [AtomicUsize; MAX_CHANNELS],
 }
 
+impl core::fmt::Debug for EmbassySunset<'_> {
+    fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
+        let mut d = f.debug_struct("EmbassySunset");
+        if let Ok(i) = self.inner.try_lock() {
+            d.field("runner", &i.runner);
+        } else {
+            d.field("inner", &"(locked)");
+        }
+        d.finish_non_exhaustive()
+    }
+}
+
 impl<'a> EmbassySunset<'a> {
     pub fn new(runner: Runner<'a>) -> Self {
         let wakers = Wakers {

embassy/src/server.rs

@@ -14,6 +14,7 @@ use embassy_sunset::{EmbassySunset, ProgressHolder};
 /// and [`stdio_stderr()`][Self::stdio_stderr] methods.
 ///
 /// This is async executor agnostic.
+#[derive(Debug)]
 pub struct SSHServer<'a> {
     sunset: EmbassySunset<'a>,
 }

src/event.rs

@@ -214,7 +214,6 @@ pub(crate) enum CliEventId {
     Banner,
     #[allow(unused)]
     Defunct,
-
     // TODO:
     // Disconnected
     // OpenTCPForwarded (new session)

src/kex.rs

@@ -54,6 +54,7 @@ const fixed_options_cipher: &[&str] = &[SSH_NAME_CHAPOLY, SSH_NAME_AES256_CTR];
 const fixed_options_mac: &[&str] = &[SSH_NAME_HMAC_SHA256];
 const fixed_options_comp: &[&str] = &[SSH_NAME_NONE];
 
+#[derive(Debug)]
 pub(crate) struct AlgoConfig {
     kexs: LocalNames,
     hostsig: LocalNames,

src/traffic.rs

@@ -1,3 +1,5 @@
+use core::fmt;
+
 #[allow(unused_imports)]
 use {
     crate::error::{Error, Result},
@@ -89,6 +91,18 @@ enum RxState {
     },
 }
 
+impl core::fmt::Debug for TrafIn<'_> {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        f.debug_struct("TrafIn").field("state", &self.state).finish_non_exhaustive()
+    }
+}
+
+impl core::fmt::Debug for TrafOut<'_> {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        f.debug_struct("TrafOut").field("state", &self.state).finish_non_exhaustive()
+    }
+}
+
 impl<'a> TrafIn<'a> {
     pub fn new(buf: &'a mut [u8]) -> Self {
         Self { buf, state: RxState::Idle }