Changeset 4042 for branches/3.2/sources/HeuristicLab.Hive.Server/3.2/ServiceCallInterception.cs

Timestamp:

07/18/10 22:16:04 (14 years ago)

Author:

kgrading

Message:

#828 added various improvements to the plugin cache manager, the execution engine, the transaction handling on the serverside and the server console

File:

• branches/3.2/sources/HeuristicLab.Hive.Server/3.2/ServiceCallInterception.cs (modified) (3 diffs)

branches/3.2/sources/HeuristicLab.Hive.Server/3.2/ServiceCallInterception.cs

@@ -9 +9 @@
 using HeuristicLab.Hive.Contracts;
 using HeuristicLab.Tracing;
+using System.Reflection;
+using HeuristicLab.Hive.Server.Core;
 
 namespace HeuristicLab.Hive.Server {
   internal class ServiceCallInterception : IMethodInterceptor {
-
     private const bool UseTransactions = true;
 
     public object Invoke(IMethodInvocation invocation) {
+      bool userTransaction = false;
+
       DateTime start = DateTime.Now;
       Logger.Info("Entering Method: " + invocation.Method.Name);
 
-      if(!ContextFactory.IsContextNull()) {
+      if (!ContextFactory.IsContextNull()) {
         Logger.Info("Not null context found - why wasn't this disposed?");
         try {
           Logger.Info("Trying to dispose");
           ContextFactory.Context.Dispose();
-        } catch (Exception e) {
+        }
+        catch (Exception e) {
           Logger.Error(e);
         }
@@ -30 +34 @@
       }
       Logger.Info("Context info: Timeout: " + ContextFactory.Context.Connection.ConnectionTimeout + " | " +
-                  ContextFactory.Context.Connection.State + " | Conn: " + ContextFactory.Context + " | HashCode is: " + ContextFactory.Context.Connection.GetHashCode());
+                  ContextFactory.Context.Connection.State + " | Conn: " + ContextFactory.Context + " | HashCode is: " +
+                  ContextFactory.Context.Connection.GetHashCode());
       Object obj = null;
 
-      /*if (invocation.Method.Name.Equals("SendStreamedJob") || invocation.Method.Name.Equals("StoreFinishedJobResultStreamed")) {        
-        ContextFactory.Context.Connection.Open();
-        if(UseTransactions) {
-          Logger.Debug("Opening Transaction");
-          ContextFactory.Context.Transaction = ContextFactory.Context.Connection.BeginTransaction(ApplicationConstants.ISOLATION_LEVEL);
-        } else {
-          Logger.Debug("Not using a Transaction");
-        }
-        try {
-          obj = invocation.Proceed();
-          Logger.Info("leaving context open for streaming");
-        }
-        catch (Exception e) {
-          Logger.Error("Exception occured during method invocation", e);              
-          ContextFactory.Context.Dispose();
-          ContextFactory.Context = null;
-        }        
-      } else { */
-        if(UseTransactions) {
-          using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = ApplicationConstants.ISOLATION_LEVEL_SCOPE })) {
-            try {
-              Logger.Debug("Current Transaction Isolation level is: " + Transaction.Current.IsolationLevel);
-              obj = invocation.Proceed();
-              scope.Complete();
-            }
-            catch (Exception e) {
-              Logger.Error("Exception occured during method invocation", e);     
-              Logger.Error("Inner Exception: ", e.InnerException);
-            }
-            finally {
-              ContextFactory.Context.Dispose();
-              Logger.Debug("Disposed Context");
-              ContextFactory.Context = null;
-              Logger.Debug("Set Context Null");
-            }
-          }
-        } else {
+      Object[] attributes = invocation.Method.GetCustomAttributes(typeof (SpringTransaction), true);
+      foreach (Object o in attributes) {
+        SpringTransaction st = (SpringTransaction) o;
+        userTransaction = st.UserTransaction;
+      }
+      if (UseTransactions && !userTransaction) {
+        using (
+          TransactionScope scope = new TransactionScope(TransactionScopeOption.Required,
+                                                        new TransactionOptions
+                                                        {IsolationLevel = ApplicationConstants.ISOLATION_LEVEL_SCOPE})) {
           try {
-            obj = invocation.Proceed();            
+            Logger.Debug("Current Transaction Isolation level is: " + Transaction.Current.IsolationLevel);
+            obj = invocation.Proceed();
+            scope.Complete();
           }
           catch (Exception e) {
-            Logger.Error("Exception occured during method invocation", e);                          
+            Logger.Error("Exception occured during method invocation", e);
+            Logger.Error("Inner Exception: ", e.InnerException);
           }
           finally {
@@ -81 +62 @@
             ContextFactory.Context = null;
             Logger.Debug("Set Context Null");
-          }  
+          }
         }
+      }
+      else {
+        try {
+          obj = invocation.Proceed();
+        }
+        catch (Exception e) {
+          Logger.Error("Exception occured during method invocation", e);
+        }
+        finally {
+          ContextFactory.Context.Dispose();
+          Logger.Debug("Disposed Context");
+          ContextFactory.Context = null;
+          Logger.Debug("Set Context Null");
+        }
+      }
       //}       
       TimeSpan ts = DateTime.Now - start;
       if (ts.Seconds > 2) {
         Logger.Warn("Invocation took: " + ts);
-      } else if (ts.Seconds > 10) {
+      }
+      else if (ts.Seconds > 10) {
         Logger.Error("Invocation took: " + ts);
-      } else {
-        Logger.Info("Invocation took: " + ts); ;
+      }
+      else {
+        Logger.Info("Invocation took: " + ts);
+        ;
       }
       Logger.Info("Leaving Method: " + invocation.Method.Name);
-      
+
       return obj;
     }
   }
 }
-     
-