Changeset 4119 for branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Client.Communication/3.3/WcfService.cs

Timestamp:

07/28/10 17:48:10 (14 years ago)

Author:

cneumuel

Message:

HiveExperiment is now able to send IOptimizers of an Experiment and receive the calculated result (#1115)

File:

• branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Client.Communication/3.3/WcfService.cs (modified) (9 diffs)

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Client.Communication/3.3/WcfService.cs

@@ -262 +262 @@
         Logger.Debug("STARTED: Sending back the finished job results");
         Logger.Debug("Building stream");
-        Stream stream =
-          GetStreamedJobResult(clientId, jobId, result, percentage, exception);
+        Stream stream = GetStreamedJobResult(clientId, jobId, result, percentage, exception);
         Logger.Debug("Builded stream");
         Logger.Debug("Making the call");
@@ -269 +268 @@
       }
     }
+
     private void proxy_StoreFinishedJobResultStreamedCompleted(object sender, StoreFinishedJobResultStreamedCompletedEventArgs e) {
       Logger.Debug("Finished storing the job");
-      Stream stream =
-        (Stream)e.UserState;
+      Stream stream = (Stream)e.UserState;
       if (stream != null) {
         Logger.Debug("Stream not null, disposing it");
@@ -278 +277 @@
       }
       if (e.Error == null) {
-        StoreFinishedJobResultCompletedEventArgs args =
-          new StoreFinishedJobResultCompletedEventArgs(
-            new object[] { e.Result }, e.Error, e.Cancelled, e.UserState);
+        StoreFinishedJobResultCompletedEventArgs args = new StoreFinishedJobResultCompletedEventArgs(new object[] { e.Result }, e.Error, e.Cancelled, e.UserState);
         Logger.Debug("calling the Finished Job Event");
         StoreFinishedJobResultCompleted(sender, args);
         Logger.Debug("ENDED: Sending back the finished job results");
-      } else
+      } else {
         HandleNetworkError(e.Error);
+      }
     }
 
@@ -300 +298 @@
       }
     }
+
     void proxy_ProcessSnapshotStreamedCompleted(object sender, ProcessSnapshotStreamedCompletedEventArgs e) {
       Stream stream =
@@ -350 +349 @@
     /// </summary>
     private Stream GetStreamedJobResult(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception) {
-      JobResult jobResult =
-          new JobResult();
+      JobResult jobResult = new JobResult();
       jobResult.ClientId = clientId;
       jobResult.JobId = jobId;
@@ -357 +355 @@
       jobResult.Exception = exception;
 
-      MultiStream stream =
-              new MultiStream();
+      MultiStream stream = new MultiStream();
 
       //first send result
-      stream.AddStream(
-        new StreamedObject<JobResult>(jobResult));
+      stream.AddStream(new StreamedObject<JobResult>(jobResult));
 
       //second stream the job binary data
-      MemoryStream memStream =
-        new MemoryStream(result, false);
+      MemoryStream memStream = new MemoryStream(result, false);
       stream.AddStream(memStream);
 
@@ -373 +368 @@
 
     public ResponseResultReceived StoreFinishedJobResultsSync(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception, bool finished) {
-      return proxy.StoreFinishedJobResultStreamed(
-        GetStreamedJobResult(clientId, jobId, result, percentage, exception));
+      return proxy.StoreFinishedJobResultStreamed(GetStreamedJobResult(clientId, jobId, result, percentage, exception));
     }
 
@@ -387 +381 @@
         return null;
       }
-
     }
 
     public ResponseResultReceived ProcessSnapshotSync(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception) {
       try {
-        return proxy.ProcessSnapshotStreamed(
-          GetStreamedJobResult(clientId, jobId, result, percentage, exception));
+        return proxy.ProcessSnapshotStreamed(GetStreamedJobResult(clientId, jobId, result, percentage, exception));
       } catch (Exception e) {
         HandleNetworkError(e);
@@ -453 +445 @@
       }
     }
-
   }
 }