| Server IP : 192.158.238.246 / Your IP : 3.138.36.87 Web Server : LiteSpeed System : Linux uniform.iwebfusion.net 4.18.0-553.27.1.lve.1.el8.x86_64 #1 SMP Wed Nov 20 15:58:00 UTC 2024 x86_64 User : jenniferflocom ( 1321) PHP Version : 8.1.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python38/lib64/python3.8/site-packages/aiohttp/__pycache__/ |
Upload File : |
U
'�7` � @ s� d dl Z d dlZd dlmZmZmZmZ ddlmZ ddl m
Z
dZ z d dl Z W n e
k
rh dZ Y nX dZG dd � d e�ZG d
d � d e�Zer�eneZdS ) � N)�Any�Dict�List�Optional� )�AbstractResolver)�get_running_loop)�ThreadedResolver�
AsyncResolver�DefaultResolverFc @ s^ e Zd ZdZd
eej dd�dd�Zdej fe
e e e e
e
ef d�dd �Zdd
�d d �ZdS )r zsUse Executor for synchronous getaddrinfo() calls, which defaults to
concurrent.futures.ThreadPoolExecutor.
N)�loop�returnc C s t |�| _d S �N)r �_loop)�selfr � r �C/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/resolver.py�__init__ s zThreadedResolver.__init__r )�hostname�port�familyr
c
� s� | j j||tj|tjd�I d H }g }|D ]r\}}}}}|tjkrj|d rjt�|tjtjB �\} }
t |
�}n|d d� \} }|�
|| |||tj tj B d�� q(|S )N)�typer �flags� � �r �hostr r �protor )
r � getaddrinfo�socket� SOCK_STREAM�
AI_ADDRCONFIG�AF_INET6� getnameinfo�NI_NUMERICHOST�NI_NUMERICSERV�int�append�AI_NUMERICHOST�AI_NUMERICSERV) r r r r Zinfos�hosts�_r �addressr Z_portr r r �resolve s4 �
�
�� zThreadedResolver.resolve�r
c � s d S r r �r r r r �close@ s zThreadedResolver.close)N)�__name__�
__module__� __qualname__�__doc__r �asyncio�AbstractEventLoopr r �AF_INET�strr& r r r r- r0 r r r r r s � � $r c @ s� e Zd ZdZdeej eedd�dd�Zde j
fe e e e
ee ef d�dd �Zde j
fe e e e
ee ef d�d
d �Zdd �d
d�ZdS )r
z9Use the `aiodns` package to make asynchronous DNS lookupsN)r �args�kwargsr
c O sH t d krtd��t|�| _t j|d|i|��| _t| jd�sD| j| _d S )Nz Resolver requires aiodns libraryr �
gethostbyname) �aiodns� RuntimeErrorr r Z DNSResolver� _resolver�hasattr�_resolve_with_queryr- )r r r9 r: r r r r G s
zAsyncResolver.__init__r )r r r r
c
� s� z| j �||�I d H }W nL tjjk
rd } z*t|j�dkrF|jd nd}t|�|�W 5 d }~X Y nX g }|jD ]$}|� ||||dt
j t
j B d�� qp|s�td��|S )Nr �DNS lookup failedr r )
r> r; r< �error�DNSError�lenr9 �OSErrorZ addressesr' r r( r) ) r r r r �resp�exc�msgr* r, r r r r- W s&
�� zAsyncResolver.resolvec
� s� |t jkrd}nd}z| j�||�I d H }W nL tjjk
rx } z*t|j�dkrZ|jd nd}t |�|�W 5 d }~X Y nX g }|D ] } |�
|| j ||dt j d�� q�|s�t d��|S )NZAAAA�Ar rA r r )
r r" r> �queryr< rB rC rD r9 rE r' r r( )
r r r r ZqtyperF rG rH r* Zrrr r r r@ q s,
�� z!AsyncResolver._resolve_with_queryr. c � s
| j �� S r )r> �cancelr/ r r r r0 � s zAsyncResolver.close)N)r1 r2 r3 r4 r r5 r6 r r r r7 r8 r& r r r- r@ r0 r r r r r
D s2 �� � � � � r
)r5 r �typingr r r r �abcr Zhelpersr �__all__r< � ImportErrorZaiodns_defaultr r
r r r r r �<module> s
0Q