Linux cpanel.rrshost.in 5.15.0-25-generic #25-Ubuntu SMP Wed Mar 30 15:54:22 UTC 2022 x86_64
Apache
: 109.123.238.221 | : 172.70.80.110
128 Domain
8.2.28
aev999
Terminal
AUTO ROOT
Adminer
Backdoor Destroyer
Linux Exploit
Lock Shell
Lock File
Create User
CREATE RDP
PHP Mailer
BACKCONNECT
HASH IDENTIFIER
README
+ Create Folder
+ Create File
/
usr /
lib /
python3 /
dist-packages /
dns /
__pycache__ /
[ HOME SHELL ]
Name
Size
Permission
Action
__init__.cpython-310.pyc
625
B
-rw-r--r--
_asyncbackend.cpython-310.pyc
2.66
KB
-rw-r--r--
_asyncio_backend.cpython-310.p...
5.03
KB
-rw-r--r--
_curio_backend.cpython-310.pyc
3.72
KB
-rw-r--r--
_immutable_attr.cpython-310.py...
2.1
KB
-rw-r--r--
_immutable_ctx.cpython-310.pyc
2.1
KB
-rw-r--r--
_trio_backend.cpython-310.pyc
4
KB
-rw-r--r--
asyncbackend.cpython-310.pyc
2.58
KB
-rw-r--r--
asyncquery.cpython-310.pyc
11.21
KB
-rw-r--r--
asyncresolver.cpython-310.pyc
5.76
KB
-rw-r--r--
dnssec.cpython-310.pyc
14.21
KB
-rw-r--r--
e164.cpython-310.pyc
3.08
KB
-rw-r--r--
edns.cpython-310.pyc
9.56
KB
-rw-r--r--
entropy.cpython-310.pyc
3.11
KB
-rw-r--r--
enum.cpython-310.pyc
2.33
KB
-rw-r--r--
exception.cpython-310.pyc
4.56
KB
-rw-r--r--
flags.cpython-310.pyc
1.97
KB
-rw-r--r--
grange.cpython-310.pyc
1.02
KB
-rw-r--r--
immutable.cpython-310.pyc
2.27
KB
-rw-r--r--
inet.cpython-310.pyc
3.51
KB
-rw-r--r--
ipv4.cpython-310.pyc
1.29
KB
-rw-r--r--
ipv6.cpython-310.pyc
3.22
KB
-rw-r--r--
message.cpython-310.pyc
40.47
KB
-rw-r--r--
name.cpython-310.pyc
27.34
KB
-rw-r--r--
namedict.cpython-310.pyc
2.92
KB
-rw-r--r--
node.cpython-310.pyc
5.72
KB
-rw-r--r--
opcode.cpython-310.pyc
2.31
KB
-rw-r--r--
query.cpython-310.pyc
29.35
KB
-rw-r--r--
rcode.cpython-310.pyc
2.97
KB
-rw-r--r--
rdata.cpython-310.pyc
19.92
KB
-rw-r--r--
rdataclass.cpython-310.pyc
2.59
KB
-rw-r--r--
rdataset.cpython-310.pyc
13.65
KB
-rw-r--r--
rdatatype.cpython-310.pyc
5.84
KB
-rw-r--r--
renderer.cpython-310.pyc
7.44
KB
-rw-r--r--
resolver.cpython-310.pyc
40.67
KB
-rw-r--r--
reversename.cpython-310.pyc
2.86
KB
-rw-r--r--
rrset.cpython-310.pyc
6.64
KB
-rw-r--r--
serial.cpython-310.pyc
2.76
KB
-rw-r--r--
set.cpython-310.pyc
7.49
KB
-rw-r--r--
tokenizer.cpython-310.pyc
15.77
KB
-rw-r--r--
transaction.cpython-310.pyc
14.24
KB
-rw-r--r--
tsig.cpython-310.pyc
9.86
KB
-rw-r--r--
tsigkeyring.cpython-310.pyc
1.6
KB
-rw-r--r--
ttl.cpython-310.pyc
1.53
KB
-rw-r--r--
update.cpython-310.pyc
8.01
KB
-rw-r--r--
version.cpython-310.pyc
542
B
-rw-r--r--
versioned.cpython-310.pyc
14.06
KB
-rw-r--r--
wire.cpython-310.pyc
2.91
KB
-rw-r--r--
xfr.cpython-310.pyc
6.18
KB
-rw-r--r--
zone.cpython-310.pyc
31.1
KB
-rw-r--r--
zonefile.cpython-310.pyc
6.86
KB
-rw-r--r--
Delete
Unzip
Zip
${this.title}
Close
Code Editor : query.cpython-310.pyc
o x7�_ԡ � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddlZ ddlZ ddlZ ddlZ ddlZ ddlZ ddlZ ddlZ zddlZddlmZ ddlmZ dZW n e ym dZY nw zddl Z W n e y� G dd� d�Z Y nw ejZ G d d � d e j j �Z!G d d � d e j j"�Z#G d d� de j j �Z$e j%j&Z&dd� Z'dd� Z(dd� Z)e*ed�r�ej+a,nej-a,dd� Z.dd� Z/dd� Z0d d � Z1 dKd d �Z2dLd d!�Z3 dMd$d%�Z4d&d'� Z5d(d)� Z6dNd*d+�Z7 dOd-d.�Z8 dPd0d1�Z9 dQd2d3�Z:d4d5� Z;d6d7� Z<dNd8d9�Z= dRd:d;�Z>d<d=� Z? dSd>d?�Z@d@dA� ZA dTdCdD�ZBe jCjDe jEjFdd/dddddddde jGjHf dEdF�Z%G dGdH� dHejI�ZJdd/ddddeJjKfdIdJ�ZLdS )UzTalk to a DNS server.� N)�SourceAddressAdapter)�HostHeaderSSLAdapterTFc @ sB e Zd ZG dd� de�ZG dd� de�ZG dd� d�Zdd� Zd S ) �sslc @ � e Zd ZdS )zssl.WantReadExceptionN��__name__� __module__� __qualname__� r r �+/usr/lib/python3/dist-packages/dns/query.py�WantReadException6 � r c @ r )zssl.WantWriteExceptionNr r r r r �WantWriteException9 r r c @ r )z ssl.SSLSocketNr r r r r � SSLSocket< r r c O s t d��)Nzno ssl support)� Exception)�self�args�kwargsr r r �create_default_context? s zssl.create_default_contextN)r r r r r r r r r r r r r 4 s r c @ � e Zd ZdZdS )�UnexpectedSourcez=A DNS query response came from an unexpected address or port.N�r r r �__doc__r r r r r F � r c @ r )� BadResponsez<A DNS query response does not respond to the question asked.Nr r r r r r J r r c @ r )�NoDOHzPDNS over HTTPS (DOH) was requested but the requests module is not available.Nr r r r r r N r r c C s$ t � � }| d u r |d fS ||| fS �N)�time)�timeout�nowr r r �_compute_timesW s r c C s� |rt | tj�r| �� dkrdS t� }d}|r |tjO }|r#|tjO }|r+|�| |� |d u r2d }n|t � � }|dkr@t j j �|� |�sIt j j �d S )Nr Tg )� isinstancer r �pending�_selector_class� selectors� EVENT_READ� EVENT_WRITE�registerr �dns� exception�Timeout�select)�fd�readable�writable�_� expiration�sel�eventsr r r r � _wait_for_ s$ �r3 c C s | a d S r )r# )�selector_classr r r �_set_selector_class{ s r5 � PollSelectorc C s t | ddd|� d S )NTF�r3 ��sr0 r r r �_wait_for_readable� � r: c C s t | ddd|� d S )NFTr7 r8 r r r �_wait_for_writable� r; r< c C sb zt j�| |d �}t j�| |d �}W n t jjy Y dS w ||ko0|dd � |dd � kS )Nr F� )r( �inet� inet_ptonr) � SyntaxError)�af�a1�a2�n1�n2r r r �_addresses_equal� s � rF c C s\ |sdS t | ||�s tj�|d �r |dd � |dd � kr dS |r$dS td|� d|� ���)NTr r= Fzgot a response from z instead of )rF r( r> � is_multicastr )rA � from_address� destination�ignore_unexpectedr r r �_matches_destination� s � �rK c C s� d }d }z t j�| �}| }W n ty |r� Y nw |r0t j�|�}|r.||kr-td��n|}|rH|sH|tjkr<d}n |tjkrDd}ntd��|rSt j�||f|�}|r^t j�||f|�}|||fS )Nz5different address families for source and destinationz0.0.0.0z::z3source_port specified but address family is unknown) r( r> �af_for_addressr � ValueError�socket�AF_INET�AF_INET6�low_level_address_tuple)�where�port�source� source_port�where_must_be_addressrA rI �safr r r �_destination_and_source� s8 �� � rX c C s\ t | |�}z |�d� |d ur|�|� |r |j|d|d�W S |W S ty- |�� � w )NF)�do_handshake_on_connect�server_hostname)�socket_factory� setblocking�bind� wrap_socketr �close)rA �typerT � ssl_contextrZ r9 r r r � _make_socket� s � �rb � � /dns-queryc C s� t st�| �� } t||||d�\}}}d}ddi}|dur7|tjkr*d�||| �}n)|tjkr6d�||| �}n | durQtj � |�}|j |d< |� |j | �}t � }n|}|dur[t|�}t�� �G}|sj|�tj�� �}|rr|�||� | r�|�dtt| ��d�� |j||| || d �}nt�| �� d �} |j |||| d | id �}W d � n1 s�w Y |j d k s�|j dkr�t d�||j |j ���t!j"j#|j | j$| j%||d�}|j&|_'| �(|�s�t)�|S )a� Return the response obtained after sending a query via DNS-over-HTTPS. *q*, a ``dns.message.Message``, the query to send. *where*, a ``str``, the nameserver IP address or the full URL. If an IP address is given, the URL will be constructed using the following schema: https://<IP-address>:<port>/<path>. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, a ``int``, the port to send the query to. The default is 443. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *session*, a ``requests.session.Session``. If provided, the session to use to send the queries. *path*, a ``str``. If *where* is an IP address, then *path* will be used to construct the URL to send the DNS query to. *post*, a ``bool``. If ``True``, the default, POST method will be used. *bootstrap_address*, a ``str``, the IP address to use to bypass the system's DNS resolver. *verify*, a ``str``, containing a path to a certificate file or directory. Returns a ``dns.message.Message``. FN�acceptzapplication/dns-messagezhttps://{}:{}{}zhttps://[{}]:{}{}�Host)z content-typezcontent-length)�headers�datar �verify� =r( )rg r ri �params�� i+ z2{} responded with status code {} Response body: {}��keyring� request_mac�one_rr_per_rrset�ignore_trailing)*�have_dohr �to_wirerX rN rO �formatrP �urllib�parse�urlsplit�hostname�replacer r � contextlib� ExitStack� enter_context�requests�sessions�Session�mount�update�str�len�post�base64�urlsafe_b64encode�rstrip�get� status_coderM �contentr( �message� from_wirern ro �elapsedr � is_responser )�qrR r rS rT rU rp rq �session�pathr� �bootstrap_addressri �wirerA r/ �transport_adapterrg �url� split_url�stack�response�rr r r �https� sx - �� � � ��� ��� � r� c C s. z| � |�W S ty t| |� Y nw q)z�Reads a datagram from the socket. A Timeout exception will be raised if the operation is not completed by the expiration time. )�recvfrom�BlockingIOErrorr: )�sock�max_sizer0 r r r � _udp_recvV s ��r� c C s@ z|r | � ||�W S | �|�W S ty t| |� Y nw q)z�Sends the specified datagram to destination over the socket. A Timeout exception will be raised if the operation is not completed by the expiration time. )�sendto�sendr� r< )r� rh rI r0 r r r � _udp_sendb s ��r� c C s4 t |tjj�r |�� }t�� }t| |||�}||fS )a� Send a DNS message to the specified UDP socket. *sock*, a ``socket``. *what*, a ``bytes`` or ``dns.message.Message``, the message to send. *destination*, a destination tuple appropriate for the address family of the socket, specifying where to send the query. *expiration*, a ``float`` or ``None``, the absolute time at which a timeout exception should be raised. If ``None``, no timeout will occur. Returns an ``(int, float)`` tuple of bytes sent and the sent time. )r! r( r� �Messagers r r� )r� �whatrI r0 � sent_time�nr r r �send_udpq s r� � c C s` d} t | d|�\} } t| j| ||�rnqt�� } tjj| |||||d�} |r+| | fS | | | fS )a~ Read a DNS message from a UDP socket. *sock*, a ``socket``. *destination*, a destination tuple appropriate for the address family of the socket, specifying where the message is expected to arrive from. When receiving a response, this would be where the associated query was sent. *expiration*, a ``float`` or ``None``, the absolute time at which a timeout exception should be raised. If ``None``, no timeout will occur. *ignore_unexpected*, a ``bool``. If ``True``, ignore responses from unexpected sources. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *keyring*, a ``dict``, the keyring to use for TSIG. *request_mac*, a ``bytes``, the MAC of the request (for TSIG). *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *raise_on_truncation*, a ``bool``. If ``True``, raise an exception if the TC bit is set. Raises if the message is malformed, if network errors occur, of if there is a timeout. If *destination* is not ``None``, returns a ``(dns.message.Message, float)`` tuple of the received message and the received time. If *destination* is ``None``, returns a ``(dns.message.Message, float, tuple)`` tuple of the received message, the received time, and the address where the message arrived from. r� T� )rn ro rp rq �raise_on_truncation)r� rK �familyr r( r� r� ) r� rI r0 rJ rp rn ro rq r� r� rH � received_timer� r r r � receive_udp� s" - �� � r� �5 c C s� | � � } t||||�\} } }t|�\}}t�� �<}| r | }n |�t| tj|��}t || | |� t || |||| j | j || � \}}|| |_ | �|�sKt�|W d � S 1 sWw Y dS )aL Return the response obtained after sending a query via UDP. *q*, a ``dns.message.Message``, the query to send *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 53. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *ignore_unexpected*, a ``bool``. If ``True``, ignore responses from unexpected sources. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *raise_on_truncation*, a ``bool``. If ``True``, raise an exception if the TC bit is set. *sock*, a ``socket.socket``, or ``None``, the socket to use for the query. If ``None``, the default, a socket is created. Note that if a socket is provided, it must be a nonblocking datagram socket, and the *source* and *source_port* are ignored. Returns a ``dns.message.Message``. N)rs rX r rz r{ r| rb rN � SOCK_DGRAMr� r� rn �macr r� r )r� rR r rS rT rU rJ rp rq r� r� r� rA rI � begin_timer0 r� r9 r� r� r r r �udp� s( ) � � $�r� c C s^ zt | ||||||||d| � } | dfW S tjjy. t| |||||||| � } | df Y S w )a� Return the response to the query, trying UDP first and falling back to TCP if UDP results in a truncated response. *q*, a ``dns.message.Message``, the query to send *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 53. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *ignore_unexpected*, a ``bool``. If ``True``, ignore responses from unexpected sources. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *udp_sock*, a ``socket.socket``, or ``None``, the socket to use for the UDP query. If ``None``, the default, a socket is created. Note that if a socket is provided, it must be a nonblocking datagram socket, and the *source* and *source_port* are ignored for the UDP query. *tcp_sock*, a ``socket.socket``, or ``None``, the socket to use for the TCP query. If ``None``, the default, a socket is created. Note that if a socket is provided, it must be a nonblocking connected stream socket, and *where*, *source* and *source_port* are ignored for the TCP query. Returns a (``dns.message.Message``, tcp) tuple where tcp is ``True`` if and only if TCP was used. TF)r� r( r� � Truncated�tcp) r� rR r rS rT rU rJ rp rq �udp_sock�tcp_sockr� r r r �udp_with_fallback s .� � �r� c C s� d}|dkrAz| � |�}|dkrt�|t|�8 }||7 }W n ttjfy. t| |� Y n tjy< t| |� Y nw |dks|S )z�Read the specified number of bytes from sock. Keep trying until we either get the desired amount, or we hit EOF. A Timeout exception will be raised if the operation is not completed by the expiration time. r� r ) �recv�EOFErrorr� r� r �SSLWantReadErrorr: �SSLWantWriteErrorr< )r� �countr0 r9 r� r r r � _net_read: s �� r� c C s~ d}t |�}||k r=z || �||d� �7 }W n ttjfy( t| |� Y n tjy6 t| |� Y nw ||k s dS dS )z�Write the specified data to the socket. A Timeout exception will be raised if the operation is not completed by the expiration time. r N)r� r� r� r r� r< r� r: )r� rh r0 �current�lr r r � _net_writeO s ��r� c C sN t |tjj�r |�� }t|�}t�d|�| }t�� }t | ||� t|�|fS )a{ Send a DNS message to the specified TCP socket. *sock*, a ``socket``. *what*, a ``bytes`` or ``dns.message.Message``, the message to send. *expiration*, a ``float`` or ``None``, the absolute time at which a timeout exception should be raised. If ``None``, no timeout will occur. Returns an ``(int, float)`` tuple of bytes sent and the sent time. �!H) r! r( r� r� rs r� �struct�packr r� )r� r� r0 r� �tcpmsgr� r r r �send_tcp_ s r� c C sL t | d|�}t�d|�\}t | ||�}t�� } tjj|||||d�} | | fS )a� Read a DNS message from a TCP socket. *sock*, a ``socket``. *expiration*, a ``float`` or ``None``, the absolute time at which a timeout exception should be raised. If ``None``, no timeout will occur. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *keyring*, a ``dict``, the keyring to use for TSIG. *request_mac*, a ``bytes``, the MAC of the request (for TSIG). *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. Raises if the message is malformed, if network errors occur, of if there is a timeout. Returns a ``(dns.message.Message, float)`` tuple of the received message and the received time. � r� rm )r� r� �unpackr r( r� r� ) r� r0 rp rn ro rq �ldatar� r� r� r� r r r � receive_tcpx s �r� c C s` | � |�}|dkr d S |tjtjtjfv r"t| |� | �tjtj �}|dkr.t |t � |���d S )Nr ) � connect_ex�errno� EINPROGRESS� EWOULDBLOCK�EALREADYr< � getsockoptrN � SOL_SOCKET�SO_ERROR�OSError�os�strerror)r9 �addressr0 �errr r r �_connect� s �r� c C s� | � � } t|�\} } t�� �H} |r|} nt||||�\}}}| �t|tj|��} t | || � t | | | � t | | || j | j |�\}}|| |_| �|�sMt�|W d � S 1 sYw Y dS )a� Return the response obtained after sending a query via TCP. *q*, a ``dns.message.Message``, the query to send *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 53. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *sock*, a ``socket.socket``, or ``None``, the socket to use for the query. If ``None``, the default, a socket is created. Note that if a socket is provided, it must be a nonblocking connected stream socket, and *where*, *port*, *source* and *source_port* are ignored. Returns a ``dns.message.Message``. N)rs r rz r{ rX r| rb rN � SOCK_STREAMr� r� r� rn r� r r� r )r� rR r rS rT rU rp rq r� r� r� r0 r� r9 rA rI r� r� r r r r� � s, " � � � $�r� c C sN z| � � W d S tjy t| |� Y n tjy% t| |� Y nw qr )� do_handshaker r� r: r� r< r8 r r r �_tls_handshake� s ��r� �U c C s� |rt | ||||||||� S | �� } t|�\} } t||||�\}}}| du r3|s3t�� } | du r3d| _t|tj || | d��4}t ||| � t || � t || | � t || || j| j|�\}}|| |_| �|�sht�|W d � S 1 stw Y dS )a: Return the response obtained after sending a query via TLS. *q*, a ``dns.message.Message``, the query to send *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *timeout*, a ``float`` or ``None``, the number of seconds to wait before the query times out. If ``None``, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 853. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the received message. *sock*, an ``ssl.SSLSocket``, or ``None``, the socket to use for the query. If ``None``, the default, a socket is created. Note that if a socket is provided, it must be a nonblocking connected SSL stream socket, and *where*, *port*, *source*, *source_port*, and *ssl_context* are ignored. *ssl_context*, an ``ssl.SSLContext``, the context to use when establishing a TLS connection. If ``None``, the default, creates one with the default configuration. *server_hostname*, a ``str`` containing the server's hostname. The default is ``None``, which means that no hostname is known, and if an SSL context is created, hostname checking will be disabled. Returns a ``dns.message.Message``. NF)ra rZ )r� rs r rX r r �check_hostnamerb rN r� r� r� r� r� rn r� r r� r )r� rR r rS rT rU rp rq r� ra rZ r� r� r0 rA rI r9 r� r� r r r �tls� s8 -� � � � $�r� c ' c s� � t |t�r tj�|�}tjj�|�}tj� |||�}|tjj kr3tj �|dddd| �}|j � |� |dur?|j|||d� |�� }t| || | �\}}} | rY|tjj krYtd��| r^tjntj}t||| ���q}t| �\}}t|||� t|�}| r�t||d|� nt�d|�| }t |||� d }d }d } d} |r�|} tjj } nd} |} d} |�s�t|�\}}!|!du s�|dur�|!|kr�|}!| r�t |d |!�\}}nt |d |!�}"t� d|"�\}t |||!�}|tjj k}#tjj!||j"|j#d | | d |#d �}$|$�$� }%|%tj$j%k�rt&|%��|$j'} d}&| du �rP|$j(�r|$j(d j| k�r tj)�*d��|$j(d }|j+tjj,k�r2tj)�*d��d}&|�-� } |tjj k�rPtj.�/| d j.�| k�rNd }nd } |$j(|&d� D ][}|�rbtj)�*d��|j+tjj,k�r�|j| k�r�| �r�|d j.| k�r�tj)�*d��d } n |tjj k�r�| }|| k�r�|tjj0k�s�|tjj k�r�|�r�d }�qW| �r�tjj0}d } �qW|�r�|j"�r�|$j1�s�tj)�*d��|$V |r�W d � dS W d � dS 1 �s�w Y dS )a� Return a generator for the responses to a zone transfer. *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *zone*, a ``dns.name.Name`` or ``str``, the name of the zone to transfer. *rdtype*, an ``int`` or ``str``, the type of zone transfer. The default is ``dns.rdatatype.AXFR``. ``dns.rdatatype.IXFR`` can be used to do an incremental transfer instead. *rdclass*, an ``int`` or ``str``, the class of the zone transfer. The default is ``dns.rdataclass.IN``. *timeout*, a ``float``, the number of seconds to wait for each response message. If None, the default, wait forever. *port*, an ``int``, the port send the message to. The default is 53. *keyring*, a ``dict``, the keyring to use for TSIG. *keyname*, a ``dns.name.Name`` or ``str``, the name of the TSIG key to use. *relativize*, a ``bool``. If ``True``, all names in the zone will be relativized to the zone origin. It is essential that the relativize setting matches the one specified to ``dns.zone.from_xfr()`` if using this generator to make a zone. *lifetime*, a ``float``, the total number of seconds to spend doing the transfer. If ``None``, the default, then there is no limit on the time the transfer may take. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *serial*, an ``int``, the SOA serial number to use as the base for an IXFR diff sequence (only meaningful if *rdtype* is ``dns.rdatatype.IXFR``). *use_udp*, a ``bool``. If ``True``, use UDP (only meaningful for IXFR). *keyalgorithm*, a ``dns.name.Name`` or ``str``, the TSIG algorithm to use. Raises on errors, and so does the generator. Returns a generator of ``dns.message.Message`` objects. r �IN�SOAz. . %u 0 0 0 0N)� algorithmzcannot do a UDP AXFRr� FTr� r� �rn ro �xfr�origin�tsig_ctx�multirp z No answer or RRset not for qnamezfirst RRset is not an SOAr= zanswers after final SOAzIXFR base serial mismatch� missing TSIG)2r! r� r( �name� from_text� rdatatype� RdataType�maker� � make_query�IXFR�rrset� authority�append�use_tsigrs rX rM rN r� r� rb r r� r� r� r� r� r� �emptyr� r� r� r� rn r� �rcode�NOERROR� TransferErrorr� �answerr) � FormError�rdtyper� �copy�serial�Serial�AXFR�had_tsig)'rR �zoner� �rdclassr rS rn �keyname� relativize�lifetimerT rU r� �use_udp� keyalgorithmr� r� r� rA rI � sock_typer9 r/ r0 r� r� �done� delete_mode� expecting_SOA� soa_rrsetr� �onamer� � mexpirationr� �is_ixfrr� r� � answer_indexr r r r� 3 s� � 8 � � � � � �� ��$�r� c @ s e Zd ZdZdZdZdZdS )�UDPModea How should UDP be used in an IXFR from :py:func:`inbound_xfr()`? NEVER means "never use UDP; always use TCP" TRY_FIRST means "try to use UDP but fall back to TCP if needed" ONLY means "raise ``dns.xfr.UseTCP`` if trying UDP does not succeed" r r= r� N)r r r r �NEVER� TRY_FIRST�ONLYr r r r r � s r c C s@ |du r t j�|�\}} |jd j} | t jjk} |�� } |�� } t | |||�\}}}t |�\}}d}|�r d}| rD|t j krDt j}d}nt j}d}t|||���}t|||� |r`t|| d|� nt�dt| ��| }t|||� t j�|| | |���}d}d}|s�t |�\}}|du s�|dur�||kr�|}|r�t|d|�\}}nt|d|�} t�d| �\} t|| |�}t jj ||j |j d| || | d�} z|� | �}W n t jj y� |s�J �|t j!kr݂ d}d}t j }Y q~w | j"}|r�|s�|j r�| j#s�t j$�%d ��W d � n 1 �sw Y W d � n 1 �sw Y |s5dS dS ) a� Conduct an inbound transfer and apply it via a transaction from the txn_manager. *where*, a ``str`` containing an IPv4 or IPv6 address, where to send the message. *txn_manager*, a ``dns.transaction.TransactionManager``, the txn_manager for this transfer (typically a ``dns.zone.Zone``). *query*, the query to send. If not supplied, a default query is constructed using information from the *txn_manager*. *port*, an ``int``, the port send the message to. The default is 53. *timeout*, a ``float``, the number of seconds to wait for each response message. If None, the default, wait forever. *lifetime*, a ``float``, the total number of seconds to spend doing the transfer. If ``None``, the default, then there is no limit on the time the transfer may take. *source*, a ``str`` containing an IPv4 or IPv6 address, specifying the source address. The default is the wildcard address. *source_port*, an ``int``, the port from which to send the message. The default is 0. *udp_mode*, a ``dns.query.UDPMode``, determines how UDP is used for IXFRs. The default is ``dns.UDPMode.NEVER``, i.e. only use TCP. Other possibilites are ``dns.UDPMode.TRY_FIRST``, which means "try UDP but fallback to TCP if needed", and ``dns.UDPMode.ONLY``, which means "try UDP and raise ``dns.xfr.UseTCP`` if it does not succeeed. Raises on errors. Nr TFr� r� r� r� r� )&r( r� r� �questionr� r� r� �from_wire_originrs rX r r r rN r� r� rb r� r� r� r� r� r� �Inboundr� r� r� r� r� rn r� �process_message�UseTCPr r� r� r) r� ) rR � txn_manager�queryrS r r rT rU �udp_moder� r� r r� r� rA rI r/ r0 �retryr �is_udpr9 r� �inboundr r� r �rwirer� r� r� r r r � inbound_xfr� s� ' � � � �� � �� � �r )T)NN) Nrc Nr FFNrd TNTr )NNFFNr� FF) Nr� Nr FFFFN) Nr� Nr FFFNN)NFNr� F)Nr� Nr FFN) Nr� Nr FFNNN)Mr rz �enumr� r� r$ rN r� r r� � urllib.parseru � dns.exceptionr( �dns.inet�dns.name� dns.message� dns.rcode�dns.rdataclass� dns.rdatatype� dns.serial�dns.xfrr} �!requests_toolbelt.adapters.sourcer �*requests_toolbelt.adapters.host_header_sslr rr � ImportErrorr r[ r) � DNSExceptionr r� r r r� r� r r3 r5 �hasattrr6 r# �SelectSelectorr: r< rF rK rX rb r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� � rdataclassr� �tsig�default_algorithm�IntEnumr r r r r r r �<module> s� � � � + �n �= �< �8 �$ �7 � J � ( �
Close
