Renamed urgent write method

Signed-off-by: Shivansh Arora <[email protected]>
shiv0408 · Oct 23, 2023 · fc95922 · fc95922
1 parent 1311929
commit fc95922
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/server/src/main/java/org/opensearch/gateway/remote/RemoteClusterStateService.java b/server/src/main/java/org/opensearch/gateway/remote/RemoteClusterStateService.java
@@ -357,7 +357,7 @@ private String writeGlobalMetadata(ClusterState clusterState) throws IOException
             result.set(globalMetadataContainer.path().buildAsString() + globalMetadataFilename);
         }, ex -> { throw new GlobalMetadataTransferException(ex.getMessage(), ex); }), latch);
 
-        GLOBAL_METADATA_FORMAT.urgentWriteAsync(
+        GLOBAL_METADATA_FORMAT.writeAsyncWithUrgentPriority(
             clusterState.metadata(),
             globalMetadataContainer,
             globalMetadataFilename,
@@ -489,7 +489,7 @@ private void writeIndexMetadataAsync(
             ex -> latchedActionListener.onFailure(new IndexMetadataTransferException(indexMetadata.getIndex().toString(), ex))
         );
 
-        INDEX_METADATA_FORMAT.urgentWriteAsync(
+        INDEX_METADATA_FORMAT.writeAsyncWithUrgentPriority(
             indexMetadata,
             indexMetadataContainer,
             indexMetadataFilename,

diff --git a/server/src/main/java/org/opensearch/repositories/blobstore/ChecksumBlobStoreFormat.java b/server/src/main/java/org/opensearch/repositories/blobstore/ChecksumBlobStoreFormat.java
@@ -218,7 +218,7 @@ public void writeAsync(
      * Use {@link #writeAsync(ToXContent, BlobContainer, String, Compressor, ActionListener, ToXContent.Params)} for
      * other use cases.
      */
-    public void urgentWriteAsync(
+    public void writeAsyncWithUrgentPriority(
         final T obj,
         final BlobContainer blobContainer,
         final String name,

diff --git a/server/src/test/java/org/opensearch/snapshots/BlobStoreFormatTests.java b/server/src/test/java/org/opensearch/snapshots/BlobStoreFormatTests.java
@@ -187,7 +187,7 @@ public void testBlobStorePriorityAsyncOperation() throws IOException, Interrupte
         CountDownLatch latch = new CountDownLatch(1);
 
         // Write blobs in different formats
-        checksumSMILE.urgentWriteAsync(
+        checksumSMILE.writeAsyncWithUrgentPriority(
             new BlobObj("cluster state diff"),
             spyContainer,
             "cluster-state-diff",