|
|
|
|
@ -23,16 +23,10 @@ |
|
|
|
|
|
|
|
|
|
#include <ares.h> |
|
|
|
|
|
|
|
|
|
#include "absl/strings/str_cat.h" |
|
|
|
|
#include "absl/types/optional.h" |
|
|
|
|
|
|
|
|
|
#include "src/core/ext/filters/client_channel/resolver/dns/c_ares/grpc_ares_ev_driver.h" |
|
|
|
|
#include "src/core/ext/filters/client_channel/server_address.h" |
|
|
|
|
#include "src/core/lib/gprpp/orphanable.h" |
|
|
|
|
#include "src/core/lib/iomgr/iomgr.h" |
|
|
|
|
#include "src/core/lib/iomgr/polling_entity.h" |
|
|
|
|
#include "src/core/lib/iomgr/resolve_address.h" |
|
|
|
|
#include "src/core/lib/iomgr/timer.h" |
|
|
|
|
#include "src/core/lib/iomgr/work_serializer.h" |
|
|
|
|
|
|
|
|
|
#define GRPC_DNS_ARES_DEFAULT_QUERY_TIMEOUT_MS 120000 |
|
|
|
|
@ -48,284 +42,61 @@ extern grpc_core::TraceFlag grpc_trace_cares_resolver; |
|
|
|
|
} \
|
|
|
|
|
} while (0) |
|
|
|
|
|
|
|
|
|
namespace grpc_core { |
|
|
|
|
|
|
|
|
|
/// An AresRequest is a handle over a complete name resolution process
|
|
|
|
|
/// (A queries, AAAA queries, etc.). An AresRequest is created with a call
|
|
|
|
|
/// to LookupAresLocked, and the name resolution process begins when
|
|
|
|
|
/// it's created. The name resolution process can be terminated abruptly
|
|
|
|
|
/// by invoking \a Orphan. The \a interested_parties parameter must remain
|
|
|
|
|
/// alive until either the \a Orphan is invoked, or \a on_done is called,
|
|
|
|
|
/// whichever happens first.
|
|
|
|
|
class AresRequest final : public InternallyRefCounted<AresRequest> { |
|
|
|
|
public: |
|
|
|
|
static OrphanablePtr<AresRequest> Create( |
|
|
|
|
absl::string_view dns_server, absl::string_view name, |
|
|
|
|
absl::string_view default_port, grpc_pollset_set* interested_parties, |
|
|
|
|
std::function<void(grpc_error*)> on_done, |
|
|
|
|
std::unique_ptr<grpc_core::ServerAddressList>* addrs, |
|
|
|
|
std::unique_ptr<grpc_core::ServerAddressList>* balancer_addrs, |
|
|
|
|
absl::optional<std::string>* service_config_json, int query_timeout_ms, |
|
|
|
|
std::shared_ptr<grpc_core::WorkSerializer> work_serializer); |
|
|
|
|
|
|
|
|
|
/// Callers should only create an AresRequest via \a LookupAresLocked, this
|
|
|
|
|
/// ctor is made public only to help the factory method.
|
|
|
|
|
AresRequest( |
|
|
|
|
std::unique_ptr<grpc_core::ServerAddressList>* addresses_out, |
|
|
|
|
std::unique_ptr<grpc_core::ServerAddressList>* balancer_addresses_out, |
|
|
|
|
absl::optional<std::string>* service_config_json_out, |
|
|
|
|
grpc_pollset_set* pollset_set, int query_timeout_ms, |
|
|
|
|
std::function<void(grpc_error*)> on_done, |
|
|
|
|
std::shared_ptr<grpc_core::WorkSerializer> work_serializer); |
|
|
|
|
|
|
|
|
|
~AresRequest() final; |
|
|
|
|
|
|
|
|
|
/// Unref and Cancel the pending request if it's still in flight. Must be
|
|
|
|
|
/// called while holding the WorkSerializer that was used to call \a
|
|
|
|
|
/// LookupAresLocked.
|
|
|
|
|
void Orphan() override; |
|
|
|
|
|
|
|
|
|
/// Initialize the gRPC ares wrapper. Must be called at least once before
|
|
|
|
|
/// ResolveAddressAres().
|
|
|
|
|
static grpc_error* Init(void); |
|
|
|
|
|
|
|
|
|
/// Uninitialized the gRPC ares wrapper. If there was more than one previous
|
|
|
|
|
/// call to AresInit(), this function uninitializes the gRPC ares
|
|
|
|
|
/// wrapper only if it has been called the same number of times as
|
|
|
|
|
/// AresInit().
|
|
|
|
|
static void Shutdown(void); |
|
|
|
|
|
|
|
|
|
private: |
|
|
|
|
/// Tracks state needed to perform one A or AAAA lookup with the c-ares lib.
|
|
|
|
|
/// Note that \a Create both constructs an AddressQuery object and arranges
|
|
|
|
|
/// for it's deletion.
|
|
|
|
|
class AddressQuery final { |
|
|
|
|
public: |
|
|
|
|
static void Create(AresRequest* request, const std::string& host, |
|
|
|
|
uint16_t port, bool is_balancer, int address_family); |
|
|
|
|
~AddressQuery(); |
|
|
|
|
|
|
|
|
|
private: |
|
|
|
|
AddressQuery(AresRequest* request, const std::string& host, uint16_t port, |
|
|
|
|
bool is_balancer, int address_family); |
|
|
|
|
static void OnHostByNameDoneLocked(void* arg, int status, int timeouts, |
|
|
|
|
struct hostent* hostent); |
|
|
|
|
|
|
|
|
|
// the request which spawned this query
|
|
|
|
|
AresRequest* request_; |
|
|
|
|
// host to resolve
|
|
|
|
|
const std::string host_; |
|
|
|
|
// port to use in resulting socket addresses, in network byte order
|
|
|
|
|
const uint16_t port_; |
|
|
|
|
// is it a grpclb address
|
|
|
|
|
const bool is_balancer_; |
|
|
|
|
// for logging and errors: the query type ("A" or "AAAA")
|
|
|
|
|
const char* qtype_; |
|
|
|
|
// the address family (AF_INET or AF_INET6)
|
|
|
|
|
const int address_family_; |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
/// Tracks state needed to perform one SRV lookup with the c-ares lib.
|
|
|
|
|
/// Note that \a Create both constructs an AddressQuery object and arranges
|
|
|
|
|
/// for it's deletion.
|
|
|
|
|
class SRVQuery final { |
|
|
|
|
public: |
|
|
|
|
static void Create(AresRequest* request); |
|
|
|
|
~SRVQuery(); |
|
|
|
|
|
|
|
|
|
private: |
|
|
|
|
explicit SRVQuery(AresRequest* request); |
|
|
|
|
|
|
|
|
|
static void OnSRVQueryDoneLocked(void* arg, int status, int timeouts, |
|
|
|
|
unsigned char* abuf, int alen); |
|
|
|
|
|
|
|
|
|
// the request which spawned this query
|
|
|
|
|
AresRequest* request_; |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
/// Tracks state needed to perform one TXT lookup with the c-ares lib.
|
|
|
|
|
/// Note that \a Create both constructs an AddressQuery object and arranges
|
|
|
|
|
/// for it's deletion.
|
|
|
|
|
class TXTQuery final { |
|
|
|
|
public: |
|
|
|
|
static void Create(AresRequest* request); |
|
|
|
|
~TXTQuery(); |
|
|
|
|
|
|
|
|
|
private: |
|
|
|
|
explicit TXTQuery(AresRequest* request); |
|
|
|
|
|
|
|
|
|
static void OnTXTDoneLocked(void* arg, int status, int timeouts, |
|
|
|
|
unsigned char* buf, int len); |
|
|
|
|
|
|
|
|
|
// the request which spawned this query
|
|
|
|
|
AresRequest* request_; |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
// An FdNode tracks an fd and its relevant state for polling it as
|
|
|
|
|
// needed to carry out a c-ares resolution.
|
|
|
|
|
class FdNode final { |
|
|
|
|
public: |
|
|
|
|
FdNode(RefCountedPtr<AresRequest> request, |
|
|
|
|
std::unique_ptr<grpc_core::GrpcPolledFd> grpc_polled_fd); |
|
|
|
|
|
|
|
|
|
~FdNode(); |
|
|
|
|
|
|
|
|
|
void MaybeRegisterForOnReadableLocked(); |
|
|
|
|
|
|
|
|
|
void MaybeRegisterForOnWritableLocked(); |
|
|
|
|
|
|
|
|
|
void MaybeShutdownLocked(absl::string_view reason); |
|
|
|
|
|
|
|
|
|
bool IsActiveLocked(); |
|
|
|
|
|
|
|
|
|
bool shutdown() { return shutdown_; } |
|
|
|
|
|
|
|
|
|
GrpcPolledFd* grpc_polled_fd() { return grpc_polled_fd_.get(); } |
|
|
|
|
|
|
|
|
|
private: |
|
|
|
|
void OnReadableLocked(grpc_error* error); |
|
|
|
|
|
|
|
|
|
static void OnReadable(void* arg, grpc_error* error); |
|
|
|
|
|
|
|
|
|
void OnWritableLocked(grpc_error* error); |
|
|
|
|
|
|
|
|
|
static void OnWritable(void* arg, grpc_error* error); |
|
|
|
|
|
|
|
|
|
RefCountedPtr<AresRequest> request_; |
|
|
|
|
// a closure wrapping OnReadableLocked, which should be
|
|
|
|
|
// invoked when the fd in this node becomes readable.
|
|
|
|
|
grpc_closure read_closure_; |
|
|
|
|
// a closure wrapping OnWritableLocked, which should be
|
|
|
|
|
// invoked when the fd in this node becomes writable.
|
|
|
|
|
grpc_closure write_closure_; |
|
|
|
|
// wrapped fd that's polled by grpc's poller for the current platform
|
|
|
|
|
std::unique_ptr<grpc_core::GrpcPolledFd> grpc_polled_fd_; |
|
|
|
|
// if the readable closure has been registered
|
|
|
|
|
bool readable_registered_ = false; |
|
|
|
|
// if the writable closure has been registered
|
|
|
|
|
bool writable_registered_ = false; |
|
|
|
|
// if the fd has been shutdown yet from grpc iomgr perspective
|
|
|
|
|
bool shutdown_ = false; |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
void ShutdownIOLocked(absl::string_view reason); |
|
|
|
|
|
|
|
|
|
grpc_millis CalculateNextAresBackupPollAlarm() const; |
|
|
|
|
|
|
|
|
|
void OnTimeoutLocked(grpc_error* error); |
|
|
|
|
|
|
|
|
|
static void OnTimeout(void* arg, grpc_error* error); |
|
|
|
|
|
|
|
|
|
void OnAresBackupPollAlarmLocked(grpc_error* error); |
|
|
|
|
|
|
|
|
|
static void OnAresBackupPollAlarm(void* arg, grpc_error* error); |
|
|
|
|
|
|
|
|
|
void NotifyOnEventLocked(); |
|
|
|
|
|
|
|
|
|
void ContinueAfterCheckLocalhostAndIPLiteralsLocked( |
|
|
|
|
absl::string_view dns_server); |
|
|
|
|
|
|
|
|
|
void DecrementPendingQueries(); |
|
|
|
|
|
|
|
|
|
void MaybeCallOnDoneLocked(); |
|
|
|
|
|
|
|
|
|
bool ResolveAsIPLiteralLocked(); |
|
|
|
|
|
|
|
|
|
bool MaybeResolveLocalHostManuallyLocked(); |
|
|
|
|
|
|
|
|
|
std::string srv_qname() const { |
|
|
|
|
return absl::StrCat("_grpclb._tcp.", target_host_); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
std::string txt_qname() const { |
|
|
|
|
return absl::StrCat("_grpc_config.", target_host_); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
// the host component of the service name to resolve
|
|
|
|
|
std::string target_host_; |
|
|
|
|
// the numeric port number to access the service on, stored in
|
|
|
|
|
// network byte order
|
|
|
|
|
uint16_t target_port_ = 0; |
|
|
|
|
// the pointer to receive the resolved addresses
|
|
|
|
|
std::unique_ptr<grpc_core::ServerAddressList>* addresses_out_; |
|
|
|
|
// the pointer to receive the resolved balancer addresses
|
|
|
|
|
std::unique_ptr<grpc_core::ServerAddressList>* balancer_addresses_out_; |
|
|
|
|
// the pointer to receive the service config in JSON
|
|
|
|
|
absl::optional<std::string>* service_config_json_out_; |
|
|
|
|
// the ares_channel owned by this request
|
|
|
|
|
ares_channel channel_ = nullptr; |
|
|
|
|
// pollset set for driving the IO events of the channel
|
|
|
|
|
grpc_pollset_set* pollset_set_; |
|
|
|
|
// work_serializer to synchronize c-ares and I/O callbacks on
|
|
|
|
|
std::shared_ptr<grpc_core::WorkSerializer> work_serializer_; |
|
|
|
|
// Number of active DNS queries (one for A, another for AAAA, etc.).
|
|
|
|
|
int pending_queries_ = 0; |
|
|
|
|
// the fds that this request is currently using.
|
|
|
|
|
std::map<ares_socket_t, std::unique_ptr<FdNode>> fds_; |
|
|
|
|
// is this request being shut down
|
|
|
|
|
bool shutting_down_ = false; |
|
|
|
|
// Owned by the ev_driver. Creates new GrpcPolledFd's
|
|
|
|
|
std::unique_ptr<grpc_core::GrpcPolledFdFactory> polled_fd_factory_; |
|
|
|
|
// query timeout in milliseconds
|
|
|
|
|
int query_timeout_ms_; |
|
|
|
|
// alarm to cancel active queries
|
|
|
|
|
grpc_timer query_timeout_; |
|
|
|
|
// cancels queries on a timeout
|
|
|
|
|
grpc_closure on_timeout_locked_; |
|
|
|
|
// alarm to poll ares_process on in case fd events don't happen
|
|
|
|
|
grpc_timer ares_backup_poll_alarm_; |
|
|
|
|
// polls ares_process on a periodic timer
|
|
|
|
|
grpc_closure on_ares_backup_poll_alarm_locked_; |
|
|
|
|
// callback to schedule when the request completes, empty means that
|
|
|
|
|
// we've already scheduled the callback
|
|
|
|
|
std::function<void(grpc_error*)> on_done_; |
|
|
|
|
// the errors explaining query failures, appended to in query callbacks
|
|
|
|
|
grpc_error* error_ = GRPC_ERROR_NONE; |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
/// Asynchronously resolve \a name. Use \a default_port if a port isn't
|
|
|
|
|
/// designated in \a name, otherwise use the port in \a name.
|
|
|
|
|
/// AresInit() must be called at least once before this function.
|
|
|
|
|
extern void (*ResolveAddressAres)(const char* name, const char* default_port, |
|
|
|
|
grpc_pollset_set* interested_parties, |
|
|
|
|
grpc_closure* on_done, |
|
|
|
|
grpc_resolved_addresses** addresses); |
|
|
|
|
|
|
|
|
|
/// Asynchronously resolve \a name. It will try to resolve grpclb SRV records in
|
|
|
|
|
/// addition to the normal address records if \a balancer_addresses is not
|
|
|
|
|
/// nullptr. For normal address records, it uses \a default_port if a port isn't
|
|
|
|
|
/// designated in \a name, otherwise it uses the port in \a name. AresInit()
|
|
|
|
|
/// must be called at least once before this function. The returned
|
|
|
|
|
/// AresRequest is safe to destroy after \a on_done is called back.
|
|
|
|
|
///
|
|
|
|
|
/// TODO(apolcyn): as a part of moving to new gRPC DNS API, remove the
|
|
|
|
|
/// work_serializer parameter and synchronize internally instead.
|
|
|
|
|
extern OrphanablePtr<AresRequest> (*LookupAresLocked)( |
|
|
|
|
absl::string_view dns_server, absl::string_view name, |
|
|
|
|
absl::string_view default_port, grpc_pollset_set* interested_parties, |
|
|
|
|
std::function<void(grpc_error*)> on_done, |
|
|
|
|
typedef struct grpc_ares_request grpc_ares_request; |
|
|
|
|
|
|
|
|
|
/* Asynchronously resolve \a name. Use \a default_port if a port isn't
|
|
|
|
|
designated in \a name, otherwise use the port in \a name. grpc_ares_init() |
|
|
|
|
must be called at least once before this function. \a on_done may be |
|
|
|
|
called directly in this function without being scheduled with \a exec_ctx, |
|
|
|
|
so it must not try to acquire locks that are being held by the caller. */ |
|
|
|
|
extern void (*grpc_resolve_address_ares)(const char* name, |
|
|
|
|
const char* default_port, |
|
|
|
|
grpc_pollset_set* interested_parties, |
|
|
|
|
grpc_closure* on_done, |
|
|
|
|
grpc_resolved_addresses** addresses); |
|
|
|
|
|
|
|
|
|
/* Asynchronously resolve \a name. It will try to resolve grpclb SRV records in
|
|
|
|
|
addition to the normal address records. For normal address records, it uses |
|
|
|
|
\a default_port if a port isn't designated in \a name, otherwise it uses the |
|
|
|
|
port in \a name. grpc_ares_init() must be called at least once before this |
|
|
|
|
function. \a on_done may be called directly in this function without being |
|
|
|
|
scheduled with \a exec_ctx, so it must not try to acquire locks that are |
|
|
|
|
being held by the caller. The returned grpc_ares_request object is owned |
|
|
|
|
by the caller and it is safe to free after on_done is called back. */ |
|
|
|
|
extern grpc_ares_request* (*grpc_dns_lookup_ares_locked)( |
|
|
|
|
const char* dns_server, const char* name, const char* default_port, |
|
|
|
|
grpc_pollset_set* interested_parties, grpc_closure* on_done, |
|
|
|
|
std::unique_ptr<grpc_core::ServerAddressList>* addresses, |
|
|
|
|
std::unique_ptr<grpc_core::ServerAddressList>* balancer_addresses, |
|
|
|
|
absl::optional<std::string>* service_config_json, int query_timeout_ms, |
|
|
|
|
char** service_config_json, int query_timeout_ms, |
|
|
|
|
std::shared_ptr<grpc_core::WorkSerializer> work_serializer); |
|
|
|
|
|
|
|
|
|
/// Indicates whether or not AAAA queries should be attempted.
|
|
|
|
|
/// E.g., return false if ipv6 is known to not be available.
|
|
|
|
|
bool AresQueryIPv6(); |
|
|
|
|
/* Cancel the pending grpc_ares_request \a request */ |
|
|
|
|
extern void (*grpc_cancel_ares_request_locked)(grpc_ares_request* request); |
|
|
|
|
|
|
|
|
|
/* Initialize gRPC ares wrapper. Must be called at least once before
|
|
|
|
|
grpc_resolve_address_ares(). */ |
|
|
|
|
grpc_error* grpc_ares_init(void); |
|
|
|
|
|
|
|
|
|
/// Sorts destinations in \a addresses according to RFC 6724.
|
|
|
|
|
void AddressSortingSort(const AresRequest* request, |
|
|
|
|
ServerAddressList* addresses, |
|
|
|
|
const std::string& logging_prefix); |
|
|
|
|
/* Uninitialized gRPC ares wrapper. If there was more than one previous call to
|
|
|
|
|
grpc_ares_init(), this function uninitializes the gRPC ares wrapper only if |
|
|
|
|
it has been called the same number of times as grpc_ares_init(). */ |
|
|
|
|
void grpc_ares_cleanup(void); |
|
|
|
|
|
|
|
|
|
namespace internal { |
|
|
|
|
/** Schedules the desired callback for request completion
|
|
|
|
|
* and destroys the grpc_ares_request */ |
|
|
|
|
void grpc_ares_complete_request_locked(grpc_ares_request* request); |
|
|
|
|
|
|
|
|
|
/// Exposed in this header for C-core tests only
|
|
|
|
|
extern void (*AresTestOnlyInjectConfig)(ares_channel channel); |
|
|
|
|
/* Indicates whether or not AAAA queries should be attempted. */ |
|
|
|
|
/* E.g., return false if ipv6 is known to not be available. */ |
|
|
|
|
bool grpc_ares_query_ipv6(); |
|
|
|
|
|
|
|
|
|
} // namespace internal
|
|
|
|
|
/* Sorts destinations in lb_addrs according to RFC 6724. */ |
|
|
|
|
void grpc_cares_wrapper_address_sorting_sort( |
|
|
|
|
const grpc_ares_request* request, grpc_core::ServerAddressList* addresses); |
|
|
|
|
|
|
|
|
|
} // namespace grpc_core
|
|
|
|
|
/* Exposed in this header for C-core tests only */ |
|
|
|
|
extern void (*grpc_ares_test_only_inject_config)(ares_channel channel); |
|
|
|
|
|
|
|
|
|
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_RESOLVER_DNS_C_ARES_GRPC_ARES_WRAPPER_H \ |
|
|
|
|
*/ |
|
|
|
|
|
apolcyn
4 years ago
committed by
GitHub