Dev/sftp start: Implementing basic SFTP functionality

demo/sftp/std/src/main.rs

@@ -95,8 +95,16 @@ impl DemoServer for StdDemo {
                 let ev = match serv.progress(&mut ph).await {
                     Ok(event) => event,
                     Err(e) => {
-                        error!("server  progress failed: {:?}", e); // NoRoom: 2048 Bytes Output buffer
-                        return Err(e);
+                        match e {
+                            Error::NoRoom {} => {
+                                warn!("NoRoom triggered. Trying again");
+                                continue;
+                            }
+                            _ => {
+                                error!("server  progress failed: {:?}", e); // NoRoom: 2048 Bytes Output buffer
+                                return Err(e);
+                            }
+                        }
                     }
                 };
 
@@ -214,19 +222,23 @@ async fn main(spawner: Spawner) {
     env_logger::builder()
         .filter_level(log::LevelFilter::Info)
         .filter_module(
-            "sunset_demo_sftp_std::demosftpserver",
+            "sunset_sftp::sftphandler::sftphandler",
             log::LevelFilter::Debug,
         )
-        .filter_module("sunset_sftp::sftphandler", log::LevelFilter::Trace)
+        // .filter_module(
+        //     "sunset_demo_sftp_std::demosftpserver",
+        //     log::LevelFilter::Debug,
+        // )
+        // .filter_module("sunset_sftp::sftphandler", log::LevelFilter::Trace)
         // .filter_module("sunset_sftp", log::LevelFilter::Trace)
         // .filter_module("sunset_sftp::sftpsource", log::LevelFilter::Debug)
-        .filter_module(
-            "sunset_sftp::sftphandler::sftpoutputchannelhandler",
-            log::LevelFilter::Info,
-        )
+        // .filter_module(
+        //     "sunset_sftp::sftphandler::sftpoutputchannelhandler",
+        //     log::LevelFilter::Info,
+        // )
         // .filter_module("sunset::channel", log::LevelFilter::Trace)
         // .filter_module("sunset_async::async_sunset", log::LevelFilter::Trace)
-        .filter_module("sunset::runner", log::LevelFilter::Debug)
+        // .filter_module("sunset::runner", log::LevelFilter::Debug)
         // .filter_module("sunset::traffic", log::LevelFilter::Trace)
         // .filter_module("sunset_sftp::sftpsink", log::LevelFilter::Info)
         // .filter_module("sunset_sftp::sftpsource", log::LevelFilter::Info)

sftp/src/sftphandler/sftphandler.rs

@@ -477,7 +477,16 @@ where
         let processing_loop = async {
             loop {
                 trace!("SFTP: About to read bytes from SSH Channel");
-                let lr = chan_in.read(buffer_in).await?;
+                let lr: usize = match chan_in.read(buffer_in).await {
+                    Ok(lr) => lr,
+                    Err(e) => match e {
+                        SunsetError::NoRoom {} => {
+                            error!("SSH channel is full");
+                            continue;
+                        }
+                        _ => return Err(e.into()),
+                    },
+                };
 
                 debug!("SFTP <---- received: {:?} bytes", lr);
                 trace!("SFTP <---- received: {:?}", &buffer_in[0..lr]);
@@ -493,11 +502,11 @@ where
         };
         match select(processing_loop, output_consumer_loop).await {
             embassy_futures::select::Either::First(r) => {
-                debug!("Processing returned: {:?}", r);
+                error!("Processing returned: {:?}", r);
                 r
             }
             embassy_futures::select::Either::Second(r) => {
-                warn!("Output consumer returned: {:?}", r);
+                error!("Output consumer returned: {:?}", r);
                 r
             }
         }