관리-도구
편집 파일: _asyncio_backend.cpython-38.pyc
U /?�f # � @ s" d Z ddlZddlZddlZddlZddlZddlZddlZej dkZ dd� Z G dd� d�Z dd � Z G d d � d ejj�ZG d d � d ejj�Zej�d��rddlZddlZddlZddlZejZejjjZddl m Z m Z m Z G dd� de�Z G dd� dej!�Z"nejj#Z"G dd� dejj$�Z$dS )z asyncio library query support� N�win32c C s, z t �� W S tk r& t �� Y S X d S �N)�asyncioZget_running_loop�AttributeErrorZget_event_loop� r r �B/opt/hc_python/lib/python3.8/site-packages/dns/_asyncio_backend.py�_get_running_loop s r c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )�_DatagramProtocolc C s d | _ d | _d S r )� transport�recvfrom��selfr r r �__init__ s z_DatagramProtocol.__init__c C s || _ d S r )r )r r r r r �connection_made s z!_DatagramProtocol.connection_madec C s$ | j r | j �� s | j �||f� d S r )r �doneZ set_result)r �data�addrr r r �datagram_received s z#_DatagramProtocol.datagram_receivedc C s | j r | j �� s | j �|� d S r )r r � set_exception)r �excr r r �error_received$ s z _DatagramProtocol.error_receivedc C sb | j r^| j �� s^|d krRzt�W q^ tk rN } z| j �|� W 5 d }~X Y q^X n | j �|� d S r )r r �EOFErrorr )r r �er r r �connection_lost( s z!_DatagramProtocol.connection_lostc C s | j �� d S r )r �closer r r r r 3 s z_DatagramProtocol.closeN) �__name__� __module__� __qualname__r r r r r r r r r r r s r c � sR |d k rDzt �| |�I d H W S t jk r@ tjj|d��Y qNX n | I d H S d S )N)�timeout)r �wait_for� TimeoutError�dns� exception�Timeout)� awaitabler r r r �_maybe_wait_for7 s r% c sL e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z � Z S )�DatagramSocketc s t � �|� || _|| _d S r )�superr r �protocol)r �familyr r( �� __class__r r r B s zDatagramSocket.__init__c � s | j �||� t|�S r )r �sendto�len)r �what� destinationr r r r r, G s zDatagramSocket.sendtoc � sN t � �� }z4| jjd ks t�|| j_t||�I d H |�� W �S d | j_X d S r )r Z create_futurer( r �AssertionErrorr% �result)r �sizer r r r r r L s zDatagramSocket.recvfromc � s | j �� d S r )r( r r r r r r W s zDatagramSocket.closec � s | j �d�S �NZpeername�r �get_extra_infor r r r � getpeernameZ s zDatagramSocket.getpeernamec � s | j �d�S �NZsocknamer4 r r r r � getsockname] s zDatagramSocket.getsocknamec � s t �d S r ��NotImplementedError�r r r r r � getpeercert` s zDatagramSocket.getpeercert) r r r r r, r r r6 r8 r< � __classcell__r r r* r r& A s r& c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )� StreamSocketc C s || _ || _|| _d S r )r) �reader�writer)r �afr? r@ r r r r e s zStreamSocket.__init__c � s" | j �|� t| j �� |�I d H S r )r@ �writer% Zdrain)r r. r r r r �sendallj s zStreamSocket.sendallc � s t | j�|�|�I d H S r )r% r? �read)r r2 r r r r �recvn s zStreamSocket.recvc � s | j �� d S r )r@ r r r r r r q s zStreamSocket.closec � s | j �d�S r3 �r@ r5 r r r r r6 t s zStreamSocket.getpeernamec � s | j �d�S r7 rF r r r r r8 w s zStreamSocket.getsocknamec � s | j �d�S )NZpeercertrF r; r r r r< z s zStreamSocket.getpeercertN) r r r r rC rE r r6 r8 r< r r r r r> d s r> Zdoh)�_compute_times� _expiration_for_this_attempt� _remainingc s8 e Zd Z� fdd�Zd dd�Zd dd�Zdd � Z� ZS ) �_NetworkBackendc s6 t � �� || _|| _|| _|| _|dkr2td��d S )Nr z9the asyncio transport for HTTPX cannot set the local port)r' r Z _local_port� _resolver�_bootstrap_address�_familyr: )r �resolver� local_port�bootstrap_addressr) r* r r r � s �z_NetworkBackend.__init__Nc � s� g }t |�\}}tj�|�r(|�|� nV| jd k r@|�| j� n>t|�}| j} |r^tj�|�} | j j || |d�I d H } | � � }|D ]f} zLt d|�} t| �}t �|�� t j| ||d�I d H } W 5 Q R X t| �W S tk r� Y q�X q�tj�d S )N)r) Zlifetimeg @)� remote_host� remote_portZ local_host)rG r! �inetZ is_address�appendrL rI rM Zaf_for_addressrK � resolve_name� addressesrH �anyioZ fail_after� connect_tcp�_CoreAnyIOStream� Exception�httpcoreZ ConnectError)r �host�portr Z local_address�socket_optionsrV �_Z expirationr) Zanswers�addressZattempt_expiration�streamr r r rX � s< � �z_NetworkBackend.connect_tcpc � s t �d S r r9 )r �pathr r^ r r r �connect_unix_socket� s z#_NetworkBackend.connect_unix_socketc � s t �|�I d H d S r )rW �sleep)r �secondsr r r rd � s z_NetworkBackend.sleep)N)N)r r r r rX rc rd r= r r r* r rJ � s � " � rJ c s* e Zd Zdddejd�� fdd� Z� ZS )�_HTTPTransportr N)rO rP rN r) c s> |d krdd l }|j�� }t� j||� t||||�| j_d S )Nr )Zdns.asyncresolverZ asyncresolver�Resolverr' r rJ �_poolZ_network_backend)r rO rP rN r) �args�kwargsr! r* r r r � s �z_HTTPTransport.__init__)r r r �socket� AF_UNSPECr r= r r r* r rf � s �rf c @ s> e Zd Zdd� Zddd�Zdd� Zd d � Zd d � Zd d� ZdS )�Backendc C s dS )Nr r r r r r �name� s z Backend.namer Nc � s� t � } |tjkrVtr,|d kr,tj�|�df}| jt||||d�I d H \} } t || | �S |tj kr�|d krpt d��t t j|d |d |||||d�|�I d H \} } t|| | �S tdd|� � ��d S )Nr )r) �protoZ remote_addrz'destination required for stream sockets� )�sslr) ro Z local_addr�server_hostnamezunsupported socket ztype )r rk � SOCK_DGRAM� _is_win32r! rS Z any_for_afZcreate_datagram_endpointr r& � SOCK_STREAM� ValueErrorr% r Zopen_connectionr> r: )r rA �socktypero �sourcer/ r � ssl_contextrr �loopr r( �r�wr r r � make_socket� s> � � � �zBackend.make_socketc � s t �|�I d H d S r )r rd )r �intervalr r r rd s z Backend.sleepc C s dS )NFr r r r r � datagram_connection_required s z$Backend.datagram_connection_requiredc C s t S r )rf r r r r �get_transport_class s zBackend.get_transport_classc � s t ||�I d H S r )r% )r r$ r r r r r s zBackend.wait_for)r NNNNN) r r r rn r} rd r r� r r r r r rm � s � /rm )%�__doc__r rk �sysZdns._asyncbackendr! Z dns._featuresZ dns.exceptionZdns.inet�platformrt r r r% Z _asyncbackendr& r> Z _featuresZhaverW r[ Zhttpcore._backends.anyioZhttpxZAsyncNetworkBackendZ_CoreAsyncNetworkBackendZ _backendsZ AnyIOStreamrY Z dns.queryrG rH rI rJ ZAsyncHTTPTransportrf Z NullTransportrm r r r r �<module> s2 # 5