feedback

Author: tlrx

server/src/main/java/org/elasticsearch/index/shard/IndexShard.java

@@ -3061,7 +3061,7 @@ public void maybeSyncGlobalCheckpoint(final String reason) {
         }
         assert assertPrimaryMode();
         // only sync if there are no operations in flight, or when using async durability
-        final SeqNoStats stats = getEngine().getSeqNoStats(replicationTracker.getGlobalCheckpoint());
+        final SeqNoStats stats = seqNoStats();
         final boolean asyncDurability = indexSettings().getTranslogDurability() == Translog.Durability.ASYNC;
         if (stats.getMaxSeqNo() == stats.getGlobalCheckpoint() || asyncDurability) {
             final var trackedGlobalCheckpointsNeedSync = replicationTracker.trackedGlobalCheckpointsNeedSync();

server/src/main/java/org/elasticsearch/index/shard/LocalShardSnapshot.java

@@ -40,7 +40,7 @@ Index getIndex() {
     }
 
     long maxSeqNo() {
-        return shard.getEngine().getSeqNoStats(-1).getMaxSeqNo();
+        return shard.withEngine(engine -> engine.getSeqNoStats(-1)).getMaxSeqNo();
     }
 
     long maxUnsafeAutoIdTimestamp() {