Revize 2c9a5fda

re #9845 Added an outer loop for information retrieval

ld_client/LDClient/Program.cs

@@ -92 +92 @@
             Config.DetectionPeriod,
             InfoFetcher,
             DefaultApiClient,
-            new ProcessUtils()
+            new ProcessUtils(),
+            Config.FetchInfoSuperiorMaxAttempts,
+            Config.FetchInfoSuperiorAttemptPeriod
         );
         
         // Create and start a new thread that periodically

ld_client/LDClient/appsettings.json

@@ -64 +64 @@
     "FetchInfoMaxAttempts": 15,
     "FetchInfoAttemptPeriod": 4000,
     "T32RemSuccessExitCode": 0,
-    "T32RemWaitTimeoutMs": 2000
+    "T32RemWaitTimeoutMs": 2000,
+    "FetchInfoSuperiorMaxAttempts": 5,
+    "FetchInfoSuperiorAttemptPeriod": 1000
   }
 }

ld_client/LDClient/detection/ProcessDetection.cs

@@ -61 +61 @@
     /// Flag used to stop the thread (process detection).
     /// </summary>
     public bool DetectionRunning = false;
+
+    /// <summary>
+    /// Superior number of attempts to fetch the information (outer loop).
+    /// </summary>
+    private uint _fetchInfoSuperiorMaxAttempts;
+    
+    /// <summary>
+    /// Period of the superior (outer) loop to fetch the data.
+    /// </summary>
+    private uint _fetchInfoSuperiorAttemptPeriod;
         
     /// <summary>
     /// Creates an instance of this class.
@@ -71 +81 @@
     /// <param name="apiClient">Instance of API clients used for sending data off to the server</param>
     /// <param name="processUtils">Instance of ProcessUtils which encapsulates common functionality when it comes to dealing with processes (limited by the needs of this application)</param>
     public ProcessDetection(string processName, uint detectionPeriodMs, IInfoFetcher infoFetcher,
-        IApiClient apiClient, IProcessUtils processUtils) {
+        IApiClient apiClient, IProcessUtils processUtils, uint fetchInfoSuperiorMaxAttempts, uint fetchInfoSuperiorAttemptPeriod) {
         _processName = processName;
         _detectionPeriodMs = detectionPeriodMs;
         _infoFetcher = infoFetcher;
         _apiClient = apiClient;
         _failedToRetrieveData = false;
         _processUtils = processUtils;
+        _fetchInfoSuperiorMaxAttempts = fetchInfoSuperiorMaxAttempts;
+        _fetchInfoSuperiorAttemptPeriod = fetchInfoSuperiorAttemptPeriod;
     }
 
     /// <summary>
@@ -86 +98 @@
     /// <returns>True, if the data was fetched successfully. False, otherwise.</returns>
     private async Task<bool> RetrieveDataFromDebugger() {
         // Try to fetch data from the debugger.
-        var success = await _infoFetcher.FetchDataAsync();
-            
-        // If the data was fetched successfully, send a payload off to the server.
-        if (success) {
-            _lastConnectedPayload = await SendDataToServerAsync(_infoFetcher.HeadSerialNumber,
-                _infoFetcher.BodySerialNumber, DatetimeFormat);
+
+        for (var i = 0; i < _fetchInfoSuperiorMaxAttempts; i++) {
+            var success = await _infoFetcher.FetchDataAsync();
+
+            // If the data was fetched successfully, send a payload off to the server.
+            if (success) {
+                _lastConnectedPayload = await SendDataToServerAsync(_infoFetcher.HeadSerialNumber,
+                    _infoFetcher.BodySerialNumber, DatetimeFormat);
+                return true;
+            }
+            await Task.Delay((int)_fetchInfoSuperiorAttemptPeriod);
         }
-        return success;
+        return false;
     }
 
     /// <summary>

ld_client/LDClient/utils/ConfigLoader.cs

@@ -185 +185 @@
         /// </summary>
         public string T32ApiPacketLen { get; private set; } = null!;
 
+        /// <summary>
+        /// Superior number of attempts to fetch the information (outer loop).
+        /// </summary>
+        public uint FetchInfoSuperiorMaxAttempts { get; private set; }
+        
+        /// <summary>
+        /// Period of the superior (outer) loop to fetch the data.
+        /// </summary>
+        public uint FetchInfoSuperiorAttemptPeriod { get; private set;  }
+
         #endregion
 
         /// <summary>
@@ -283 +293 @@
                 T32ApiAddress = debugger["T32ApiAddress"];
                 T32ApiPort = debugger["T32ApiPort"];
                 T32ApiPacketLen = debugger["T32ApiPacketLen"];
-                
+                FetchInfoSuperiorMaxAttempts = uint.Parse(debugger["FetchInfoSuperiorMaxAttempts"]);
+                FetchInfoSuperiorAttemptPeriod = uint.Parse(debugger["FetchInfoSuperiorAttemptPeriod"]);
+
             } catch (Exception e) {
                 Console.WriteLine(e);
                 Environment.Exit(ErrorExitCode);