follower ignore read operation. (#798)

sofastack · Mar 25, 2022 · 08b5348 · 08b5348
1 parent a77c4d0
commit 08b5348
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/jraft-rheakv/rheakv-core/src/main/java/com/alipay/sofa/jraft/rhea/storage/KVOperation.java b/jraft-rheakv/rheakv-core/src/main/java/com/alipay/sofa/jraft/rhea/storage/KVOperation.java
@@ -286,6 +286,11 @@ public byte getOp() {
         return op;
     }
 
+    public boolean isReadOp() {
+        return GET == this.op || MULTI_GET == this.op || SCAN == this.op || CONTAINS_KEY == this.op
+               || REVERSE_SCAN == this.op;
+    }
+
     public int getStep() {
         return (Integer) this.attach;
     }

diff --git a/...akv/rheakv-core/src/main/java/com/alipay/sofa/jraft/rhea/storage/KVStoreStateMachine.java b/...akv/rheakv-core/src/main/java/com/alipay/sofa/jraft/rhea/storage/KVStoreStateMachine.java
@@ -97,6 +97,12 @@ public void onApply(final Iterator it) {
                         } else {
                             kvOp = this.serializer.readObject(buf, KVOperation.class);
                         }
+                        // follower ignore read operation
+                        if (kvOp != null && kvOp.isReadOp()) {
+                            ++index;
+                            it.next();
+                            continue;
+                        }
                     } catch (final Throwable t) {
                         ++index;
                         throw new StoreCodecException("Decode operation error", t);