Changeset 4092 for branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/Facades/ClientFacade.cs

Timestamp:

07/23/10 14:17:20 (14 years ago)

Author:

cneumuel

Message:

replaced transaction- and context management from Spring-advice by custom context management (see ContextFactory) (#1098)

File:

• branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/Facades/ClientFacade.cs (modified) (3 diffs)

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/Facades/ClientFacade.cs

@@ -33 +33 @@
 using HeuristicLab.Hive.Server.Core.InternalInterfaces;
 using System.Transactions;
+using HeuristicLab.Hive.Server.LINQDataAccess;
+using HeuristicLab.Hive.Server.DataAccess;
 
 namespace HeuristicLab.Hive.Server.Core {
-  [ServiceBehavior(InstanceContextMode =
-    InstanceContextMode.PerCall, ConcurrencyMode = ConcurrencyMode.Multiple)]
-  public class ClientFacade: IClientFacade {
+  [ServiceBehavior(InstanceContextMode = InstanceContextMode.PerCall, ConcurrencyMode = ConcurrencyMode.Multiple)]
+  public class ClientFacade : IClientFacade {
 
-    public ClientFacade() {      
+    public ClientFacade() {
     }
 
     private IClientCommunicator clientCommunicator = ServiceLocator.GetClientCommunicator();
 
+    private IContextFactory contextFactory = ServiceLocator.GetContextFactory();
+
     #region IClientCommunicator Members
 
     public Response Login(ClientDto clientInfo) {
-      return clientCommunicator.Login(clientInfo);
+      using (contextFactory.GetContext()) {
+        return clientCommunicator.Login(clientInfo);
+      }
     }
 
     public ResponseHB ProcessHeartBeat(HeartBeatData hbData) {
-      return clientCommunicator.ProcessHeartBeat(hbData);
+      using (contextFactory.GetContext()) {
+        return clientCommunicator.ProcessHeartBeat(hbData);
+      }
     }
 
     public ResponseJob SendJob(Guid clientId) {
-      return clientCommunicator.SendJob(clientId);
+      using (contextFactory.GetContext()) {
+        return clientCommunicator.SendJob(clientId);
+      }
     }
 
-    /*public ResponseSerializedJob SendSerializedJob(Guid clientId) {
-      return clientCommunicator.SendSerializedJob(clientId);
-    } */
-
-    public ResponseResultReceived StoreFinishedJobResult(Guid clientId,
-      Guid jobId,
-      byte[] result,
-      double percentage, 
-      Exception exception) {
-      return clientCommunicator.StoreFinishedJobResult(clientId, jobId, result, percentage, exception);
+    public ResponseResultReceived StoreFinishedJobResult(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception) {
+      using (contextFactory.GetContext()) {
+        return clientCommunicator.StoreFinishedJobResult(clientId, jobId, result, percentage, exception);
+      }
     }
 
     public Response Logout(Guid clientId) {
-      return clientCommunicator.Logout(clientId);
+      using (contextFactory.GetContext()) {
+        return clientCommunicator.Logout(clientId);
+      }
     }
 
     public Response IsJobStillNeeded(Guid jobId) {
-      return clientCommunicator.IsJobStillNeeded(jobId);
+      using (contextFactory.GetContext()) {
+        return clientCommunicator.IsJobStillNeeded(jobId); 
+      }
     }
 
     public ResponsePlugin SendPlugins(List<HivePluginInfoDto> pluginList) {
-      return clientCommunicator.SendPlugins(pluginList);
+      using (contextFactory.GetContext()) {
+        return clientCommunicator.SendPlugins(pluginList);      
+      }
     }
 
     public ResponseResultReceived ProcessSnapshot(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception) {
-      return clientCommunicator.ProcessSnapshot(clientId, jobId, result, percentage, exception);
+      using (contextFactory.GetContext()) {
+        return clientCommunicator.ProcessSnapshot(clientId, jobId, result, percentage, exception); 
+      }
     }
 
 
     public ResponseCalendar GetCalendar(Guid clientId) {
-      return clientCommunicator.GetCalendar(clientId);
+      using (contextFactory.GetContext()) {
+        return clientCommunicator.GetCalendar(clientId); 
+      }
     }
 
-    public Response SetCalendarStatus(Guid clientId, CalendarState state) {
-      return clientCommunicator.SetCalendarStatus(clientId, state);      
+    public Response SetCalendarStatus(Guid clientId, CalendarState state) { 
+      using (contextFactory.GetContext()) {
+        return clientCommunicator.SetCalendarStatus(clientId, state);
+      }
     }
     #endregion
@@ -98 +113 @@
     #region IClientFacade Members
 
-    [SpringTransaction(UserTransaction = true)]
+    /// <summary>
+    /// Do not use automatic transactions here
+    /// </summary>
     public Stream SendStreamedJob(Guid clientId) {
-      MultiStream stream = new MultiStream();
+      using (contextFactory.GetContext(false)) {
+        MultiStream stream = new MultiStream();
 
-      ResponseJob job = null;
+        ResponseJob job = null;
 
-      job = this.SendJob(clientId);      
+        job = this.SendJob(clientId);
 
-      //first send response
-      stream.AddStream(new StreamedObject<ResponseJob>(job));
+        //first send response
+        stream.AddStream(new StreamedObject<ResponseJob>(job));
 
-      IJobManager jobManager = ServiceLocator.GetJobManager();
-      IInternalJobManager internalJobManager = (IInternalJobManager) jobManager;
-      
-      //second stream the job binary data
-      MemoryStream memoryStream = new MemoryStream();      
-      if(job.Job != null)
-        stream.AddStream(new MemoryStream(internalJobManager.GetSerializedJobDataById(job.Job.Id)));
-      
-      OperationContext clientContext = OperationContext.Current;
+        IJobManager jobManager = ServiceLocator.GetJobManager();
+        IInternalJobManager internalJobManager = (IInternalJobManager)jobManager;
+
+        //second stream the job binary data
+        MemoryStream memoryStream = new MemoryStream();
+        if (job.Job != null)
+          stream.AddStream(new MemoryStream(internalJobManager.GetSerializedJobDataById(job.Job.Id)));
+
+        OperationContext clientContext = OperationContext.Current;
         clientContext.OperationCompleted += new EventHandler(delegate(object sender, EventArgs args) {
           if (stream != null) {
@@ -124 +142 @@
         });
 
-      return stream;
+        return stream;
+      }
     }
 
     public Stream SendStreamedPlugins(List<HivePluginInfoDto> pluginList) {
-      return new StreamedObject<ResponsePlugin>(this.SendPlugins(pluginList));
+      using (contextFactory.GetContext()) {
+        return new StreamedObject<ResponsePlugin>(this.SendPlugins(pluginList));
+      }
     }
 
     public ResponseResultReceived StoreFinishedJobResultStreamed(Stream stream) {
-      return ((IInternalClientCommunicator)clientCommunicator).ProcessJobResult(stream, true);
-    } 
+      using (contextFactory.GetContext()) {
+        return ((IInternalClientCommunicator)clientCommunicator).ProcessJobResult(stream, true);
+      }
+    }
 
     public ResponseResultReceived ProcessSnapshotStreamed(Stream stream) {
-      return ((IInternalClientCommunicator)clientCommunicator).ProcessJobResult(stream, false);
+      using (contextFactory.GetContext()) {
+        return ((IInternalClientCommunicator)clientCommunicator).ProcessJobResult(stream, false);  
+      }
     }
     #endregion