Changeset 4145

Timestamp:

08/04/10 15:13:28 (14 years ago)

Author:

cneumuel

Message:

worked on "request snapshot" feature (#1115)

Location:

branches/3.3-HiveMigration/sources/HeuristicLab.Hive

Files:

• HeuristicLab.Hive.Experiment.Views/3.3/JobItemView.cs (modified) (4 diffs)
• HeuristicLab.Hive.Experiment/3.3/HiveExperiment.cs (modified) (5 diffs)
• HeuristicLab.Hive.Experiment/3.3/JobItem.cs (modified) (4 diffs)

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Experiment.Views/3.3/JobItemView.cs

@@ -47 +47 @@
       Content.LatestSnapshotChanged += new EventHandler(Content_LatestSnapshotChanged);
       Content.JobDtoChanged += new EventHandler(Content_JobDtoChanged);
+      Content.SnapshotRequestedStateChanged += new EventHandler(Content_SnapshotRequestedStateChanged);
     }
 
@@ -52 +53 @@
       Content.LatestSnapshotChanged -= new EventHandler(Content_LatestSnapshotChanged);
       Content.JobDtoChanged -= new EventHandler(Content_JobDtoChanged);
+      Content.SnapshotRequestedStateChanged -= new EventHandler(Content_SnapshotRequestedStateChanged);
       base.DeregisterContentEvents();
     }
@@ -92 +94 @@
     protected override void SetEnabledStateOfControls() {
       base.SetEnabledStateOfControls();
-      openSnapshotButton.Enabled = Content != null && Content.LatestSnapshot != null;
+      if (Content != null) {
+        openSnapshotButton.Enabled = Content.SnapshotRequestedState == SnapshotRequestedState.Idle;
+        requestSnapshotButton.Enabled = Content.SnapshotRequestedState == SnapshotRequestedState.Requested;
+      }
       this.jobIdTextBox.ReadOnly = this.ReadOnly;
       this.stateTextBox.ReadOnly = this.ReadOnly;
@@ -115 +120 @@
 
     private void requestSnapshotButton_Click(object sender, EventArgs e) {
-      
+      this.Content.RequestSnapshot();
+    }
+
+    private void Content_SnapshotRequestedStateChanged(object sender, EventArgs e) {
+      SetEnabledStateOfControls();
     }
   }

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Experiment/3.3/HiveExperiment.cs

@@ -158 +158 @@
       isPollingResults = false;
       resultPollingThreads = new Dictionary<Guid, Thread>();
+      RegisterEvents();
       InitTimer();
     }
@@ -191 +192 @@
       this.IsPollingResults = false;
       this.stopResultsPollingPending = false;
+      RegisterEvents();
       LogMessage("I was deserialized.");
     }
-
+    
     private void InitTimer() {
       timer = new System.Timers.Timer(100);
@@ -556 +558 @@
       lock (locker) {
         log.LogMessage(message);
+      }
+    }
+
+    void JobItem_SnapshotRequestedStateChanged(object sender, EventArgs e) {
+      JobItem jobItem = (JobItem)sender;
+      if (jobItem.SnapshotRequestedState == SnapshotRequestedState.Requested) {
+        RequestSnapshot(jobItem.JobDto.Id);
       }
     }
@@ -588 +597 @@
           );
       }
-      SerializedJob jobResult = response.Obj;
-      if (jobResult != null) {
-        Logger.Debug("HiveEngine: Results-polling - Got result!");
-
-        //job = XmlParser.Deserialize<Job>(new MemoryStream(jobResult.SerializedJobData));
-
-        throw new NotImplementedException("[chn] how to create a view in 3.3 and why should i do this here? shouldnt the caller of this method receive a result and decide what to do?");
-        //ControlManager.Manager.ShowControl(job.Engine.CreateView());
+      if (response.Success) {
+        GetJobItemById(jobId).LogMessage("Snapshot polling successfull for job " + jobId);
+        GetJobItemById(jobId).LatestSnapshot = response;
+      } else {
+        GetJobItemById(jobId).LogMessage("Error: Polling of Snapshot failed for job " + jobId + ": " + response.StatusMessage);
       }
     }
@@ -763 +769 @@
       if (handler != null) handler(this, EventArgs.Empty);
     }
+
+    private void RegisterEvents() {
+      jobItems.CollectionReset += new CollectionItemsChangedEventHandler<IndexedItem<JobItem>>(jobItems_CollectionReset);
+      jobItems.ItemsAdded += new CollectionItemsChangedEventHandler<IndexedItem<JobItem>>(jobItems_ItemsAdded);
+      jobItems.ItemsRemoved += new CollectionItemsChangedEventHandler<IndexedItem<JobItem>>(jobItems_ItemsRemoved);
+      jobItems.ItemsReplaced += new CollectionItemsChangedEventHandler<IndexedItem<JobItem>>(jobItems_ItemsReplaced);
+    }
+
+    private void DeregisterEvents() {
+      jobItems.CollectionReset += new CollectionItemsChangedEventHandler<IndexedItem<JobItem>>(jobItems_CollectionReset);
+      jobItems.ItemsAdded += new CollectionItemsChangedEventHandler<IndexedItem<JobItem>>(jobItems_ItemsAdded);
+      jobItems.ItemsRemoved += new CollectionItemsChangedEventHandler<IndexedItem<JobItem>>(jobItems_ItemsRemoved);
+      jobItems.ItemsReplaced += new CollectionItemsChangedEventHandler<IndexedItem<JobItem>>(jobItems_ItemsReplaced);
+    }
+
+
+    void jobItems_ItemsReplaced(object sender, CollectionItemsChangedEventArgs<IndexedItem<JobItem>> e) {
+      UpdateSnapshotRequestedEvents(e);
+    }
+
+    private void UpdateSnapshotRequestedEvents(CollectionItemsChangedEventArgs<IndexedItem<JobItem>> e) {
+      foreach (var item in e.OldItems) {
+        item.Value.SnapshotRequestedStateChanged -= new EventHandler(JobItem_SnapshotRequestedStateChanged);
+      }
+      foreach (var item in e.Items) {
+        item.Value.SnapshotRequestedStateChanged += new EventHandler(JobItem_SnapshotRequestedStateChanged);
+      }
+    }
+
+    void jobItems_ItemsRemoved(object sender, CollectionItemsChangedEventArgs<IndexedItem<JobItem>> e) {
+      UpdateSnapshotRequestedEvents(e);
+    }
+
+    void jobItems_ItemsAdded(object sender, CollectionItemsChangedEventArgs<IndexedItem<JobItem>> e) {
+      UpdateSnapshotRequestedEvents(e);
+    }
+
+    void jobItems_CollectionReset(object sender, CollectionItemsChangedEventArgs<IndexedItem<JobItem>> e) {
+      foreach (var item in e.OldItems) {
+        item.Value.SnapshotRequestedStateChanged -= new EventHandler(JobItem_SnapshotRequestedStateChanged);
+      }
+    }
     #endregion
   }

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

@@ -13 +13 @@
 
 namespace HeuristicLab.Hive.Experiment {
+  public enum SnapshotRequestedState { Idle, Requested }
+
   [StorableClass]
   public class JobItem : Item {
@@ -51 +53 @@
           latestSnapshot = value;
           latestSnapshotTime = DateTime.Now;
+          SnapshotRequestedState = Experiment.SnapshotRequestedState.Idle;
           OnLatestSnapshotChanged();
         }
@@ -74 +77 @@
       set { this.optimizer = value; }
     }
-    
+
+    [Storable]
+    private SnapshotRequestedState snapshotRequestedState;
+    public SnapshotRequestedState SnapshotRequestedState {
+      get { return snapshotRequestedState; }
+      private set {
+        this.snapshotRequestedState = value;
+        OnSnapshotRequestedStateChanged();
+      }
+    }
+
     public JobItem() {
       log = new Log();
@@ -117 +130 @@
       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;
+    }
+
   }
 }