Changeset 375 for trunk/sources/HeuristicLab.CEDMA.Operators

Timestamp:

07/09/08 21:37:36 (16 years ago)

Author:

gkronber

Message:

worked on #188

Location:

trunk/sources/HeuristicLab.CEDMA.Operators

Files:

• HeuristicLab.CEDMA.Operators.csproj (modified) (2 diffs)
• OnGridProcessor.cs (moved) (moved from trunk/sources/HeuristicLab.DistributedEngine/OnGridProcessor.cs) (2 diffs)

trunk/sources/HeuristicLab.CEDMA.Operators/HeuristicLab.CEDMA.Operators.csproj

@@ -42 +42 @@
       <RequiredTargetFramework>3.5</RequiredTargetFramework>
     </Reference>
+    <Reference Include="System.Runtime.Serialization">
+      <RequiredTargetFramework>3.0</RequiredTargetFramework>
+    </Reference>
+    <Reference Include="System.ServiceModel">
+      <RequiredTargetFramework>3.0</RequiredTargetFramework>
+    </Reference>
     <Reference Include="System.Xml.Linq">
       <RequiredTargetFramework>3.5</RequiredTargetFramework>
@@ -53 +59 @@
   <ItemGroup>
     <Compile Include="HeuristicLabCedmaOperatorsPlugin.cs" />
+    <Compile Include="OnGridProcessor.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
   </ItemGroup>
   <ItemGroup>
     <None Include="HeuristicLab.snk" />
+  </ItemGroup>
+  <ItemGroup>
+    <ProjectReference Include="..\HeuristicLab.CEDMA.Console\HeuristicLab.CEDMA.Console.csproj">
+      <Project>{F8880599-F224-4EC7-9288-5C4A6853E7BE}</Project>
+      <Name>HeuristicLab.CEDMA.Console</Name>
+    </ProjectReference>
+    <ProjectReference Include="..\HeuristicLab.CEDMA.DB.Interfaces\HeuristicLab.CEDMA.DB.Interfaces.csproj">
+      <Project>{4F9BB789-D561-436B-B226-2BF44B7D0804}</Project>
+      <Name>HeuristicLab.CEDMA.DB.Interfaces</Name>
+    </ProjectReference>
+    <ProjectReference Include="..\HeuristicLab.Core\HeuristicLab.Core.csproj">
+      <Project>{F43B59AB-2B8C-4570-BC1E-15592086517C}</Project>
+      <Name>HeuristicLab.Core</Name>
+    </ProjectReference>
+    <ProjectReference Include="..\HeuristicLab.Data\HeuristicLab.Data.csproj">
+      <Project>{F473D9AF-3F09-4296-9F28-3C65118DAFFA}</Project>
+      <Name>HeuristicLab.Data</Name>
+    </ProjectReference>
   </ItemGroup>
   <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />

trunk/sources/HeuristicLab.CEDMA.Operators/OnGridProcessor.cs

@@ -25 +25 @@
 using HeuristicLab.Core;
 using HeuristicLab.Data;
-using HeuristicLab.Grid;
 using System.Threading;
+using HeuristicLab.CEDMA.DB.Interfaces;
+using System.ServiceModel;
+using HeuristicLab.CEDMA.Console;
 
-namespace HeuristicLab.DistributedEngine {
+namespace HeuristicLab.CEDMA.Operators {
   public class OnGridProcessor : OperatorBase {
     public override string Description {
@@ -36 +38 @@
     public OnGridProcessor()
       : base() {
+      AddVariableInfo(new VariableInfo("AgentId", "Id of the agent that the run should be associated to.", typeof(IntData), VariableKind.In));
       AddVariableInfo(new VariableInfo("OperatorGraph", "The operator graph that should be executed on the grid", typeof(IOperatorGraph), VariableKind.In));
-      AddVariableInfo(new VariableInfo("GridServerUrl", "Url of the grid server", typeof(StringData), VariableKind.In));
+      AddVariableInfo(new VariableInfo("ServerUrl", "Url of the CEDMA server", typeof(StringData), VariableKind.In));
     }
 
     public override IOperation Apply(IScope scope) {
       IOperatorGraph operatorGraph = scope.GetVariableValue<IOperatorGraph>("OperatorGraph", false);
-      string gridServerUrl = scope.GetVariableValue<StringData>("GridServerUrl", true).Data;
-      JobManager jobManager = new JobManager(gridServerUrl);
-      jobManager.Reset();
-      Scope globalScope = new Scope();
-      AtomicOperation operation = new AtomicOperation(operatorGraph.InitialOperator, globalScope);
-      WaitHandle w = jobManager.BeginExecuteOperation(globalScope, operation);
-      
-      ThreadPool.QueueUserWorkItem(delegate(object status) {
-        w.WaitOne();
-        jobManager.EndExecuteOperation(operation);
-      });
+      string serverUrl = scope.GetVariableValue<StringData>("ServerUrl", true).Data;
+      long agentId = scope.GetVariableValue<IntData>("AgentId", true).Data;
+
+      NetTcpBinding binding = new NetTcpBinding();
+      binding.MaxReceivedMessageSize = 10000000; // 10Mbytes
+      binding.ReaderQuotas.MaxStringContentLength = 10000000; // also 10M chars
+      binding.ReaderQuotas.MaxArrayLength = 10000000; // also 10M elements;
+      binding.Security.Mode = SecurityMode.None;
+      using(ChannelFactory<IDatabase> factory = new ChannelFactory<IDatabase>(binding)) {
+        IDatabase database = factory.CreateChannel(new EndpointAddress(serverUrl));
+        long id = database.InsertRun(agentId, DbPersistenceManager.Save(operatorGraph));
+        database.UpdateRunStatus(id, ProcessStatus.Waiting);
+      }
       return null;
     }