Changeset 4368 for branches/3.3-Hive/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.LINQDataAccess/3.3/JobDao.cs

Timestamp:

09/07/10 10:22:27 (14 years ago)

Author:

cneumuel

Message:

• created HiveClient which shows an overview over all submitted HiveExperiments
• its possible to download all submitted HiveExperiments including results
• Experiments are now sent as a whole to the Hive and the Hive-Slaves take care of creating child-jobs (if necessary). The parent job is then paused and will be reactivated when all child-jobs are finished
• WcfService-Clients are now consistently managed by WcfServicePool which allows to use IDisposable-Pattern and always keeps exactly one proxy-object until all callers disposed them.
• created ProgressView which is able to lock a View and display progress of an action. It also allows to simulate progress if no progress-information is available so that users don't get too nervous while waiting.

File:

• branches/3.3-Hive/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.LINQDataAccess/3.3/JobDao.cs (modified) (10 diffs)

branches/3.3-Hive/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.LINQDataAccess/3.3/JobDao.cs

@@ -73 +73 @@
       Job j = DtoToEntity(job.JobInfo, null);
       j.SerializedJob = job.SerializedJobData;
-      foreach (Guid assignRessourceId in job.JobInfo.AssignedResourceIds)
-        j.AssignedResources.Add(new AssignedResource { ResourceId = assignRessourceId });
+      //foreach (Guid assignRessourceId in job.JobInfo.AssignedResourceIds)
+      //  j.AssignedResources.Add(new AssignedResource { ResourceId = assignRessourceId });
       Context.Jobs.InsertOnSubmit(j);
       CommitChanges();
@@ -98 +98 @@
                      j.JobState == Enum.GetName(typeof(JobState), JobState.Aborted) ||
                      j.JobState == Enum.GetName(typeof(JobState), JobState.SnapshotRequested) ||
-                     j.JobState == Enum.GetName(typeof(JobState), JobState.SnapshotSent)) &&
+                     j.JobState == Enum.GetName(typeof(JobState), JobState.SnapshotSent) ||
+                     j.JobState == Enum.GetName(typeof(JobState), JobState.WaitForChildJobs)) &&
                     (j.ResourceId.Equals(slave.Id))
               select EntityToDto(j, null)).ToList();
     }
 
-    public IEnumerable<JobDto> FindFittingJobsForSlave(JobState state, int freeCores, int freeMemory, Guid slaveId) {
+    public IEnumerable<JobDto> FindFittingJobs(JobState state, int freeCores, int freeMemory, Guid slaveId) {
       SlaveGroupDao cgd = new SlaveGroupDao();
 
@@ -111 +112 @@
 
       var q = (from ar in Context.AssignedResources
-               where ar.Job.JobState == Enum.GetName(typeof(JobState), JobState.Offline) &&
+               where ar.Job.JobState == Enum.GetName(typeof(JobState), state) &&
                      ar.Job.CoresNeeded <= freeCores &&
                      ar.Job.MemoryNeeded <= freeMemory &&
@@ -120 +121 @@
     }
 
+    public IEnumerable<JobDto> FindJobsWithFinishedChilds(Guid slaveId) {
+      SlaveGroupDao cgd = new SlaveGroupDao();
+      
+      List<Guid> idList = new List<Guid>(cgd.FindAllGroupAndParentGroupIdsForSlave(slaveId));
+      //Add myself too - enables jobs for one specific host!
+      idList.Add(slaveId);
+
+      var query = from ar in Context.AssignedResources
+                  where ar.Job.JobState == Enum.GetName(typeof(JobState), JobState.WaitForChildJobs) &&
+                    (from child in Context.Jobs
+                     where child.ParentJobId == ar.Job.JobId
+                     select child.JobState == Enum.GetName(typeof(JobState), JobState.Finished)).All(x => x)
+                  orderby ar.Job.Priority descending
+                  select EntityToDto(ar.Job, null);
+      var list = query.ToList();
+      return list;
+    }
+
     public IEnumerable<JobDto> GetJobsByState(JobState state) {
       return (from j in Context.Jobs
@@ -127 +146 @@
 
     public void AssignSlaveToJob(Guid slaveId, Guid jobId) {
-      Slave c = Context.Resources.OfType<Slave>().SingleOrDefault(slave => slave.ResourceId.Equals(slaveId));
+      Slave s = Context.Resources.OfType<Slave>().SingleOrDefault(slave => slave.ResourceId.Equals(slaveId));
       Job j = Context.Jobs.SingleOrDefault(job => job.JobId.Equals(jobId));
-      c.Jobs.Add(j);
-      j.Slave = c;
+      s.Jobs.Add(j);
+      j.Slave = s;
+      CommitChanges();
+    }
+
+    public void UnAssignSlaveToJob(Guid jobId) {
+      Job j = Context.Jobs.SingleOrDefault(job => job.JobId.Equals(jobId));
+      j.Slave = null;
       CommitChanges();
     }
@@ -153 +178 @@
     }
 
-    public bool IsUserAuthorizedForJobs(string userId, params Guid[] jobIds) {
+    public bool IsUserAuthorizedForJobs(Guid userId, params Guid[] jobIds) {
       var jobs = from job in Context.Jobs
                  where jobIds.Contains(job.JobId)
@@ -159 +184 @@
       return jobs.All(job => job.UserId == userId);
     }
+
+    public IEnumerable<JobDto> FindJobsByParentId(Guid? parentJobId, bool recursive) {
+      IQueryable<JobDto> query = from job in Context.Jobs
+                                 where parentJobId == null ? !job.ParentJobId.HasValue : job.ParentJobId.Value == parentJobId
+                                 select EntityToDto(job, null);
+      List<JobDto> jobs = query.ToList();
+      if (recursive) {
+        List<JobDto> childs = new List<JobDto>();
+        foreach (JobDto job in jobs) {
+          childs.AddRange(FindJobsByParentId(job.Id, recursive));
+        }
+        jobs.AddRange(childs);
+      }
+      return jobs;
+    }
+
     #endregion
 
@@ -181 +222 @@
       target.JobState = Enum.GetName(typeof(JobState), source.State);
       target.UserId = source.UserId;
+      if (source.ParentJob != null) {
+        target.ParentJobId = source.ParentJob.Id;
+      }
+
+      foreach (Guid assignRessourceId in source.AssignedResourceIds) {
+        if (!target.AssignedResources.Select(x => x.ResourceId).Contains(assignRessourceId)) {
+          target.AssignedResources.Add(new AssignedResource { ResourceId = assignRessourceId });
+        }
+      }
+
       return target;
     }
 
-    //Assigned ressources are not used atm!
     //Slave is not used ATM - not sure when we stopped using those...
     public override JobDto EntityToDto(Job source, JobDto target) {
@@ -199 +249 @@
       target.DateFinished = source.DateFinished;
       target.Id = source.JobId;
-      
+
       target.Exception = source.Exception;
       target.Percentage = source.Percentage;
@@ -206 +256 @@
       target.State = (JobState)Enum.Parse(typeof(JobState), source.JobState, true);
       target.UserId = source.UserId;
+
+      if (source.ParentJobId.HasValue) {
+        target.ParentJob = new JobDto() { Id = source.ParentJobId.Value };
+      }
+      target.AssignedResourceIds = source.AssignedResources.Select(x => x.ResourceId).ToList();
+
       return target;
     }