From 5ea26773f7ef41ef7b0d26ed00b50b8a11442466 Mon Sep 17 00:00:00 2001
From: kistenklaus <karlsasssie@gmail.com>
Date: Sat, 6 Jul 2024 21:25:13 +0200
Subject: [PATCH] remove processing

---
 src-tauri/lib/tcp/src/tcpcan.rs             | 96 +++++++++++----------
 src-tauri/src/cnl/can_adapter/tcp/client.rs |  3 +-
 2 files changed, 51 insertions(+), 48 deletions(-)

diff --git a/src-tauri/lib/tcp/src/tcpcan.rs b/src-tauri/lib/tcp/src/tcpcan.rs
index d091c20..ad40562 100644
--- a/src-tauri/lib/tcp/src/tcpcan.rs
+++ b/src-tauri/lib/tcp/src/tcpcan.rs
@@ -298,54 +298,56 @@ impl TcpCan {
     pub async fn recv(&self) -> Option<TNetworkFrame> {
         let mut rx_lock = self.rx_stream.lock().await;
         let rx_stream = rx_lock.deref_mut();
-        let mut rx_buffer = [0; 24];
+        let mut rx_buffer = [0; 4094];
         loop {
-            tokio::select! {
-                rx_res = rx_stream.read_exact(&mut rx_buffer) => {
-                    match rx_res {
-                        Ok(_) => match TcpFrame::from_bin(&rx_buffer).unwrap() {
-                            TcpFrame::NetworkFrame(network_frame) => return Some(network_frame),
-                            TcpFrame::KeepAlive => {
-                                self.wdg.reset().await;
-                            },
-                            TcpFrame::SyncEnd => {
-                                // what a clusterfuck
-                                let mut sync_swap : Option<oneshot::Sender<()>>= None;
-                                let mut sync_complete_signal_guard = self.sync_complete_signal.lock().await;
-                                let sync_complete_signal = sync_complete_signal_guard.deref_mut();
-                                std::mem::swap(sync_complete_signal, &mut sync_swap);
-                                if let Some(sync_signal) = sync_swap {
-                                    if let Err(_) = sync_signal.send(()) {
-                                        cprintln!("<yellow>Received unexpected SYNC_DONE frame.</yellow>");
-                                    }
-                                };
-
-
-
-
-                            },
-                        },
-                        Err(_) => {
-                            cprintln!("<red>TCP connection closed</red>");
-                            if let Some(host) = &self.id_host{
-                                if let Some(node_id) = &self.node_id {
-                                    host.free_id(*node_id);
-                                }
-                            }
-                            return None;
-                        }
-                    }
-                },
-                _wdg_timeout = self.wdg.timeout() =>  {
-                    cprintln!("<red>TCP connection watchdog timed out</red>");
-                    if let Some(host) = &self.id_host{
-                        if let Some(node_id) = &self.node_id {
-                            host.free_id(*node_id);
-                        }
-                    }
-                    return None;
-                },
-            }
+            rx_stream.read(&mut rx_buffer).await.unwrap();
+            // rx_stream.read_exact(&mut rx_buffer).await;
+            // tokio::select! {
+            //     rx_res = 
+            //         match rx_res {
+            //             Ok(_) => match TcpFrame::from_bin(&rx_buffer).unwrap() {
+            //                 TcpFrame::NetworkFrame(network_frame) => return Some(network_frame),
+            //                 TcpFrame::KeepAlive => {
+            //                     self.wdg.reset().await;
+            //                 },
+            //                 TcpFrame::SyncEnd => {
+            //                     // what a clusterfuck
+            //                     let mut sync_swap : Option<oneshot::Sender<()>>= None;
+            //                     let mut sync_complete_signal_guard = self.sync_complete_signal.lock().await;
+            //                     let sync_complete_signal = sync_complete_signal_guard.deref_mut();
+            //                     std::mem::swap(sync_complete_signal, &mut sync_swap);
+            //                     if let Some(sync_signal) = sync_swap {
+            //                         if let Err(_) = sync_signal.send(()) {
+            //                             cprintln!("<yellow>Received unexpected SYNC_DONE frame.</yellow>");
+            //                         }
+            //                     };
+            //
+            //
+            //
+            //
+            //                 },
+            //             },
+            //             Err(_) => {
+            //                 cprintln!("<red>TCP connection closed</red>");
+            //                 if let Some(host) = &self.id_host{
+            //                     if let Some(node_id) = &self.node_id {
+            //                         host.free_id(*node_id);
+            //                     }
+            //                 }
+            //                 return None;
+            //             }
+            //         }
+            //     },
+            //     _wdg_timeout = self.wdg.timeout() =>  {
+            //         cprintln!("<red>TCP connection watchdog timed out</red>");
+            //         if let Some(host) = &self.id_host{
+            //             if let Some(node_id) = &self.node_id {
+            //                 host.free_id(*node_id);
+            //             }
+            //         }
+            //         return None;
+            //     },
+            // }
         }
     }
     pub async fn addr(&self) -> std::io::Result<SocketAddr> {
diff --git a/src-tauri/src/cnl/can_adapter/tcp/client.rs b/src-tauri/src/cnl/can_adapter/tcp/client.rs
index 5545861..4c35750 100644
--- a/src-tauri/src/cnl/can_adapter/tcp/client.rs
+++ b/src-tauri/src/cnl/can_adapter/tcp/client.rs
@@ -1,4 +1,4 @@
-use std::{net::SocketAddr, sync::Arc, time::Instant};
+use std::{net::SocketAddr, sync::Arc, time::{Duration, Instant}};
 
 use crate::notification::notify_warning;
 
@@ -44,6 +44,7 @@ impl TcpClient {
                     }
                     break;
                 };
+                continue;
 
                 let network_frame = tnetwork_frame.value;
                 let timestamp = tnetwork_frame.timestamp;