File: //home/arjun/projects/env/lib/python3.10/site-packages/aiohttp/__pycache__/resolver.cpython-310.pyc
o
+we� � @ s� U d dl Z d dlZd dlmZmZmZmZmZmZ ddl m
Z
ddl m Z dZ
zd dlZW n ey8 dZY nw dZG dd � d e
�ZG d
d � d e
�Zeeeef ZerWeneZeed < dS )
� N)�Any�Dict�List�Optional�Type�Union� )�AbstractResolver)�get_running_loop)�ThreadedResolver�
AsyncResolver�DefaultResolverFc @ sb e Zd ZdZddeej ddfdd�Zdej fde
d e d
e de e
e
ef 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 t |�| _d S �N)r
�_loop)�selfr � r �I/home/arjun/projects/env/lib/python3.10/site-packages/aiohttp/resolver.py�__init__ s zThreadedResolver.__init__r �hostname�port�familyc
� s� �| j j||tj|tjd�I d H }g }|D ]L\}}}}}|tjkrFt|�dk r(q|d r=t�|tjtj B �\} }
t
|
�}n|d d� \} }n |tj ksMJ �|\} }|� || |||tj
tjB d�� q|S )N)�typer �flags� � �r �hostr r �protor )r � getaddrinfo�socket� SOCK_STREAM�
AI_ADDRCONFIG�AF_INET6�len� getnameinfo�NI_NUMERICHOST�NI_NUMERICSERV�int�AF_INET�append�AI_NUMERICHOST�AI_NUMERICSERV) r r r r �infos�hosts�_r �addressr �_portr r r �resolve s> � �
�
�� zThreadedResolver.resolvec � s �d S r r �r r r r �closeJ s �zThreadedResolver.closer �r N)�__name__�
__module__� __qualname__�__doc__r �asyncio�AbstractEventLoopr r! r* �strr) r r r r3 r5 r r r r r s ����
�,r c @ s� e Zd ZdZ ddeej dededdfdd�Zd e j
fd
e d e d e de
ee ef fd
d�Zd e j
fd
e d e d e de
ee ef fdd�Zddd�ZdS )r z9Use the `aiodns` package to make asynchronous DNS lookupsNr �args�kwargsr c O sL t d u rtd��t|�| _t j|d|i|��| _t| jd�s$| j| _d S d S )Nz Resolver requires aiodns libraryr �
gethostbyname) �aiodns� RuntimeErrorr
r � DNSResolver� _resolver�hasattr�_resolve_with_queryr3 )r r r> r? r r r r Q s
�zAsyncResolver.__init__r r r r c
� s� �z | j �||�I d H }W n! tjjy. } zt|j�dkr#|jd nd}t|�|�d }~ww g }|jD ]}|� ||||dt
j t
j B d�� q4|sMtd��|S )Nr �DNS lookup failedr r )
rD r@ rA �error�DNSErrorr% r> �OSError� addressesr+ r! r, r- ) r r r r �resp�exc�msgr/ r1 r r r r3 a s, �
��
�� zAsyncResolver.resolvec
� s� �|t jkr d}nd}z | j�||�I d H }W n! tjjy8 } zt|j�dkr-|jd nd}t |�|�d }~ww g }|D ]} |�
|| j ||dt j d�� q=|sTt d��|S )N�AAAA�Ar rG r r )
r! r$ rD �queryrA rH rI r% r> rJ r+ r r, )
r r r r �qtyperL rM rN r/ �rrr r r rF { s2 �
���� z!AsyncResolver._resolve_with_queryc � s �| j �� d S r )rD �cancelr4 r r r r5 � s �zAsyncResolver.closer r6 )r7 r8 r9 r: r r; r< r r r! r* r= r) r r r3 rF r5 r r r r r N sB ����
�����
�����
� r r
)r; r! �typingr r r r r r �abcr �helpersr
�__all__rA � ImportError�aiodns_defaultr r � _DefaultTyper
�__annotations__r r r r �<module> s
�:Q