getMaxSeqNo withEngine

Author: kingherc

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

@@ -1386,7 +1386,7 @@ public CommitStats commitStats() {
      * @throws AlreadyClosedException if shard is closed
      */
     public SeqNoStats seqNoStats() {
-        return getEngine().getSeqNoStats(replicationTracker.getGlobalCheckpoint());
+        return withEngine(engine -> engine.getSeqNoStats(replicationTracker.getGlobalCheckpoint()));
     }
 
     public IndexingStats indexingStats() {
@@ -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 = withEngine(engine -> engine.getSeqNoStats(replicationTracker.getGlobalCheckpoint()));
         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() {