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

Timestamp:

08/04/10 10:44:14 (14 years ago)

Author:

cneumuel

Message:

merged with changes from Hive-3.2

File:

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

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

@@ -53 +53 @@
     private const string itemDescription = "A runner for a single experiment, which's algorithms are executed in the Hive.";
     private const int resultPollingIntervalMs = 15000;
+    private const int snapshotPollingIntervalMs = 1000;
     private const int maxSnapshotRetries = 20;
     private object locker = new object();
@@ -169 +170 @@
       clone.executionTime = this.executionTime;
       clone.pendingOptimizersByJobId = new Dictionary<Guid, IOptimizer>();
+
       foreach (var pair in this.pendingOptimizersByJobId)
         clone.pendingOptimizersByJobId[pair.Key] = (IOptimizer)cloner.Clone(pair.Value);
+
       foreach (var pair in this.parentOptimizersByPendingOptimizer)
-        clone.parentOptimizersByPendingOptimizer[pair.Key] = (IOptimizer)cloner.Clone(pair.Value);
+        clone.parentOptimizersByPendingOptimizer[(IOptimizer)cloner.Clone(pair.Key)] = (IOptimizer)cloner.Clone(pair.Value);
+
       clone.log = (ILog)cloner.Clone(log);
       clone.stopPending = this.stopPending;
@@ -243 +247 @@
     public void Prepare() {
       if (experiment != null) {
+        StopResultPolling();
+        pendingOptimizersByJobId.Clear();
+        parentOptimizersByPendingOptimizer.Clear();
+        jobItems.Clear();
         experiment.Prepare();
         this.ExecutionState = Core.ExecutionState.Prepared;
@@ -251 +259 @@
     public void Start() {
       OnStarted();
+      ExecutionTime = new TimeSpan();
       lastUpdateTime = DateTime.Now;
       this.ExecutionState = Core.ExecutionState.Started;
@@ -295 +304 @@
     private void CreateResultPollingThreads() {
       foreach (JobItem jobItem in JobItems) {
-        if (!resultPollingThreads.ContainsKey(jobItem.JobDto.Id)) {
+        if (!resultPollingThreads.ContainsKey(jobItem.JobDto.Id) && jobItem.JobDto.State != State.Finished) {
           resultPollingThreads.Add(jobItem.JobDto.Id, CreateResultPollingThread(jobItem.JobDto));
         }
@@ -303 +312 @@
     public void StartResultPolling() {
       this.stopResultsPollingPending = false;
-      CreateResultPollingThreads();
-      foreach (Thread pollingThread in resultPollingThreads.Values) {
-        if (pollingThread.ThreadState != System.Threading.ThreadState.Running) {
-          pollingThread.Start();
-        }
-      }
       this.IsPollingResults = true;
+      lock (resultPollingThreads) {
+        CreateResultPollingThreads();
+        foreach (Thread pollingThread in resultPollingThreads.Values) {
+          if (pollingThread.ThreadState != System.Threading.ThreadState.Running) {
+            pollingThread.Start();
+          }
+        }
+      }
     }
 
@@ -452 +463 @@
 
           do {
-            Thread.Sleep(resultPollingIntervalMs);
             if (stopPending || !this.IsPollingResults) {
               return;
@@ -479 +489 @@
               UpdateSnapshot(jobResponse);
             }
+
+            Thread.Sleep(resultPollingIntervalMs);
           } while (restoredObject == null || restoredObject.ExecutionState != Core.ExecutionState.Stopped);
 
@@ -486 +498 @@
           IOptimizer originalOptimizer = pendingOptimizersByJobId[job.Id];
           IOptimizer restoredOptimizer = ((OptimizerJob)restoredObject).Optimizer;
-
+          
           ReplaceOptimizer(parentOptimizersByPendingOptimizer[originalOptimizer], originalOptimizer, restoredOptimizer);
           pendingOptimizersByJobId.Remove(job.Id);
           parentOptimizersByPendingOptimizer.Remove(originalOptimizer);
 
+        } catch (ThreadInterruptedException exception) {
+
+        } finally {
+          GetJobItemById(job.Id).LogMessage("ResultsPolling Thread stopped");
+          lock (resultPollingThreads) {
+            resultPollingThreads.Remove(job.Id);
+            if (resultPollingThreads.Count == 0) {
+              IsPollingResults = false;
+            }
+          }
+
+          // check if finished
           if (pendingOptimizersByJobId.Count == 0) {
-            // finished
             this.ExecutionState = Core.ExecutionState.Stopped;
             OnStopped();
           }
-        } catch (ThreadInterruptedException exception) {
-
-        } finally {
-          GetJobItemById(job.Id).LogMessage("ResultsPolling Thread stopped");
-          resultPollingThreads.Remove(job.Id);
-          if (resultPollingThreads.Count == 0) {
-            IsPollingResults = false;
-          }
         }
       });
@@ -519 +534 @@
 
     private void LogMessage(string message) {
-      // HeuristicLab.Log is not Thread-Safe, so lock every call
+      // HeuristicLab.Log is not Thread-Safe, so lock on every call
       lock (locker) {
         log.LogMessage(message);
+      }
+    }
+
+    public void RequestSnapshot(Guid jobId) {
+      IExecutionEngineFacade executionEngineFacade = GetExecutionEngineFacade();
+      ResponseObject<SerializedJob> response;
+      int retryCount = 0;
+
+      Response snapShotResponse = executionEngineFacade.RequestSnapshot(jobId);
+      if (snapShotResponse.StatusMessage == ApplicationConstants.RESPONSE_JOB_IS_NOT_BEEING_CALCULATED) {
+        // job already finished
+        Logger.Debug("HiveEngine: Abort - GetLastResult(false)");
+        response = executionEngineFacade.GetLastSerializedResult(jobId, false, false);
+        Logger.Debug("HiveEngine: Abort - Server: " + response.StatusMessage + " success: " + response.Success);
+      } else {
+        // server sent snapshot request to client
+        // poll until snapshot is ready
+        do {
+          Thread.Sleep(snapshotPollingIntervalMs);
+          Logger.Debug("HiveEngine: Abort - GetLastResult(true)");
+          response = executionEngineFacade.GetLastSerializedResult(jobId, false, true);
+          Logger.Debug("HiveEngine: Abort - Server: " + response.StatusMessage + " success: " + response.Success);
+          retryCount++;
+          // loop while
+          // 1. problem with communication with server
+          // 2. job result not yet ready
+        } while (
+          (retryCount < maxSnapshotRetries) && (
+          !response.Success ||
+          response.StatusMessage == ApplicationConstants.RESPONSE_JOB_RESULT_NOT_YET_HERE)
+          );
+      }
+      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());
       }
     }