Changeset 704 for trunk/sources/HeuristicLab.Communication.Operators/DataStreamFinisher.cs

Timestamp:

10/29/08 16:01:41 (16 years ago)

Author:

abeham

Message:

[TICKET #297] communication restructuring

File:

• trunk/sources/HeuristicLab.Communication.Operators/DataStreamFinisher.cs (modified) (1 diff)

trunk/sources/HeuristicLab.Communication.Operators/DataStreamFinisher.cs

@@ -42 +42 @@
       IDataStream datastream = GetVariableValue<IDataStream>("DataStream", scope, true);
 
+      datastream.Write("REQUEST_CLOSE");
+      string response = datastream.Read();
+      if (!response.Equals("REQUEST_CLOSE")) throw new InvalidOperationException("ERROR in DataStreamFinisher: Closing connection was denied");
+      datastream.Write("ACK");
+      response = datastream.Read();
+      if (!response.Equals("ACK")) throw new InvalidOperationException("ERROR in DataStreamFinisher: Closing connection was denied");
       datastream.Close();