sruehl commented on a change in pull request #10: Fixed NPE in 
S7PlcConnection#close.
URL: https://github.com/apache/incubator-plc4x/pull/10#discussion_r207145613
 
 

 ##########
 File path: 
plc4j/protocols/s7/src/main/java/org/apache/plc4x/java/s7/connection/S7PlcConnection.java
 ##########
 @@ -183,14 +194,19 @@ public void close() {
                 (short) 0x0000, (short) 0x000F, DisconnectReason.NORMAL, 
Collections.emptyList(),
                 null);
             ChannelFuture sendDisconnectRequestFuture = 
channel.writeAndFlush(disconnectRequest);
-            sendDisconnectRequestFuture.addListener((ChannelFutureListener) 
future -> {
-                // Close the session itself.
-                channel.closeFuture().await();
+            // Wait if the PLC closes the connection
+            try {
+                // TODO 02.08.18 jf: Do we have global constants for things 
like timeouts?
+                channel.closeFuture().await(1_000);
+            } catch (InterruptedException e) {
+                logger.warn("Connection was not closed by PLC, has to be 
closed from driver side now.", e);
 
 Review comment:
   Here we should add a `Thread.currentThread().interrupt();` after the 
logging. (Sonar would tell you this later anyway ;)

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services

Reply via email to