X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fconnect%2Fnetconf%2Flistener%2FNetconfDeviceCommunicator.java;h=257cd464a996ebc4efd906dceb6fae8db3800da3;hb=07797c1f8e35731ca7dce1d4524f669a171b731e;hp=ce5aa79af0f85c44dc0beaa68650597f4974213a;hpb=d8d8f731bbe6c58fcbd0e616734e2e230aaf4ab4;p=controller.git diff --git a/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/listener/NetconfDeviceCommunicator.java b/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/listener/NetconfDeviceCommunicator.java index ce5aa79af0..257cd464a9 100644 --- a/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/listener/NetconfDeviceCommunicator.java +++ b/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/listener/NetconfDeviceCommunicator.java @@ -110,7 +110,7 @@ public class NetconfDeviceCommunicator implements NetconfClientSessionListener, @Override public void operationComplete(Future future) throws Exception { - if (!future.isSuccess()) { + if (!future.isSuccess() && !future.isCancelled()) { logger.debug("{}: Connection failed", id, future.cause()); NetconfDeviceCommunicator.this.remoteDevice.onRemoteSessionFailed(future.cause()); } @@ -197,9 +197,8 @@ public class NetconfDeviceCommunicator implements NetconfClientSessionListener, // Disconnect from device if(session != null) { session.close(); + // tear down not necessary, called indirectly by above close } - - tearDown(id + ": Netconf session closed"); } @Override @@ -325,10 +324,8 @@ public class NetconfDeviceCommunicator implements NetconfClientSessionListener, } private void processNotification(final NetconfMessage notification) { - logger.debug("{}: Notification received: {}", id, notification); - if(logger.isTraceEnabled()) { - logger.trace("{}: Notification received: {}", id, msgToS(notification)); + logger.trace("{}: Notification received: {}", id, notification); } remoteDevice.onNotification(notification);