WIP

WildernessLabs · Dec 12, 2024 · bf4f256 · bf4f256
1 parent 881d02d
commit bf4f256
Showing 1 changed file with 4 additions and 13 deletions.
diff --git a/Source/v2/Meadow.HCom/Connections/SerialConnection.ListenerProc.cs b/Source/v2/Meadow.HCom/Connections/SerialConnection.ListenerProc.cs
@@ -61,8 +61,6 @@ async Task ReOpen() // local function
 
                 while (!_port.IsOpen)
                 {
-                    await Task.Delay(500);
-
                     if (timeout-- < 0)
                     {
                         return;
@@ -77,6 +75,7 @@ async Task ReOpen() // local function
                     {
                         Debug.WriteLine($"Failed to re-open port");
                     }
+                    await Task.Delay(100);
                 }
             }
 
@@ -92,16 +91,6 @@ async Task ReOpen() // local function
                         try
                         {
                             receivedLength = _port.Read(readBuffer, 0, readBuffer.Length);
-                            if (receivedLength == 0)
-                            {
-                                Debug.WriteLine($"Received 0 bytes");
-                                throw new OperationCanceledException();
-                            }
-                        }
-                        catch (OperationCanceledException)
-                        {
-                            await ReOpen();
-                            goto read;
                         }
                         catch (InvalidOperationException)
                         {
@@ -351,7 +340,9 @@ async Task ReOpen() // local function
                     catch (OperationCanceledException)
                     {
                         // this happens on disconnect - could be cable pulled, could be device reset
-                        Debug.WriteLine($"Operation Cancelled");
+                        Debug.WriteLine($"Operation Cancelled. Port open: {_port.IsOpen}");
+                        if (!_port.IsOpen) { await ReOpen();
+                        }
                     }
                     catch (Exception ex)
                     {