X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FFollowerLogInformationImpl.java;h=91a5dddb981b3f7b09e9a79dd44fa0c09d4448a2;hb=ff957698c85aa1b57cdc6d7a8bca2c9dc96ba1ec;hp=9820638ab706ba0753da5ff1d574bc657da9b962;hpb=664c122de279729ca1a5e33f1b95606dab861ab7;p=controller.git 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 9820638ab7..91a5dddb98 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 @@ -9,10 +9,9 @@ package org.opendaylight.controller.cluster.raft; import com.google.common.base.Stopwatch; -import scala.concurrent.duration.FiniteDuration; - import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicLong; +import scala.concurrent.duration.FiniteDuration; public class FollowerLogInformationImpl implements FollowerLogInformation { @@ -35,6 +34,7 @@ public class FollowerLogInformationImpl implements FollowerLogInformation { this.followerTimeoutMillis = followerTimeoutDuration.toMillis(); } + @Override public long incrNextIndex(){ return nextIndex.incrementAndGet(); } @@ -49,6 +49,7 @@ public class FollowerLogInformationImpl implements FollowerLogInformation { this.nextIndex.set(nextIndex); } + @Override public long incrMatchIndex(){ return matchIndex.incrementAndGet(); } @@ -58,16 +59,19 @@ public class FollowerLogInformationImpl implements FollowerLogInformation { this.matchIndex.set(matchIndex); } + @Override public String getId() { return id; } - public AtomicLong getNextIndex() { - return nextIndex; + @Override + public long getNextIndex() { + return nextIndex.get(); } - public AtomicLong getMatchIndex() { - return matchIndex; + @Override + public long getMatchIndex() { + return matchIndex.get(); } @Override