introduce a new exception for segment upload failures and handle inte…

…rrupted latch.await

Signed-off-by: Varun Bansal <[email protected]>

server/src/main/java/org/opensearch/index/shard/RemoteStoreRefreshListener.java

@@ -295,7 +295,7 @@ public void onFailure(Exception e) {
  remoteStoreSettings.getClusterRemoteSegmentTransferTimeout().millis(),
  TimeUnit.MILLISECONDS
  ) == false) {
- throw new InterruptedException("Timeout while waiting for remote segment transfer to complete");
+ throw new SegmentUploadFailedException("Timeout while waiting for remote segment transfer to complete");
  }
  } catch (EngineException e) {
  logger.warn("Exception while reading SegmentInfosSnapshot", e);

server/src/main/java/org/opensearch/index/shard/SegmentUploadFailedException.java

@@ -0,0 +1,18 @@
+/*
+ * SPDX-License-Identifier: Apache-2.0
+ *
+ * The OpenSearch Contributors require contributions made to
+ * this file be licensed under the Apache-2.0 license or a
+ * compatible open source license.
+ */
+
+package org.opensearch.index.shard;
+
+import java.io.IOException;
+
+public class SegmentUploadFailedException extends IOException {
+
+ public SegmentUploadFailedException(String message) {
+ super(message);
+ }
+}