Returns a ``dns.message.Message``.
"""
- if not backend:
- backend = dns.asyncbackend.get_default_backend()
wire = q.to_wire()
(begin_time, expiration) = _compute_times(timeout)
s = None
if sock:
s = sock
else:
+ if not backend:
+ backend = dns.asyncbackend.get_default_backend()
af = dns.inet.af_for_address(where)
stuple = _source_tuple(af, source, source_port)
s = await backend.make_socket(af, socket.SOCK_DGRAM, 0, stuple)
Returns a ``dns.message.Message``.
"""
- if not backend:
- backend = dns.asyncbackend.get_default_backend()
wire = q.to_wire()
(begin_time, expiration) = _compute_times(timeout)
s = None
af = dns.inet.af_for_address(where)
stuple = _source_tuple(af, source, source_port)
dtuple = (where, port)
+ if not backend:
+ backend = dns.asyncbackend.get_default_backend()
s = await backend.make_socket(af, socket.SOCK_STREAM, 0, stuple,
dtuple, timeout)
await send_tcp(s, wire, expiration)
Returns a ``dns.message.Message``.
"""
- if not backend:
- backend = dns.asyncbackend.get_default_backend()
(begin_time, expiration) = _compute_times(timeout)
if not sock:
if ssl_context is None:
af = dns.inet.af_for_address(where)
stuple = _source_tuple(af, source, source_port)
dtuple = (where, port)
+ if not backend:
+ backend = dns.asyncbackend.get_default_backend()
s = await backend.make_socket(af, socket.SOCK_STREAM, 0, stuple,
dtuple, timeout, ssl_context,
server_hostname)
else:
s = sock
try:
- #
- # If a socket was provided, there's no special TLS handling needed.
- #
timeout = _timeout(expiration)
response = await tcp(q, where, timeout, port, source, source_port,
one_rr_per_rrset, ignore_trailing, s, backend)