commit de618c90e3eb8f1c421bf2ba5eabbad26b1853db
author Jordan Halterman <jordan@opennetworking.org> Tue Feb 06 10:28:39 2018 -0800
committer Thomas Vachuska <tom@opennetworking.org> Tue Feb 06 18:52:56 2018 +0000
tree 397df17e345594c6c015d3b4873f420fe24362c3
parent af35f7a7605ff1f71178f38f5cb5e9491996f0b0

Log state transition events in DistributedClusterStore

Change-Id: I3710f70f9cf745e3b5349b8f146ae72d1f74942d

core/store/dist/src/main/java/org/onosproject/store/cluster/impl/DistributedClusterStore.java

diff --git a/core/store/dist/src/main/java/org/onosproject/store/cluster/impl/DistributedClusterStore.java b/core/store/dist/src/main/java/org/onosproject/store/cluster/impl/DistributedClusterStore.java
index af1cffe..c5fe9e8 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/cluster/impl/DistributedClusterStore.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/cluster/impl/DistributedClusterStore.java
@@ -236,7 +236,8 @@
 
     @Override
     public void markFullyStarted(boolean started) {
-        updateNode(localNode.id(), started ? State.READY : State.ACTIVE, null);
+        ControllerNode.State state = started ? State.READY : State.ACTIVE;
+        updateNode(localNode.id(), state, null);
     }
 
     @Override
@@ -269,6 +270,10 @@
         Version currentVersion = nodeVersions.get(nodeId);
         if (!Objects.equals(currentState, newState)
                 || (newVersion != null && !Objects.equals(currentVersion, newVersion))) {
+            if (localNode.id().equals(nodeId)) {
+                log.info("Local node state changed: {}", newState);
+            }
+            log.debug("Node {} state changed: {}", nodeId, newState);
             nodeStates.put(nodeId, newState);
             if (newVersion != null) {
                 nodeVersions.put(nodeId, newVersion);