관리-도구
편집 파일: _trio_backend.cpython-38.pyc
U /?�fM � @ 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 k rt �| �S tj�� S d S �N)r Z move_on_after�dns� _asyncbackendZ NullContext��timeout� r �?/opt/hc_python/lib/python3.8/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 � �|j� || _d S r )�super�__init__�family�socket)�selfr �� __class__r r r ! s zDatagramSocket.__init__c � sB t |��" | j�||�I d H W 5 Q R � S Q R X tjj|d��d S �Nr )r r �sendtor � exception�Timeout)r �what� destinationr r r r r % s &�zDatagramSocket.sendtoc � s@ t |�� | j�|�I d H W 5 Q R � S Q R X tjj|d��d S r )r r �recvfromr r r �r �sizer r r r r , s $zDatagramSocket.recvfromc � s | j �� d S r )r �close�r r r r r 1 s zDatagramSocket.closec � s | j �� S r )r � getpeernamer r r r r 4 s zDatagramSocket.getpeernamec � s | j �� S r )r � getsocknamer r r r r 7 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 @ sF e Zd Zddd�Zdd� Zdd� Zdd � Zd d � Zd d � Zdd� Z dS )� StreamSocketFc C s || _ || _|| _d S r )r �stream�tls)r r r) r* r r r r ? s zStreamSocket.__init__c � s@ t |�� | j�|�I d H W 5 Q R � S Q R X tjj|d��d S r )r r) Zsend_allr r r )r r r r r r �sendallD s $zStreamSocket.sendallc � s@ t |�� | j�|�I d H W 5 Q R � S Q R X tjj|d��d S r )r r) Z receive_somer r r r r r r �recvI s $zStreamSocket.recvc � s | j �� I d H d S r )r) �acloser r r r r N s zStreamSocket.closec � s$ | j r| jjj�� S | jj�� S d S r )r* r) �transport_streamr r r r r r r Q s zStreamSocket.getpeernamec � s$ | j r| jjj�� S | jj�� S d S r )r* r) r. r r r r r r r W s zStreamSocket.getsocknamec � s< | j r4t|�� | j�� I d H W 5 Q R X | j�� S t�d S r )r* r r) � do_handshaker# r! r" r r r r# ] s zStreamSocket.getpeercertN)F) r$ r% r& r r+ r, r r r r# r r r r r( > 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 q 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 ]�} zvtj�| �} |d k s�| j dkr�|| j f} nd } | |f}t d|�}t|�}t� �| tjd| ||�I d H }t|j�W S tk �r Y q�Y q�X q�tj�d S )N)r Zlifetimer g @)r0 r �inetZ is_address�appendr6 r2 r7 Zaf_for_addressr5 � resolve_name� addressesr4 r1 �Backend� make_socketr � SOCK_STREAM�_CoreTrioStreamr) � Exception�httpcoreZ ConnectError)r �host�portr Z local_address�socket_optionsr> �_Z expirationr Zanswers�address�af�sourcer Zattempt_expiration�sockr r r � connect_tcpx sJ � � z_NetworkBackend.connect_tcpc � s t �d S r r )r �pathr rG 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 rQ � s z_NetworkBackend.sleep)N)N)r$ r% r& r rM rO rQ r' r r r r r3 p s � % � r3 c s* e Zd Zdddejd�� fdd� Z� ZS )�_HTTPTransportr N)r9 r: r8 r c s> |d krdd l }|j�� }t� j||� t||||�| j_d S )Nr )Zdns.asyncresolverZ asyncresolver�Resolverr r r3 �_poolZ_network_backend)r r9 r: r8 r �args�kwargsr r r r r � s �z_HTTPTransport.__init__)r$ r% r& r � AF_UNSPECr r' r r r r rS � s �rS c @ s6 e Zd Zdd� Zd dd�Zdd� Zd d � Zd d � ZdS )r? c C s dS )Nr r r r r r �name� s z Backend.namer Nc � s4 t j�|||�} d } zl|r0| �t||��I d H |tjkr~d} t|�� | �t||��I d H d} W 5 Q R X | s~tjj |d��W n t k r� | � � � Y nX |tj kr�t | �S |tjk�r t �| �} d} |�rd} zt j| ||d�} W n& t k �r | �� I d H � Y nX t|| | �S tdd|� � ��d S )NFTr )�server_hostnamezunsupported socket ztype )r r �bind�_lltuplerA r �connectr r r rC r � SOCK_DGRAMr Z SocketStreamZ SSLStreamr- r( r! ) r rJ �socktype�protorK r r � ssl_contextrZ �sr) � connectedr* r r r r@ � sJ � � �zBackend.make_socketc � s t �|�I d H d S r rP )r �intervalr r r rQ � s z Backend.sleepc C s t S r )rS r r r r �get_transport_class� s zBackend.get_transport_classc � s8 t |�� |I d H W 5 Q R � S Q R X 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& rY r@ rQ re rf r r r r r? � s � /r? )$�__doc__r r Z trio.socketZdns._asyncbackendr Z dns._featuresZ dns.exceptionZdns.inetZ _featuresZhave� ImportErrorr r; Zlow_level_address_tupler\ r r r( rD Zhttpcore._backends.trioZhttpxZAsyncNetworkBackendZ_CoreAsyncNetworkBackendZ _backendsZ TrioStreamrB Z dns.queryr0 r1 r2 r3 ZAsyncHTTPTransportrS Z NullTransportr? r r r r �<module> s0 ( 4