NameResolutionPal.Unix enabled async name resolution

src/libraries/Common/src/Interop/Unix/System.Native/Interop.HostEntry.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Runtime.InteropServices;
 
 internal static partial class Interop
@@ -33,9 +32,17 @@ internal unsafe struct HostEntry
             internal int IPAddressCount;       // Number of IP addresses in the list
         }
 
+        internal unsafe delegate void GetHostEntryForNameCallback(HostEntry* entry, int status);
+
+        [DllImport(Libraries.SystemNative, EntryPoint = "SystemNative_PlatformSupportsGetAddrInfoAsync")]
+        internal static extern bool PlatformSupportsGetAddrInfoAsync();
+
         [DllImport(Libraries.SystemNative, EntryPoint = "SystemNative_GetHostEntryForName")]
         internal static extern unsafe int GetHostEntryForName(string address, HostEntry* entry);
 
+        [DllImport(Libraries.SystemNative, EntryPoint = "SystemNative_GetHostEntryForNameAsync")]
+        internal static extern unsafe int GetHostEntryForNameAsync(string address, HostEntry* entry, GetHostEntryForNameCallback callback);
+
         [DllImport(Libraries.SystemNative, EntryPoint = "SystemNative_FreeHostEntry")]
         internal static extern unsafe void FreeHostEntry(HostEntry* entry);
     }

src/libraries/Native/Unix/Common/pal_config.h.in

@@ -9,6 +9,7 @@
 #cmakedefine01 HAVE_F_DUPFD_CLOEXEC
 #cmakedefine01 HAVE_O_CLOEXEC
 #cmakedefine01 HAVE_GETIFADDRS
+#cmakedefine01 HAVE_GETADDRINFO_A
 #cmakedefine01 HAVE_UTSNAME_DOMAINNAME
 #cmakedefine01 HAVE_STAT64
 #cmakedefine01 HAVE_VFORK

src/libraries/Native/Unix/System.Native/CMakeLists.txt

@@ -62,6 +62,10 @@ if (GEN_SHARED_LIB)
     endif ()
     endif ()
     install_with_stripped_symbols (System.Native PROGRAMS .)
+
+    if (HAVE_GETADDRINFO_A)
+        target_link_libraries(System.Native anl)
+    endif ()
 endif ()
 
 add_library(System.Native-Static

src/libraries/Native/Unix/System.Native/pal_networking.c

@@ -56,6 +56,10 @@
 #if HAVE_LINUX_CAN_H
 #include <linux/can.h>
 #endif
+#if HAVE_GETADDRINFO_A
+#include <stdatomic.h>
+#include <signal.h>
+#endif
 #if HAVE_KQUEUE
 #if KEVENT_HAS_VOID_UDATA
 static void* GetKeventUdata(uintptr_t udata)
@@ -253,32 +257,14 @@ static int32_t CopySockAddrToIPAddress(sockaddr* addr, sa_family_t family, IPAdd
     return -1;
 }
 
-int32_t SystemNative_GetHostEntryForName(const uint8_t* address, HostEntry* entry)
+static int32_t GetHostEntries(const uint8_t* address, struct addrinfo* info, HostEntry* entry)
 {
-    if (address == NULL || entry == NULL)
-    {
-        return GetAddrInfoErrorFlags_EAI_BADARG;
-    }
-
     int32_t ret = GetAddrInfoErrorFlags_EAI_SUCCESS;
 
-    struct addrinfo* info = NULL;
 #if HAVE_GETIFADDRS
     struct ifaddrs* addrs = NULL;
 #endif
 
-    // Get all address families and the canonical name
-    struct addrinfo hint;
-    memset(&hint, 0, sizeof(struct addrinfo));
-    hint.ai_family = AF_UNSPEC;
-    hint.ai_flags = AI_CANONNAME;
-
-    int result = getaddrinfo((const char*)address, NULL, &hint, &info);
-    if (result != 0)
-    {
-        return ConvertGetAddrInfoAndGetNameInfoErrorsToPal(result);
-    }
-
     entry->CanonicalName = NULL;
     entry->Aliases = NULL;
     entry->IPAddressList = NULL;
@@ -306,7 +292,8 @@ int32_t SystemNative_GetHostEntryForName(const uint8_t* address, HostEntry* entr
 
 #if HAVE_GETIFADDRS
     char name[_POSIX_HOST_NAME_MAX];
-    result = gethostname((char*)name, _POSIX_HOST_NAME_MAX);
+
+    int result = gethostname((char*)name, _POSIX_HOST_NAME_MAX);
 
     bool includeIPv4Loopback = true;
     bool includeIPv6Loopback = true;
@@ -356,6 +343,8 @@ int32_t SystemNative_GetHostEntryForName(const uint8_t* address, HostEntry* entr
             }
         }
     }
+#else
+    (void)address;
 #endif
 
     if (entry->IPAddressCount > 0)
@@ -432,12 +421,144 @@ int32_t SystemNative_GetHostEntryForName(const uint8_t* address, HostEntry* entr
     return ret;
 }
 
+#if HAVE_GETADDRINFO_A
+struct GetAddrInfoAsyncState
+{
+    struct gaicb gai_request;
+    struct gaicb* gai_requests;
+    struct sigevent sigevent;
+
+    uint8_t* address;
+    HostEntry* entry;
+    GetHostEntryForNameCallback callback;
+};
+
+static void GetHostEntryForNameAsyncComplete(sigval_t context)
+{
+    struct GetAddrInfoAsyncState* state = (struct GetAddrInfoAsyncState*)context.sival_ptr;
+
+    atomic_thread_fence(memory_order_acquire);
+
+    GetHostEntryForNameCallback callback = state->callback;
+
+    int ret = ConvertGetAddrInfoAndGetNameInfoErrorsToPal(gai_error(&state->gai_request));
+
+    if (ret == 0)
+    {
+        const uint8_t* address = state->address;
+        struct addrinfo* info = state->gai_request.ar_result;
+
+        ret = GetHostEntries(address, info, state->entry);
+    }
+
+    if (callback != NULL)
+    {
+        callback(state->entry, ret);
+    }
+
+    free(state->address);
+    free(state);
+}
+#endif
+
+int32_t SystemNative_PlatformSupportsGetAddrInfoAsync()
+{
+    return HAVE_GETADDRINFO_A;
+}
+
+// Get all address families and the canonical name
+static const struct addrinfo s_hostEntryForNameHints = {.ai_family = AF_UNSPEC, .ai_flags = AI_CANONNAME};
+
+int32_t SystemNative_GetHostEntryForName(const uint8_t* address, HostEntry* entry)
+{
+    if (address == NULL || entry == NULL)
+    {
+        return GetAddrInfoErrorFlags_EAI_BADARG;
+    }
+
+    struct addrinfo* info = NULL;
+
+    int result = getaddrinfo((const char*)address, NULL, &s_hostEntryForNameHints, &info);
+    if (result != 0)
+    {
+        return ConvertGetAddrInfoAndGetNameInfoErrorsToPal(result);
+    }
+
+    return GetHostEntries(address, info, entry);
+}
+
+int32_t SystemNative_GetHostEntryForNameAsync(const uint8_t* address, HostEntry* entry, GetHostEntryForNameCallback callback)
+{
+#if HAVE_GETADDRINFO_A
+    if (address == NULL)
+    {
+        return GetAddrInfoErrorFlags_EAI_BADARG;
+    }
+
+    struct GetAddrInfoAsyncState* state = malloc(sizeof(*state));
+
+    if (state == NULL)
+    {
+        return GetAddrInfoErrorFlags_EAI_MEMORY;
+    }
+
+    char* localAddress = strdup((const char*)address);
+
+    *state = (struct GetAddrInfoAsyncState) {
+        .gai_request = {
+            .ar_name = localAddress,
+            .ar_service = NULL,
+            .ar_request = &s_hostEntryForNameHints,
+            .ar_result = NULL
+        },
+        .gai_requests = &state->gai_request,
+        .sigevent = {
+            .sigev_notify = SIGEV_THREAD,
+            .sigev_value = {
+                .sival_ptr = state
+            },
+            .sigev_notify_function = GetHostEntryForNameAsyncComplete
+        },
+        .address = (uint8_t*)localAddress,
+        .entry = entry,
+        .callback = callback
+    };
+
+    atomic_thread_fence(memory_order_release);
+
+    int32_t result = getaddrinfo_a(GAI_NOWAIT, &state->gai_requests, 1, &state->sigevent);
+
+    if (result != 0)
+    {
+        free(localAddress);
+        free(state);
+        return ConvertGetAddrInfoAndGetNameInfoErrorsToPal(result);
+    }
+
+    return result;
+#else
+    (void)address;
+    (void)entry;
+    (void)callback;
+
+    // GetHostEntryForNameAsync is not supported on this platform.
+    return -1;
+#endif
+}
+
 void SystemNative_FreeHostEntry(HostEntry* entry)
 {
     if (entry != NULL)
     {
-        free(entry->CanonicalName);
-        free(entry->IPAddressList);
+        if (entry->CanonicalName != NULL)
+        {
+            free(entry->CanonicalName);
+        }
+
+        if (entry->IPAddressList != NULL)
+        {
+            free(entry->IPAddressList);
+        }
 
         entry->CanonicalName = NULL;
         entry->IPAddressList = NULL;
@@ -468,13 +589,13 @@ static inline NativeFlagsType ConvertGetNameInfoFlagsToNative(int32_t flags)
 }
 
 int32_t SystemNative_GetNameInfo(const uint8_t* address,
-                               int32_t addressLength,
-                               int8_t isIPv6,
-                               uint8_t* host,
-                               int32_t hostLength,
-                               uint8_t* service,
-                               int32_t serviceLength,
-                               int32_t flags)
+                                 int32_t addressLength,
+                                 int8_t isIPv6,
+                                 uint8_t* host,
+                                 int32_t hostLength,
+                                 uint8_t* service,
+                                 int32_t serviceLength,
+                                 int32_t flags)
 {
     assert(address != NULL);
     assert(addressLength > 0);

src/libraries/Native/Unix/System.Native/pal_networking.h

@@ -310,10 +310,14 @@ typedef struct
     uint32_t Padding;    // Pad out to 8-byte alignment
 } SocketEvent;
 
+PALEXPORT int32_t SystemNative_PlatformSupportsGetAddrInfoAsync(void);
+
 PALEXPORT int32_t SystemNative_GetHostEntryForName(const uint8_t* address, HostEntry* entry);
 
-PALEXPORT void SystemNative_FreeHostEntry(HostEntry* entry);
+typedef void (*GetHostEntryForNameCallback)(HostEntry* entry, int status);
+PALEXPORT int32_t SystemNative_GetHostEntryForNameAsync(const uint8_t* address, HostEntry* entry, GetHostEntryForNameCallback callback);
 
+PALEXPORT void SystemNative_FreeHostEntry(HostEntry* entry);
 
 PALEXPORT int32_t SystemNative_GetNameInfo(const uint8_t* address,
                                int32_t addressLength,

src/libraries/Native/Unix/configure.cmake

@@ -6,7 +6,7 @@ include(CheckPrototypeDefinition)
 include(CheckStructHasMember)
 include(CheckSymbolExists)
 include(CheckTypeSize)
-
+include(CMakePushCheckState)
 
 if (CLR_CMAKE_TARGET_ANDROID)
     set(PAL_UNIX_NAME \"ANDROID\")
@@ -822,6 +822,19 @@ check_symbol_exists(
     HAVE_INOTIFY_RM_WATCH)
 set (CMAKE_REQUIRED_LIBRARIES ${PREVIOUS_CMAKE_REQUIRED_LIBRARIES})
 
+if (CLR_CMAKE_TARGET_LINUX)
+    cmake_push_check_state(RESET)
+    set (CMAKE_REQUIRED_DEFINITIONS "-D_GNU_SOURCE")
+    set (CMAKE_REQUIRED_LIBRARIES "-lanl")
+
+    check_symbol_exists(
+        getaddrinfo_a
+        netdb.h
+        HAVE_GETADDRINFO_A)
+
+    cmake_pop_check_state()
+endif ()
+
 set (HAVE_INOTIFY 0)
 if (HAVE_INOTIFY_INIT AND HAVE_INOTIFY_ADD_WATCH AND HAVE_INOTIFY_RM_WATCH)
     set (HAVE_INOTIFY 1)

src/libraries/System.Net.NameResolution/src/System/Net/Dns.cs

@@ -490,7 +490,7 @@ private static void ValidateHostName(string hostName)
             const int MaxHostName = 255;
 
             if (hostName.Length > MaxHostName ||
-                (hostName.Length == MaxHostName && hostName[MaxHostName - 1] != '.')) // If 255 chars, the last one must be a dot.
+               (hostName.Length == MaxHostName && hostName[MaxHostName - 1] != '.')) // If 255 chars, the last one must be a dot.
             {
                 throw new ArgumentOutOfRangeException(nameof(hostName),
                     SR.Format(SR.net_toolong, nameof(hostName), MaxHostName.ToString(NumberFormatInfo.CurrentInfo)));