X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FFollowerLogInformationImpl.java;h=883bfbb4e4184f0cbf0843002dfa3498ca13f622;hp=1c8d5e6e10647bcbac9ad7f55dd247e6f51f94c6;hb=f782b6b1af793cafc89bda53cbb940dd71bc25ba;hpb=9491b06df9419e58db3089a4c5cd9f5407cb9aac diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/FollowerLogInformationImpl.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/FollowerLogInformationImpl.java index 1c8d5e6e10..883bfbb4e4 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/FollowerLogInformationImpl.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/FollowerLogInformationImpl.java @@ -11,7 +11,16 @@ package org.opendaylight.controller.cluster.raft; import com.google.common.base.Preconditions; import com.google.common.base.Stopwatch; import java.util.concurrent.TimeUnit; +import javax.annotation.Nonnull; +import javax.annotation.Nullable; +import org.opendaylight.controller.cluster.raft.behaviors.LeaderInstallSnapshotState; +/** + * Implementation of the FollowerLogInformation interface. + * + * @author Moiz Raja + * @author Thomas Pantelis + */ public class FollowerLogInformationImpl implements FollowerLogInformation { private final Stopwatch stopwatch = Stopwatch.createUnstarted(); @@ -27,8 +36,23 @@ public class FollowerLogInformationImpl implements FollowerLogInformation { private short payloadVersion = -1; + // Assume the HELIUM_VERSION version initially for backwards compatibility until we obtain the follower's + // actual version via AppendEntriesReply. Although we no longer support the Helium version, a pre-Boron + // follower will not have the version field in AppendEntriesReply so it will be set to 0 which is + // HELIUM_VERSION. + private short raftVersion = RaftVersions.HELIUM_VERSION; + private final PeerInfo peerInfo; + private LeaderInstallSnapshotState installSnapshotState; + + /** + * Constructs an instance. + * + * @param peerInfo the associated PeerInfo of the follower. + * @param matchIndex the initial match index. + * @param context the RaftActorContext. + */ public FollowerLogInformationImpl(PeerInfo peerInfo, long matchIndex, RaftActorContext context) { this.nextIndex = context.getCommitIndex(); this.matchIndex = matchIndex; @@ -42,13 +66,18 @@ public class FollowerLogInformationImpl implements FollowerLogInformation { } @Override - public long decrNextIndex() { - return nextIndex--; + public boolean decrNextIndex() { + if (nextIndex >= 0) { + nextIndex--; + return true; + } + + return false; } @Override public boolean setNextIndex(long nextIndex) { - if(this.nextIndex != nextIndex) { + if (this.nextIndex != nextIndex) { this.nextIndex = nextIndex; return true; } @@ -57,13 +86,13 @@ public class FollowerLogInformationImpl implements FollowerLogInformation { } @Override - public long incrMatchIndex(){ + public long incrMatchIndex() { return matchIndex++; } @Override public boolean setMatchIndex(long matchIndex) { - if(this.matchIndex != matchIndex) { + if (this.matchIndex != matchIndex) { this.matchIndex = matchIndex; return true; } @@ -88,13 +117,13 @@ public class FollowerLogInformationImpl implements FollowerLogInformation { @Override public boolean isFollowerActive() { - if(peerInfo.getVotingState() == VotingState.VOTING_NOT_INITIALIZED) { + if (peerInfo.getVotingState() == VotingState.VOTING_NOT_INITIALIZED) { return false; } long elapsed = stopwatch.elapsed(TimeUnit.MILLISECONDS); - return (stopwatch.isRunning()) && - (elapsed <= context.getConfigParams().getElectionTimeOutInterval().toMillis()); + return stopwatch.isRunning() + && elapsed <= context.getConfigParams().getElectionTimeOutInterval().toMillis(); } @Override @@ -119,25 +148,23 @@ public class FollowerLogInformationImpl implements FollowerLogInformation { @Override public boolean okToReplicate() { - if(peerInfo.getVotingState() == VotingState.VOTING_NOT_INITIALIZED) { + if (peerInfo.getVotingState() == VotingState.VOTING_NOT_INITIALIZED) { return false; } // Return false if we are trying to send duplicate data before the heartbeat interval - if(getNextIndex() == lastReplicatedIndex){ - if(lastReplicatedStopwatch.elapsed(TimeUnit.MILLISECONDS) < context.getConfigParams() - .getHeartBeatInterval().toMillis()){ - return false; - } + if (getNextIndex() == lastReplicatedIndex && lastReplicatedStopwatch.elapsed(TimeUnit.MILLISECONDS) + < context.getConfigParams().getHeartBeatInterval().toMillis()) { + return false; } resetLastReplicated(); return true; } - private void resetLastReplicated(){ + private void resetLastReplicated() { lastReplicatedIndex = getNextIndex(); - if(lastReplicatedStopwatch.isRunning()){ + if (lastReplicatedStopwatch.isRunning()) { lastReplicatedStopwatch.reset(); } lastReplicatedStopwatch.start(); @@ -153,6 +180,36 @@ public class FollowerLogInformationImpl implements FollowerLogInformation { this.payloadVersion = payloadVersion; } + @Override + public short getRaftVersion() { + return raftVersion; + } + + @Override + public void setRaftVersion(short raftVersion) { + this.raftVersion = raftVersion; + } + + @Override + @Nullable + public LeaderInstallSnapshotState getInstallSnapshotState() { + return installSnapshotState; + } + + @Override + public void setLeaderInstallSnapshotState(@Nonnull LeaderInstallSnapshotState state) { + if (this.installSnapshotState == null) { + this.installSnapshotState = Preconditions.checkNotNull(state); + } + } + + @Override + public void clearLeaderInstallSnapshotState() { + Preconditions.checkState(installSnapshotState != null); + installSnapshotState.close(); + installSnapshotState = null; + } + @Override public String toString() { return "FollowerLogInformationImpl [id=" + getId() + ", nextIndex=" + nextIndex + ", matchIndex=" + matchIndex