Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/dns/__pycache__/_trio_backend.cpython-39.pyc
Ðазад
a h�h! � @ s d Z ddlZddlZddlZddlZddlZddlZddlZej � d�sPe d��dd� Z ej jZG dd� dejj�ZG d d � d ejj�Zej � d �r�ddlZddlZddlZejZejjjZdd lm Z m Z m Z G d d� de�Z G dd� dej �Z!nejj"Z!G dd� dejj#�Z#dS )z$trio async I/O library query support� N�trioztrio not found or too oldc C s | d urt �| �S tj�� S d S �N)r Z move_on_after�dns� _asyncbackendZ NullContext��timeout� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/dns/_trio_backend.py�_maybe_timeout s r c sL e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z � Z S )�DatagramSocketc s t � �|jtj� || _d S r )�super�__init__�family�socket� SOCK_DGRAM)�self�sock�� __class__r r r ! s zDatagramSocket.__init__c � s� t |��Z |d u r2| j�|�I d H W d � S | j�||�I d H W d � S W d � n1 sh0 Y tjj|d��d S �Nr )r r �send�sendtor � exception�Timeout)r �what� destinationr r r r r % s @�zDatagramSocket.sendtoc � sL t |��" | j�|�I d H W d � S 1 s00 Y tjj|d��d S r )r r �recvfromr r r �r �sizer r r r r / s 0zDatagramSocket.recvfromc � s | j �� d S r )r �close�r r r r r 4 s zDatagramSocket.closec � s | j �� S r )r � getpeernamer r r r r! 7 s zDatagramSocket.getpeernamec � s | j �� S r )r � getsocknamer r r r r" : s zDatagramSocket.getsocknamec � s t �d S r ��NotImplementedError�r r r r r � getpeercert= s zDatagramSocket.getpeercert) �__name__� __module__� __qualname__r r r r r! r" r& � __classcell__r r r r r s r c sN e Zd Zd� fdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zdd� Z � Z S )� StreamSocketFc s t � �|tj� || _|| _d S r )r r r � SOCK_STREAM�stream�tls)r r r- r. r r r r B s zStreamSocket.__init__c � sL t |��" | j�|�I d H W d � S 1 s00 Y tjj|d��d S r )r r- Zsend_allr r r )r r r r r r �sendallG s 0zStreamSocket.sendallc � sL t |��" | j�|�I d H W d � S 1 s00 Y tjj|d��d S r )r r- Z receive_somer r r r r r r �recvL s 0zStreamSocket.recvc � s | j �� I d H d S r )r- �acloser r r r r Q s zStreamSocket.closec � s$ | j r| jjj�� S | jj�� S d S r )r. r- �transport_streamr r! r r r r r! T s zStreamSocket.getpeernamec � s$ | j r| jjj�� S | jj�� S d S r )r. r- r2 r r" r r r r r" Z s zStreamSocket.getsocknamec � sP | j rHt|�� | j�� I d H W d � n1 s40 Y | j�� S t�d S r )r. r r- � do_handshaker& r$ r% r r r r& ` s . zStreamSocket.getpeercert)F) r' r( r) r r/ r0 r r! r" r& r* r r r r r+ A s r+ Zdoh)�_compute_times� _expiration_for_this_attempt� _remainingc s8 e Zd Z� fdd�Zd dd�Zd dd�Zdd � Z� ZS ) �_NetworkBackendc s& t � �� || _|| _|| _|| _d S r )r r � _local_port� _resolver�_bootstrap_address�_family)r �resolver� local_port�bootstrap_addressr r r r r t s z_NetworkBackend.__init__Nc � s" g }t |�\}}tj�|�r(|�|� nV| jd ur@|�| j� n>t|�}| j} |r^tj�|�} | j j || |d�I d H } | � � }|D ]�} zvtj�| �} |d us�| j dkr�|| j f} nd } | |f}t d|�}t|�}t� �| tjd| ||�I d H }t|j�W S t�y Y q�Y q�0 q�tj�d S )N)r Zlifetimer g @)r4 r �inetZ is_address�appendr: r6 r; Zaf_for_addressr9 � resolve_name� addressesr8 r5 �Backend� make_socketr r, �_CoreTrioStreamr- � Exception�httpcoreZ ConnectError)r �host�portr Z local_address�socket_optionsrB �_Z expirationr Zanswers�address�af�sourcer Zattempt_expirationr r r r � connect_tcp{ s< � � z_NetworkBackend.connect_tcpc � s t �d S r r# )r �pathr rJ r r r �connect_unix_socket� s z#_NetworkBackend.connect_unix_socketc � s t �|�I d H d S r �r �sleep)r �secondsr r r rS � s z_NetworkBackend.sleep)N)N)r' r( r) r rO rQ rS r* r r r r r7 s s � % � r7 c s* e Zd Zdddejd�� fdd� Z� ZS )�_HTTPTransportr N)r= r> r< r c sJ |d u r"|d u r"dd l }|j�� }t� j|i |�� t||||�| j_d S )Nr )Zdns.asyncresolverZ asyncresolver�Resolverr r r7 �_poolZ_network_backend)r r= r> r< r �args�kwargsr r r r r � s �z_HTTPTransport.__init__)r' r( r) r � AF_UNSPECr r* r r r r rU � s �rU c @ s6 e Zd Zdd� Zd dd�Zdd� Zd d � Zd d � ZdS )rC c C s dS )Nr r r r r r �name� s z Backend.namer Nc � sL t j�|||�} d } z�|r0| �t||��I d H |tjksB|d ur�d} t|��* | �t||��I d H d} W d � n1 s~0 Y | s�tjj |d��W n t y� | � � � Y n0 |tj kr�t | �S |tjk�r6t �| �} d} |�r*d} zt j| ||d�} W n$ t �y( | �� I d H � Y n0 t|| | �S tdd|� � ��d S )NFTr )�server_hostnamezunsupported socket ztype )r r �bind�_lltupler, r �connectr r r rF r r r Z SocketStreamZ SSLStreamr1 r+ r$ ) r rM �socktype�protorN r r � ssl_contextr\ �sr- � connectedr. r r r rD � sF "� � �zBackend.make_socketc � s t �|�I d H d S r rR )r �intervalr r r rS � s z Backend.sleepc C s t S r )rU r r r r �get_transport_class� s zBackend.get_transport_classc � sD t |�� |I d H W d � S 1 s(0 Y tjj|d��d S r )r r r r )r Z awaitabler r r r �wait_for� s (�zBackend.wait_for)r NNNNN)r' r( r) r[ rD rS rf rg r r r r rC � s � /rC )$�__doc__r r Z trio.socketZdns._asyncbackendr Z dns._featuresZ dns.exceptionZdns.inetZ _featuresZhave� ImportErrorr r? Zlow_level_address_tupler^ r r r+ rG Zhttpcore._backends.trioZhttpxZAsyncNetworkBackendZ_CoreAsyncNetworkBackendZ _backendsZ TrioStreamrE Z dns.queryr4 r5 r6 r7 ZAsyncHTTPTransportrU Z NullTransportrC r r r r �<module> s0 !( 4
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка