Changeset 6398 for branches/MPI/HeuristicLab.MPIEngine

Timestamp:

06/08/11 15:52:16 (14 years ago)

Author:

svonolfe

Message:

Added MPIEngine view (#1542)

Location:

branches/MPI/HeuristicLab.MPIEngine/3.3

Files:

• HeuristicLab.MPIEngine-3.3.csproj (modified) (3 diffs)
• HeuristicLabMPIEnginePlugin.cs.frame (modified) (1 diff)
• MPIEngine.cs (modified) (6 diffs)
• MPIEngineView.cs (added)
• MPIEngineView.designer.cs (added)

branches/MPI/HeuristicLab.MPIEngine/3.3/HeuristicLab.MPIEngine-3.3.csproj

@@ -110 +110 @@
       <HintPath>..\..\..\..\..\..\Program Files\HeuristicLab 3.3\HeuristicLab.Common-3.3.dll</HintPath>
     </Reference>
+    <Reference Include="HeuristicLab.Common.Resources-3.3">
+      <HintPath>..\..\..\..\..\..\Program Files\HeuristicLab 3.3\HeuristicLab.Common.Resources-3.3.dll</HintPath>
+    </Reference>
     <Reference Include="HeuristicLab.Core-3.3">
       <HintPath>..\..\..\..\..\..\Program Files\HeuristicLab 3.3\HeuristicLab.Core-3.3.dll</HintPath>
     </Reference>
+    <Reference Include="HeuristicLab.Core.Views-3.3">
+      <HintPath>..\..\..\..\..\..\Program Files\HeuristicLab 3.3\HeuristicLab.Core.Views-3.3.dll</HintPath>
+    </Reference>
+    <Reference Include="HeuristicLab.MainForm-3.3">
+      <HintPath>..\..\..\..\..\..\Program Files\HeuristicLab 3.3\HeuristicLab.MainForm-3.3.dll</HintPath>
+    </Reference>
+    <Reference Include="HeuristicLab.MainForm.WindowsForms-3.3">
+      <HintPath>..\..\..\..\..\..\Program Files\HeuristicLab 3.3\HeuristicLab.MainForm.WindowsForms-3.3.dll</HintPath>
+    </Reference>
     <Reference Include="HeuristicLab.Optimization-3.3">
       <HintPath>..\..\..\..\..\..\Program Files\HeuristicLab 3.3\HeuristicLab.Optimization-3.3.dll</HintPath>
@@ -133 +145 @@
     <Reference Include="System" />
     <Reference Include="System.Core" />
+    <Reference Include="System.Drawing" />
     <Reference Include="System.Runtime.Serialization" />
     <Reference Include="System.ServiceModel" />
+    <Reference Include="System.Windows.Forms" />
     <Reference Include="System.Xml.Linq" />
     <Reference Include="System.Data.DataSetExtensions" />
@@ -141 +155 @@
   </ItemGroup>
   <ItemGroup>
+    <Compile Include="MPIEngineView.cs">
+      <SubType>UserControl</SubType>
+    </Compile>
+    <Compile Include="MPIEngineView.designer.cs">
+      <DependentUpon>MPIEngineView.cs</DependentUpon>
+    </Compile>
     <Compile Include="HeuristicLabMPIEnginePlugin.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />

branches/MPI/HeuristicLab.MPIEngine/3.3/HeuristicLabMPIEnginePlugin.cs.frame

@@ -33 +33 @@
   [PluginDependency("HeuristicLab.Collections", "3.3")]
   [PluginDependency("HeuristicLab.Common", "3.3")]
+  [PluginDependency("HeuristicLab.Common.Resources", "3.3")]
   [PluginDependency("HeuristicLab.Core", "3.3")]
+  [PluginDependency("HeuristicLab.Core.Views", "3.3")]
+  [PluginDependency("HeuristicLab.MainForm", "3.3")]
+  [PluginDependency("HeuristicLab.MainForm.WindowsForms", "3.3")]
   [PluginDependency("HeuristicLab.MPInet", "1.0.0")]
   [PluginDependency("HeuristicLab.MPIAlgorithmRunner", "3.3")]

branches/MPI/HeuristicLab.MPIEngine/3.3/MPIEngine.cs

@@ -37 +37 @@
 using Microsoft.Hpc.Scheduler.Properties;
 using System.Xml;
+using System.ComponentModel;
 
 namespace HeuristicLab.MPIEngine {
@@ -47 +48 @@
   public class MPIEngine : Engine {
     private string username;
+
+    [Category("MPISettings")]
+    [Browsable(true)]
+    public string UserName {
+      get {
+        return username;
+      }
+
+      set {
+        username = value;
+      }
+    }
+
     private string password;
 
+    [Category("MPISettings")]
+    [Browsable(true)]
+    [PasswordPropertyText(true)]
+    public string Password {
+      get {
+        return password;
+      }
+
+      set {
+        password = value;
+      }
+    }
+
     [Storable]
     private string headNode;
 
+    [Category("MPISettings")]
+    [Browsable(true)]
+    public string HeadNode {
+      get {
+        return headNode;
+      }
+
+      set {
+        headNode = value;
+      }
+    }
+
     [Storable]
     private string path;
 
+    [Category("MPISettings")]
+    [Browsable(true)]
+    public string Path {
+      get {
+        return path;
+      }
+
+      set {
+        path = value;
+      }
+    }
+
+    [Storable]
+    private int updateInterval;
+
+    [Category("MPISettings")]
+    [Browsable(true)]
+    public int UpdateInterval {
+      get {
+        return updateInterval;
+      }
+
+      set {
+        updateInterval = value;
+      }
+    }
+
     [Storable]
     private int cpuPerNode;
 
+    [Category("MPISettings")]
+    [Browsable(true)]
+    public int CpuPerNode {
+      get {
+        return cpuPerNode;
+      }
+
+      set {
+        cpuPerNode = value;
+      }
+    }
+
     [Storable]
     private List<string> requestedNodes;
+
+    [Category("MPISettings")]
+    [Browsable(true)]
+    public List<string> RequestedNodes {
+      get {
+        return requestedNodes;
+      }
+
+      set {
+        requestedNodes = value;
+      }
+    }
 
     [StorableConstructor]
@@ -69 +159 @@
       headNode = original.headNode;
       path = original.path;
+      updateInterval = original.updateInterval;
       cpuPerNode = original.cpuPerNode;
       requestedNodes = new List<string>();
@@ -80 +171 @@
       headNode = "blade00.hpc.fh-hagenberg.at";
       path = @"C:\public\MPISupport";
-      cpuPerNode = 8;
+      updateInterval = 5000;
+      cpuPerNode = 3;
       requestedNodes = new List<string>();
       requestedNodes.Add("BLADE00");
@@ -172 +264 @@
           netTCPBinding.ReaderQuotas = quotas;
           netTCPBinding.MaxReceivedMessageSize = int.MaxValue;
+          netTCPBinding.SendTimeout = new TimeSpan(100000000);
+          netTCPBinding.ReceiveTimeout = new TimeSpan(100000000);
           ChannelFactory<IAlgorithmBroker> factory = new ChannelFactory<IAlgorithmBroker>(netTCPBinding, address);
           IAlgorithmBroker proxy = factory.CreateChannel();
 
-          proxy.TransmitAlgorithm(new MPITransportWrapper<IAlgorithm>(algorithm));
+          proxy.TransmitAlgorithm(new MPITransportWrapper<IAlgorithm>(algorithm), updateInterval);
 
           while (!proxy.IsAlgorithmTerminated()) {
@@ -191 +285 @@
             }
 
-            System.Threading.Thread.Sleep(5000);
+            System.Threading.Thread.Sleep(updateInterval);
           }
         }