Changeset 3220 for trunk/sources/HeuristicLab.Hive.Server/3.2

Timestamp:

03/25/10 19:57:44 (14 years ago)

Author:

kgrading

Message:

improved the DAL further, changed minor details for the presentation (#830)

File:

• trunk/sources/HeuristicLab.Hive.Server/3.2/ServiceCallInterception.cs (modified) (1 diff)

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

@@ -9 +9 @@
 
 namespace HeuristicLab.Hive.Server {
-  class ServiceCallInterception: IMethodInterceptor {
-    #region IMethodInterceptor Members
+  internal class ServiceCallInterception : IMethodInterceptor {
+
+    private bool useTransactions = false;
 
     public object Invoke(IMethodInvocation invocation) {
-      Console.WriteLine(DateTime.Now + " - " + Thread.CurrentThread.ManagedThreadId + " - Entering Method " + invocation.Method.Name);
+      Console.WriteLine(DateTime.Now + " - " + Thread.CurrentThread.ManagedThreadId + " - Entering Method " +
+                        invocation.Method.Name);
 
-      Object obj;
-      
-      using (TransactionScope scope = new TransactionScope()) {
+      if(ContextFactory.Context != null) {
+        Console.WriteLine("Error - Not null context found - why wasn't this disposed?");
+        ContextFactory.Context = null;
+      }
+
+      Object obj = null;
+
+      if (invocation.Method.Name.Equals("SendStreamedJob") || invocation.Method.Name.Equals("StoreFinishedJobResultStreamed")) {        
+        ContextFactory.Context.Connection.Open();
+        if(useTransactions)
+          ContextFactory.Context.Transaction = ContextFactory.Context.Connection.BeginTransaction();
         try {
           obj = invocation.Proceed();
-          scope.Complete();
-        } finally {
+          Console.WriteLine("leaving context open for Streaming");
+        }
+        catch (Exception e) {          
+          Console.WriteLine(e);
           ContextFactory.Context.Dispose();
-          Console.WriteLine("setting old context null");
           ContextFactory.Context = null;
-          Console.WriteLine("Disposing old Context");      
+        }        
+      } else {
+        if(useTransactions) {
+          using (TransactionScope scope = new TransactionScope()) {
+            try {
+              obj = invocation.Proceed();
+              scope.Complete();
+            }
+            catch (Exception e) {
+              Console.WriteLine("Exception Occured");
+              Console.WriteLine(e);
+            }
+            finally {
+              ContextFactory.Context.Dispose();
+              Console.WriteLine("setting old context null");
+              ContextFactory.Context = null;
+              Console.WriteLine("Disposing old Context");
+            }
+          }
+        } else {
+          try {
+            obj = invocation.Proceed();            
+          }
+          catch (Exception e) {
+            Console.WriteLine("Exception Occured");
+            Console.WriteLine(e);
+          }
+          finally {
+            ContextFactory.Context.Dispose();
+            Console.WriteLine("setting old context null");
+            ContextFactory.Context = null;
+            Console.WriteLine("Disposing old Context");
+          }  
         }
-      }     
-      Console.WriteLine(DateTime.Now + " - " + Thread.CurrentThread.ManagedThreadId + " - Leaving Method " + invocation.Method.Name);            
+      }
+      Console.WriteLine(DateTime.Now + " - " + Thread.CurrentThread.ManagedThreadId + " - Leaving Method " +
+                          invocation.Method.Name);
+
       return obj;
     }
-
-    #endregion
   }
 }
+     
+