Changeset 6033 for branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.4/ServiceClients/HiveExperiment.cs

Timestamp:

04/19/11 18:58:53 (13 years ago)

Author:

cneumuel

Message:

#1233

• created baseclass for jobs (ItemJob) which derives OperatorJobs and EngineJobs
• created special view for OptimizerJobs which derives from a more general view
• removed logic from domain class HiveExperiment and moved it into RefreshableHiveExperiment
• improved ItemTreeView
• corrected plugin dependencies
• fixed bug in database trigger when deleting HiveExperiments
• added delete cascade for Plugin and PluginData
• lots of fixes

File:

• branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.4/ServiceClients/HiveExperiment.cs (modified) (11 diffs)

branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.4/ServiceClients/HiveExperiment.cs

@@ -24 +24 @@
 using System.ComponentModel;
 using System.Linq;
-using HeuristicLab.Clients.Hive.Jobs;
 using HeuristicLab.Common;
 using HeuristicLab.Core;
-using HeuristicLab.Optimization;
 using HeuristicLab.Persistence.Default.CompositeSerializers.Storable;
 
@@ -33 +31 @@
   [StorableClass]
   public partial class HiveExperiment : IDeepCloneable, IContent, IProgressReporter {
-    private JobResultPoller jobResultPoller;
-
     [Storable]
     private bool useLocalPlugins;
@@ -71 +67 @@
       get { return hiveJobs; }
       set {
-        DeregisterHiveJobsEvents();
         if (hiveJobs != value) {
           hiveJobs = value;
-          RegisterHiveJobsEvents();
           OnHiveJobsChanged();
         }
@@ -92 +86 @@
     }
 
-    /** include jobs when refreshing **/
-    [Storable]
-    private bool includeJobs;
-    public bool IncludeJobs {
-      get { return includeJobs; }
-      set { includeJobs = value; }
-    }
-
-    [Storable]
-    private bool refreshAutomatically;
-    public bool RefreshAutomatically {
-      get { return refreshAutomatically; }
-      set {
-        if (refreshAutomatically != value) {
-          refreshAutomatically = value;
-          OnRefreshAutomaticallyChanged();
-          if (RefreshAutomatically) {
-            StartResultPolling();
-          } else {
-            StopResultPolling();
-          }
-        }
-      }
-    }
-
     [Storable]
     private IProgress progress;
@@ -127 +96 @@
     public HiveExperiment() {
       this.ResourceNames = "HEAL";
-      this.includeJobs = true;
-      this.refreshAutomatically = true;
+      this.HiveJobs = new ItemCollection<HiveJob>();
     }
 
@@ -140 +108 @@
       this.Description = original.Description;
       this.Id = original.Id;
-
+      this.HiveJobs = cloner.Clone(original.HiveJobs);
       this.UseLocalPlugins = original.UseLocalPlugins;
       this.ExecutionTime = original.ExecutionTime;
@@ -148 +116 @@
     }
     #endregion
-
-    public override string ToString() {
-      return Name;
-    }
 
     #region Events
@@ -167 +131 @@
 
     public event EventHandler HiveJobsChanged;
-    private void OnHiveJobsChanged() {
-      if (jobResultPoller != null && jobResultPoller.IsPolling) {
-        jobResultPoller.Stop();
-        DeregisterResultPollingEvents();
-      }
-      if (HiveJobs != null && HiveJobs.Count > 0 && GetAllHiveJobs().All(x => x.Job.Id != Guid.Empty)) {
-        if (this.RefreshAutomatically)
-          StartResultPolling();
-      }
+    protected virtual void OnHiveJobsChanged() {
       EventHandler handler = HiveJobsChanged;
       if (handler != null) handler(this, EventArgs.Empty);
@@ -185 +141 @@
       if (handler != null) handler(this, EventArgs.Empty);
     }
-
-    public event EventHandler RefreshAutomaticallyChanged;
-    private void OnRefreshAutomaticallyChanged() {
-      EventHandler handler = RefreshAutomaticallyChanged;
-      if (handler != null) handler(this, EventArgs.Empty);
-    }
     #endregion
-
-    private void RegisterHiveJobsEvents() {
-      //if (HiveJobs != null) {
-      //  HiveJobs.JobStateChanged += new EventHandler(HiveJob_JobStateChanged);
-      //}
-    }
-
-    private void DeregisterHiveJobsEvents() {
-      //if (HiveJobs != null) {
-      //  HiveJobs.JobStateChanged -= new EventHandler(HiveJob_JobStateChanged);
-      //}
-    }
-
-    private void HiveJob_JobStateChanged(object sender, EventArgs e) {
-      //if (this.HiveJobs != null) {
-      //  this.RootJobId = HiveJobs.Job.Id;
-      //}
-    }
-
-    public Experiment GetExperiment(int idx) {
-      if (this.HiveJobs != null) {
-        var hj = HiveJobs.ElementAtOrDefault(idx);
-        if (hj != null)
-          return hj.OptimizerJob.OptimizerAsExperiment;
-      }
-      return null;
-    }
-
-    public void AddExperiment(Experiment experiment) {
-      if (this.HiveJobs == null) 
-        this.HiveJobs = new ItemCollection<HiveJob>();
-      this.HiveJobs.Add(new HiveJob(experiment));
-    }
-
-    public void SetExperiment(Experiment experiment) {
-      if (this.HiveJobs == null)
-        this.HiveJobs = new ItemCollection<HiveJob>();
-      else
-        this.HiveJobs.Clear();
-      this.HiveJobs.Add(new HiveJob(experiment));
-    }
-
+    
     protected override void OnPropertyChanged(PropertyChangedEventArgs e) {
       base.OnPropertyChanged(e);
@@ -240 +149 @@
       }
     }
-
-    #region JobResultPoller Events
-
-    public void StartResultPolling() {
-      if (jobResultPoller == null) {
-        jobResultPoller = new JobResultPoller(HiveJobs, /*ApplicationConstants.ResultPollingInterval*/new TimeSpan(0, 0, 5)); //TODO: find a better place for ApplicationConstants
-        RegisterResultPollingEvents();
-      }
-
-      if (!jobResultPoller.IsPolling) {
-        jobResultPoller.Start();
-      }
-    }
-
-    public void StopResultPolling() {
-      if (jobResultPoller != null && jobResultPoller.IsPolling) {
-        jobResultPoller.Stop();
-      }
-    }
-
-    private void RegisterResultPollingEvents() {
-      jobResultPoller.ExceptionOccured += new EventHandler<EventArgs<Exception>>(jobResultPoller_ExceptionOccured);
-      jobResultPoller.JobResultsReceived += new EventHandler<EventArgs<IEnumerable<LightweightJob>>>(jobResultPoller_JobResultReceived);
-      jobResultPoller.IsPollingChanged += new EventHandler(jobResultPoller_IsPollingChanged);
-    }
-    private void DeregisterResultPollingEvents() {
-      jobResultPoller.ExceptionOccured -= new EventHandler<EventArgs<Exception>>(jobResultPoller_ExceptionOccured);
-      jobResultPoller.JobResultsReceived -= new EventHandler<EventArgs<IEnumerable<LightweightJob>>>(jobResultPoller_JobResultReceived);
-      jobResultPoller.IsPollingChanged -= new EventHandler(jobResultPoller_IsPollingChanged);
-    }
-    private void jobResultPoller_IsPollingChanged(object sender, EventArgs e) {
-      this.refreshAutomatically = jobResultPoller.IsPolling;
-      OnRefreshAutomaticallyChanged();
-    }
-    private void jobResultPoller_JobResultReceived(object sender, EventArgs<IEnumerable<LightweightJob>> e) {
-      foreach (LightweightJob lightweightJob in e.Value) {
-        HiveJob hj = GetHiveJobById(lightweightJob.Id);
-        if (hj != null) {
-          DateTime lastJobDataUpdate = hj.Job.LastJobDataUpdate;
-          hj.UpdateFromLightweightJob(lightweightJob);
-
-          // lastJobDataUpdate equals DateTime.MinValue right after it was uploaded. When the first results are polled, this value is updated
-          if (lastJobDataUpdate != DateTime.MinValue && lastJobDataUpdate < hj.Job.LastJobDataUpdate) {
-            OptimizerJob optimizerJob = ExperimentManagerClient.LoadOptimizerJob(hj.Job.Id);
-            if (optimizerJob == null) {
-              // something bad happened to this job. bad job, BAAAD job!
-            } else {
-              // if the job is paused, download but don't integrate into parent optimizer (to avoid Prepare)
-              if (hj.Job.State == JobState.Paused) {
-                hj.OptimizerJob = optimizerJob;
-              } else {
-                if (lightweightJob.ParentJobId.HasValue) {
-                  HiveJob parentHiveJob = GetHiveJobById(lightweightJob.ParentJobId.Value);
-                  parentHiveJob.UpdateChildOptimizer(optimizerJob, hj.Job.Id);
-                }
-              }
-            }
-          }
-        }
-      }
-      GC.Collect(); // force GC, because .NET is too lazy here (deserialization takes a lot of memory)
-      if (AllJobsFinished()) {
-        this.ExecutionState = Core.ExecutionState.Stopped;
-        StopResultPolling();
-        //OnStopped();
-      }
-      UpdateTotalExecutionTime();
-      UpdateStats();
-    }
-
-    public HiveJob GetHiveJobById(Guid jobId) {
-      foreach (HiveJob job in HiveJobs) {
-        HiveJob hj = job.GetHiveJobByJobId(jobId);
-        if (hj != null)
-          return hj;
-      }
-      return null;
-    }
-
-    private void UpdateStats() {
-      var jobs = GetAllHiveJobs();
-      this.JobCount = jobs.Count();
-      this.CalculatingCount = jobs.Count(j => j.Job.State == JobState.Calculating);
-      this.FinishedCount = jobs.Count(j => j.Job.State == JobState.Finished);
-    }
-
-    public IEnumerable<HiveJob> GetAllHiveJobs() {
-      var jobs = new List<HiveJob>();
-      foreach (HiveJob job in HiveJobs) {
-        jobs.AddRange(job.GetAllHiveJobs());
-      }
-      return jobs;
-    }
-
-    public bool AllJobsFinished() {
-      return GetAllHiveJobs().All(j => j.Job.State == JobState.Finished
-                                            || j.Job.State == JobState.Aborted
-                                            || j.Job.State == JobState.Failed);
-    }
-
-    private void jobResultPoller_ExceptionOccured(object sender, EventArgs<Exception> e) {
-      //OnExceptionOccured(e.Value);
-    }
-
-    public void UpdateTotalExecutionTime() {
-      this.ExecutionTime = TimeSpan.FromMilliseconds(GetAllHiveJobs().Sum(x => x.Job.ExecutionTime.HasValue ? x.Job.ExecutionTime.Value.TotalMilliseconds : 0));
-    }
-    #endregion
-
+    
     protected override void RaisePropertyChanged(string propertyName) {
       if (!(propertyName == "ExecutionTime")
@@ -362 +163 @@
         && HiveJobs.All(x => x.Job.DateFinished.HasValue && x.Job.DateCreated.HasValue);
     }
+
+    public IEnumerable<HiveJob> GetAllHiveJobs() {
+      var jobs = new List<HiveJob>();
+      foreach (HiveJob job in HiveJobs) {
+        jobs.AddRange(job.GetAllHiveJobs());
+      }
+      return jobs;
+    }
+
+    public override string ToString() {
+      return Name;
+    }
+
+    public virtual void OnLoaded() { }
   }
 }