| Server IP : 192.158.238.246 / Your IP : 3.141.38.5 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/python37/lib64/python3.7/site-packages/aiohttp/__pycache__/ |
Upload File : |
B
�k�a� � @ s� U d dl Z d dlZd dlmZmZmZmZmZmZ ddl m
Z
ddl m Z dZ
y d dlZW n ek
rr dZY nX dZG dd � d e
�ZG d
d � d e
�Zeeeef Zer�eneZeed < dS )
� N)�Any�Dict�List�Optional�Type�Union� )�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 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 �C/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/resolver.py�__init__ s zThreadedResolver.__init__r )�hostname�port�familyr c
� s� | j j||tj|tjd�I d H }g }x�|D ]�\}}}}}|tjkr�t|�dk rPq*|d rzt�|tjtj B �\} }
t
|
�}q�|d d� \} }n|tj ks�t �|\} }|�
|| |||tjtjB d�� q*W |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�AssertionError�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 )Nr )r r r r �closeJ s zThreadedResolver.close)N)�__name__�
__module__� __qualname__�__doc__r �asyncio�AbstractEventLoopr r r( �strr' r r r r0 r1 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_queryr0 )r r r9 r: r r r r Q s
zAsyncResolver.__init__r )r r r r c
� s� y| j �||�I d H }W nL tjjk
rd } z*t|j�dkrF|jd nd}t|�|�W d d }~X Y nX g }x.|jD ]$}|� ||||dt
j t
j B d�� qrW |s�td��|S )Nr zDNS lookup failedr )r r r r r r )
r> r; r< �error�DNSErrorr# r9 �OSErrorZ addressesr* r r+ r, ) r r r r �resp�exc�msgr- r/ r r r r0 a s" zAsyncResolver.resolvec
� s� |t jkrd}nd}y| j�||�I d H }W nL tjjk
rx } z*t|j�dkrZ|jd nd}t |�|�W d d }~X Y nX g }x(|D ] } |�
|| j ||dt j d�� q�W |s�t d��|S )NZAAAA�Ar zDNS lookup failedr )r r r r r r )
r r" r> �queryr< rA rB r# r9 rC r* r r+ )
r r r r ZqtyperD rE rF r- Zrrr r r r@ { s(
z!AsyncResolver._resolve_with_query)r c � s | j �� d S )N)r> �cancel)r r r r r1 � s zAsyncResolver.close)N)r2 r3 r4 r5 r r6 r7 r r r r( r8 r' r r r0 r@ r1 r r r r r N s
r r
)r6 r �typingr r r r r r �abcr Zhelpersr
�__all__r< � ImportErrorZaiodns_defaultr r Z _DefaultTyper
�__annotations__r r r r �<module> s
:Q