chore: add check for DtKV.get()

dtprj · Jun 21, 2024 · 94a9778 · 94a9778
1 parent 3fc81d7
commit 94a9778
Showing 1 changed file with 2 additions and 0 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
@@ -127,6 +127,8 @@ private Object exec0(long index, RaftInput input, KvStatus kvStatus) {
      * @see com.github.dtprj.dongting.raft.server.RaftGroup#getLeaseReadIndex(DtTime)
      */
     public byte[] get(long index, String key) {
+        KvStatus kvStatus = this.kvStatus;
+        ensureRunning(kvStatus);
         return kvStatus.kvImpl.get(index, key);
     }