From: Tom Pantelis Date: Fri, 20 Feb 2015 19:16:09 +0000 (+0000) Subject: Merge "BUG 2676 : Add diagnostic message when AppendEntriesReply comes in very late" X-Git-Tag: release/lithium~529 X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=commitdiff_plain;h=06950c3d3c05271bf1d08c137265deb77be7fa94;hp=10ba1f7eaed04dd07c1fb1a36090a1f67d1d411e;p=controller.git Merge "BUG 2676 : Add diagnostic message when AppendEntriesReply comes in very late" --- diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/AbstractLeader.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/AbstractLeader.java index b2bb127eab..66b8fba674 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/AbstractLeader.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/AbstractLeader.java @@ -171,6 +171,14 @@ public abstract class AbstractLeader extends AbstractRaftActorBehavior { return this; } + if(followerLogInformation.timeSinceLastActivity() > + context.getConfigParams().getElectionTimeOutInterval().toMillis()) { + LOG.error("{} : handleAppendEntriesReply delayed beyond election timeout, " + + "appendEntriesReply : {}, timeSinceLastActivity : {}, lastApplied : {}, commitIndex : {}", + logName(), appendEntriesReply, followerLogInformation.timeSinceLastActivity(), + context.getLastApplied(), context.getCommitIndex()); + } + followerLogInformation.markFollowerActive(); if (appendEntriesReply.isSuccess()) {