Rename AsyncLucenePersistedState to AsyncPersistedState (#73652)

This class actually has nothing to do with Lucene. This commit adjusts the name
to match.

Author: DaveCTurner

server/src/main/java/org/elasticsearch/gateway/GatewayMetaState.java

@@ -122,7 +122,7 @@ public void start(Settings settings, TransportService transportService, ClusterS
                     if (DiscoveryNode.isMasterNode(settings)) {
                         persistedState = new LucenePersistedState(persistedClusterStateService, currentTerm, clusterState);
                     } else {
-                        persistedState = new AsyncLucenePersistedState(settings, transportService.getThreadPool(),
+                        persistedState = new AsyncPersistedState(settings, transportService.getThreadPool(),
                             new LucenePersistedState(persistedClusterStateService, currentTerm, clusterState));
                     }
                     if (DiscoveryNode.canContainData(settings)) {
@@ -244,16 +244,16 @@ public void close() throws IOException {
     // visible for testing
     public boolean allPendingAsyncStatesWritten() {
         final PersistedState ps = persistedState.get();
-        if (ps instanceof AsyncLucenePersistedState) {
-            return ((AsyncLucenePersistedState) ps).allPendingAsyncStatesWritten();
+        if (ps instanceof AsyncPersistedState) {
+            return ((AsyncPersistedState) ps).allPendingAsyncStatesWritten();
         } else {
             return true;
         }
     }
 
-    static class AsyncLucenePersistedState extends InMemoryPersistedState {
+    static class AsyncPersistedState extends InMemoryPersistedState {
 
-        private static final Logger logger = LogManager.getLogger(AsyncLucenePersistedState.class);
+        private static final Logger logger = LogManager.getLogger(AsyncPersistedState.class);
 
         static final String THREAD_NAME = "AsyncLucenePersistedState#updateTask";
 
@@ -265,7 +265,7 @@ static class AsyncLucenePersistedState extends InMemoryPersistedState {
 
         private final Object mutex = new Object();
 
-        AsyncLucenePersistedState(Settings settings, ThreadPool threadPool, PersistedState persistedState) {
+        AsyncPersistedState(Settings settings, ThreadPool threadPool, PersistedState persistedState) {
             super(persistedState.getCurrentTerm(), persistedState.getLastAcceptedState());
             final String nodeName = Objects.requireNonNull(Node.NODE_NAME_SETTING.get(settings));
             threadPoolExecutor = EsExecutors.newFixed(

server/src/test/java/org/elasticsearch/gateway/GatewayMetaStatePersistedStateTests.java

@@ -352,7 +352,7 @@ public void testDataOnlyNodePersistence() throws Exception {
             gateway.start(settings, transportService, clusterService,
                 new MetaStateService(nodeEnvironment, xContentRegistry()), null, null, persistedClusterStateService);
             final CoordinationState.PersistedState persistedState = gateway.getPersistedState();
-            assertThat(persistedState, instanceOf(GatewayMetaState.AsyncLucenePersistedState.class));
+            assertThat(persistedState, instanceOf(GatewayMetaState.AsyncPersistedState.class));
 
             //generate random coordinationMetadata with different lastAcceptedConfiguration and lastCommittedConfiguration
             CoordinationMetadata coordinationMetadata;
@@ -372,9 +372,9 @@ public void testDataOnlyNodePersistence() throws Exception {
             CoordinationMetadata persistedCoordinationMetadata =
                 persistedClusterStateService.loadOnDiskState().metadata.coordinationMetadata();
             assertThat(persistedCoordinationMetadata.getLastAcceptedConfiguration(),
-                equalTo(GatewayMetaState.AsyncLucenePersistedState.staleStateConfiguration));
+                equalTo(GatewayMetaState.AsyncPersistedState.staleStateConfiguration));
             assertThat(persistedCoordinationMetadata.getLastCommittedConfiguration(),
-                equalTo(GatewayMetaState.AsyncLucenePersistedState.staleStateConfiguration));
+                equalTo(GatewayMetaState.AsyncPersistedState.staleStateConfiguration));
 
             persistedState.markLastAcceptedStateAsCommitted();
             assertBusy(() -> assertTrue(gateway.allPendingAsyncStatesWritten()));
@@ -388,9 +388,9 @@ public void testDataOnlyNodePersistence() throws Exception {
             assertClusterStateEqual(expectedClusterState, persistedState.getLastAcceptedState());
             persistedCoordinationMetadata = persistedClusterStateService.loadOnDiskState().metadata.coordinationMetadata();
             assertThat(persistedCoordinationMetadata.getLastAcceptedConfiguration(),
-                equalTo(GatewayMetaState.AsyncLucenePersistedState.staleStateConfiguration));
+                equalTo(GatewayMetaState.AsyncPersistedState.staleStateConfiguration));
             assertThat(persistedCoordinationMetadata.getLastCommittedConfiguration(),
-                equalTo(GatewayMetaState.AsyncLucenePersistedState.staleStateConfiguration));
+                equalTo(GatewayMetaState.AsyncPersistedState.staleStateConfiguration));
             assertTrue(persistedClusterStateService.loadOnDiskState().metadata.clusterUUIDCommitted());
 
             // generate a series of updates and check if batching works
@@ -421,7 +421,7 @@ public void testDataOnlyNodePersistence() throws Exception {
 
             try (CoordinationState.PersistedState reloadedPersistedState = newGatewayPersistedState()) {
                 assertEquals(currentTerm, reloadedPersistedState.getCurrentTerm());
-                assertClusterStateEqual(GatewayMetaState.AsyncLucenePersistedState.resetVotingConfiguration(state),
+                assertClusterStateEqual(GatewayMetaState.AsyncPersistedState.resetVotingConfiguration(state),
                     reloadedPersistedState.getLastAcceptedState());
                 assertNotNull(reloadedPersistedState.getLastAcceptedState().metadata().index(indexName));
             }