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
