Added initialization of retry policy for Networking Workload (#474)

Co-authored-by: Rakeshwar Reddy Kambaiahgari <[email protected]>

Author: RakeshwarK

src/VirtualClient/VirtualClient.Actions/Network/NetworkingWorkload/CPS/CPSExecutor.cs

@@ -33,17 +33,6 @@ public CPSExecutor(VirtualClientComponent component)
         {
             this.ProcessStartRetryPolicy = Policy.Handle<Exception>(exc => exc.Message.Contains("sockwiz")).Or<VirtualClientException>()
                 .WaitAndRetryAsync(5, retries => TimeSpan.FromSeconds(retries * 3));
-
-            this.Parameters.SetIfNotDefined(nameof(this.ConnectionDuration), 0);
-            this.Parameters.SetIfNotDefined(nameof(this.DataTransferMode), 1);
-            this.Parameters.SetIfNotDefined(nameof(this.DisplayInterval), 10);
-            this.Parameters.SetIfNotDefined(nameof(this.ConnectionsPerThread), 100);
-            this.Parameters.SetIfNotDefined(nameof(this.MaxPendingRequestsPerThread), 100);
-            this.Parameters.SetIfNotDefined(nameof(this.Port), 7201);
-            this.Parameters.SetIfNotDefined(nameof(this.WarmupTime), 8);
-            this.Parameters.SetIfNotDefined(nameof(this.DelayTime), 0);
-            this.Parameters.SetIfNotDefined(nameof(this.ConfidenceLevel), 99);
-            this.Parameters.SetIfNotDefined(nameof(this.AdditionalParams), string.Empty);
         }
 
         /// <summary>
@@ -57,17 +46,6 @@ public CPSExecutor(IServiceCollection dependencies, IDictionary<string, IConvert
             this.fileSystem = dependencies.GetService<IFileSystem>();
             this.ProcessStartRetryPolicy = Policy.Handle<Exception>(exc => exc.Message.Contains("sockwiz")).Or<VirtualClientException>()
                 .WaitAndRetryAsync(5, retries => TimeSpan.FromSeconds(retries * 3));
-
-            this.Parameters.SetIfNotDefined(nameof(this.ConnectionDuration), 0);
-            this.Parameters.SetIfNotDefined(nameof(this.DataTransferMode), 1);
-            this.Parameters.SetIfNotDefined(nameof(this.DisplayInterval), 10);
-            this.Parameters.SetIfNotDefined(nameof(this.ConnectionsPerThread), 100);
-            this.Parameters.SetIfNotDefined(nameof(this.MaxPendingRequestsPerThread), 100);
-            this.Parameters.SetIfNotDefined(nameof(this.Port), 7201);
-            this.Parameters.SetIfNotDefined(nameof(this.WarmupTime), 8);
-            this.Parameters.SetIfNotDefined(nameof(this.DelayTime), 0);
-            this.Parameters.SetIfNotDefined(nameof(this.ConfidenceLevel), 99);
-            this.Parameters.SetIfNotDefined(nameof(this.AdditionalParams), string.Empty);
         }
 
         /// <summary>

src/VirtualClient/VirtualClient.Actions/Network/NetworkingWorkload/Latte/LatteExecutor.cs

@@ -29,6 +29,8 @@ public class LatteExecutor : NetworkingWorkloadToolExecutor
         public LatteExecutor(VirtualClientComponent component)
            : base(component)
         {
+            this.ProcessStartRetryPolicy = Policy.Handle<Exception>(exc => exc.Message.Contains("sockwiz_tcp_listener_open bind"))
+                .WaitAndRetryAsync(5, retries => TimeSpan.FromSeconds(retries * 3));
         }
 
         /// <summary>

src/VirtualClient/VirtualClient.Actions/Network/NetworkingWorkload/NTttcp/NTttcpExecutor.cs

@@ -34,6 +34,8 @@ public class NTttcpExecutor : NetworkingWorkloadToolExecutor
         public NTttcpExecutor(VirtualClientComponent component)
            : base(component)
         {
+            this.ProcessStartRetryPolicy = Policy.Handle<Exception>(exc => exc.Message.Contains("sockwiz_tcp_listener_open bind"))
+               .WaitAndRetryAsync(5, retries => TimeSpan.FromSeconds(retries * 3));
         }
 
         /// <summary>
@@ -46,9 +48,6 @@ public NTttcpExecutor(IServiceCollection dependencies, IDictionary<string, IConv
         {
             this.ProcessStartRetryPolicy = Policy.Handle<Exception>(exc => exc.Message.Contains("sockwiz_tcp_listener_open bind"))
                .WaitAndRetryAsync(5, retries => TimeSpan.FromSeconds(retries * 3));
-
-            this.Parameters.SetIfNotDefined(nameof(this.ThreadCount), 1);
-            this.Parameters.SetIfNotDefined(nameof(this.TestDuration), 60);
         }
 
         /// <summary>

src/VirtualClient/VirtualClient.Actions/Network/NetworkingWorkload/SockPerf/SockPerfExecutor.cs

@@ -29,6 +29,8 @@ public class SockPerfExecutor : NetworkingWorkloadToolExecutor
         public SockPerfExecutor(VirtualClientComponent component)
            : base(component)
         {
+            this.ProcessStartRetryPolicy = Policy.Handle<Exception>(exc => exc.Message.Contains("sockwiz_tcp_listener_open bind"))
+               .WaitAndRetryAsync(5, retries => TimeSpan.FromSeconds(retries * 3));
         }
 
         /// <summary>
@@ -41,10 +43,6 @@ public SockPerfExecutor(IServiceCollection dependencies, IDictionary<string, ICo
         {
             this.ProcessStartRetryPolicy = Policy.Handle<Exception>(exc => exc.Message.Contains("sockwiz_tcp_listener_open bind"))
                .WaitAndRetryAsync(5, retries => TimeSpan.FromSeconds(retries * 3));
-
-            this.Parameters.SetIfNotDefined(nameof(this.Port), 6100);
-            this.Parameters.SetIfNotDefined(nameof(this.MessagesPerSecond), "max");
-            this.Parameters.SetIfNotDefined(nameof(this.ConfidenceLevel), 99);
         }
 
         /// <summary>