U
e5d4f � @ sx d Z ddlZddlZddlZddlZddlZddlZddlmZ ddlm Z G dd� d�Z
G dd � d e
�Z G d
d � d �Z G d d
� d
�Z
G dd� d�ZG dd� de�Zdae�� ZG dd� dej�Ze� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Z d"d#� Z d$d%� Z d&d'� Z d(d)� Z eZ!eZ"eZ#e Z$z dd*l%mZmZmZm Z W n e&k
�rb Y nX eZ'eZ(eZ)e Z*dS )+)�AbstractEventLoopPolicy�AbstractEventLoop�AbstractServer�Handle� TimerHandle�get_event_loop_policy�set_event_loop_policy�get_event_loop�set_event_loop�new_event_loop�get_child_watcher�set_child_watcher�_set_running_loop�get_running_loop�_get_running_loop� N� )�format_helpers)�
exceptionsc @ sB e Zd ZdZddd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )r )� _callback�_args�
_cancelled�_loop�_source_traceback�_repr� __weakref__�_contextNc C s\ |d krt �� }|| _|| _|| _|| _d| _d | _| j�� rRt �
t � d��| _
nd | _
d S )NFr )� contextvarsZ copy_contextr r r r r r � get_debugr �
extract_stack�sys� _getframer )�self�callback�args�loop�context� r& �&/usr/lib64/python3.8/asyncio/events.py�__init__ s
�zHandle.__init__c C sl | j jg}| jr|�d� | jd k r:|�t�| j| j�� | jrh| jd }|�d|d � d|d � �� |S )N� cancelled�����z created at r �:r ) � __class__�__name__r �appendr r �_format_callback_sourcer r )r! �info�framer& r& r' �
_repr_info/ s
�
zHandle._repr_infoc C s( | j d k r| j S | �� }d�d�|��S )Nz<{}>� )r r2 �format�join)r! r0 r& r& r' �__repr__; s
zHandle.__repr__c C s0 | j s,d| _ | j�� r t| �| _d | _d | _d S �NT)r r r �reprr r r �r! r& r& r' �cancelA s
z
Handle.cancelc C s | j S �N)r r9 r& r& r' r) L s zHandle.cancelledc
C s� z| j j| jf| j�� W n| ttfk
r4 � Y nd tk
r� } zFt�| j| j�}d|� �}||| d�}| j rz| j |d< | j
� |� W 5 d }~X Y nX d } d S )NzException in callback )�messageZ exception�handleZsource_traceback) r �runr r �
SystemExit�KeyboardInterrupt�
BaseExceptionr r/ r r �call_exception_handler)r! �exc�cb�msgr% r& r& r' �_runO s$ �
�
z Handle._run)N)
r- �
__module__� __qualname__� __slots__r( r2 r6 r: r) rF r& r& r& r' r s
r c s~ e Zd ZddgZd� fdd� Z� fdd�Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z dd� Z � fdd�Z
dd� Z� ZS )r �
_scheduled�_whenNc s0 t � �||||� | jr | jd= || _d| _d S )Nr* F)�superr( r rK rJ )r! �whenr" r# r$ r% �r, r& r' r( h s
zTimerHandle.__init__c s0 t � �� }| jrdnd}|�|d| j� �� |S )N� r zwhen=)rL r2 r �insertrK )r! r0 �posrN r& r' r2 p s
zTimerHandle._repr_infoc C s
t | j�S r; )�hashrK r9 r& r& r' �__hash__v s zTimerHandle.__hash__c C s | j |j k S r; �rK �r! �otherr& r& r' �__lt__y s zTimerHandle.__lt__c C s | j |j k rdS | �|�S r7 �rK �__eq__rU r& r& r' �__le__| s zTimerHandle.__le__c C s | j |j kS r; rT rU r& r& r' �__gt__� s zTimerHandle.__gt__c C s | j |j krdS | �|�S r7 rX rU r& r& r' �__ge__� s zTimerHandle.__ge__c C s> t |t�r:| j|jko8| j|jko8| j|jko8| j|jkS tS r; )�
isinstancer rK r r r �NotImplementedrU r& r& r' rY � s
�
�
�zTimerHandle.__eq__c C s | � |�}|tkrtS | S r; )rY r^ )r! rV Zequalr& r& r' �__ne__� s
zTimerHandle.__ne__c s | j s| j�| � t� �� d S r; )r r �_timer_handle_cancelledrL r: r9 rN r& r' r: � s zTimerHandle.cancelc C s | j S r; rT r9 r& r& r' rM � s zTimerHandle.when)N)r- rG rH rI r( r2 rS rW rZ r[ r\ rY r_ r: rM �
__classcell__r& r& rN r' r c s r c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dS )r c C s t �d S r; ��NotImplementedErrorr9 r& r& r' �close� s zAbstractServer.closec C s t �d S r; rb r9 r& r& r' �get_loop� s zAbstractServer.get_loopc C s t �d S r; rb r9 r& r& r' �
is_serving� s zAbstractServer.is_servingc � s t �d S r; rb r9 r& r& r' �
start_serving� s z AbstractServer.start_servingc � s t �d S r; rb r9 r& r& r' �
serve_forever� s z AbstractServer.serve_foreverc � s t �d S r; rb r9 r& r& r' � wait_closed� s zAbstractServer.wait_closedc � s | S r; r& r9 r& r& r' �
__aenter__� s zAbstractServer.__aenter__c � s | � � | �� I d H d S r; )rd ri )r! rC r& r& r' � __aexit__� s zAbstractServer.__aexit__N) r- rG rH rd re rf rg rh ri rj rk r& r& r& r' r � s r c @ sR e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd �d d �Zd d � Zd!d"� Zd#d$� Zd%d%d%d%d&�d'd(�Zdtd)d*�Zdudd%d%d%ddddddd+�
d,d-�Zdvejejdd.ddddd/d0� d1d2�Zdwd/d3�d4d5�Zd6ddd7�d8d9�Z dxddddd:�d;d<�Z dydd.ddd/d=�d>d?�Z dzd%d%d%ddddd@�dAdB�Z dCdD� Z dEdF� Z!e"j#e"j#e"j#dG�dHdI�Z$e"j#e"j#e"j#dG�dJdK�Z%dLdM� Z&dNdO� Z'dPdQ� Z(dRdS� Z)dTdU� Z*dVdW� Z+dXdY� Z,dZd[� Z-d\d]� Z.d{dd3�d^d_�Z/d`da� Z0dbdc� Z1ddde� Z2dfdg� Z3dhdi� Z4djdk� Z5dldm� Z6dndo� Z7dpdq� Z8drds� Z9dS )|r c C s t �d S r; rb r9 r& r& r' � run_forever� s z AbstractEventLoop.run_foreverc C s t �d S r; rb )r! Zfuturer& r& r' �run_until_complete� s z$AbstractEventLoop.run_until_completec C s t �d S r; rb r9 r& r& r' �stop� s zAbstractEventLoop.stopc C s t �d S r; rb r9 r& r& r' �
is_running� s z AbstractEventLoop.is_runningc C s t �d S r; rb r9 r& r& r' � is_closed� s zAbstractEventLoop.is_closedc C s t �d S r; rb r9 r& r& r' rd � s zAbstractEventLoop.closec � s t �d S r; rb r9 r& r& r' �shutdown_asyncgens� s z$AbstractEventLoop.shutdown_asyncgensc C s t �d S r; rb )r! r= r& r& r' r` � s z)AbstractEventLoop._timer_handle_cancelledc G s | j d|f|�� S )Nr )�
call_later�r! r" r# r& r& r' � call_soon s zAbstractEventLoop.call_soonc G s t �d S r; rb )r! Zdelayr" r# r& r& r' rr s z AbstractEventLoop.call_laterc G s t �d S r; rb )r! rM r" r# r& r& r' �call_at s zAbstractEventLoop.call_atc C s t �d S r; rb r9 r& r& r' �time s zAbstractEventLoop.timec C s t �d S r; rb r9 r& r& r' �
create_future s z AbstractEventLoop.create_futureN)�namec C s t �d S r; rb )r! �cororx r& r& r' � create_task s z AbstractEventLoop.create_taskc G s t �d S r; rb rs r& r& r' �call_soon_threadsafe s z&AbstractEventLoop.call_soon_threadsafec G s t �d S r; rb )r! �executor�funcr# r& r& r' �run_in_executor s z!AbstractEventLoop.run_in_executorc C s t �d S r; rb )r! r| r& r& r' �set_default_executor s z&AbstractEventLoop.set_default_executorr )�family�type�proto�flagsc � s t �d S r; rb )r! �host�portr� r� r� r� r& r& r' � getaddrinfo# s z AbstractEventLoop.getaddrinfoc � s t �d S r; rb )r! Zsockaddrr� r& r& r' � getnameinfo' s z AbstractEventLoop.getnameinfo)
�sslr� r� r� �sock�
local_addr�server_hostname�ssl_handshake_timeout�happy_eyeballs_delay�
interleavec
� s t �d S r; rb )r! �protocol_factoryr� r� r� r� r� r� r� r� r� r� r� r� r& r& r' �create_connection* s z#AbstractEventLoop.create_connection�d T) r� r� r� �backlogr� �
reuse_address�
reuse_portr� rg c
� s t �d S r; rb )
r! r� r� r� r� r� r� r� r� r� r� r� rg r& r& r' �
create_server3 s 3z AbstractEventLoop.create_server)�fallbackc � s t �d S r; rb )r! � transport�file�offset�countr� r& r& r' �sendfileh s zAbstractEventLoop.sendfileF)� server_sider� r� c � s t �d S r; rb )r! r� ZprotocolZ
sslcontextr� r� r� r& r& r' � start_tlsp s zAbstractEventLoop.start_tls)r� r� r� r� c � s t �d S r; rb )r! r� �pathr� r� r� r� r& r& r' �create_unix_connection{ s z(AbstractEventLoop.create_unix_connection)r� r� r� r� rg c � s t �d S r; rb )r! r� r� r� r� r� r� rg r& r& r' �create_unix_server� s z$AbstractEventLoop.create_unix_server)r� r� r� r� r� �allow_broadcastr� c � s t �d S r; rb ) r! r� r� Z remote_addrr� r� r� r� r� r� r� r& r& r' �create_datagram_endpoint� s !z*AbstractEventLoop.create_datagram_endpointc � s t �d S r; rb �r! r� �piper& r& r' �connect_read_pipe� s z#AbstractEventLoop.connect_read_pipec � s t �d S r; rb r� r& r& r' �connect_write_pipe� s z$AbstractEventLoop.connect_write_pipe)�stdin�stdout�stderrc � s t �d S r; rb )r! r� �cmdr� r� r� �kwargsr& r& r' �subprocess_shell� s z"AbstractEventLoop.subprocess_shellc � s t �d S r; rb )r! r� r� r� r� r# r� r& r& r' �subprocess_exec� s z!AbstractEventLoop.subprocess_execc G s t �d S r; rb �r! �fdr" r# r& r& r' �
add_reader� s z AbstractEventLoop.add_readerc C s t �d S r; rb �r! r� r& r& r' �
remove_reader� s z AbstractEventLoop.remove_readerc G s t �d S r; rb r� r& r& r' �
add_writer� s z AbstractEventLoop.add_writerc C s t �d S r; rb r� r& r& r' �
remove_writer� s z AbstractEventLoop.remove_writerc � s t �d S r; rb )r! r� �nbytesr& r& r' � sock_recv s zAbstractEventLoop.sock_recvc � s t �d S r; rb )r! r� Zbufr& r& r' �sock_recv_into s z AbstractEventLoop.sock_recv_intoc � s t �d S r; rb )r! r� �datar& r& r' � sock_sendall s z AbstractEventLoop.sock_sendallc � s t �d S r; rb )r! r� Zaddressr& r& r' � sock_connect s z AbstractEventLoop.sock_connectc � s t �d S r; rb )r! r� r& r& r' � sock_accept s z AbstractEventLoop.sock_acceptc � s t �d S r; rb )r! r� r� r� r� r� r& r& r' �
sock_sendfile s z AbstractEventLoop.sock_sendfilec G s t �d S r; rb )r! �sigr" r# r& r& r' �add_signal_handler s z$AbstractEventLoop.add_signal_handlerc C s t �d S r; rb )r! r� r& r& r' �remove_signal_handler s z'AbstractEventLoop.remove_signal_handlerc C s t �d S r; rb )r! �factoryr& r& r' �set_task_factory s z"AbstractEventLoop.set_task_factoryc C s t �d S r; rb r9 r& r& r' �get_task_factory" s z"AbstractEventLoop.get_task_factoryc C s t �d S r; rb r9 r& r& r' �get_exception_handler' s z'AbstractEventLoop.get_exception_handlerc C s t �d S r; rb )r! Zhandlerr& r& r' �set_exception_handler* s z'AbstractEventLoop.set_exception_handlerc C s t �d S r; rb �r! r% r& r& r' �default_exception_handler- s z+AbstractEventLoop.default_exception_handlerc C s t �d S r; rb r� r& r& r' rB 0 s z(AbstractEventLoop.call_exception_handlerc C s t �d S r; rb r9 r& r& r' r 5 s zAbstractEventLoop.get_debugc C s t �d S r; rb )r! Zenabledr& r& r' � set_debug8 s zAbstractEventLoop.set_debug)r )NN)NN)r N)N)N)NN)r N):r- rG rH rl rm rn ro rp rd rq r` rt rr ru rv rw rz r{ r~ r r� r� r� �socketZ AF_UNSPECZ
AI_PASSIVEr� r� r� r� r� r� r� r� �
subprocess�PIPEr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rB r r� r& r& r& r' r � s� �
� �
� � 5� � � � � � ! � � %
� � � r c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) r c C s t �d S r; rb r9 r& r& r' r ? s z&AbstractEventLoopPolicy.get_event_loopc C s t �d S r; rb �r! r$ r& r& r' r I s z&AbstractEventLoopPolicy.set_event_loopc C s t �d S r; rb r9 r& r& r' r
M s z&AbstractEventLoopPolicy.new_event_loopc C s t �d S r; rb r9 r& r& r' r U s z)AbstractEventLoopPolicy.get_child_watcherc C s t �d S r; rb )r! �watcherr& r& r' r Y s z)AbstractEventLoopPolicy.set_child_watcherN)r- rG rH r r r
r r r& r& r& r' r < s
r c @ sB e Zd ZdZG dd� dej�Zdd� Zdd� Zdd � Z d
d � Z
dS ) �BaseDefaultEventLoopPolicyNc @ s e Zd ZdZdZdS )z!BaseDefaultEventLoopPolicy._LocalNF)r- rG rH r � _set_calledr& r& r& r' �_Localm s r� c C s | � � | _d S r; )r� �_localr9 r& r& r' r( q s z#BaseDefaultEventLoopPolicy.__init__c C sX | j jd kr2| j js2tt�� tj�r2| �| �� � | j jd krPt dt�� j
��| j jS )Nz,There is no current event loop in thread %r.) r� r r� r] � threadingZcurrent_threadZ _MainThreadr r
� RuntimeErrorrx r9 r& r& r' r t s �� �z)BaseDefaultEventLoopPolicy.get_event_loopc C s d| j _|| j _d S r7 )r� r� r r� r& r& r' r � s z)BaseDefaultEventLoopPolicy.set_event_loopc C s | � � S r; )�
_loop_factoryr9 r& r& r' r
� s z)BaseDefaultEventLoopPolicy.new_event_loop) r- rG rH r� r� �localr� r( r r r
r& r& r& r' r� ^ s
r� c @ s e Zd ZdZdS )� _RunningLoop)NNN)r- rG rH �loop_pidr& r& r& r' r� � s r� c C s t � } | d krtd��| S )Nzno running event loop)r r� �r$ r& r& r' r � s r c C s& t j\} }| d k r"|t�� kr"| S d S r; )�
_running_loopr� �os�getpid)Z running_loop�pidr& r& r' r � s
r c C s | t �� ft_d S r; )r� r� r� r� r� r& r& r' r
� s r
c C s. t � td kr ddlm} | � aW 5 Q R X d S )Nr ��DefaultEventLoopPolicy)�_lock�_event_loop_policy� r� r� r& r& r' �_init_event_loop_policy� s r� c C s t d krt� t S r; )r� r� r& r& r& r' r � s r c C s | a d S r; )r� )Zpolicyr& r& r' r � s r c C s t � } | d k r| S t� �� S r; )r r r )Z current_loopr& r& r' r � s
r c C s t � �| � d S r; )r r r� r& r& r' r � s r c C s
t � �� S r; )r r
r& r& r& r' r
� s r
c C s
t � �� S r; )r r r& r& r& r' r � s r c C s t � �| �S r; )r r )r� r& r& r' r � s r )r r
r r )+�__all__r r� r� r� r r� r� r r r r r r r r� r� ZLockr� r� r� r� r r r
r� r r r r r
r r Z_py__get_running_loopZ_py__set_running_loopZ_py_get_running_loopZ_py_get_event_loopZ_asyncio� ImportErrorZ_c__get_running_loopZ_c__set_running_loopZ_c_get_running_loopZ_c_get_event_loopr& r& r& r' � sV J@* q"9