File: //usr/local/lib/python3.10/dist-packages/aiohttp/__pycache__/resolver.cpython-310.pyc
o
���g� � @ s� U d dl Z d dlZd dlmZmZmZmZmZmZm Z ddl
m Z m Z dZ
z d dlZeejd�ZW n
ey> dZdZY nw ejejB ZejejB ZG dd � d e �ZG d
d � d e �Zee eef ZergeneZ ee d < dS )
� N)�Any�Dict�List�Optional�Tuple�Type�Union� )�AbstractResolver�
ResolveResult)�ThreadedResolver�
AsyncResolver�DefaultResolver� getaddrinfoFc
@ s\ e Zd ZdZddeej ddfdd�Zdej fde
d e d
ej de
e fd d �Zdd
d�ZdS )r z�Threaded resolver.
Uses an Executor for synchronous getaddrinfo() calls.
concurrent.futures.ThreadPoolExecutor is used by default.
N�loop�returnc C s |pt �� | _d S �N)�asyncio�get_running_loop�_loop)�selfr � r �;/usr/local/lib/python3.10/dist-packages/aiohttp/resolver.py�__init__ s zThreadedResolver.__init__r �host�port�familyc � s� �| j j||tj|tjd�I d H }g }|D ]I\}}}}}|tjkrFt|�dk r(q|d r=| j �|t�I d H \} }
t |
�}n|d d� \} }n |tj
ksMJ �|\} }|� t || |||t
d�� q|S )N)�typer �flags� � ��hostnamer r r �protor )r r �socket� SOCK_STREAM�
AI_ADDRCONFIG�AF_INET6�len� getnameinfo�_NAME_SOCKET_FLAGS�int�AF_INET�appendr �_NUMERIC_SOCKET_FLAGS) r r r r �infos�hosts�_r# �address�
resolved_host�_portr r r �resolve! s@ � �
�
�� zThreadedResolver.resolvec � s �d S r r �r r r r �closeM s �zThreadedResolver.closer �r N)�__name__�
__module__� __qualname__�__doc__r r �AbstractEventLoopr r$ r, �strr+ �
AddressFamilyr r r5 r7 r r r r r s ����
�,r c @ s� e Zd ZdZ ddeej dededdfdd�Zd e j
fd
e d e d e j
dee fd
d�Zd e j
fd
e d e d e deee ef fdd�Zddd�ZdS )r
z9Use the `aiodns` package to make asynchronous DNS lookupsNr �args�kwargsr c O s> t d u rtd��t j|i |��| _t| jd�s | j| _d S d S )Nz Resolver requires aiodns library�
gethostbyname)�aiodns� RuntimeError� DNSResolver� _resolver�hasattr�_resolve_with_queryr5 )r r r@ rA r r r r T s �zAsyncResolver.__init__r r r r c � sD �z| j j||tj|tjd�I d H }W n" tjjy5 } zt|j �dkr)|j d nd}t
d |�|�d }~ww g }|j D ]]}|j } |j
}|tjkryt| �dkrm| d rm| j �| d �d�g| dd � �R t�I d H }
|
j} n | d �d�} | d }n|tjks�J �| d �d�} | d }|�t|| ||dtd�� q;|s�t
d d��|S )N)r r r r r �DNS lookup failedr r �asciir! )rF r r$ r% r& rC �error�DNSErrorr( r@ �OSError�nodes�addrr r' r) �decoder* �noder, r- r r. ) r r r r �resp�exc�msgr0 rQ r2 �resultr3 r r r r5 c sV �� ��
�
��
zAsyncResolver.resolvec
� s� �|t jkr d}nd}z | j�||�I d H }W n" tjjy9 } zt|j�dkr-|jd nd}t d |�|�d }~ww g }|D ]} |�
|| j ||dt j d�� q>|sVt d d��|S )N�AAAA�Ar rI r r! )
r$ r' rF �queryrC rK rL r( r@ rM r- r �AI_NUMERICHOST)
r r r r �qtyperR rS rT r0 �rrr r r rH � s2 �
����
z!AsyncResolver._resolve_with_queryc � s �| j �� d S r )rF �cancelr6 r r r r7 � s �zAsyncResolver.closer r8 )r9 r: r; r< r r r= r r r$ r, r> r+ r? r r r5 r rH r7 r r r r r
Q sB ����
�����
�4����
� r
r ) r r$ �typingr r r r r r r �abcr
r �__all__rC rG rE �aiodns_default� ImportErrorrY �AI_NUMERICSERVr. �NI_NUMERICHOST�NI_NUMERICSERVr* r r
� _DefaultTyper �__annotations__r r r r �<module> s$
$ � :i