Changeset 6111 for branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.4/ExperimentManager/JobResultPoller.cs

Timestamp:

05/03/11 17:14:02 (13 years ago)

Author:

cneumuel

Message:

#1233

• improved the way jobs are downloaded by ExperimentManager and HiveEngine

File:

• branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.4/ExperimentManager/JobResultPoller.cs (modified) (4 diffs)

branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.4/ExperimentManager/JobResultPoller.cs

@@ -26 +26 @@
 
 namespace HeuristicLab.Clients.Hive {
-  internal class JobResultPoller {
+  public class JobResultPoller {
     private bool stopRequested { get; set; }
     private AutoResetEvent waitHandle;
     private Thread thread;
 
-    private IEnumerable<HiveJob> hiveJobs;
-    public IEnumerable<HiveJob> HiveJobs {
-      get { return hiveJobs; }
-      set { hiveJobs = value; }
+    private Guid hiveExperimentId;
+    public Guid HiveExperimentId {
+      get { return hiveExperimentId; }
+      set { hiveExperimentId = value; }
     }
 
@@ -54 +54 @@
     }
 
-    public JobResultPoller(IEnumerable<HiveJob> hiveJobs, TimeSpan interval) {
+    public JobResultPoller(Guid hiveExperimentId, TimeSpan interval) {
       this.isPolling = false;
-      this.hiveJobs = hiveJobs;
+      this.hiveExperimentId = hiveExperimentId;
       this.interval = interval;
     }
@@ -75 +75 @@
     }
 
-    public void RunPolling() {
+    private void RunPolling() {
       try {
         waitHandle = new AutoResetEvent(false);
@@ -94 +94 @@
     }
 
-    private void FetchJobResults() {
-      ServiceLocator.Instance.CallHiveService(service => {
+    public IEnumerable<LightweightJob> FetchJobResults() {
+      return ServiceLocator.Instance.CallHiveService(service => {
         var responses = new List<LightweightJob>();
-        foreach (HiveJob hiveJob in HiveJobs) {
-          responses.AddRange(service.GetLightweightChildJobs(hiveJob.Job.Id, true, true));
-        }
+        responses.AddRange(service.GetLightweightExperimentJobs(hiveExperimentId));
         OnJobResultsReceived(responses);
+        return responses;
       });
     }