Changeset 3870 for trunk/sources/HeuristicLab.Problems.ExternalEvaluation/3.3/Drivers

Timestamp:

05/30/10 18:58:01 (15 years ago)

Author:

abeham

Message:

#866

• Updated external evaluation problem

File:

• trunk/sources/HeuristicLab.Problems.ExternalEvaluation/3.3/Drivers/ExternalEvaluationStreamDriver.cs (modified) (4 diffs)

trunk/sources/HeuristicLab.Problems.ExternalEvaluation/3.3/Drivers/ExternalEvaluationStreamDriver.cs

@@ -33 +33 @@
     public override bool CanChangeDescription { get { return false; } }
 
-    private CodedInputStream inputStream;
     private Stream input;
-    private CodedOutputStream outputStream;
     private Stream output;
 
@@ -42 +40 @@
       : base() {
       if (!input.CanRead) throw new ArgumentException("Input stream cannot be read", "input");
-      this.inputStream = CodedInputStream.CreateInstance(input);
       this.input = input;
       if (!output.CanWrite) throw new ArgumentException("Output stream cannot be written", "output");
-      this.outputStream = CodedOutputStream.CreateInstance(output);
       this.output = output;
     }
@@ -51 +47 @@
     #region Overrides
     public override QualityMessage Evaluate(SolutionMessage solution) {
-      solution.WriteTo(outputStream);
-      outputStream.Flush();
-      output.Flush();
-      QualityMessage message = QualityMessage.ParseFrom(inputStream);
+      Send(solution);
+      QualityMessage message = QualityMessage.ParseDelimitedFrom(input);
       return message;
     }
 
     public override void EvaluateAsync(SolutionMessage solution, Action<QualityMessage> callback) {
-      solution.WriteTo(outputStream);
-      outputStream.Flush();
-      output.Flush();
+      Send(solution);
       System.Threading.ThreadPool.QueueUserWorkItem(new System.Threading.WaitCallback(ReceiveAsync), callback);
+    }
+
+    private void Send(SolutionMessage solution) {
+      lock (output) {
+        solution.WriteDelimitedTo(output);
+        output.Flush();
+      }
     }
 
     public override void Stop() {
       base.Stop();
-      inputStream = null;
       input.Close();
-      outputStream = null;
       output.Close();
     }
@@ -76 +73 @@
     private void ReceiveAsync(object callback) {
       QualityMessage message;
-      lock (inputStream) { // only one thread can read from the stream at one time
-        message = QualityMessage.ParseFrom(inputStream);
+      lock (input) { // only one thread can read from the stream at one time
+        message = QualityMessage.ParseDelimitedFrom(input);
       }
       ((Action<QualityMessage>)callback).Invoke(message);