a
XC?h�! � @ s� d dl Z d dlZ d dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd dlZd dlZz d dlZW n ey� dZY n0 ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ dd
lmZ dd lm Z dd lm Z dd
lm Z ddl m Z dZ!dZ"dZ#e$ed�Z%dZ&e'� Z(dd� Z)dd� Z*dd� Z+d,dd�Z,d-d d �Z-d d � Z.e$ed ��r�d!d"� Z/nd#d"� Z/d$d%� Z0G d&d'� d'ej1�Z2G d(d)� d)ej3�Z4G d*d+� d+ej5�Z6dS ).� N� )� constants)�
coroutines)�events)�
exceptions)�futures)� protocols)�sslproto)� staggered)�tasks)�
transports)�trsock)�logger)�
BaseEventLoop�Server�d g �?�AF_INET6i�Q c C s0 | j }tt|dd �tj�r$t|j�S t| �S d S )N�__self__)Z _callback�
isinstance�getattrr �Task�reprr �str)�handle�cb� r �8/opt/alt/python39/lib64/python3.9/asyncio/base_events.py�_format_handleJ s
r c C s( | t jkrdS | t jkr dS t| �S d S )Nzz)�
subprocess�PIPE�STDOUTr )�fdr r r � _format_pipeS s
r" c C sJ t td�std��n2z| �tjtjd� W n tyD td��Y n0 d S )N� SO_REUSEPORTz)reuse_port not supported by socket moduler zTreuse_port not supported by socket module, SO_REUSEPORT defined but not implemented.)�hasattr�socket�
ValueError�
setsockopt�
SOL_SOCKETr# �OSError��sockr r r �_set_reuseport\ s
r, c C s� t td�sd S |dtjtjhvs(| d u r,d S |tjkr>tj}n|tjkrPtj}nd S |d u rbd}nVt|t�rz|dkrzd}n>t|t�r�|dkr�d}n&z t |�}W n t
t fy� Y d S 0 |tj kr�tj
g}tr�|�tj� n|g}t| t�r�| �d�} d| v �rd S |D ]r}zVt�|| � t�rH|tjk�rH|||d| |||ffW S |||d| |ffW S W n t�yv Y n0 �qd S )N� inet_ptonr � � Zidna�%)r$ r% � IPPROTO_TCPZ IPPROTO_UDP� SOCK_STREAM�
SOCK_DGRAMr �bytesr �int� TypeErrorr& � AF_UNSPEC�AF_INET� _HAS_IPv6�appendr �decoder- r) ) �host�port�family�type�protoZflowinfoZscopeidZafs�afr r r � _ipaddr_infog sN
�
rB c C s� t �� }| D ]*}|d }||vr(g ||< || �|� q t|�� �}g }|dkr||�|d d |d � � |d d |d �= |�dd� tj�tj |� �D �� |S )Nr r c s s | ]}|d ur|V qd S �Nr )�.0�ar r r � � s �z(_interleave_addrinfos..)
� collections� OrderedDictr: �list�values�extend� itertools�chain�
from_iterable� zip_longest)Z addrinfosZfirst_address_family_countZaddrinfos_by_family�addrr> Zaddrinfos_listsZ reorderedr r r �_interleave_addrinfos� s"
��rQ c C s4 | � � s"| �� }t|ttf�r"d S t�| ��� d S rC )� cancelled� exceptionr �
SystemExit�KeyboardInterruptr Z _get_loop�stop)�fut�excr r r �_run_until_complete_cb� s
rY � TCP_NODELAYc C s@ | j tjtjhv r<| jtjkr<| jtjkr<| �tjtj d� d S �Nr )
r> r% r8 r r? r2 r@ r1 r' rZ r* r r r � _set_nodelay� s
�
�r\ c C s d S rC r r* r r r r\ � s c C s t d ur t| t j�r td��d S )Nz"Socket cannot be of type SSLSocket)�sslr Z SSLSocketr6 r* r r r �_check_ssl_socket� s r^ c @ sT e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dS )�_SendfileFallbackProtocolc C sh t |tj�std��|| _|�� | _|�� | _|j | _
|� � |� | � | j
r^| jj
�� | _nd | _d S )Nz.transport should be _FlowControlMixin instance)r r Z_FlowControlMixinr6 �
_transportZ get_protocol�_protoZ
is_reading�_should_resume_readingZ_protocol_paused�_should_resume_writing�
pause_reading� set_protocol�_loop�
create_future�_write_ready_fut)�self�transpr r r �__init__� s
z"_SendfileFallbackProtocol.__init__c � s2 | j �� rtd��| j}|d u r$d S |I d H d S )NzConnection closed by peer)r` �
is_closing�ConnectionErrorrh )ri rW r r r �drain� s
z _SendfileFallbackProtocol.drainc C s t d��d S )Nz?Invalid state: connection should have been established already.�� RuntimeError)ri � transportr r r �connection_made� s z)_SendfileFallbackProtocol.connection_madec C s@ | j d ur0|d u r$| j �td�� n | j �|� | j�|� d S )Nz Connection is closed by peer)rh �
set_exceptionrm ra �connection_lost)ri rX r r r rt � s
� z)_SendfileFallbackProtocol.connection_lostc C s | j d urd S | jj�� | _ d S rC )rh r` rf rg �ri r r r �
pause_writing� s
z'_SendfileFallbackProtocol.pause_writingc C s$ | j d u rd S | j �d� d | _ d S )NF)rh �
set_resultru r r r �resume_writing� s
z(_SendfileFallbackProtocol.resume_writingc C s t d��d S �Nz'Invalid state: reading should be pausedro )ri �datar r r �
data_received s z'_SendfileFallbackProtocol.data_receivedc C s t d��d S ry ro ru r r r � eof_received s z&_SendfileFallbackProtocol.eof_receivedc � sF | j �| j� | jr | j �� | jd ur2| j�� | jrB| j�� d S rC ) r` re ra rb �resume_readingrh �cancelrc rx ru r r r �restore s
z!_SendfileFallbackProtocol.restoreN) �__name__�
__module__� __qualname__rk rn rr rt rv rx r{ r| r r r r r r_ � s r_ c @ sx e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
e dd� �Z dd� Z
dd� Zdd� Zdd� ZdS ) r c C s@ || _ || _d| _g | _|| _|| _|| _|| _d| _d | _ d S )Nr F)
rf �_sockets�
_active_count�_waiters�_protocol_factory�_backlog� _ssl_context�_ssl_handshake_timeout�_serving�_serving_forever_fut)ri �loop�sockets�protocol_factoryZ ssl_context�backlog�ssl_handshake_timeoutr r r rk s zServer.__init__c C s d| j j� d| j�d�S )N�)� __class__r� r� ru r r r �__repr__% s zServer.__repr__c C s | j d7 _ d S r[ )r� ru r r r �_attach( s zServer._attachc C s. | j d8 _ | j dkr*| jd u r*| �� d S )Nr r )r� r� �_wakeupru r r r �_detach, s zServer._detachc C s, | j }d | _ |D ]}|�� s|�|� qd S rC )r� �donerw )ri �waiters�waiterr r r r� 2 s
zServer._wakeupc C sJ | j r
d S d| _ | jD ].}|�| j� | j�| j|| j| | j| j� qd S �NT) r� r� Zlistenr� rf �_start_servingr� r� r� )ri r+ r r r r� 9 s
�zServer._start_servingc C s | j S rC )rf ru r r r �get_loopC s zServer.get_loopc C s | j S rC )r� ru r r r �
is_servingF s zServer.is_servingc C s" | j d u rdS tdd� | j D ��S )Nr c s s | ]}t �|�V qd S rC )r
ZTransportSocket)rD �sr r r rF M r. z!Server.sockets..)r� �tupleru r r r r� I s
zServer.socketsc C sn | j }|d u rd S d | _ |D ]}| j�|� q d| _| jd urX| j�� sX| j�� d | _| jdkrj| �� d S )NFr ) r� rf Z
_stop_servingr� r� r� r~ r� r� )ri r� r+ r r r �closeO s
�
z Server.closec � s | � � t�d�I d H d S )Nr )r� r �sleepru r r r �
start_servingb s zServer.start_servingc � s� | j d urtd| �d���| jd u r4td| �d���| �� | j�� | _ zRz| j I d H W n6 tjy� z | �� | � � I d H W � n� 0 Y n0 W d | _ nd | _ 0 d S )Nzserver z, is already being awaited on serve_forever()z
is closed)
r� rp r� r� rf rg r ZCancelledErrorr� � wait_closedru r r r �
serve_foreverh s
�
zServer.serve_foreverc � s< | j d u s| jd u rd S | j�� }| j�|� |I d H d S rC )r� r� rf rg r: )ri r� r r r r� } s
zServer.wait_closedN)r� r� r� rk r� r� r� r� r� r� r� �propertyr� r� r� r� r� r r r r r s
r c @ sh e Zd Zdd� Zdd� Zdd� Zdd�d d
�Zd d � Zd
d� Zd�ddd�dd�Z d�ddddddd�dd�Z
d�dd�Z d�dd�Z d�dd �Z
d�d d �Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Zd5d6� Zd7d8� Zd9d:� Z d;d<� Z e j fd=d>�Z d?d@� Z!dAdB� Z"ddC�dDdE�Z#ddC�dFdG�Z$ddC�dHdI�Z%dJdK� Z&dLdM� Z'dNdO� Z(ddC�dPdQ�Z)dRdS� Z*dTdU� Z+dVdW� Z,dXdXdXdXdY�dZd[�Z-d�d\d]�Z.d�dd^�d_d`�Z/dadb� Z0dcdd� Z1dedf� Z2d�dgdh�Z3d�ddXdXdXdddddddi�
djdk�Z4d�dldm�Z5d�dd^�dndo�Z6dpdq� Z7drds� Z8ddddt�dudv�Z9d�dXdXdXe:ddddw�dxdy�Z;dXed|d}� Z?d�e$ r. z4BaseEventLoop.shutdown_asyncgens..)Zreturn_exceptionsr� z;an error occurred during closing of asynchronous generator )�messagerS Zasyncgen) r� �lenr� rI �clearr �_gather�zipr � Exception�call_exception_handler)ri Z
closing_agensZresults�resultr� r r r �shutdown_asyncgens s&
�
��z BaseEventLoop.shutdown_asyncgensc � s\ d| _ | jd u rd S | �� }tj| j|fd�}|�� z|I d H W |�� n
|�� 0 d S )NT)�targetr� )r� r� rg � threadingZThread� _do_shutdown�start�join)ri �future�threadr r r �shutdown_default_executor1 s
z'BaseEventLoop.shutdown_default_executorc
C sX z | j jdd� | �|jd � W n2 tyR } z| �|j|� W Y d }~n
d }~0 0 d S )NT��wait)r� �shutdownr� rw r� rs )ri r Zexr r r r > s
zBaseEventLoop._do_shutdownc C s( | � � rtd��t�� d ur$td��d S )Nz"This event loop is already runningz7Cannot run the event loop while another loop is running)r� rp r Z_get_running_loopru r r r �_check_runningE s �z BaseEventLoop._check_runningc C s� | � � | �� | �| j� t�� | _t�� }tj | j
| j d� zJt �
| � | �� | jrLq^qLW d| _d | _t �
d � | �d� tj |� n,d| _d | _t �
d � | �d� tj |� 0 d S )N)� firstiter� finalizerF)r� r � _set_coroutine_origin_tracking�_debugr � get_identr� �sys�get_asyncgen_hooks�set_asyncgen_hooksr� r� r Z_set_running_loop� _run_oncer� )ri Zold_agen_hooksr r r � run_foreverL s.
�
�
zBaseEventLoop.run_foreverc C s� | � � | �� t�|� }tj|| d�}|r4d|_|�t� zFz | � � W n* |rp|�
� rp|� � sp|� � � Y n0 W |�
t� n |�
t� 0 |�
� s�td��|�� S )Nr� Fz+Event loop stopped before Future completed.)r� r r Zisfuturer Z
ensure_futureZ_log_destroy_pendingZadd_done_callbackrY r r� rR rS Zremove_done_callbackrp r� )ri r Znew_taskr r r �run_until_completec s"
z BaseEventLoop.run_until_completec C s
d| _ d S r� )r� ru r r r rV � s zBaseEventLoop.stopc C sp | � � rtd��| jrd S | jr,t�d| � d| _| j�� | j�� d| _ | j
}|d urld | _
|j dd� d S )Nz!Cannot close a running event loopzClose %rTFr ) r� rp r� r r �debugr� r� r� r� r� r
�ri �executorr r r r� � s
zBaseEventLoop.closec C s | j S rC )r� ru r r r r� � s zBaseEventLoop.is_closedc C s0 | � � s,|d| ��t| d� | �� s,| �� d S )Nzunclosed event loop r� )r� r� r� r� )ri Z_warnr r r �__del__� s zBaseEventLoop.__del__c C s
| j d uS rC )r� ru r r r r� � s zBaseEventLoop.is_runningc C s t �� S rC )r� r� ru r r r r� � s zBaseEventLoop.time)�contextc G s4 | j | �� | |g|�R d|i�}|jr0|jd= |S )Nr r� )�call_atr� r� )ri Zdelay�callbackr r� �timerr r r �
call_later� s �zBaseEventLoop.call_laterc G sZ | � � | jr"| �� | �|d� t�|||| |�}|jrB|jd= t�| j |� d|_ |S )Nr r� T)
r� r �
_check_thread�_check_callbackr Z TimerHandler� �heapq�heappushr� )ri �whenr r r� r r r r r � s zBaseEventLoop.call_atc G sB | � � | jr"| �� | �|d� | �|||�}|jr>|jd= |S )N� call_soonr� )r� r r r! �
_call_soonr� �ri r r r� r r r r r% � s
zBaseEventLoop.call_soonc C sD t �|�st �|�r$td|� d���t|�s@td|� d|����d S )Nz coroutines cannot be used with z()z"a callable object was expected by z(), got )r Z iscoroutineZiscoroutinefunctionr6 r� )ri r �methodr r r r! � s
�
���z BaseEventLoop._check_callbackc C s. t �||| |�}|jr |jd= | j�|� |S )Nr� )r ZHandler� r� r: )ri r r� r r r r r r& s
zBaseEventLoop._call_soonc C s, | j d u rd S t�� }|| j kr(td��d S )NzMNon-thread-safe operation invoked on an event loop other than the current one)r� r r rp )ri Z thread_idr r r r s
�zBaseEventLoop._check_threadc G sB | � � | jr| �|d� | �|||�}|jr6|jd= | �� |S )Nr� r� )r� r r! r& r� r� r' r r r r� s z"BaseEventLoop.call_soon_threadsafec G sh | � � | jr| �|d� |d u rL| j}| �� |d u rLtjjdd�}|| _tj|j |g|�R � | d�S )N�run_in_executorZasyncio)Zthread_name_prefixr� )
r� r r! r� r� �
concurrentr �ThreadPoolExecutorZ wrap_futureZsubmit)ri r �funcr� r r r r) % s ��z BaseEventLoop.run_in_executorc C s& t |tjj�s t�dtd� || _d S )Nz{Using the default executor that is not an instance of ThreadPoolExecutor is deprecated and will be prohibited in Python 3.9� )r r* r r+ r� r� �DeprecationWarningr� r r r r �set_default_executor5 s �z"BaseEventLoop.set_default_executorc C s� |� d|��g}|r$|� d|��� |r8|� d|��� |rL|� d|��� |r`|� d|��� d�|�}t�d|� | �� }t�||||||�} | �� | }
d|� d |
d
d �d | ��}|
| jkr�t�|� n
t�|� | S )
N�:zfamily=ztype=zproto=zflags=�, zGet address info %szGetting address info z took g @�@z.3fzms: ) r: r r r r� r% � getaddrinfor� �info) ri r< r= r> r? r@ �flags�msg�t0�addrinfo�dtr r r �_getaddrinfo_debug> s&
z BaseEventLoop._getaddrinfo_debugr �r> r? r@ r4 c
� s2 | j r| j}ntj}| �d |||||||�I d H S rC )r r9 r% r2 r) )ri r< r= r> r? r@ r4 Z getaddr_funcr r r r2 V s �zBaseEventLoop.getaddrinfoc � s | � d tj||�I d H S rC )r) r% � getnameinfo)ri Zsockaddrr4 r r r r; ` s
�zBaseEventLoop.getnameinfo)�fallbackc
� s� | j r|�� dkrtd��t|� | �||||� z| �||||�I d H W S tjyv } z|sb� W Y d }~n
d }~0 0 | �||||�I d H S )Nr z the socket must be non-blocking) r Z
gettimeoutr& r^ �_check_sendfile_params�_sock_sendfile_nativer �SendfileNotAvailableError�_sock_sendfile_fallback)ri r+ �file�offset�countr< rX r r r �
sock_sendfiled s � �zBaseEventLoop.sock_sendfilec � s t �d|�d|�d���d S )Nz-syscall sendfile is not available for socket z
and file z combination�r r? �ri r+ rA rB rC r r r r> s s
��z#BaseEventLoop._sock_sendfile_nativec
� s� |r|� |� |r t|tj�ntj}t|�}d}z�|rNt|| |�}|dkrNq�t|�d |� }| �d |j|�I d H } | szq�| �||d | � �I d H || 7 }q2|W |dkr�t |d�r�|� || � S n&|dk� r�t |d�� r�|� || � 0 d S )Nr �seek)
rG �minr Z!SENDFILE_FALLBACK_READBUFFER_SIZE� bytearray�
memoryviewr) �readintoZ sock_sendallr$ )
ri r+ rA rB rC � blocksize�buf�
total_sent�view�readr r r r@ z s6
��
� �z%BaseEventLoop._sock_sendfile_fallbackc C s� dt |dd�vrtd��|jtjks,td��|d urbt|t�sLtd�|���|dkrbtd�|���t|t�sztd�|���|dk r�td�|���d S )N�b�modez$file should be opened in binary modez+only SOCK_STREAM type sockets are supportedz+count must be a positive integer (got {!r})r z0offset must be a non-negative integer (got {!r})) r r& r? r% r2 r r5 r6 �formatrF r r r r= � s2
��
����z$BaseEventLoop._check_sendfile_paramsc � sD g }|� |� |\}}}}} d }
z�tj|||d�}
|
�d� |d ur�|D ]t\}}}}} z|
�| � W q�W qH ty� } z8d| �d| j�� � �}
t| j|
�} |� | � W Y d } ~ qHd } ~ 0 0 qH|�� �| � |
| �I d H |
W S t�y } z*|� | � |
d u�r
|
�
� � W Y d } ~ n(d } ~ 0 |
d u�r8|
�
� � Y n0 d S )N�r> r? r@ Fz*error while attempting to bind on address �: ) r: r% � setblocking�bindr) �strerror�lower�errno�pop� sock_connectr� )ri r Z addr_infoZlocal_addr_infosZ
my_exceptionsr> �type_r@ �_r� r+ ZladdrrX r5 r r r �
_connect_sock� sB
��� "
zBaseEventLoop._connect_sock)
r] r> r@ r4 r+ �
local_addrr� r� �happy_eyeballs_delay�
interleavec
� sz |
d ur|st d��|
d u r0|r0|s,t d��|}
| d urD|sDt d��|d urTt|� | d urh|
d u rhd}
|d usz|d u�r |d ur�t d���j||f|tj||�d�I d H }|s�td��| d ur�j| |tj||�d�I d H ��s�td��nd �|
r�t||
�}g � | d u �rV|D ]B}z ��� |��I d H }W �q�W n t�yN Y �qY n0 �qn.tj � ��fdd �|D �| �d
�I d H \}}}|d u �r.d d � � D �� t
� �dk�r�� d
�nJt � d
��t �fdd �� D ���r�� d
�td�
d�dd � � D �����n.|d u �rt d��|jtjk�r.t d|�����j||||
| d�I d H \}}�j�rr|�d�}t�d|||||� ||fS )Nz+server_hostname is only meaningful with sslz:You must set server_hostname when using ssl without a host�1ssl_handshake_timeout is only meaningful with sslr �8host/port and sock can not be specified at the same time�r> r? r@ r4 r� �!getaddrinfo() returned empty listc 3 s | ]}t ��j� |��V qd S rC )� functools�partialr_ )rD r7 )r � laddr_infosri r r rF ! s ��z2BaseEventLoop.create_connection..r� c S s g | ]}|D ]}|�q qS r r )rD �subrX r r r r� ' r. z3BaseEventLoop.create_connection..r c 3 s | ]}t |�� kV qd S rC �r �rD rX )�modelr r rF - r. zMultiple exceptions: {}r1 c s s | ]}t |�V qd S rC rk rl r r r rF 2 r. z5host and port was not specified and no sock specified�"A Stream Socket was expected, got )r� r% z %r connected to %s:%r: (%r, %r))r& r^ �_ensure_resolvedr% r2 r) rQ r_ r
Zstaggered_racer� r �allrS r r? � _create_connection_transportr �get_extra_infor r )ri r� r< r= r] r> r@ r4 r+ r` r� r� ra rb �infosr7 r^ rq r� r )r ri rm ri r �create_connection� s� ��
� �
�
��
�
���
�z BaseEventLoop.create_connectionc � s� |� d� |� }| �� }|rHt|t�r*d n|} | j||| ||||d�}
n| �|||�}
z|I d H W n |
�� � Y n0 |
|fS )NF�r� r� r� )rV rg r �boolr� r� r� ) ri r+ r� r] r� r� r� r� r� r� rq r r r rq M s"
�z*BaseEventLoop._create_connection_transportc
� s� |� � rtd��t|dtjj�}|tjju r:td|����|tjju r�z| �||||�I d H W S tj y� } z|sv� W Y d }~n
d }~0 0 |s�td|����| �
||||�I d H S )NzTransport is closingZ_sendfile_compatiblez(sendfile is not supported for transport zHfallback is disabled and native sendfile is not supported for transport ) rl rp r r Z
_SendfileModeZ UNSUPPORTEDZ
TRY_NATIVE�_sendfile_nativer r? �_sendfile_fallback)ri rq rA rB rC r< rR rX r r r �sendfileg s4 � � � ���zBaseEventLoop.sendfilec � s t �d��d S )Nz!sendfile syscall is not supportedrE )ri rj rA rB rC r r r rw � s �z BaseEventLoop._sendfile_nativec
� s| |r|� |� |r t|d�nd}t|�}d}t|�}�z |r�t|| |�}|dkr�|W |dkrvt|d�rv|� || � |�� I d H S t|�d |� } | �d |j| �I d H }
|
s�|W |dkr�t|d�r�|� || � |�� I d H S |� � I d H |�
| d |
� � ||
7 }q8W |dk�r4t|d��r4|� || � |�� I d H n4|dk�rht|d��rh|� || � |�� I d H 0 d S )Ni @ r rG ) rG rH rI r_ r$ r rJ r) rK rn �write) ri rj rA rB rC rL rM rN r@ rO rP r r r rx � s@
�� �z BaseEventLoop._sendfile_fallbackru c
� s� t d u rtd��t|t j�s*td|����t|dd�sFtd|�d���| �� }tj| ||||||dd�}|� � |�
|� | � |j |�} | � |j
�}
z|I d H W n, ty� |�� | �� |
�� � Y n0 |jS )Nz"Python ssl module is not availablez@sslcontext is expected to be an instance of ssl.SSLContext, got Z_start_tls_compatibleFz
transport z is not supported by start_tls())r� r� )r] rp r Z
SSLContextr6 r rg r Z SSLProtocolrd re r% rr r} �
BaseExceptionr� r~ Z_app_transport) ri rq r� r� r� r� r� r� Z ssl_protocolZ
conmade_cbZ resume_cbr r r � start_tls� s> ��
��
zBaseEventLoop.start_tls)r> r@ r4 �
reuse_address�
reuse_port�allow_broadcastr+ c � s |
d ur�|
j tjkr"td|
����� s>�s>|s>|s>|s>|s>| r~t� �|||||| d�} d�dd� | �� D ��} td| � d���|
�d� d }
�n� s��s�|d kr�td
��||fd ff}�n�ttd ��r�|tj k�r�� �fD ] }|d ur�t
|t �s�t d
��qڈ �rx� d dv�rxz"t
�t�
� �j��r.t�� � W nF t�yD Y n4 t�yv } zt�d� |� W Y d }~n
d }~0 0 ||f� �fff}n�i }d � fd�ffD ]�\}}|d u�r�t
|t��r�t|�dk�s�t d��| j||tj||| d�I d H }|�s td��|D ]:\}}}}}||f}||v�r0d d g||< ||| |< �q�q�� �fdd�|�� D �}|�sjtd��g }|tu�r�|�r�td��ntjdt dd� |D ]�\\}}\}}d }
d }
zxtj|tj|d�}
|�r�t |
� | �r�|
� tj tj d� |
�d� � �r|
�!|� ��r*| �s&| �"|
|�I d H |}
W n` t�yn } z(|
d u�rP|
�#� |�$| � W Y d } ~ n.d } ~ 0 |
d u�r�|
�#� � Y n0 �q��q�|d �|� } | �%� } | �&|
| |
| �} | j'�r�� �r�t�(d � �| | � nt�)d �| | � z| I d H W n | �#� � Y n0 | | fS ) Nz A UDP Socket was expected, got )r` � remote_addrr> r@ r4 r} r~ r r1 c s s$ | ] \}}|r|� d |� �V qdS )�=Nr )rD �k�vr r r rF � r. z9BaseEventLoop.create_datagram_endpoint..zKsocket modifier keyword arguments can not be used when sock is specified. (�)Fr zunexpected address family)NN�AF_UNIXzstring is expected)r � z2Unable to check or remove stale UNIX socket %r: %rr r- z2-tuple is expectedre rf c s8 g | ]0\}}� r |d du s�r,|d du s||f�qS )r Nr r )rD �keyZ addr_pair�r` r� r r r� & s �z:BaseEventLoop.create_datagram_endpoint..z can not get address informationz~Passing `reuse_address=True` is no longer supported, as the usage of SO_REUSEPORT in UDP poses a significant security concern.zdThe *reuse_address* parameter has been deprecated as of 3.5.10 and is scheduled for removal in 3.11.)�
stacklevelrT z@Datagram endpoint local_addr=%r remote_addr=%r created: (%r, %r)z2Datagram endpoint remote_addr=%r created: (%r, %r))*r? r% r3 r& �dictr �itemsrV r$ r� r r r6 �stat�S_ISSOCK�os�st_mode�remove�FileNotFoundErrorr) r �errorr� r� ro �_unsetr� r� r. r, r' r( Z SO_BROADCASTrW r\ r� r: rg r� r r3 r ) ri r� r` r� r> r@ r4 r} r~ r r+ ZoptsZproblemsZr_addrZaddr_pairs_inforP �errZ
addr_infos�idxrs Zfamr^ Zpror� r� r Z
local_addressZremote_addressrX r� r� rq r r� r �create_datagram_endpoint� s ���������
��
�
�
�� �
�
���z&BaseEventLoop.create_datagram_endpointc
� s^ |d d� \}}t |||||g|dd � �R � } | d ur>| gS |j||||||d�I d H S d S )Nr- r: )rB r2 )
ri r� r> r? r@ r4 r� r< r= r3 r r r ro t s �z BaseEventLoop._ensure_resolvedc � s8 | j ||f|tj|| d�I d H }|s4td|�d���|S )N)r> r? r4 r� z getaddrinfo(z) returned empty list)ro r% r2 r) )ri r< r= r> r4 rs r r r �_create_server_getaddrinfo� s � z(BaseEventLoop._create_server_getaddrinfor ) r> r4 r+ r� r] r} r~ r� r� c � s� t |t�rtd��| d ur*|d u r*td��|d ur:t|� |d usL�d u�rL|d ur\td��| d u rxtjdkovtjdk} g }
|dkr�d g}n$t |t �s�t |t
j j �s�|g}n|}� ���fdd�|D �}t
j|d �i�I d H }ttj�|��}d
}�z8|D �]}|\}}}}}zt�|||�}W n6 tj�yV �j�rNtjd |||d d
� Y q�Y n0 |
�|� | �rz|�tjtjd � |
�r�t |� t �r�|tj k�r�t td��r�|�tj tj!d � z|�"|� W q� t#�y } z(t#|j$d||j%�&� f �d �W Y d }~q�d }~0 0 q�d }W |�sJ|
D ]}|�'� �q n |�sH|
D ]}|�'� �q80 n4|d u �r^td��|j(tj)k�rztd|����|g}
|
D ]}|�*d
� �q�t+�|
|||| �}| �r�|�,� t
�-d�I d H �j�r�t�.d|� |S )Nz*ssl argument must be an SSLContext or Nonerc rd �posix�cygwinr/ c s g | ]}�j |�� �d ��qS ))r> r4 )r� )rD r< �r> r4 r= ri r r r� � s �
�z/BaseEventLoop.create_server..r� Fz:create_server() failed to create socket.socket(%r, %r, %r)T��exc_info� IPPROTO_IPV6z0error while attempting to bind on address %r: %sz)Neither host/port nor sock were specifiedrn r z
%r is serving)/r rv r6 r& r^ r� r� r �platformr rG �abc�Iterabler r� �setrL rM rN r% r� r r �warningr: r' r( Z SO_REUSEADDRr, r9 r r$ r� Z IPV6_V6ONLYrW r) rZ rX rY r� r? r2 rV r r� r� r3 )ri r� r< r= r> r4 r+ r� r] r} r~ r� r� r� ZhostsZfsrs Z completed�resrA Zsocktyper@ Z canonnameZsar� r� r r� r �
create_server� s�
��
��
�
���� ���
� zBaseEventLoop.create_server)r] r� c � s� |j tjkrtd|����|d ur.|s.td��|d ur>t|� | j|||dd|d�I d H \}}| jr~|�d�}t� d|||� ||fS )Nrn rc r/ T)r� r� r% z%r handled: (%r, %r))
r? r% r2 r& r^ rq r rr r r )ri r� r+ r] r� rq r� r r r �connect_accepted_socket s �
�
z%BaseEventLoop.connect_accepted_socketc � sd |� }| � � }| �|||�}z|I d H W n |�� � Y n0 | jr\t�d|�� ||� ||fS )Nz Read pipe %r connected: (%r, %r))rg r� r� r r r �fileno�ri r� r� r� r� rq r r r �connect_read_pipe s
�z BaseEventLoop.connect_read_pipec � sd |� }| � � }| �|||�}z|I d H W n |�� � Y n0 | jr\t�d|�� ||� ||fS )Nz!Write pipe %r connected: (%r, %r))rg r� r� r r r r� r� r r r �connect_write_pipe0 s
�z BaseEventLoop.connect_write_pipec C s� |g}|d ur"|� dt|�� �� |d urJ|tjkrJ|� dt|�� �� n8|d urf|� dt|�� �� |d ur�|� dt|�� �� t�d�|�� d S )Nzstdin=zstdout=stderr=zstdout=zstderr=� )r: r" r r r r r )ri r5 r� r� r� r3 r r r �_log_subprocess@ s z BaseEventLoop._log_subprocess) r� r� r� �universal_newlinesr� r� �encoding�errors�textc � s� t |ttf�std��|r"td��|s.td��|dkr>td��| rJtd��| d urZtd��|
d urjtd��|� }
d }| jr�d | }| �||||� | j|
|d
||||fi | ��I d H }| jr�|d ur�t�d ||� ||
fS ) Nzcmd must be a string� universal_newlines must be Falsezshell must be Truer �bufsize must be 0�text must be False�encoding must be None�errors must be Nonezrun shell command %rT�%s: %r) r r4 r r& r r� r� r r3 )ri r� �cmdr� r� r� r� r� r� r� r� r� r� r� � debug_logrq r r r �subprocess_shellM s6 �� z BaseEventLoop.subprocess_shellc � s� |r t d��|rt d��|dkr(t d��| r4t d��| d urDt d��|
d urTt d��|f| }|� }d }| jr�d|��}| �||||� | j||d ||||fi |
��I d H }| jr�|d ur�t�d
||� ||fS ) Nr� zshell must be Falser r� r� r� r� zexecute program Fr� )r& r r� r� r r3 )ri r� Zprogramr� r� r� r� r� r� r� r� r� r� r� Z
popen_argsr� r� rq r r r �subprocess_execq s6
�� z BaseEventLoop.subprocess_execc C s | j S rC )r� ru r r r �get_exception_handler� s z#BaseEventLoop.get_exception_handlerc C s( |d ur t |�s td|����|| _d S )Nz+A callable object or None is expected, got )r� r6 r� )ri Zhandlerr r r �set_exception_handler� s
�z#BaseEventLoop.set_exception_handlerc C s |� d�}|sd}|� d�}|d ur6t|�||jf}nd}d|vr`| jd ur`| jjr`| jj|d< |g}t|�D ]�}|dv r|qn|| }|dkr�d�t�|��}d }||� � 7 }n2|dkr�d�t�|��}d
}||� � 7 }nt
|�}|� |� d |� �� qnt j
d �|�|d
� d S )Nr� z!Unhandled exception in event looprS FZsource_tracebackZhandle_traceback> r� rS r/ z+Object created at (most recent call last):
z+Handle created at (most recent call last):
rU �
r� )�getr? �
__traceback__r� r� �sortedr � traceback� format_list�rstripr r: r r� ) ri r r� rS r� Z log_linesr� �value�tbr r r �default_exception_handler� s<
��� z'BaseEventLoop.default_exception_handlerc C s� | j d u rRz| �|� W q� ttfy0 � Y q� tyN tjddd� Y q�0 n�z| � | |� W n� ttfyz � Y nr ty� } zZz| �d||d�� W n6 ttfy� � Y n ty� tjddd� Y n0 W Y d }~n
d }~0 0 d S )Nz&Exception in default exception handlerTr� z$Unhandled error in exception handler)r� rS r zeException in default exception handler while handling an unexpected error in custom exception handler)r� r� rT rU r{ r r� )ri r rX r r r r� � s4
�� �z$BaseEventLoop.call_exception_handlerc C s |j r
d S | j�|� d S rC )�
_cancelledr� r: �ri r r r r �
_add_callback s zBaseEventLoop._add_callbackc C s | � |� | �� d S rC )r� r� r� r r r �_add_callback_signalsafe s
z&BaseEventLoop._add_callback_signalsafec C s |j r| jd7 _d S r[ )r� r� r� r r r �_timer_handle_cancelled! s z%BaseEventLoop._timer_handle_cancelledc C s� t | j�}|tkr`| j| tkr`g }| jD ] }|jr r@ r= r_ rt rq ry rw rx r| r� r� r% r2 ro r� r7 Z
AI_PASSIVEr� r� r� r� r� r r r� r� r� r� r� r� r� r� r� r r r� r� r r r r r � s � ��
�
�
�
�
&
�
�
% �� �
� /� / �� � �� z� � %� "29Nr )r r )r )7rG �collections.abcZconcurrent.futuresr* rg r" rL r� r% r� r r r� r� r r� r� r] � ImportErrorr/ r r r r r r r r
r r r
�logr �__all__r� r� r$ r9 r� �objectr� r r" r, rB rQ rY r\ r^ �Protocolr_ ZAbstractServerr ZAbstractEventLoopr r r r r � sd
;
Do