BUG 1815 - Do not allow Shards to be created till an appropriate schema context is...

[controller.git] / opendaylight / md-sal / sal-akka-raft / src / main / java / org / opendaylight / controller / cluster / raft / RaftActor.java

diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActor.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActor.java
index 6e1a13cf0c19669443b9273e1d2703a3ff2dede9..0a4e2170e527e0dd74cae73802ae7893eba436be 100644 (file)
--- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActor.java
+++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActor.java
@@ -148,14 +148,18 @@ public abstract class RaftActor extends UntypedPersistentActor {
 
         } else if (message instanceof ReplicatedLogEntry) {
             ReplicatedLogEntry logEntry = (ReplicatedLogEntry) message;
 
         } else if (message instanceof ReplicatedLogEntry) {
             ReplicatedLogEntry logEntry = (ReplicatedLogEntry) message;

-            LOG.info("Received ReplicatedLogEntry for recovery:{}", logEntry.getIndex());
+            if(LOG.isDebugEnabled()) {
+                LOG.debug("Received ReplicatedLogEntry for recovery:{}", logEntry.getIndex());
+            }

             replicatedLog.append(logEntry);
 
         } else if (message instanceof ApplyLogEntries) {
             ApplyLogEntries ale = (ApplyLogEntries) message;
 
             replicatedLog.append(logEntry);
 
         } else if (message instanceof ApplyLogEntries) {
             ApplyLogEntries ale = (ApplyLogEntries) message;
 

-            LOG.info("Received ApplyLogEntries for recovery, applying to state:{} to {}",
-                context.getLastApplied() + 1, ale.getToIndex());
+            if(LOG.isDebugEnabled()) {
+                LOG.debug("Received ApplyLogEntries for recovery, applying to state:{} to {}",
+                    context.getLastApplied() + 1, ale.getToIndex());
+            }

 
             for (long i = context.getLastApplied() + 1; i <= ale.getToIndex(); i++) {
                 applyState(null, "recovery", replicatedLog.get(i).getData());
 
             for (long i = context.getLastApplied() + 1; i <= ale.getToIndex(); i++) {
                 applyState(null, "recovery", replicatedLog.get(i).getData());


@@ -198,7 +202,9 @@ public abstract class RaftActor extends UntypedPersistentActor {
 
         } else if (message instanceof ApplyLogEntries){
             ApplyLogEntries ale = (ApplyLogEntries) message;
 
         } else if (message instanceof ApplyLogEntries){
             ApplyLogEntries ale = (ApplyLogEntries) message;

-            LOG.info("Persisting ApplyLogEntries with index={}", ale.getToIndex());
+            if(LOG.isDebugEnabled()) {
+                LOG.debug("Persisting ApplyLogEntries with index={}", ale.getToIndex());
+            }

             persist(new ApplyLogEntries(ale.getToIndex()), new Procedure<ApplyLogEntries>() {
                 @Override
                 public void apply(ApplyLogEntries param) throws Exception {
             persist(new ApplyLogEntries(ale.getToIndex()), new Procedure<ApplyLogEntries>() {
                 @Override
                 public void apply(ApplyLogEntries param) throws Exception {