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

Timestamp:

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

Author:

cneumuel

Message:

worked on "request snapshot" feature (#1115)

File:

• branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Experiment/3.3/HiveExperiment.cs (modified) (5 diffs)

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
   }