Improved Transporter keep alive and disconnection/connection procedures.

Added Disconnected machine state.

1 files changed, 84 insertions, 62 deletions

diff --git a/Software/Visual_Studio/PPC/Tango.PPC.Common/Connection/DefaultMachineProvider.cs b/Software/Visual_Studio/PPC/Tango.PPC.Common/Connection/DefaultMachineProvider.cs
index 09d4ed9f8..52d738220 100644
--- a/Software/Visual_Studio/PPC/Tango.PPC.Common/Connection/DefaultMachineProvider.cs
+++ b/Software/Visual_Studio/PPC/Tango.PPC.Common/Connection/DefaultMachineProvider.cs
@@ -18,6 +18,8 @@ using Tango.PPC.Common.Messages;
 using Tango.Emulations.Emulators;
 using Tango.Transport.Transporters;
 using Tango.Integration;
+using Tango.Transport;
+using System.Threading;
 
 namespace Tango.PPC.Common.Connection
 {
@@ -29,6 +31,7 @@ namespace Tango.PPC.Common.Connection
     public class DefaultMachineProvider : ExtendedObject, IMachineProvider
     {
         private bool _isInitialized;
+        private Thread _connection_thread;
 
         /// <summary>
         /// Occurs when current <see cref="IMachineOperator" /> has changed.
@@ -89,6 +92,82 @@ namespace Tango.PPC.Common.Connection
             MachineOperator = new MachineOperator();
             MachineOperator.EnableEventsNotification = true;
             MachineOperator.EnableJobResume = true;
+            MachineOperator.UseKeepAlive = true;
+        }
+
+        private async void ConnectionThreadMethod()
+        {
+            while (true)
+            {
+                if (MachineOperator.State != TransportComponentState.Connected)
+                {
+                    try
+                    {
+                        LogManager.Log("Starting machine connection procedure...");
+
+                        var settings = SettingsManager.Default.GetOrCreate<PPCSettings>();
+
+                        var demo = settings.DemoMode;
+
+                        if (!demo)
+                        {
+                            if (String.IsNullOrWhiteSpace(settings.EmbeddedComPort))
+                            {
+                                TimeSpan timeout = TimeSpan.FromSeconds(SettingsManager.Default.GetOrCreate<PPCSettings>().MachineScanningTimeoutSeconds);
+
+                                LogManager.Log("Scanning for machine on available serial ports...");
+                                Transport.Discovery.UsbCommunicationScanner<ConnectRequest, ConnectResponse> scanner = new Transport.Discovery.UsbCommunicationScanner<ConnectRequest, ConnectResponse>(UsbSerialBaudRates.BR_115200);
+                                var response = await scanner.Scan(new ConnectRequest() { Password = "1234" }, timeout);
+
+                                LogManager.Log("Machine discovered on port: " + response.Adapter.Address);
+                                LogManager.Log("Device Information:");
+                                LogManager.Log(response.Response.DeviceInformation.ToJsonString());
+
+                                LogManager.Log("Disconnecting machine operator...");
+                                await MachineOperator.Disconnect();
+                                MachineOperator.Adapter = response.Adapter;
+                                MachineOperator.JobHandlingMode = JobHandlerModes.SettingUp;
+                                LogManager.Log("Connecting machine operator...");
+                                MachineOperatorChanged?.Invoke(this, new MachineOperatorChangedEventArgs(MachineOperator, MachineOperator));
+                                await MachineOperator.Connect();
+                            }
+                            else
+                            {
+                                LogManager.Log($"Connecting to machine on {settings.EmbeddedComPort}...");
+
+                                UsbTransportAdapter adapter = new UsbTransportAdapter(settings.EmbeddedComPort, UsbSerialBaudRates.BR_115200);
+                                MachineOperator.Adapter = adapter;
+                                MachineOperator.JobHandlingMode = JobHandlerModes.SettingUp;
+                                MachineOperatorChanged?.Invoke(this, new MachineOperatorChangedEventArgs(MachineOperator, MachineOperator));
+                                await MachineOperator.Connect();
+                            }
+                        }
+                        else
+                        {
+                            LogManager.Log("Application in demo mode!");
+
+                            LogManager.Log("Starting embedded emulator...");
+                            MachineEmulator emulator = new MachineEmulator(new BasicTransporter(new MemoryTransportAdapter("emulator")));
+                            await emulator.Start();
+
+                            LogManager.Log("Emulator started. Connecting to emulator...");
+
+                            MemoryTransportAdapter adapter = new MemoryTransportAdapter("emulator");
+                            MachineOperator.Adapter = adapter;
+                            MachineOperator.JobHandlingMode = JobHandlerModes.SettingUp;
+                            LogManager.Log("Connecting machine operator...");
+                            MachineOperatorChanged?.Invoke(this, new MachineOperatorChangedEventArgs(MachineOperator, MachineOperator));
+                            await MachineOperator.Connect();
+                        }
+                    }
+                    catch (Exception ex)
+                    {
+                        LogManager.Log(ex, "Error while trying to scan and connect to the machine.");
+                    }
+                }
+
+                Thread.Sleep(5000);
+            }
         }
 
         /// <summary>
@@ -122,70 +201,13 @@ namespace Tango.PPC.Common.Connection
         /// Tries to connect to the machine by scanning all available serial ports.
         /// The timeout for a scan cycle is specified on <see cref="PPCSettings.MachineScanningTimeoutSeconds"/>.
         /// </summary>
-        private async void ConnectToMachine()
+        private void ConnectToMachine()
         {
-            try
-            {
-                LogManager.Log("Starting machine connection procedure...");
-
-                var settings = SettingsManager.Default.GetOrCreate<PPCSettings>();
-
-                var demo = settings.DemoMode;
-
-                if (!demo)
-                {
-                    if (String.IsNullOrWhiteSpace(settings.EmbeddedComPort))
-                    {
-                        TimeSpan timeout = TimeSpan.FromSeconds(SettingsManager.Default.GetOrCreate<PPCSettings>().MachineScanningTimeoutSeconds);
-
-                        LogManager.Log("Scanning for machine on available serial ports...");
-                        Transport.Discovery.UsbCommunicationScanner<ConnectRequest, ConnectResponse> scanner = new Transport.Discovery.UsbCommunicationScanner<ConnectRequest, ConnectResponse>(UsbSerialBaudRates.BR_115200);
-                        var response = await scanner.Scan(new ConnectRequest() { Password = "1234" }, timeout);
-
-                        LogManager.Log("Machine discovered on port: " + response.Adapter.Address);
-                        LogManager.Log("Device Information:");
-                        LogManager.Log(response.Response.DeviceInformation.ToJsonString());
-
-                        LogManager.Log("Disconnecting machine operator...");
-                        await MachineOperator.Disconnect();
-                        MachineOperator.Adapter = response.Adapter;
-                        MachineOperator.JobHandlingMode = JobHandlerModes.SettingUp;
-                        LogManager.Log("Connecting machine operator...");
-                        MachineOperatorChanged?.Invoke(this, new MachineOperatorChangedEventArgs(MachineOperator, MachineOperator));
-                        await MachineOperator.Connect();
-                    }
-                    else
-                    {
-                        LogManager.Log($"Connecting to machine on {settings.EmbeddedComPort}...");
-
-                        UsbTransportAdapter adapter = new UsbTransportAdapter(settings.EmbeddedComPort, UsbSerialBaudRates.BR_115200);
-                        MachineOperator.Adapter = adapter;
-                        MachineOperator.JobHandlingMode = JobHandlerModes.SettingUp;
-                        MachineOperatorChanged?.Invoke(this, new MachineOperatorChangedEventArgs(MachineOperator, MachineOperator));
-                        await MachineOperator.Connect();
-                    }
-                }
-                else
-                {
-                    LogManager.Log("Application in demo mode!");
-
-                    LogManager.Log("Starting embedded emulator...");
-                    MachineEmulator emulator = new MachineEmulator(new BasicTransporter(new MemoryTransportAdapter("emulator")));
-                    await emulator.Start();
-
-                    LogManager.Log("Emulator started. Connecting to emulator...");
-
-                    MemoryTransportAdapter adapter = new MemoryTransportAdapter("emulator");
-                    MachineOperator.Adapter = adapter;
-                    MachineOperator.JobHandlingMode = JobHandlerModes.SettingUp;
-                    LogManager.Log("Connecting machine operator...");
-                    MachineOperatorChanged?.Invoke(this, new MachineOperatorChangedEventArgs(MachineOperator, MachineOperator));
-                    await MachineOperator.Connect();
-                }
-            }
-            catch (Exception ex)
+            if (_connection_thread == null)
             {
-                LogManager.Log(ex, "Error while trying to scan and connect to the machine.");
+                _connection_thread = new Thread(ConnectionThreadMethod);
+                _connection_thread.IsBackground = true;
+                _connection_thread.Start();
             }
         }