Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/dns/__pycache__/asyncquery.cpython-39.pyc
Ðазад
a h�hex � @ s d Z ddlZddlZddlZddlZddlZddlZddlZddl m Z m Z m Z m Z mZmZ ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z) e(r�ddl*Z*ej+j,Z-dd� Z.d?dd �Z/d@ej0j1eej2j3e4f e e e5 e e6e5f d �d d �Z7dAej0j1e e e e5 e8e8e e ej9j:ej;j<f e e4 e8e8e8e ej2j3 e d� dd�Z=dBej2j3e>e e5 e6e e> e6e8e8e8e8e ej0j1 e ej0j? e8ej2j3d�dd�Z@dCej2j3e>e e5 e6e e> e6e8e8e8e ej0j1 e ej0jA e ej0j? e8e ej2j3e8f d�dd�ZBdDej0jAeej2j3e4f e e5 e e6e5f d�dd�ZCd d � ZDdEej0jAe e5 e8e e ej9j:ej;j<f e e4 e8e ej2j3e5f d �d d �ZEdFej2j3e>e e5 e6e e> e6e8e8e ej0jA e ej0j? ej2j3d!� d"d#�ZFdGej2j3e>e e5 e6e e> e6e8e8e ej0jA e ej0j? e e)jG e e> ee8e>f ej2j3d&�d'd(�ZHe d) d)d*�d+d,�ZIdd-ddd d dd.d%d%ddejJe jKfej2j3e>e e5 e6e e> e6e8e8e d/ e>e8ee8e>f e e> e d) e6e ej2j3d0�d1d2�ZLdHej2j3e>e>e e5 e6e e> e6e8e8ee8e>f e ej0j? e e> e8ej2j3d3�d4d5�ZMdIej2j3e>e e5 e6e e> e6e8e8e ejNjO ee8e>f e ej0j? e e> e e> ej2j3d6�d7d8�ZNejPjQej0jRej2j3e e6 e e5 e5e d9�d:d;�ZSdddddde"jTdfe>ejPjQe ej2j3 e6e e5 e e5 e e> e6e"e ej0j? dd<� d=d>�ZUdS )JzTalk to a DNS server.� N)�Any�Dict�Optional�Tuple�Union�cast)� NullContext) � BadResponse� HTTPVersion�NoDOH�NoDOQ�UDPMode� _check_status�_compute_times�_make_dot_ssl_context�_matches_destination� _remaining�have_doh�sslc C sN |s|rF|d u r>| t jkr d}n | t jkr0d}ntd| � ���||fS d S d S )Nz0.0.0.0z::zunknown address family )�socket�AF_INET�AF_INET6�NotImplementedError)�af�address�port� r �~/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/dns/asyncquery.py� _source_tuple> s r c C s* | d ur"|st � � }t| | d�S d S d S �Nr )�time�max)� expiration�nowr r r �_timeoutN s r$ )�sock�what� destinationr" �returnc � s@ t |tjj�r|�� }t�� }| �||t||��I dH }||fS )a� Send a DNS message to the specified UDP socket. *sock*, a ``dns.asyncbackend.DatagramSocket``. *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. The expiration value is meaningless for the asyncio backend, as asyncio's transport sendto() never blocks. Returns an ``(int, float)`` tuple of bytes sent and the sent time. N)� isinstance�dns�message�Message�to_wirer �sendtor$ )r% r& r' r" � sent_time�nr r r �send_udpW s r1 F� ) r% r' r" �ignore_unexpected�one_rr_per_rrset�keyring� request_mac�ignore_trailing�raise_on_truncation� ignore_errors�queryr( c � s� d} | � dt|��I dH \} } t| j| ||�s0qt�� } z tjj| |||||d�}W nn tjjy� } z6| r�| dur�| � |�� �s�W Y d}~qn� W Y d}~n&d}~0 t y� | r�Y qn� Y n0 | r�| dur�| � |�s�q|| | fS )aj Read a DNS message from a UDP socket. *sock*, a ``dns.asyncbackend.DatagramSocket``. See :py:func:`dns.query.receive_udp()` for the documentation of the other parameters, and exceptions. Returns a ``(dns.message.Message, float, tuple)`` tuple of the received message, the received time, and the address where the message arrived from. r2 � N)r5 r6 r4 r7 r8 ) �recvfromr$ r �familyr r* r+ � from_wire� Truncated� is_response� Exception)r% r' r" r3 r4 r5 r6 r7 r8 r9 r: �wireZ from_address� received_time�r�er r r � receive_udpu s@ �� �� � rF �5 )�q�where�timeoutr �source� source_portr3 r4 r7 r8 r% �backendr9 r( c � s$ | � � } t|�\}}tj�|�}t||f|�}| r<t| �}nJ| sJtj�� } t |||�}| � � rh||f}nd}| � |t j d||�I dH }|4 I dH �v}t|| ||�I dH t|||||| j| j|| | | � I dH \}}}|| |_| s�| �|�s�t�|W d �I dH S 1 I dH �s0 Y dS )aF Return the response obtained after sending a query via UDP. *sock*, a ``dns.asyncbackend.DatagramSocket``, or ``None``, the socket to use for the query. If ``None``, the default, a socket is created. Note that if a socket is provided, the *source*, *source_port*, and *backend* are ignored. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.udp()` for the documentation of the other parameters, exceptions, and return type of this method. Nr )r- r r* �inet�af_for_address�_lltupler � asyncbackend�get_default_backendr Z datagram_connection_required� make_socketr � SOCK_DGRAMr1 rF r5 �macr r@ r )rH rI rJ r rK rL r3 r4 r7 r8 r% rM r9 rB � begin_timer" r r' �cm�stuple�dtuple�srD rC �_r r r �udp� s@ � r\ )rH rI rJ r rK rL r3 r4 r7 �udp_sock�tcp_sockrM r9 r( c � st z0t | ||||||||d| | | � I dH } | dfW S tjjyn t| |||||||| | � I dH } | df Y S 0 dS )a� Return the response to the query, trying UDP first and falling back to TCP if UDP results in a truncated response. *udp_sock*, a ``dns.asyncbackend.DatagramSocket``, 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 the *source*, *source_port*, and *backend* are ignored for the UDP query. *tcp_sock*, a ``dns.asyncbackend.StreamSocket``, 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 *where*, *source*, *source_port*, and *backend* are ignored for the TCP query. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.udp_with_fallback()` for the documentation of the other parameters, exceptions, and return type of this method. TNF)r\ r* r+ r? �tcp)rH rI rJ r rK rL r3 r4 r7 r] r^ rM r9 �responser r r �udp_with_fallback� s> #� � ra )r% r& r" r( c � s\ t |tjj�r |jdd�}nt|��dd�| }t�� }| �|t ||��I dH t|�|fS )z�Send a DNS message to the specified TCP socket. *sock*, a ``dns.asyncbackend.StreamSocket``. See :py:func:`dns.query.send_tcp()` for the documentation of the other parameters, exceptions, and return type of this method. T)Zprepend_length� �bigN) r) r* r+ r, r- �len�to_bytesr �sendallr$ )r% r& r" �tcpmsgr/ r r r �send_tcp8 s rh c � sL d}|dkrH| � |t|��I dH }|dkr2td��|t|� }|| }q|S )z|Read the specified number of bytes from stream. Keep trying until we either get the desired amount, or we hit EOF. r2 r NZEOF)�recvr$ �EOFErrorrd )r% �countr" rZ r0 r r r � _read_exactlyQ s rl )r% r" r4 r5 r6 r7 r( c � sX t | d|�I dH }t�d|�\}t | ||�I dH }t�� } tjj|||||d�} | | fS )z�Read a DNS message from a TCP socket. *sock*, a ``dns.asyncbackend.StreamSocket``. See :py:func:`dns.query.receive_tcp()` for the documentation of the other parameters, exceptions, and return type of this method. rb N�!H�r5 r6 r4 r7 )rl �struct�unpackr r* r+ r> ) r% r" r4 r5 r6 r7 �ldata�lrB rC rD r r r � receive_tcp_ s �rs ) rH rI rJ r rK rL r4 r7 r% rM r( c � s | � � } t|�\} } |r0|�� I dH t|�} nJtj�|�}t|||�}||f}| s^tj� � } | � |t j d|||�I dH } | 4 I dH �d}t || | �I dH t|| || j| j|�I dH \}}|| |_| �|�s�t�|W d �I dH S 1 I dH � s�0 Y dS )aO Return the response obtained after sending a query via TCP. *sock*, a ``dns.asyncbacket.StreamSocket``, or ``None``, the socket to use for the query. If ``None``, the default, a socket is created. Note that if a socket is provided *where*, *port*, *source*, *source_port*, and *backend* are ignored. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.tcp()` for the documentation of the other parameters, exceptions, and return type of this method. Nr )r- r � getpeernamer r* rN rO r rQ rR rS r � SOCK_STREAMrh rs r5 rU r r@ r )rH rI rJ r rK rL r4 r7 r% rM rB rV r" rW r rX rY rZ rD rC r r r r_ } s, � � r_ �U T)rH rI rJ r rK rL r4 r7 r% rM � ssl_context�server_hostname�verifyr( c � s� t |�\} }|rt|�}n`| du r,t| | �} tj�|�}t|||�}||f}| sZtj�� } | � |t j d|||| | �I dH }|4 I dH �T}t |�}t | ||||||||| � I dH }t�� }|| |_|W d �I dH S 1 I dH s�0 Y dS )a� Return the response obtained after sending a query via TLS. *sock*, an ``asyncbackend.StreamSocket``, 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 connected SSL stream socket, and *where*, *port*, *source*, *source_port*, *backend*, *ssl_context*, and *server_hostname* are ignored. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.tls()` for the documentation of the other parameters, exceptions, and return type of this method. Nr )r r r r* rN rO r rQ rR rS r ru r$ r_ r )rH rI rJ r rK rL r4 r7 r% rM rw rx ry rV r" rW r rX rY rZ r` Zend_timer r r �tls� sJ � � rz zdns.asyncresolver.Resolver)�resolverr( c C s | d u rdd l }|j�� } | S r )Zdns.asyncresolverZ asyncresolver�Resolver)r{ r* r r r �_maybe_get_resolver� s r} i� z /dns-queryzhttpx.AsyncClient)rH rI rJ r rK rL r4 r7 �client�path�postry �bootstrap_addressr{ r= � http_versionr( c " � sB zt j�|�}W n ty& d}Y n0 |dur|t j�|�r||tjkr\d|� d|� | � �}q�|tjkr�d|� d|� | � �}n|}i }| du r�tj � |�}|j du r�td��t j�|j �r�|j } |j |d< |j dur�|j }|t jks�|t jk�r`t�s`| du �r<t| �} |j du�sJ �| �|j |�I dH }t�t|�� ��} t| | |||||||| | d� I dH S t�sjt�|�r�t|tj��s�td ��| � � }d d i}|t j t jfv }|t j t jfv }t j � � }|du �r�d}d }n|}|}|�r�t!|�} n.|�"� |||| || | |d �} tj||| | d�} | 4 I dH ��} | �rh|�#d t$t%|��d�� |�&| j'||||d�|�I dH } n<t(�)|��*d�}|�+� } |�&| j,||d| i|d�|�I dH } W d �I dH �q�1 I dH �s�0 Y | j-dk �s�| j-dk�rt|� d| j-� d| j.����t j/j0| j.| j1| j2||d�}!| j3�4� |!_5| �6|!��s>t7�|!S )a� Return the response obtained after sending a query via DNS-over-HTTPS. *client*, a ``httpx.AsyncClient``. If provided, the client to use for the query. Unlike the other dnspython async functions, a backend cannot be provided in this function because httpx always auto-detects the async backend. See :py:func:`dns.query.https()` for the documentation of the other parameters, exceptions, and return type of this method. Nzhttps://�:z https://[z]:zno hostname in URLZ sni_hostname)ry r� z.session parameter must be an httpx.AsyncClient�acceptzapplication/dns-messager )� local_address�http1�http2ry � local_portr� r{ r= )r� r� ry � transport)z content-typezcontent-length)�headers�content� extensions� =r* )r� �paramsr� �� i+ z responded with status code z Response body: rn )8r* rN rO � ValueErrorZ is_addressr r r �urllib�parse�urlparse�hostnamer r ZH3�DEFAULTr r} � resolve_name�random�choice�list� addresses�_http3r r) �httpxZ AsyncClientr- ZH1ZH2rQ rR r Zget_transport_class�update�strrd �wait_forr� �base64�urlsafe_b64encode�rstrip�decode�get� status_coder� r+ r> r5 r6 �elapsed� total_secondsr r@ r )"rH rI rJ r rK rL r4 r7 r~ r r� ry r� r{ r= r� r �urlr� �parsedZanswersrB r� Zh1Zh2rM r� r� rW r� Z the_clientr` ZtwirerD r r r �https s� �� � � ���� ��8 ��� r� )rH rI r� rJ r rK rL r4 r7 ry rM r� r� r( c � s� t jjstd��tj�|�} | j} | jd ur2| j}d| _ | � � }t j� | �\}}|� 4 I d H �� }||| | dd�4 I d H ��}|� ||||�}t |�\}}|�|�I d H }|4 I d H �J |�||| � |�t|��I d H }t|�� ||� W d �I d H �q1 I d H �s 0 Y t�� }W d �I d H �qL1 I d H �sB0 Y t jj|| j| j||d�}W d �I d H �q�1 I d H �s�0 Y t|| d�|_| �|��s�t�|S )Nz DNS-over-HTTP3 is not available.r T)� verify_mode� server_nameZh3rn � ) r* �quic� have_quicr r� r� r� r� r �idr- �factories_for_backend�connectr � make_streamZsend_h3�receiver r r� r r+ r> r5 r6 r! r@ r )rH rI r� rJ r rK rL r4 r7 ry rM r� r� Z url_partsrB �cfactory�mfactory�context� the_manager�the_connection�startr" �stream�finishrD r r r r� � sB � >6�4 r� )rH rI rJ r rK rL r4 r7 � connectionry rM r� rx r( c � s� t jjstd��| dur$| du r$| } d| _| �� } |rLt jj}t jj}|}nt j�| �\}}|� 4 I dH ��}||| | d�4 I dH ��}|s�|�||||�}t |�\}}|� |�I dH }|4 I dH �> |� | d�I dH |� t |��I dH } W d �I dH �q1 I dH �s0 Y t�� }W d �I dH �qN1 I dH �sD0 Y t jj| | j| j||d�}W d �I dH �q�1 I dH �s�0 Y t|| d�|_| �|��s�t�|S )ai Return the response obtained after sending an asynchronous query via DNS-over-QUIC. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.quic()` for the documentation of the other parameters, exceptions, and return type of this method. z DNS-over-QUIC is not available.Nr )r� r� Trn r� )r* r� r� r r� r- Z null_factoryr� r� r r� �sendr� r r r+ r> r5 r6 r! r@ r )rH rI rJ r rK rL r4 r7 r� ry rM r� rx rB r� r� r� r� r� r� r" r� r� rD r r r r� � sJ � B6�4 r� )� txn_managerrZ r: �serialrJ r" r( c C s� |j d j}|tjjk}| �� }|�� } |jtj k} | r`t tj j |�} | � | dt|��I dH n4t tj j|�} t�dt| ��| } | �| |�I dH tj�| ||| ���}d}d}|�spt|�\}}|du s�|dur�||kr�|}| �rt|�}| �d|�I dH \}}n2t| d|�I dH }t�d|�\}t| ||�I dH }tjj||j |j d||| |d�}|� |�}|V |j }q�|j �r�|j �s�tj!�"d ��W d � n1 �s�0 Y dS ) z'Given a socket, does the zone transfer.r Nrm Fr; rb T)r5 r6 �xfr�origin�tsig_ctx�multir4 z missing TSIG)#�question�rdtyper* � rdatatype�IXFRZfrom_wire_originr- �typer rT r rQ �DatagramSocketr. r$ � StreamSocketro �packrd rf r� ZInboundr r< rl rp r+ r> r5 rU Zprocess_messager� Zhad_tsig� exceptionZ FormError)r� rZ r: r� rJ r" r� Zis_ixfrr� rB Zis_udpr] r^ rg Zinbound�doner� r[ Z mexpirationZrwirerq rr rD r r r � _inbound_xfr( sV ��� r� ) rI r� r: r rJ �lifetimerK rL �udp_moderM r( c � s� |du rt j�|�\}} n t j�|�} t j�| �} t| ||�} | |f} | sTt j�� } t |�\}}|j d j t j j k�r@|tjk�r@| �| tjd| | t|��I dH }|4 I dH �z z:t|||| ||�2 z 3 dH W }q�6 W W d �I dH dS t jj�y |tjk�r � Y n0 W d �I dH �q@1 I dH �s60 Y | �| tjd| | t|��I dH }|4 I dH �< t|||| ||�2 z3 dH W }�q�6 W d �I dH �q�1 I dH �s�0 Y dS )am Conduct an inbound transfer and apply it via a transaction from the txn_manager. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.inbound_xfr()` for the documentation of the other parameters, exceptions, and return type of this method. Nr )r* r� Z make_queryZextract_serial_from_queryrN rO r rQ rR r r� r� r� r� r �NEVERrS r rT r$ r� ZUseTCPZONLYru )rI r� r: r rJ r� rK rL r� rM r� r rX rY r[ r" rZ r r r � inbound_xfr^ s: "� � 6� r� )N)N) NNFFNr2 FFFN) NrG Nr FFFFNNF) NrG Nr FFFNNNF)N)NFNr2 F)NrG Nr FFNN) Nrv Nr FFNNNNT) Nrv Nr FFTNNT) Nrv Nr FFNTNNN)V�__doc__r� � contextlibr� r ro r � urllib.parser� �typingr r r r r r Zdns.asyncbackendr* Z dns.exceptionZdns.inetZ dns.messageZdns.nameZdns.quicZ dns.rcodeZdns.rdataclassZ dns.rdatatypeZdns.transactionZdns._asyncbackendr Z dns.queryr r r r r r r r r r r r r� rN Zlow_level_address_tuplerP r r$ rQ r� r+ r, �bytes�float�intr1 �bool�name�NameZtsig�KeyrF r� �Backendr\ r� ra rh rl rs r_ � SSLContextrz r} � AF_UNSPECr� r� r� r� ZAsyncQuicConnectionZ transactionZTransactionManagerZSocketr� r� r� r r r r �<module> sX 8 � � � � @ � � E � � G � � �� ! � � ; � � G� � � + � � 8 � � E� 9� �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка