Fallback to netty client if AWS Crt client is not available on the target platform / architecture (opensearch-project#20698)

Signed-off-by: Andriy Redko <drreta@gmail.com>
Signed-off-by: Ankit Jain <jainankitk@apache.org>

Author: reta

CHANGELOG.md

@@ -33,6 +33,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 - Leveraging segment-global ordinal mapping for efficient terms aggregation ([#20624](https://github.com/opensearch-project/OpenSearch/pull/20624))
 - Support Docker distribution builds for ppc64le, arm64 and s390x ([#20678](https://github.com/opensearch-project/OpenSearch/pull/20678))
 - Harden detection of HTTP/3 support by ensuring Quic native libraries are available for the target platform ([#20680](https://github.com/opensearch-project/OpenSearch/pull/20680))
+- Fallback to netty client if AWS Crt client is not available on the target platform / architecture ([#20698](https://github.com/opensearch-project/OpenSearch/pull/20698))
 - Fix ShardSearchFailure in transport-grpc ([#20641](https://github.com/opensearch-project/OpenSearch/pull/20641))
 
 ### Dependencies

plugins/repository-s3/src/main/java/org/opensearch/repositories/s3/S3AsyncService.java

@@ -49,6 +49,7 @@
 import org.opensearch.repositories.s3.S3ClientSettings.IrsaCredentials;
 import org.opensearch.repositories.s3.async.AsyncExecutorContainer;
 import org.opensearch.repositories.s3.async.AsyncTransferEventLoopGroup;
+import org.opensearch.repositories.s3.utils.AwsCrtUtils;
 import org.opensearch.secure_sm.AccessController;
 
 import java.io.Closeable;
@@ -335,7 +336,16 @@ static SdkAsyncHttpClient buildHttpClient(
         if (S3Repository.NETTY_ASYNC_HTTP_CLIENT_TYPE.equals(asyncHttpClientType)) {
             return buildAsyncNettyHttpClient(clientSettings, asyncTransferEventLoopGroup);
         }
-        return buildAsyncCrtHttpClient(clientSettings);
+        if (AwsCrtUtils.isAwsCrtAvailable() == true) {
+            return buildAsyncCrtHttpClient(clientSettings);
+        } else {
+            logger.warn(
+                "AWS CRT client is not available on the target platform, falling back to "
+                    + S3Repository.NETTY_ASYNC_HTTP_CLIENT_TYPE
+                    + " client type"
+            );
+            return buildAsyncNettyHttpClient(clientSettings, asyncTransferEventLoopGroup);
+        }
     }
 
     static SdkAsyncHttpClient buildAsyncNettyHttpClient(

plugins/repository-s3/src/main/java/org/opensearch/repositories/s3/utils/AwsCrtUtils.java

@@ -0,0 +1,44 @@
+/*
+ * 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.repositories.s3.utils;
+
+import software.amazon.awssdk.crt.CRT;
+import software.amazon.awssdk.crt.CRT.UnknownPlatformException;
+
+/**
+ * An utility class to check if AWS CRT client is available on the current platform and architecture.
+ */
+public final class AwsCrtUtils {
+    static final boolean isAwsCrtAvailable;
+
+    static {
+        boolean crtAvailable;
+        try {
+            final String archIdentifier = CRT.getArchIdentifier();
+            crtAvailable = (archIdentifier != null && archIdentifier.isBlank() == false);
+        } catch (ExceptionInInitializerError | UnknownPlatformException ex) {
+            crtAvailable = false;
+        }
+        // CRT native libraries are not available on some platforms
+        isAwsCrtAvailable = crtAvailable;
+    }
+
+    private AwsCrtUtils() {
+
+    }
+
+    /**
+     * Check if AWS CRT client is available on the current platform and architecture.
+     *
+     * @return true if AWS CRT client is available
+     */
+    public static boolean isAwsCrtAvailable() {
+        return isAwsCrtAvailable;
+    }
+}

plugins/repository-s3/src/test/java/org/opensearch/repositories/s3/S3AsyncServiceTests.java

@@ -18,6 +18,7 @@
 import org.opensearch.common.settings.Settings;
 import org.opensearch.repositories.s3.async.AsyncExecutorContainer;
 import org.opensearch.repositories.s3.async.AsyncTransferEventLoopGroup;
+import org.opensearch.repositories.s3.utils.AwsCrtUtils;
 import org.opensearch.secure_sm.AccessController;
 import org.opensearch.test.OpenSearchTestCase;
 import org.junit.Before;
@@ -29,6 +30,8 @@
 
 import io.netty.channel.nio.NioEventLoopGroup;
 
+import static org.hamcrest.CoreMatchers.equalTo;
+import static org.junit.Assume.assumeThat;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
@@ -173,6 +176,8 @@ public void testBuildHttpClientWithNetty() {
     }
 
     public void testBuildHttpClientWithCRT() {
+        assumeThat("AWS CRT client is not available on the target platform", AwsCrtUtils.isAwsCrtAvailable(), equalTo(true));
+
         final int port = randomIntBetween(10, 1080);
         final String userName = randomAlphaOfLength(10);
         final String password = randomAlphaOfLength(10);