Changeset 7045

Timestamp:

11/22/11 18:13:48 (13 years ago)

Author:

ascheibe

Message:

#1672 switch more service calls to IsolationLevel=ReadUncommitted transactions to prevent db deadlocks

File:

• trunk/sources/HeuristicLab.Services.Hive/3.3/HiveService.cs (modified) (3 diffs)

trunk/sources/HeuristicLab.Services.Hive/3.3/HiveService.cs

@@ -87 +87 @@
       authen.AuthenticateForAnyRole(HiveRoles.Administrator, HiveRoles.Client, HiveRoles.Slave);
       author.AuthorizeForTask(taskId, Permission.Read);
-      return dao.GetTask(taskId);
+
+      return trans.UseTransaction(() => {
+        return dao.GetTask(taskId);
+      }, false, false);
     }
 
@@ -100 +103 @@
     public IEnumerable<LightweightTask> GetLightweightTasks(IEnumerable<Guid> taskIds) {
       authen.AuthenticateForAnyRole(HiveRoles.Administrator, HiveRoles.Client);
-      var tasks = dao.GetTasks(x => taskIds.Contains(x.TaskId)).Select(x => new LightweightTask(x)).ToArray();
-      foreach (var task in tasks)
-        author.AuthorizeForTask(task.Id, Permission.Read);
-      return tasks;
+
+      return trans.UseTransaction(() => {
+        var tasks = dao.GetTasks(x => taskIds.Contains(x.TaskId)).Select(x => new LightweightTask(x)).ToArray();
+        foreach (var task in tasks)
+          author.AuthorizeForTask(task.Id, Permission.Read);
+        return tasks;
+      }, false, false);
     }
 
     public IEnumerable<LightweightTask> GetLightweightChildTasks(Guid? parentTaskId, bool recursive, bool includeParent) {
       authen.AuthenticateForAnyRole(HiveRoles.Administrator, HiveRoles.Client);
-      var tasks = GetChildTasks(parentTaskId, recursive, includeParent).Select(x => new LightweightTask(x)).ToArray();
-      foreach (var task in tasks)
-        author.AuthorizeForTask(task.Id, Permission.Read);
-      return tasks;
+
+      return trans.UseTransaction(() => {
+        var tasks = GetChildTasks(parentTaskId, recursive, includeParent).Select(x => new LightweightTask(x)).ToArray();
+        foreach (var task in tasks)
+          author.AuthorizeForTask(task.Id, Permission.Read);
+        return tasks;
+      }, false, false);
     }
 
@@ -117 +126 @@
       authen.AuthenticateForAnyRole(HiveRoles.Administrator, HiveRoles.Client);
       author.AuthorizeForJob(jobId, Permission.Read);
-      return dao.GetTasks(x => x.JobId == jobId).Select(x => new LightweightTask(x)).ToArray();
+
+      return trans.UseTransaction(() => {
+        return dao.GetTasks(x => x.JobId == jobId).Select(x => new LightweightTask(x)).ToArray();
+      }, false, false);
     }