finish

Signed-off-by: OneSizeFitQuorum <[email protected]>
apache · Jan 10, 2025 · 68ff863 · 68ff863
1 parent bdde3ae
commit 68ff863
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 0 deletions.
diff --git a/ratis-server-api/src/main/java/org/apache/ratis/server/DivisionInfo.java b/ratis-server-api/src/main/java/org/apache/ratis/server/DivisionInfo.java
@@ -80,4 +80,10 @@ default boolean isAlive() {
    *         otherwise, return null.
    */
   long[] getFollowerNextIndices();
+
+  /**
+   * @return an array of match indices of the followers if this server division is the leader;
+   *         otherwise, return null.
+   */
+  long[] getFollowerMatchIndices();
 }
diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderStateImpl.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderStateImpl.java
@@ -1214,6 +1214,10 @@ long[] getFollowerNextIndices() {
     return getLogAppenders().mapToLong(s -> s.getFollower().getNextIndex()).toArray();
   }
 
+  long[] getFollowerMatchIndices() {
+    return getLogAppenders().mapToLong(s -> s.getFollower().getMatchIndex()).toArray();
+  }
+
   static Map<RaftPeerId, RaftPeer> newMap(Collection<RaftPeer> peers, String str) {
     Objects.requireNonNull(peers, () -> str + " == null");
     final Map<RaftPeerId, RaftPeer> map = new HashMap<>();

diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java
@@ -206,6 +206,14 @@ public long[] getFollowerNextIndices() {
           .map(LeaderStateImpl::getFollowerNextIndices)
           .orElse(null);
     }
+
+    @Override
+    public long[] getFollowerMatchIndices() {
+      return role.getLeaderState()
+          .filter(leader -> isLeader())
+          .map(LeaderStateImpl::getFollowerMatchIndices)
+          .orElse(null);
+    }
   }
 
   private final RaftServerProxy proxy;