Add MXBean to report shard registered DTCL/DCL info

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

diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/client/messages/OnDemandRaftState.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/client/messages/OnDemandRaftState.java
index 9bbee881ea4afa3b1b99a772f96c228d9b8246c2..d9298f95686162691329b61d88aadbf007cf7337 100644 (file)
--- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/client/messages/OnDemandRaftState.java
+++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/client/messages/OnDemandRaftState.java
@@ -133,126 +133,127 @@ public class OnDemandRaftState {
         return customRaftPolicyClassName;
     }
 
         return customRaftPolicyClassName;
     }
 

-    public abstract static class AbstractBuilder<T extends AbstractBuilder<T>> {
+    public abstract static class AbstractBuilder<B extends AbstractBuilder<B, T>, T extends OnDemandRaftState> {

         @SuppressWarnings("unchecked")
         @SuppressWarnings("unchecked")

-        protected T self() {
-            return (T) this;
+        protected B self() {
+            return (B) this;

         }
 
         @Nonnull
         protected abstract OnDemandRaftState state();
 
         }
 
         @Nonnull
         protected abstract OnDemandRaftState state();
 

-        public T lastLogIndex(long value) {
+        public B lastLogIndex(long value) {

             state().lastLogIndex = value;
             return self();
         }
 
             state().lastLogIndex = value;
             return self();
         }
 

-        public T lastLogTerm(long value) {
+        public B lastLogTerm(long value) {

             state().lastLogTerm = value;
             return self();
         }
 
             state().lastLogTerm = value;
             return self();
         }
 

-        public T currentTerm(long value) {
+        public B currentTerm(long value) {

             state().currentTerm = value;
             return self();
         }
 
             state().currentTerm = value;
             return self();
         }
 

-        public T commitIndex(long value) {
+        public B commitIndex(long value) {

             state().commitIndex = value;
             return self();
         }
 
             state().commitIndex = value;
             return self();
         }
 

-        public T lastApplied(long value) {
+        public B lastApplied(long value) {

             state().lastApplied = value;
             return self();
         }
 
             state().lastApplied = value;
             return self();
         }
 

-        public T lastIndex(long value) {
+        public B lastIndex(long value) {

             state().lastIndex = value;
             return self();
         }
 
             state().lastIndex = value;
             return self();
         }
 

-        public T lastTerm(long value) {
+        public B lastTerm(long value) {

             state().lastTerm = value;
             return self();
         }
 
             state().lastTerm = value;
             return self();
         }
 

-        public T snapshotIndex(long value) {
+        public B snapshotIndex(long value) {

             state().snapshotIndex = value;
             return self();
         }
 
             state().snapshotIndex = value;
             return self();
         }
 

-        public T snapshotTerm(long value) {
+        public B snapshotTerm(long value) {

             state().snapshotTerm = value;
             return self();
         }
 
             state().snapshotTerm = value;
             return self();
         }
 

-        public T replicatedToAllIndex(long value) {
+        public B replicatedToAllIndex(long value) {

             state().replicatedToAllIndex = value;
             return self();
         }
 
             state().replicatedToAllIndex = value;
             return self();
         }
 

-        public T inMemoryJournalDataSize(long value) {
+        public B inMemoryJournalDataSize(long value) {

             state().inMemoryJournalDataSize = value;
             return self();
         }
 
             state().inMemoryJournalDataSize = value;
             return self();
         }
 

-        public T inMemoryJournalLogSize(long value) {
+        public B inMemoryJournalLogSize(long value) {

             state().inMemoryJournalLogSize = value;
             return self();
         }
 
             state().inMemoryJournalLogSize = value;
             return self();
         }
 

-        public T leader(String value) {
+        public B leader(String value) {

             state().leader = value;
             return self();
         }
 
             state().leader = value;
             return self();
         }
 

-        public T raftState(String value) {
+        public B raftState(String value) {

             state().raftState = value;
             return self();
         }
 
             state().raftState = value;
             return self();
         }
 

-        public T votedFor(String value) {
+        public B votedFor(String value) {

             state().votedFor = value;
             return self();
         }
 
             state().votedFor = value;
             return self();
         }
 

-        public T isVoting(boolean isVoting) {
+        public B isVoting(boolean isVoting) {

             state().isVoting = isVoting;
             return self();
         }
 
             state().isVoting = isVoting;
             return self();
         }
 

-        public T followerInfoList(List<FollowerInfo> followerInfoList) {
+        public B followerInfoList(List<FollowerInfo> followerInfoList) {

             state().followerInfoList = followerInfoList;
             return self();
         }
 
             state().followerInfoList = followerInfoList;
             return self();
         }
 

-        public T peerAddresses(Map<String, String> peerAddresses) {
+        public B peerAddresses(Map<String, String> peerAddresses) {

             state().peerAddresses = peerAddresses;
             return self();
         }
 
             state().peerAddresses = peerAddresses;
             return self();
         }
 

-        public T peerVotingStates(Map<String, Boolean> peerVotingStates) {
+        public B peerVotingStates(Map<String, Boolean> peerVotingStates) {

             state().peerVotingStates = ImmutableMap.copyOf(peerVotingStates);
             return self();
         }
 
             state().peerVotingStates = ImmutableMap.copyOf(peerVotingStates);
             return self();
         }
 

-        public T isSnapshotCaptureInitiated(boolean value) {
+        public B isSnapshotCaptureInitiated(boolean value) {

             state().isSnapshotCaptureInitiated = value;
             return self();
         }
 
             state().isSnapshotCaptureInitiated = value;
             return self();
         }
 

-        public T customRaftPolicyClassName(String className) {
+        public B customRaftPolicyClassName(String className) {

             state().customRaftPolicyClassName = className;
             return self();
         }
 
             state().customRaftPolicyClassName = className;
             return self();
         }
 

-        public OnDemandRaftState build() {
-            return state();
+        @SuppressWarnings("unchecked")
+        public T build() {
+            return (T) state();

         }
     }
 
         }
     }
 

-    public static class Builder extends AbstractBuilder<Builder> {
+    public static class Builder extends AbstractBuilder<Builder, OnDemandRaftState> {

         private final OnDemandRaftState state = new OnDemandRaftState();
 
         @Override
         private final OnDemandRaftState state = new OnDemandRaftState();
 
         @Override