0x1998 - MANAGER
Düzenlenen Dosya: resolver.cpython-37.opt-1.pyc
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 Z getaddrinfo�socketZ SOCK_STREAMZ AI_ADDRCONFIG�AF_INET6�lenZ getnameinfoZNI_NUMERICHOSTZNI_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 r* r+ 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 r3 r4 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 ) r8 r5 r6 �error�DNSErrorr r3 �OSErrorZ addressesr$ r r% r& ) r r r r �resp�exc�msgr' r) r r r r* 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 r8 Zqueryr6 r; r< r r3 r= r$ r r% ) r r r r Zqtyper> r? r@ r' Zrrr r r r: { s( z!AsyncResolver._resolve_with_query)r c � s | j �� d S )N)r8 �cancel)r r r r r+ � s zAsyncResolver.close)N)r, r- r. r/ r r0 r1 r r r r" r2 r! r r r* r: r+ r r r r r N s r r )r0 r �typingr r r r r r �abcr Zhelpersr �__all__r6 � ImportErrorZaiodns_defaultr r Z _DefaultTyper �__annotations__r r r r �<module> s :Q
geri dön