Changeset 16993 for branches/2924_DotNetCoreMigration/HeuristicLab.PluginInfrastructure/3.3/Isolation/Runner.cs

Timestamp:

05/29/19 12:16:15 (5 years ago)

Author:

dpiringe

Message:

#2924:

• added IEnumerable<T> GetInstances<T>(params object[] args) where T: class and IEnumerable<object> GetInstances(Type type, params object[] args) method to IApplicationManager and implemented them in LightweightApplicationManager -> to instantiate types with specific constructor arguments
• added RunnerState State { get; } property in IRunnerHost, was already in RunnerHost
• added user authentication for NativeRunnerHost
• added optional check for a running docker daemon and available image for type DockerRunnerHost + Exception DockerException
• added caching of the saved IApplication in ApplicationRunner to prevent a new instance every get call
• removed System.ServiceModel.Primitives NuGet package
• lots of formatting

File:

• branches/2924_DotNetCoreMigration/HeuristicLab.PluginInfrastructure/3.3/Isolation/Runner.cs (modified) (6 diffs)

branches/2924_DotNetCoreMigration/HeuristicLab.PluginInfrastructure/3.3/Isolation/Runner.cs

@@ -4 +4 @@
 using System.Runtime.Serialization;
 using System.Runtime.Serialization.Formatters.Binary;
-using System.Text;
 using System.Threading;
 
@@ -11 +10 @@
   public abstract class Runner : IRunner {
 
+    #region Vars
     [NonSerialized]
     private Thread listener;
@@ -19 +19 @@
     [NonSerialized]
     protected static IFormatter formatter = new BinaryFormatter();
-    
+    #endregion
+
+    #region Properties
     public bool QuietMode { get; set; }
-     
+
     public IEnumerable<AssemblyInfo> AssembliesToLoad { get; set; }
+    #endregion
+
 
     public static void Serialize(IRunner runner, Stream stream) => formatter.Serialize(stream, runner);
@@ -41 +45 @@
     protected abstract void OnRunnerJob(RunnerJob runnerJob);
 
+    #region Helper
     private void StartExecutor() {
       executor = new Thread(Execute);
@@ -46 +51 @@
       executor.Start();
     }
+
     private void StartListener() {
       listener = new Thread(() => {
         Stream stdin = Console.OpenStandardInput();
-        while (executor.IsAlive) 
+        while (executor.IsAlive)
           OnRunnerJob((RunnerJob)formatter.Deserialize(stdin));
       });
@@ -55 +61 @@
       listener.Start();
     }
-
+    #endregion
   }
 }