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)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Clients.Hive/3.4/ExperimentManager/JobResultPoller.cs
r6006 r6111 26 26 27 27 namespace HeuristicLab.Clients.Hive { 28 internalclass JobResultPoller {28 public class JobResultPoller { 29 29 private bool stopRequested { get; set; } 30 30 private AutoResetEvent waitHandle; 31 31 private Thread thread; 32 32 33 private IEnumerable<HiveJob> hiveJobs;34 public IEnumerable<HiveJob> HiveJobs{35 get { return hive Jobs; }36 set { hive Jobs= value; }33 private Guid hiveExperimentId; 34 public Guid HiveExperimentId { 35 get { return hiveExperimentId; } 36 set { hiveExperimentId = value; } 37 37 } 38 38 … … 54 54 } 55 55 56 public JobResultPoller( IEnumerable<HiveJob> hiveJobs, TimeSpan interval) {56 public JobResultPoller(Guid hiveExperimentId, TimeSpan interval) { 57 57 this.isPolling = false; 58 this.hive Jobs = hiveJobs;58 this.hiveExperimentId = hiveExperimentId; 59 59 this.interval = interval; 60 60 } … … 75 75 } 76 76 77 p ublicvoid RunPolling() {77 private void RunPolling() { 78 78 try { 79 79 waitHandle = new AutoResetEvent(false); … … 94 94 } 95 95 96 p rivate voidFetchJobResults() {97 ServiceLocator.Instance.CallHiveService(service => {96 public IEnumerable<LightweightJob> FetchJobResults() { 97 return ServiceLocator.Instance.CallHiveService(service => { 98 98 var responses = new List<LightweightJob>(); 99 foreach (HiveJob hiveJob in HiveJobs) { 100 responses.AddRange(service.GetLightweightChildJobs(hiveJob.Job.Id, true, true)); 101 } 99 responses.AddRange(service.GetLightweightExperimentJobs(hiveExperimentId)); 102 100 OnJobResultsReceived(responses); 101 return responses; 103 102 }); 104 103 }
Note: See TracChangeset
for help on using the changeset viewer.