� !A?hX� � �l � d Z ddlZddlZddlZddlZddlZddlZddlZ ddlZn # e $ r dZY nw xY wddl mZ ddl mZ ddl m Z ddl mZ ddl mZ dd l mZ dd l mZ ddl mZ ddlmZ d � Z G d� dej � � Z G d� dej ej � � Z G d� de� � Z G d� de� � ZdS ))�BaseSelectorEventLoop� N� )�base_events)� constants)�events)�futures)� protocols)�sslproto)� transports)�trsock)�loggerc �~ � | � |� � }t |j |z � � S # t $ r Y dS w xY w�NF)�get_key�boolr �KeyError)�selector�fd�event�keys �D/opt/alt/python-internal/lib64/python3.11/asyncio/selector_events.py�_test_selector_eventr sU � �(����r�"�"�� �C�J��&�'�'�'�� � � � ��u�u����s �. � <�<c �� � � e Zd Z d3� fd� Zd3ddd�d�Z d3ddddej ej d�d�Z d4d�Z � fd �Z d � Zd� Zd� Z d � Zd� Zdddej ej fd�Zdddej ej fd�Zddej ej fd�Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd3d�Zd� Zd� Zd � Z d!� Z!d"� Z"d5d$�Z#d%� Z$d&� Z%d'� Z&d(� Z'd)� Z(d*� Z)d+� Z*d3d,�Z+d-� Z,d.� Z-d/� Z.d0� Z/d1� Z0d2� Z1� xZ2S )6r Nc � �� t � � � � � |�t j � � }t j d|j j � � || _ | � � � t j � � | _ d S )NzUsing selector: %s) �super�__init__� selectors�DefaultSelectorr �debug� __class__�__name__� _selector�_make_self_pipe�weakref�WeakValueDictionary�_transports)�selfr r s �r r zBaseSelectorEventLoop.__init__1 sv �� � ���������� �0�2�2�H���)�8�+=�+F�G�G�G�!���������"�6�8�8����� ��extra�serverc �* � t | |||||� � S �N)�_SelectorSocketTransport)r' �sock�protocol�waiterr* r+ s r �_make_socket_transportz,BaseSelectorEventLoop._make_socket_transport; s! � �'��d�H�f�(-�v�7� 7� 7r( F)�server_side�server_hostnamer* r+ �ssl_handshake_timeout�ssl_shutdown_timeoutc �p � t j | |||||| | �� � }t | ||||�� � |j S )N)r5 r6 r) )r �SSLProtocolr. �_app_transport)r' �rawsockr0 � sslcontextr1 r3 r4 r* r+ r5 r6 �ssl_protocols r �_make_ssl_transportz)BaseSelectorEventLoop._make_ssl_transport@ s\ � � �+��(�J����"7�!5� � � �� !��w��',�V� =� =� =� =��*�*r( c �* � t | |||||� � S r- )�_SelectorDatagramTransport)r' r/ r0 �addressr1 r* s r �_make_datagram_transportz.BaseSelectorEventLoop._make_datagram_transportQ s$ � �)�$��h�*1�6�5�B� B� Br( c �4 �� | � � � rt d� � �| � � � rd S | � � � t � � � � � | j �"| j � � � d | _ d S d S )Nz!Cannot close a running event loop)� is_running�RuntimeError� is_closed�_close_self_piper �closer" )r' r s �r rG zBaseSelectorEventLoop.closeV s� �� ��?�?��� D��B�C�C�C��>�>��� ��F������� ��� � �����>�%��N� � �"�"�"�!�D�N�N�N� &�%r( c �� � | � | j � � � � � | j � � � d | _ | j � � � d | _ | xj dz c_ d S )Nr )�_remove_reader�_ssock�filenorG �_csock� _internal_fds�r' s r rF z&BaseSelectorEventLoop._close_self_pipea