COBS wire encoding (#1)

* using COBS encoding over the wire * separation of serialization/deserialization from writing/reading, added ser/de tests * added trace logs in reading and writing Signed-off-by: gabrik <[email protected]>
ZettaScaleLabs · Jul 18, 2022 · 01042e9 · 01042e9
1 parent 7e4954b
commit 01042e9
Show file tree

Hide file tree

Showing 4 changed files with 257 additions and 106 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -32,8 +32,11 @@ readme = "README.md"
 tokio = {version = "1.17.0", features = ["io-util"] }
 tokio-serial = "5.4.1"
 futures = "0.3.21"
+cobs = "0.2"
+log = "0.4"
 
 [dev-dependencies]
 clap = { version = "3.1", features = ["derive"] }
+env_logger = "0.9.0"
 tokio = {version = "1.17.0", features = ["full"] }
 rand = "0.8"
diff --git a/examples/serial-echo.rs b/examples/serial-echo.rs
@@ -33,6 +33,9 @@ struct Args {
 
 #[tokio::main]
 async fn main() -> tokio_serial::Result<()> {
+    // initiate logging
+    env_logger::init();
+
     let args = Args::parse();
     let mut buff = [0u8; 65535];
 
@@ -78,7 +81,7 @@ async fn main() -> tokio_serial::Result<()> {
                 tokio::time::sleep(Duration::from_secs_f64(timeout_duration)).await;
             };
 
-            let _out = tokio::select! {
+            tokio::select! {
                 res = port.read_msg(&mut buff) => {
                     let read = res?;
                     if read > 0 {