Changeset 1166 for trunk/sources/HeuristicLab.Hive.Server.ADODataAccess/JobAdapter.cs

Timestamp:

01/22/09 00:30:46 (15 years ago)

Author:

svonolfe

Message:

Improved memory consumption, fixed bug that already calculated jobs where reset (#372)

File:

• trunk/sources/HeuristicLab.Hive.Server.ADODataAccess/JobAdapter.cs (modified) (3 diffs)

trunk/sources/HeuristicLab.Hive.Server.ADODataAccess/JobAdapter.cs

@@ -37 +37 @@
     IJobAdapter {
     #region Fields
-    dsHiveServer.JobDataTable data =
-        new dsHiveServer.JobDataTable();
-
     private IClientAdapter clientAdapter = null;
 
@@ -165 +162 @@
 
     protected override dsHiveServer.JobRow 
-      InsertNewRow(Job job) {      
+      InsertNewRow(Job job) {
+      dsHiveServer.JobDataTable data =
+        new dsHiveServer.JobDataTable();
+
       dsHiveServer.JobRow row = data.NewJobRow();
       data.AddJobRow(row);
@@ -267 +267 @@
     }
 
+    public ICollection<Job> GetActiveJobsOf(ClientInfo client) {
+
+      if (client != null) {
+        return
+          base.FindMultiple(
+            delegate() {
+              return Adapter.GetDataByCalculatingClient(client.Id);
+            },
+            delegate() {
+              return from job in
+                       cache.AsEnumerable<dsHiveServer.JobRow>()
+                     where !job.IsResourceIdNull() &&
+                            job.ResourceId == client.Id && 
+                           !job.IsJobStateNull() && 
+                            job.JobState == "calculating"
+                     select job;
+            });
+      }
+
+      return null;
+    }
+
     public ICollection<Job> GetJobsOf(User user) {
       if (user != null) {