Changeset 1939 for trunk/sources/HeuristicLab.Hive.Server.Core/3.2

Timestamp:

05/28/09 18:38:46 (15 years ago)

Author:

svonolfe

Message:

Large amounts of data are now transferred streamed (fixed ticket #660)

Location:

trunk/sources/HeuristicLab.Hive.Server.Core/3.2

Files:

• ClientCommunicator.cs (modified) (1 diff)
• ClientFacade.cs (modified) (2 diffs)

trunk/sources/HeuristicLab.Hive.Server.Core/3.2/ClientCommunicator.cs

@@ -451 +451 @@
         JobResult jobResult =
           new JobResult();
-        jobResult.Client = client;
-        jobResult.Job = job;
+        jobResult.ClientId = client.Id;
+        jobResult.JobId = job.Id;
         jobResult.Result = result;
         jobResult.Percentage = percentage;

trunk/sources/HeuristicLab.Hive.Server.Core/3.2/ClientFacade.cs

@@ -28 +28 @@
 using HeuristicLab.Hive.Contracts;
 using HeuristicLab.PluginInfrastructure;
+using System.IO;
+using System.Runtime.Serialization.Formatters.Binary;
 
 namespace HeuristicLab.Hive.Server.Core {
@@ -74 +76 @@
 
     #endregion
+
+    #region IClientFacade Members
+
+    public Stream SendStreamedJob(Guid clientId) {
+      return
+        new StreamedObject<ResponseJob>(
+          this.SendJob(clientId));
+    }
+
+    public Stream SendStreamedPlugins(List<HivePluginInfo> pluginList) {
+      return
+        new StreamedObject<ResponsePlugin>(
+          this.SendPlugins(pluginList));
+    }
+
+    public ResponseResultReceived StoreFinishedJobResultStreamed(Stream stream) {
+      BinaryFormatter formatter =
+          new BinaryFormatter();
+      JobResult result = (JobResult)formatter.Deserialize(stream);
+
+      return this.StoreFinishedJobResult(
+          result.ClientId,
+          result.JobId,
+          result.Result,
+          result.Percentage,
+          result.Exception);
+    } 
+
+    public ResponseResultReceived ProcessSnapshotStreamed(Stream stream) {
+      BinaryFormatter formatter =
+          new BinaryFormatter();
+      JobResult result = (JobResult)formatter.Deserialize(stream);
+
+      return this.ProcessSnapshot(
+          result.ClientId,
+          result.JobId,
+          result.Result,
+          result.Percentage,
+          result.Exception);
+    }
+
+    #endregion
   }
 }