1 // Copyright 2024 The gRPC Authors
2 //
3 // Licensed under the Apache License, Version 2.0 (the "License");
4 // you may not use this file except in compliance with the License.
5 // You may obtain a copy of the License at
6 //
7 // http://www.apache.org/licenses/LICENSE-2.0
8 //
9 // Unless required by applicable law or agreed to in writing, software
10 // distributed under the License is distributed on an "AS IS" BASIS,
11 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 // See the License for the specific language governing permissions and
13 // limitations under the License.
14 #include <grpc/support/port_platform.h>
15
16 #ifdef GPR_WINDOWS
17 #include <grpc/event_engine/event_engine.h>
18 #include <inttypes.h>
19 #include <string.h>
20 #include <sys/types.h>
21
22 #include <string>
23
24 #include "absl/strings/str_cat.h"
25 #include "absl/strings/str_format.h"
26 #include "src/core/lib/event_engine/windows/native_windows_dns_resolver.h"
27 #include "src/core/lib/iomgr/error.h"
28 #include "src/core/util/host_port.h"
29 #include "src/core/util/status_helper.h"
30
31 namespace grpc_event_engine {
32 namespace experimental {
33
34 namespace {
35 absl::StatusOr<std::vector<EventEngine::ResolvedAddress>>
LookupHostnameBlocking(absl::string_view name,absl::string_view default_port)36 LookupHostnameBlocking(absl::string_view name, absl::string_view default_port) {
37 std::vector<EventEngine::ResolvedAddress> addresses;
38 // parse name, splitting it into host and port parts
39 std::string host;
40 std::string port;
41 grpc_core::SplitHostPort(name, &host, &port);
42 if (host.empty()) {
43 return absl::InvalidArgumentError(absl::StrCat("Unparsable name: ", name));
44 }
45 if (port.empty()) {
46 if (default_port.empty()) {
47 return absl::InvalidArgumentError(
48 absl::StrFormat("No port in name %s or default_port argument", name));
49 }
50 port = std::string(default_port);
51 }
52 // Call getaddrinfo
53 struct addrinfo hints;
54 memset(&hints, 0, sizeof(hints));
55 hints.ai_family = AF_UNSPEC; // ipv4 or ipv6
56 hints.ai_socktype = SOCK_STREAM; // stream socket
57 hints.ai_flags = AI_PASSIVE; // for wildcard IP address
58 struct addrinfo* result = nullptr;
59 int getaddrinfo_error =
60 getaddrinfo(host.c_str(), port.c_str(), &hints, &result);
61 if (getaddrinfo_error != 0) {
62 return absl::UnknownError(
63 absl::StrFormat("Address lookup failed for %s os_error: %s", name,
64 grpc_core::StatusToString(
65 GRPC_WSA_ERROR(WSAGetLastError(), "getaddrinfo"))
66 .c_str()));
67 }
68 // Success path: collect and return all addresses
69 for (auto* resp = result; resp != nullptr; resp = resp->ai_next) {
70 addresses.emplace_back(resp->ai_addr, resp->ai_addrlen);
71 }
72 if (result) freeaddrinfo(result);
73 return addresses;
74 }
75
76 } // namespace
NativeWindowsDNSResolver(std::shared_ptr<EventEngine> event_engine)77 NativeWindowsDNSResolver::NativeWindowsDNSResolver(
78 std::shared_ptr<EventEngine> event_engine)
79 : event_engine_(std::move(event_engine)) {}
80
LookupHostname(EventEngine::DNSResolver::LookupHostnameCallback on_resolved,absl::string_view name,absl::string_view default_port)81 void NativeWindowsDNSResolver::LookupHostname(
82 EventEngine::DNSResolver::LookupHostnameCallback on_resolved,
83 absl::string_view name, absl::string_view default_port) {
84 event_engine_->Run(
85 [name, default_port, on_resolved = std::move(on_resolved)]() mutable {
86 on_resolved(LookupHostnameBlocking(name, default_port));
87 });
88 }
89
LookupSRV(EventEngine::DNSResolver::LookupSRVCallback on_resolved,absl::string_view)90 void NativeWindowsDNSResolver::LookupSRV(
91 EventEngine::DNSResolver::LookupSRVCallback on_resolved,
92 absl::string_view /* name */) {
93 // Not supported
94 event_engine_->Run([on_resolved = std::move(on_resolved)]() mutable {
95 on_resolved(absl::UnimplementedError(
96 "The Native resolver does not support looking up SRV records"));
97 });
98 }
99
LookupTXT(EventEngine::DNSResolver::LookupTXTCallback on_resolved,absl::string_view)100 void NativeWindowsDNSResolver::LookupTXT(
101 EventEngine::DNSResolver::LookupTXTCallback on_resolved,
102 absl::string_view /* name */) {
103 // Not supported
104 event_engine_->Run([on_resolved = std::move(on_resolved)]() mutable {
105 on_resolved(absl::UnimplementedError(
106 "The Native resolver does not support looking up TXT records"));
107 });
108 }
109
110 } // namespace experimental
111 } // namespace grpc_event_engine
112
113 #endif // GPR_WINDOWS
114