Changeset 5093 for branches/HeuristicLab.Hive-3.3/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/LifecycleManager.cs

Timestamp:

12/13/10 14:13:15 (13 years ago)

Author:

cneumuel

Message:

#1260

• moved all state-information into lifecycleManager
• changed isolation level for transactions to ReadCommited
• made currentlyFetching-status on slave more rubust
• made LogServiceReader more rubust

File:

• branches/HeuristicLab.Hive-3.3/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/LifecycleManager.cs (modified) (1 diff)

branches/HeuristicLab.Hive-3.3/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/LifecycleManager.cs

@@ -35 +35 @@
     private bool shutdownRequested;
     private PluginManager pm;
+
+    private Dictionary<Guid, DateTime> lastHeartbeats = new Dictionary<Guid, DateTime>();
+    public Dictionary<Guid, DateTime> LastHeartbeats {
+      get { return lastHeartbeats; }
+    }
+
+    /// <summary>
+    /// Contains a list job JobIds which have been sent to a slave, but the slave has not yet sent 
+    /// a jobProgress of the job with a heartbeat, because he has not finished downloading/deserializing it.
+    /// The number value indicates a TimeToLive count that is decremented with each server-heartbeat.
+    /// When the number reaches zero, the jobs is assumed to be lost and is set Offline again.
+    /// </summary>
+    private Dictionary<Guid, int> newAssignedJobs = new Dictionary<Guid, int>();
+    public Dictionary<Guid, int> NewAssignedJobs {
+      get { return newAssignedJobs; }
+    }
+
+    /// <summary>
+    /// When a slave reconnects and he has finished results waiting it calls IsJobStillNeeded. If the finished 
+    /// result has not yet been collected from anywhere else, the job will be sent by the slave and the job state is set to Pending.
+    /// Now the job be in pending state until it is received from the reconnected slave or the TimeToLive value of this dictionary has reached zero.
+    /// </summary>
+    private Dictionary<Guid, int> pendingJobs = new Dictionary<Guid, int>();
+    public Dictionary<Guid, int> PendingJobs {
+      get { return pendingJobs; }
+    }
 
     private TimeSpan interval = new TimeSpan(0, 0, 10);