commit cf527d1c7a793720b4c3c73985d53108a7c3abaa
author xueliang <xue.liang.fujitsu@gmail.com> Mon Nov 07 14:31:06 2016 +0900
committer Gerrit Code Review <gerrit@onlab.us> Tue Nov 08 20:05:32 2016 +0000
tree 823284b37e13c441a4a3abaf3c86fef44ef89988
parent d41e225de6094e2a90c06bcbf10ddab3bac6f9c9

[ONOS-5598] Alarm Consumer for Fujitsu OLT

Change-Id: I3206307f6adcc078d9b0a1aa26d6de6ad00f9824

protocols/netconf/ctl/src/main/java/org/onosproject/netconf/ctl/NetconfStreamThread.java

diff --git a/protocols/netconf/ctl/src/main/java/org/onosproject/netconf/ctl/NetconfStreamThread.java b/protocols/netconf/ctl/src/main/java/org/onosproject/netconf/ctl/NetconfStreamThread.java
index 64e7210..184a074 100644
--- a/protocols/netconf/ctl/src/main/java/org/onosproject/netconf/ctl/NetconfStreamThread.java
+++ b/protocols/netconf/ctl/src/main/java/org/onosproject/netconf/ctl/NetconfStreamThread.java
@@ -173,6 +173,7 @@
                         netconfDeviceEventListeners.forEach(
                                 listener -> listener.event(event));
                         socketClosed = true;
+                        log.debug("Netconf device {} ERROR cInt == -1 socketClosed = true", netconfDeviceInfo);
                     }
                     char c = (char) cInt;
                     state = state.evaluateChar(c);
@@ -181,6 +182,8 @@
                         String deviceReply = deviceReplyBuilder.toString();
                         if (deviceReply.equals(END_PATTERN)) {
                             socketClosed = true;
+                            log.debug("Netconf device {} socketClosed = true DEVICE_UNREGISTERED {}",
+                                     netconfDeviceInfo, deviceReply);
                             NetconfDeviceOutputEvent event = new NetconfDeviceOutputEvent(
                                     NetconfDeviceOutputEvent.Type.DEVICE_UNREGISTERED,
                                     null, null, Optional.of(-1), netconfDeviceInfo);
@@ -192,6 +195,8 @@
                             if (deviceReply.contains(RPC_REPLY) ||
                                     deviceReply.contains(RPC_ERROR) ||
                                     deviceReply.contains(HELLO)) {
+                                log.debug("Netconf device {} sessionDelegate.notify() DEVICE_REPLY {} {}",
+                                    netconfDeviceInfo, getMsgId(deviceReply), deviceReply);
                                 NetconfDeviceOutputEvent event = new NetconfDeviceOutputEvent(
                                         NetconfDeviceOutputEvent.Type.DEVICE_REPLY,
                                         null, deviceReply, getMsgId(deviceReply), netconfDeviceInfo);
@@ -199,6 +204,9 @@
                                 netconfDeviceEventListeners.forEach(
                                         listener -> listener.event(event));
                             } else if (deviceReply.contains(NOTIFICATION_LABEL)) {
+                                log.debug("Netconf device {} DEVICE_NOTIFICATION {} {} {}",
+                                         netconfDeviceInfo, enableNotifications,
+                                         getMsgId(deviceReply), deviceReply);
                                 if (enableNotifications) {
                                     final String finalDeviceReply = deviceReply;
                                     netconfDeviceEventListeners.forEach(
@@ -208,7 +216,7 @@
                                                     netconfDeviceInfo)));
                                 }
                             } else {
-                                log.info("Error on replay from device {} ", deviceReply);
+                                log.debug("Error on reply from device {} {}", netconfDeviceInfo, deviceReply);
                             }
                             deviceReplyBuilder.setLength(0);
                         }