| Server IP : 54.37.205.81 / Your IP : 216.73.216.76 Web Server : nginx/1.22.1 System : Linux vps-249481fa 6.1.0-50-cloud-amd64 #1 SMP PREEMPT_DYNAMIC Debian 6.1.176-1 (2026-07-02) x86_64 User : debian ( 1000) PHP Version : 8.2.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /usr/lib/python3/dist-packages/tornado/platform/__pycache__/ |
Upload File : |
�
��b�
� � � d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlm Z m
Z
d dl Z e j rd dl m
Z
mZmZmZmZ G d� de � � ZdS ) � N)�Future)�gen)�IOLoop)�Resolver� is_valid_ip)� Generator�Any�List�Tuple�Dictc
�| � e Zd ZdZdd�Zdedededdfd�Zded eddfd
�Ze j
dd e d
ededdfd�� � Z dS )�
CaresResolvera� Name resolver based on the c-ares library.
This is a non-blocking and non-threaded resolver. It may not produce
the same results as the system resolver, but can be used for non-blocking
resolution when threads cannot be used.
c-ares fails to resolve some names when ``family`` is ``AF_UNSPEC``,
so it is only recommended for use in ``AF_INET`` (i.e. IPv4). This is
the default for ``tornado.simple_httpclient``, but other libraries
may default to ``AF_UNSPEC``.
.. versionchanged:: 5.0
The ``io_loop`` argument (deprecated since version 4.1) has been removed.
.. deprecated:: 6.2
This class is deprecated and will be removed in Tornado 7.0. Use the default
thread-based resolver instead.
�returnNc � � t j � � | _ t j | j �� � | _ i | _ d S )N)�
sock_state_cb)r �current�io_loop�pycares�Channel�_sock_state_cb�channel�fds)�selfs �@/usr/lib/python3/dist-packages/tornado/platform/caresresolver.py�
initializezCaresResolver.initialize# s3 � � �~�'�'�� � ��T�5H�I�I�I�� ������ �fd�readable�writablec �J � |r t j nd|r t j ndz }|s$| j � |� � | j |= d S || j v r'| j � ||� � || j |< d S | j � || j |� � || j |< d S )Nr ) r �READ�WRITEr �remove_handlerr �update_handler� add_handler�_handle_events)r r r r �states r r z CaresResolver._sock_state_cb( s� � � (�/����a�H�4S�F�L�L�RS�T��� !� �L� '� '�� +� +� +���� � � �
�4�8�^�^� �L� '� '��E� 2� 2� 2� �D�H�R�L�L�L� �L� $� $�R��)<�e� D� D� D� �D�H�R�L�L�Lr �eventsc � � t j }t j }|t j z r|}|t j z r|}| j � ||� � d S �N)r �ARES_SOCKET_BADr r! r" r �
process_fd)r r r( �read_fd�write_fds r r& z CaresResolver._handle_events4 sX � ��)���*�� �F�K� � ��G� �F�L� � ��H� � � � ���2�2�2�2�2r r �host�port�familyz*Generator[Any, Any, List[Tuple[int, Any]]]c # �6 �
K � t |� � r|g}nrt � � �
| j � ||�
fd�� � �
V �\ }}|r5t d|�dt
j � |� � �d|��� � �|j }g }|D ]�}d|v r
t j
} n d|v r
t j } n t j } |t j k r|| k rt d|| fz � � �|�
t j t | � � ||ff� � ��|S )Nc �2 �� �� | |f� � S r* )�
set_result)�result�error�futs �r �<lambda>z'CaresResolver.resolve.<locals>.<lambda>G s �� �C�N�N�F�E�?�4S�4S� r zC-Ares returned error z: z while resolving �.�:z%Requested socket family %d but got %d)r r r �
gethostbyname�IOErrorr �errno�strerror� addresses�socket�AF_INET�AF_INET6� AF_UNSPEC�append�typing�cast�int) r r/ r0 r1 r? r5 r6 �addrinfo�address�address_familyr7 s @r �resolvezCaresResolver.resolve= s` �� � � � �t� � � )� ��I�I� �(�(�C� �L� &� &��f� S� S� S� S�
�
�
� #&�I�I�M�F�E��
� �g� �u�u�g�m� 4� 4�U� ;� ;� ;� ;�T�T�C�� � � �(�I��� � Q� Q�G��g�~�~�!'� ����� � �!'� ���!'�!1����)�)�)�f��.F�.F� �;�v�~�>V�V�� � �
�O�O�V�[��n� =� =���� O� P� P� P� P��r )r N)r )
�__name__�
__module__� __qualname__�__doc__r rG �boolr r& r � coroutine�strrK � r r r r s� � � � � � �� �&� � � �
!��
!��
!��
!��
!�
!�
!�
!�3�� 3�c� 3�d� 3� 3� 3� 3� �]�23� � �� � "� �,/� � 5� � � � �]� � � r r )r r@ �tornado.concurrentr �tornador �tornado.ioloopr �tornado.netutilr r rE �
TYPE_CHECKINGr r r
r r r rS r r �<module>rY s� �� ����
�
�
�
� %� %� %� %� %� %� � � � � � � !� !� !� !� !� !� 1� 1� 1� 1� 1� 1� 1� 1�
�
�
�
� �� 9�8�8�8�8�8�8�8�8�8�8�8�8�8�8�N� N� N� N� N�H� N� N� N� N� Nr