Changeset 6267 for branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Services.Hive.DataAccess/3.4/TransactionManager.cs

Timestamp:

05/24/11 16:55:48 (13 years ago)

Author:

cneumuel

Message:

#1233

• extended statistics recording:
  • execution times of users are captured
  • execution times and start-to-finish time of finished jobs is captured (to computer hive overhead)
  • data of deleted jobs is automatically captured in DeletedJobStatistics
• changed ExecutionTime type in database from string to float (milliseconds are stored instead of TimeSpan.ToString())
• added IsPrivileged field to job to indicate if it should be executed in a privileged sandbox
• added CpuUtilization field to slave to be able to report cpu utilization
• added GetJobsByResourceId to retrieve all jobs which are currently beeing calculated in a slave(-group)
• TransactionManager now allows to use serializable tranactions (used for lifecycle trigger)

File:

• branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Services.Hive.DataAccess/3.4/TransactionManager.cs (modified) (3 diffs)

branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Services.Hive.DataAccess/3.4/TransactionManager.cs

@@ -1 +1 @@
 using System;
 using System.Transactions;
-using HeuristicLab.Services.Hive.Common;
 
 namespace HeuristicLab.Services.Hive.DataAccess {
   public class TransactionManager {
-    public void UseTransaction(Action call) {
-      TransactionScope transaction = CreateTransaction();
+    public void UseTransaction(Action call, bool serializable = false) {
+      TransactionScope transaction = serializable ? CreateSerializableTransaction() : CreateTransaction();
       try {
         call();
@@ -16 +15 @@
     }
 
-    public T UseTransaction<T>(Func<T> call) {
-      TransactionScope transaction = CreateTransaction();
+    public T UseTransaction<T>(Func<T> call, bool serializable = false) {
+      TransactionScope transaction = serializable ? CreateSerializableTransaction() : CreateTransaction();
       try {
         T result = call();
@@ -29 +28 @@
 
     private static TransactionScope CreateTransaction() {
-      return new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = ApplicationConstants.IsolationLevelScope });
+      return new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = IsolationLevel.ReadUncommitted });
+    }
+    private static TransactionScope CreateSerializableTransaction() {
+      return new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = IsolationLevel.Serializable });
     }
   }