chore: remove term from StateMachine.exec()

dtprj · Jun 20, 2024 · 974d772 · 974d772
1 parent d2dfc4e
commit 974d772
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/server/src/main/java/com/github/dtprj/dongting/dtkv/server/DtKV.java b/server/src/main/java/com/github/dtprj/dongting/dtkv/server/DtKV.java
@@ -69,7 +69,7 @@ public Decoder<? extends Encodable> createBodyDecoder(int bizType) {
     }
 
     @Override
-    public FiberFuture<Object> exec(long index, int term, RaftInput input) {
+    public FiberFuture<Object> exec(long index, RaftInput input) {
         KvStatus kvStatus = this.kvStatus;
         ensureRunning(kvStatus);
         StrEncoder key = (StrEncoder) input.getHeader();

diff --git a/server/src/main/java/com/github/dtprj/dongting/raft/impl/ApplyManager.java b/server/src/main/java/com/github/dtprj/dongting/raft/impl/ApplyManager.java
@@ -141,7 +141,7 @@ private FrameCallResult exec(RaftTask rt, long index, FrameCall<Void> resumePoin
                     FiberFuture<Object> f = null;
                     Throwable execEx = null;
                     try {
-                        f = stateMachine.exec(index, rt.getItem().getTerm(), input);
+                        f = stateMachine.exec(index, input);
                         execCount++;
                     } catch (Throwable e) {
                         execEx = e;

diff --git a/server/src/main/java/com/github/dtprj/dongting/raft/sm/StateMachine.java b/server/src/main/java/com/github/dtprj/dongting/raft/sm/StateMachine.java
@@ -31,7 +31,7 @@ public interface StateMachine extends LifeCircle, RaftCodecFactory {
     /**
      * this method is called in raft thread.
      */
-    FiberFuture<Object> exec(long index, int term, RaftInput input);
+    FiberFuture<Object> exec(long index, RaftInput input);
 
     /**
      * this method is called in raft thread.