Changeset 2193 for branches/HeuristicLab.Modeling Database Backend/sources/HeuristicLab.CEDMA.Server/3.3/DispatcherBase.cs

Timestamp:

07/28/09 15:26:29 (15 years ago)

Author:

gkronber

Message:

Added problem view for the cedma server. #712

File:

• branches/HeuristicLab.Modeling Database Backend/sources/HeuristicLab.CEDMA.Server/3.3/DispatcherBase.cs (modified) (9 diffs)

branches/HeuristicLab.Modeling Database Backend/sources/HeuristicLab.CEDMA.Server/3.3/DispatcherBase.cs

@@ -36 +36 @@
 using HeuristicLab.Core;
 using HeuristicLab.Modeling;
+using HeuristicLab.Modeling.Database;
 
 namespace HeuristicLab.CEDMA.Server {
   public abstract class DispatcherBase : IDispatcher {
     private IModelingDatabase database;
-    private DataSet dataset;
     private List<int> allowedTargetVariables;
     private Dictionary<int, List<int>> activeInputVariables;
-
+    private Problem problem;
     internal event EventHandler Changed;
     private object locker = new object();
@@ -49 +49 @@
     public IEnumerable<string> TargetVariables {
       get {
-        if (dataset != null) {
-          return dataset.Problem.AllowedTargetVariables.Select(x => dataset.Problem.Dataset.GetVariableName(x));
+        if (problem != null) {
+          return problem.AllowedTargetVariables.Select(x => problem.Dataset.GetVariableName(x));
         } else return new string[0];
       }
@@ -57 +57 @@
     public IEnumerable<string> InputVariables {
       get {
-        if (dataset != null) {
-          return dataset.Problem.AllowedInputVariables.Select(x => dataset.Problem.Dataset.GetVariableName(x));
+        if (problem != null) {
+          return problem.AllowedInputVariables.Select(x => problem.Dataset.GetVariableName(x));
         } else return new string[0];
       }
     }
 
-    public DispatcherBase(IModelingDatabase database) {
+    public DispatcherBase(IModelingDatabase database, Problem problem) {
+      this.problem = problem;
       this.database = database;
       allowedTargetVariables = new List<int>();
@@ -69 +70 @@
     }
 
-    public IAlgorithm GetNextJob() {
-      if (dataset == null) {
-        var datasetEntities = store.Query("?DataSet <" + Ontology.InstanceOf.Uri + "> <" + Ontology.TypeDataSet.Uri + "> .", 0, 1)
-          .Select(x => (Entity)x.Get("DataSet"));
-        if (datasetEntities.Count() == 0) return null;
-        dataset = new DataSet(store, datasetEntities.ElementAt(0));
-        foreach (int targetVar in dataset.Problem.AllowedTargetVariables) {
+    public HeuristicLab.Modeling.IAlgorithm GetNextJob() {
+      if (problem == null) {
+        foreach (int targetVar in problem.AllowedTargetVariables) {
           activeInputVariables.Add(targetVar, new List<int>());
-          activeInputVariables[targetVar].AddRange(dataset.Problem.AllowedInputVariables);
+          activeInputVariables[targetVar].AddRange(problem.AllowedInputVariables);
         }
         OnChanged();
@@ -93 +90 @@
         }
 
-        IAlgorithm selectedAlgorithm = SelectAndConfigureAlgorithm(targetVariable, inputVariables, dataset.Problem);
+        HeuristicLab.Modeling.IAlgorithm selectedAlgorithm = SelectAndConfigureAlgorithm(targetVariable, inputVariables, problem);
 
         return selectedAlgorithm;
@@ -103 +100 @@
       return targetVariables[rand.Next(targetVariables.Length)];
     }
-    public abstract IAlgorithm SelectAndConfigureAlgorithm(int targetVariable, int[] inputVariables, Problem problem);
+    public abstract HeuristicLab.Modeling.IAlgorithm SelectAndConfigureAlgorithm(int targetVariable, int[] inputVariables, Problem problem);
 
     #region IViewable Members
 
     public IView CreateView() {
-      return new DispatcherView(this);
+      return new ProblemView(this);
     }
 
@@ -115 +112 @@
     internal void EnableTargetVariable(string name) {
       lock (locker)
-        allowedTargetVariables.Add(dataset.Problem.Dataset.GetVariableIndex(name));
+        allowedTargetVariables.Add(problem.Dataset.GetVariableIndex(name));
     }
 
     internal void DisableTargetVariable(string name) {
       lock (locker)
-        allowedTargetVariables.Remove(dataset.Problem.Dataset.GetVariableIndex(name));
+        allowedTargetVariables.Remove(problem.Dataset.GetVariableIndex(name));
     }
 
     internal void EnableInputVariable(string target, string name) {
       lock (locker) {
-        int targetIndex = dataset.Problem.Dataset.GetVariableIndex(target);
-        int inputIndex = dataset.Problem.Dataset.GetVariableIndex(name);
+        int targetIndex = problem.Dataset.GetVariableIndex(target);
+        int inputIndex = problem.Dataset.GetVariableIndex(name);
         if (!activeInputVariables[targetIndex].Contains(inputIndex)) {
           activeInputVariables[targetIndex].Add(inputIndex);
@@ -135 +132 @@
     internal void DisableInputVariable(string target, string name) {
       lock (locker) {
-        int targetIndex = dataset.Problem.Dataset.GetVariableIndex(target);
-        int inputIndex = dataset.Problem.Dataset.GetVariableIndex(name);
+        int targetIndex = problem.Dataset.GetVariableIndex(target);
+        int inputIndex = problem.Dataset.GetVariableIndex(name);
         while (activeInputVariables[targetIndex].Remove(inputIndex)) { }
       }
@@ -146 +143 @@
 
     internal IEnumerable<string> GetInputVariables(string target) {
-      return activeInputVariables[dataset.Problem.Dataset.GetVariableIndex(target)]
-        .Select(i => dataset.Problem.Dataset.GetVariableName(i));
+      return activeInputVariables[problem.Dataset.GetVariableIndex(target)]
+        .Select(i => problem.Dataset.GetVariableName(i));
     }
   }