Changeset 4368 for branches/3.3-Hive/sources/HeuristicLab.Hive/HeuristicLab.Hive.Experiment/3.3/JobItem.cs

Timestamp:

09/07/10 10:22:27 (14 years ago)

Author:

cneumuel

Message:

• created HiveClient which shows an overview over all submitted HiveExperiments
• its possible to download all submitted HiveExperiments including results
• Experiments are now sent as a whole to the Hive and the Hive-Slaves take care of creating child-jobs (if necessary). The parent job is then paused and will be reactivated when all child-jobs are finished
• WcfService-Clients are now consistently managed by WcfServicePool which allows to use IDisposable-Pattern and always keeps exactly one proxy-object until all callers disposed them.
• created ProgressView which is able to lock a View and display progress of an action. It also allows to simulate progress if no progress-information is available so that users don't get too nervous while waiting.

File:

• branches/3.3-Hive/sources/HeuristicLab.Hive/HeuristicLab.Hive.Experiment/3.3/JobItem.cs (modified) (8 diffs)

branches/3.3-Hive/sources/HeuristicLab.Hive/HeuristicLab.Hive.Experiment/3.3/JobItem.cs

@@ -12 +12 @@
 using HeuristicLab.Optimization;
 using HeuristicLab.Hive.Contracts.ResponseObjects;
+using HeuristicLab.Hive.JobBase;
+using System.IO;
+using HeuristicLab.Persistence.Default.Xml;
+using HeuristicLab.PluginInfrastructure;
+using System.Reflection;
+using HeuristicLab.Hive.Experiment.Jobs;
 
 namespace HeuristicLab.Hive.Experiment {
@@ -22 +28 @@
     public override Image ItemImage {
       get {
-        if (State == JobState.Offline) return HeuristicLab.Common.Resources.VS2008ImageLibrary.ExecutablePrepared;
-        else if (State == JobState.Calculating) return HeuristicLab.Common.Resources.VS2008ImageLibrary.ExecutableStarted;
-        else if (State == JobState.Aborted) return HeuristicLab.Common.Resources.VS2008ImageLibrary.ExecutableStopped;
-        else if (State == JobState.Failed) return HeuristicLab.Common.Resources.VS2008ImageLibrary.Error;
-        else if (State == JobState.Finished) return HeuristicLab.Common.Resources.VS2008ImageLibrary.ExecutableStopped;
+        if (jobDto.State == JobState.Offline) return HeuristicLab.Common.Resources.VS2008ImageLibrary.ExecutablePrepared;
+        else if (jobDto.State == JobState.Calculating) return HeuristicLab.Common.Resources.VS2008ImageLibrary.ExecutableStarted;
+        else if (jobDto.State == JobState.Aborted) return HeuristicLab.Common.Resources.VS2008ImageLibrary.ExecutableStopped;
+        else if (jobDto.State == JobState.Failed) return HeuristicLab.Common.Resources.VS2008ImageLibrary.Error;
+        else if (jobDto.State == JobState.Finished) return HeuristicLab.Common.Resources.VS2008ImageLibrary.ExecutableStopped;
         else return HeuristicLab.Common.Resources.VS2008ImageLibrary.Event;
       }
@@ -33 +39 @@
     [Storable]
     private JobDto jobDto;
-    /// <summary>
-    /// Some static information about the job. Don't use State-Information out of there
-    /// </summary>
     public JobDto JobDto {
       get { return jobDto; }
@@ -49 +52 @@
 
     [Storable]
-    private JobResult jobResult;
-    public JobResult JobResult {
-      private get { return jobResult; }
+    private IJob job;
+    public IJob Job {
+      get { return job; }
       set {
-        if (jobResult != value) {
-          jobResult = value;
-          OnJobStateChanged();
-          OnToStringChanged();
-          OnItemImageChanged();
-        }
-      }
-    }
-
-    public JobState State {
-      get { return jobResult != null ? JobResult.State : JobDto.State; }
-    }
-
-    public double? Percentage {
-      get { return jobResult != null ? JobResult.Percentage : JobDto.Percentage; }
-    }
-
-    public string Exception {
-      get { return jobResult != null ? JobResult.Exception : JobDto.Exception; }
-    }
-
-    public DateTime? DateCalculated {
-      get { return jobResult != null ? JobResult.DateCalculated : JobDto.DateCalculated; }
-    }
-
-    public DateTime? DateFinished {
-      get { return jobResult != null ? JobResult.DateFinished : JobDto.DateFinished; }
-    }
-    
-    [Storable]
-    private ResponseObject<SerializedJob> latestSnapshot;
-    public ResponseObject<SerializedJob> LatestSnapshot {
-      get { return latestSnapshot; }
+        if (job != value) {
+          job = value;
+          IsFinalResultAvailable = job.ExecutionState == ExecutionState.Stopped;
+          OnJobChanged();
+        }
+      }
+    }
+
+    [Storable]
+    private ICollection<JobItem> childJobItems;
+    public IEnumerable<JobItem> ChildJobItems {
+      get { return childJobItems; }
+    }
+
+    [Storable]
+    private bool isFinalResultAvailable;
+    public bool IsFinalResultAvailable {
+      get { return isFinalResultAvailable; }
       set {
-        if (latestSnapshot != value) {
-          latestSnapshot = value;
-          if (value != null) {
-            latestSnapshotTime = DateTime.Now;
-          }
-          SnapshotRequestedState = Experiment.SnapshotRequestedState.Idle;
-          OnLatestSnapshotChanged();
-        }
-      }
-    }
-
-    [Storable]
-    private DateTime latestSnapshotTime;
-    public DateTime LatestSnapshotTime {
-      get { return latestSnapshotTime; }
-    }
-
-    [Storable]
-    private ILog log;
-    public ILog Log {
-      get { return log; }
-    }
-
-    [Storable]
-    private IOptimizer optimizer;
-    public IOptimizer Optimizer {
-      get { return optimizer; }
-      set { this.optimizer = value; }
-    }
-
-    [Storable]
-    private SnapshotRequestedState snapshotRequestedState;
-    public SnapshotRequestedState SnapshotRequestedState {
-      get { return snapshotRequestedState; }
-      private set {
-        this.snapshotRequestedState = value;
-        OnSnapshotRequestedStateChanged();
-      }
-    }
-
+        if (isFinalResultAvailable != value) {
+          isFinalResultAvailable = value;
+          if (isFinalResultAvailable)
+            OnFinalResultAvailable();
+        }
+      }
+    }
+   
     public JobItem() {
-      log = new Log();
+      childJobItems = new List<JobItem>();
+    }
+
+    public JobItem(JobResult jobResult) : this() {
+      this.jobDto = new JobDto();
+      UpdateJob(jobResult);
     }
 
     public override string ToString() {
       if (jobDto != null) {
-        return optimizer.Name;
+        return job.Name;
       } else {
         return base.ToString();
@@ -139 +100 @@
     }
 
-    public event EventHandler LatestSnapshotChanged;
-    private void OnLatestSnapshotChanged() {
-      LogMessage("LatestSnapshotChanged");
-      EventHandler handler = LatestSnapshotChanged;
-      if (handler != null) handler(this, EventArgs.Empty);
-    }
-
+    public void UpdateJob(JobResult jobResult) {
+      if (jobResult != null) {
+        jobDto.Id = jobResult.Id;
+        jobDto.DateCreated = jobResult.DateCreated;
+        jobDto.DateCalculated = jobResult.DateCalculated;
+        jobDto.DateFinished = jobResult.DateFinished;
+        jobDto.Exception = jobResult.Exception;
+        jobDto.Id = jobResult.Id;
+        jobDto.Percentage = jobResult.Percentage;
+        jobDto.State = jobResult.State;
+        // what about parentJob
+        OnJobStateChanged();
+        OnToStringChanged();
+        OnItemImageChanged();
+      }
+    }
+
+    public void AddChildJob(JobItem child) {
+      this.childJobItems.Add(child);
+      OnChildJobAdded();
+    }
+
+    //public IEnumerable<JobItem> GetChildJobItems() {
+    //  if (childJobItems == null)
+    //    childJobItems = CreateChildJobItems();
+    //  return childJobItems;
+    //}
+
+    //protected IEnumerable<JobItem> CreateChildJobItems() {
+    //  return (from j in Job.ChildJobs
+    //          select new JobItem() {
+    //            Job = j,
+    //            JobDto = new JobDto() {
+    //              State = JobState.Offline
+    //            }
+    //          }).ToList();
+    //}
+
+    public SerializedJob ToSerializedJob() {
+      MemoryStream memStream = new MemoryStream();
+      XmlGenerator.Serialize(job, memStream);
+      byte[] jobByteArray = memStream.ToArray();
+      memStream.Dispose();
+
+      UpdateRequiredPlugins();
+
+      this.JobDto.CoresNeeded = job.CoresNeeded;
+      this.JobDto.MemoryNeeded = job.MemoryNeeded;
+
+      SerializedJob serializedJob = new SerializedJob() {
+        JobInfo = jobDto,
+        SerializedJobData = jobByteArray
+      };
+
+      return serializedJob;
+    }
+
+    private void UpdateRequiredPlugins() {
+      // find out which which plugins are needed for the given object
+      this.JobDto.PluginsNeeded = HivePluginInfoDto.FindPluginsNeeded(job.GetType());
+    }
+   
     public event EventHandler JobDtoChanged;
     private void OnJobDtoChanged() {
@@ -155 +171 @@
     public event EventHandler JobStateChanged;
     private void OnJobStateChanged() {
-      LogMessage("JobStateChanged (State: " + this.State + ", Percentage: " + this.Percentage + ")");
+      LogMessage("JobStateChanged (State: " + this.JobDto.State + ", Percentage: " + this.JobDto.Percentage + ")");
       EventHandler handler = JobStateChanged;
+      if (handler != null) handler(this, EventArgs.Empty);
+    }
+    
+    public event EventHandler ChildJobAdded;
+    private void OnChildJobAdded() {
+      var handler = ChildJobAdded;
+      if (handler != null) handler(this, EventArgs.Empty);
+    }
+    
+    public event EventHandler JobChanged;
+    private void OnJobChanged() {
+      var handler = JobChanged;
+      if (handler != null) handler(this, EventArgs.Empty);
+    }
+
+    public event EventHandler FinalResultAvailable;
+    private void OnFinalResultAvailable() {
+      var handler = FinalResultAvailable;
       if (handler != null) handler(this, EventArgs.Empty);
     }
@@ -162 +196 @@
     public void LogMessage(string message) {
       lock (locker) {
-        log.LogMessage(message);
+        if (job != null) {
+          job.Log.LogMessage(message);
+        }
       }
     }
@@ -169 +205 @@
       LogMessage("I am beeing cloned");
       JobItem clone = (JobItem)base.Clone(cloner);
-      clone.latestSnapshotTime = this.latestSnapshotTime;
       clone.jobDto = (JobDto)cloner.Clone(this.jobDto);
-      clone.latestSnapshot = (ResponseObject<SerializedJob>)cloner.Clone(this.latestSnapshot);
-      clone.log = (ILog)cloner.Clone(this.log);
-      clone.optimizer = (IOptimizer)cloner.Clone(this.optimizer);
-      clone.jobResult = (JobResult)cloner.Clone(this.jobResult);
+      clone.job = (IJob)cloner.Clone(this.job);
       return clone;
     }
 
-
-    public event EventHandler SnapshotRequestedStateChanged;
-    private void OnSnapshotRequestedStateChanged() {
-      EventHandler handler = SnapshotRequestedStateChanged;
-      if (handler != null) handler(this, EventArgs.Empty);
-    }
-
-    public void RequestSnapshot() {
-      this.SnapshotRequestedState = Experiment.SnapshotRequestedState.Requested;
-    }
-
-
+    public void UpdateFinalResults(IJob j) {
+      if (this.Job is OptimizerJob && j is OptimizerJob) {
+        ((OptimizerJob)this.Job).Optimizer.Runs.AddRange(((OptimizerJob)j).Optimizer.Runs);
+        IsFinalResultAvailable = true; //job.ExecutionState == ExecutionState.Stopped; //??
+      } else {
+        throw new NotSupportedException();
+      }
+    }
+
+    internal bool ReplaceChildJob(IJob job) {
+      var matches = this.childJobItems.Where(child => child.Job.InternalId == job.InternalId);
+      if (matches.Count() > 0) {
+        matches.First().job = job;
+        return true;
+      }
+      return false;
+    }
   }
 }