Changeset 2223 for trunk/sources/HeuristicLab.CEDMA.Server/3.3/DispatcherBase.cs

Timestamp:

08/03/09 14:23:54 (16 years ago)

Author:

mkommend

Message:

reintegrated branch new heuristic.modeling database backend (ticket #712)

File:

• trunk/sources/HeuristicLab.CEDMA.Server/3.3/DispatcherBase.cs (modified) (9 diffs)

trunk/sources/HeuristicLab.CEDMA.Server/3.3/DispatcherBase.cs

@@ -27 +27 @@
 using System.Net;
 using System.ServiceModel;
-using HeuristicLab.CEDMA.DB.Interfaces;
-using HeuristicLab.CEDMA.DB;
 using System.ServiceModel.Description;
 using System.Linq;
@@ -35 +33 @@
 using HeuristicLab.Core;
 using HeuristicLab.Modeling;
+using HeuristicLab.Modeling.Database;
 
 namespace HeuristicLab.CEDMA.Server {
   public abstract class DispatcherBase : IDispatcher {
-    private IStore store;
-    private DataSet dataset;
+    private IModelingDatabase database;
     private List<int> allowedTargetVariables;
     private Dictionary<int, List<int>> activeInputVariables;
-
+    private Problem problem;
     internal event EventHandler Changed;
     private object locker = new object();
@@ -48 +46 @@
     public IEnumerable<string> TargetVariables {
       get {
-        if (dataset != null) {
-          return dataset.Problem.AllowedTargetVariables.Select(x => dataset.Problem.Dataset.GetVariableName(x));
+        if (problem != null) {
+          return Enumerable.Range(0, problem.Dataset.Columns).Select(x => problem.Dataset.GetVariableName(x));
         } else return new string[0];
       }
@@ -56 +54 @@
     public IEnumerable<string> InputVariables {
       get {
-        if (dataset != null) {
-          return dataset.Problem.AllowedInputVariables.Select(x => dataset.Problem.Dataset.GetVariableName(x));
+        if (problem != null) {
+          return TargetVariables;
         } else return new string[0];
       }
     }
 
-    public DispatcherBase(IStore store) {
-      this.store = store;
+    public DispatcherBase(IModelingDatabase database, Problem problem) {
+      this.problem = problem;
       allowedTargetVariables = new List<int>();
       activeInputVariables = new Dictionary<int, List<int>>();
+      problem.Changed += (sender, args) => {
+        lock (locker) {
+          allowedTargetVariables.Clear();
+          activeInputVariables.Clear();
+        }
+        OnChanged();
+      };
+      this.database = database;
     }
 
-    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) {
-          activeInputVariables.Add(targetVar, new List<int>());
-          activeInputVariables[targetVar].AddRange(dataset.Problem.AllowedInputVariables);
-        }
-        OnChanged();
-      }
+    public HeuristicLab.Modeling.IAlgorithm GetNextJob() {
       if (allowedTargetVariables.Count > 0) {
         int[] targetVariables, inputVariables;
@@ -92 +87 @@
         }
 
-        IAlgorithm selectedAlgorithm = SelectAndConfigureAlgorithm(targetVariable, inputVariables, dataset.Problem);
+        HeuristicLab.Modeling.IAlgorithm selectedAlgorithm = SelectAndConfigureAlgorithm(targetVariable, inputVariables, problem);
 
         return selectedAlgorithm;
@@ -102 +97 @@
       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
@@ -114 +109 @@
     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.ContainsKey(targetIndex)) activeInputVariables[targetIndex] = new List<int>();
         if (!activeInputVariables[targetIndex].Contains(inputIndex)) {
           activeInputVariables[targetIndex].Add(inputIndex);
@@ -134 +130 @@
     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);
+        if (!activeInputVariables.ContainsKey(targetIndex)) activeInputVariables[targetIndex] = new List<int>();
         while (activeInputVariables[targetIndex].Remove(inputIndex)) { }
       }
@@ -145 +142 @@
 
     internal IEnumerable<string> GetInputVariables(string target) {
-      return activeInputVariables[dataset.Problem.Dataset.GetVariableIndex(target)]
-        .Select(i => dataset.Problem.Dataset.GetVariableName(i));
+      int targetIndex = problem.Dataset.GetVariableIndex(target);
+      if (!activeInputVariables.ContainsKey(targetIndex)) activeInputVariables[targetIndex] = new List<int>();
+      return activeInputVariables[targetIndex]
+        .Select(i => problem.Dataset.GetVariableName(i));
     }
   }