f
��_
g c @ sj d Z ddlZddlZddlZddlZddlZddlZddlmZ G dd� d�Z G dd� de �Z
G d d
� d
�Z G d d � d �Z G d
d� d�Z
G dd� de
�Zdae�� ZG dd� dej�Ze� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Z d#d$� Z d%d&� Z d'd(� Z eZ eZ!eZ"eZ#z dd)l$mZmZmZmZ W n e%�yT Y n0 eZ&eZ'eZ(eZ)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_helpersc @ sB e Zd ZdZddd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )r )� _callback�_args�
_cancelled�_loop�_source_traceback�_reprZ __weakref__�_contextNc C s\ |d u rt �� }|| _|| _|| _|| _d| _d | _| j�� rRt �
t � d��| _
nd | _
d S )NFr )� contextvarsZ copy_contextr r r r r r � get_debugr Z
extract_stack�sysZ _getframer )�self�callback�args�loop�context� r! �'/usr/lib64/python3.10/asyncio/events.py�__init__ s
�zHandle.__init__c C sl | j jg}| jr|�d� | jd ur:|�t�| j| j�� | jrh| jd }|�d|d � d|d � �� |S )N� cancelled�����z created at r z:r ) � __class__�__name__r Zappendr r �_format_callback_sourcer r )r �infoZframer! r! r" �
_repr_info. s
�
zHandle._repr_infoc C s( | j d ur| j S | �� }d�d�|��S )Nz<{}>z )r r* ZformatZjoin)r r) r! r! r" �__repr__: s
zHandle.__repr__c C s0 | j s,d| _ | j�� r t| �| _d | _d | _d S �NT)r r r Zreprr r r �r r! r! r" �cancel@ s
z
Handle.cancelc C � | j S �N)r r- r! r! r" r$ K � zHandle.cancelledc
C s� z | j j| jg| j�R � W n| ttfy4 � Y nf ty� } zNt�| j| j�}d|� �}||| d�}| j rx| j |d< | j
� |� W Y d }~n
d }~0 0 d } d S )NzException in callback )ZmessageZ exception�handleZsource_traceback) r Zrunr r Z
SystemExitZKeyboardInterruptZ
BaseExceptionr r( r r �call_exception_handler)r �excZcbZmsgr r! r! r" �_runN s" �
�
"z Handle._runr0 )
r' �
__module__� __qualname__� __slots__r# r* r+ r. r$ r5 r! r! r! r" r s
r c sv e Zd ZddgZd� fdd� Z� fdd�Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z � fdd�Z dd� Z
� ZS )r �
_scheduled�_whenNc s0 t � �||||� | jr | jd= || _d| _d S )Nr% F)�superr# r r: r9 )r �whenr r r r �r& r! r" r# g s
zTimerHandle.__init__c s0 t � �� }| jrdnd}|�|d| j� �� |S )Ni r zwhen=)r; r* r Zinsertr: )r r) Zposr= r! r" r* o s
zTimerHandle._repr_infoc C s
t | j�S r0 )Zhashr: r- r! r! r" �__hash__u r1 zTimerHandle.__hash__c C s t |t�r| j|jk S tS r0 ��
isinstancer r: �NotImplemented�r Zotherr! r! r" �__lt__x �
zTimerHandle.__lt__c C s$ t |t�r | j|jk p | �|�S tS r0 �r@ r r: �__eq__rA rB r! r! r" �__le__} �
zTimerHandle.__le__c C s t |t�r| j|jkS tS r0 r? rB r! r! r" �__gt__� rD zTimerHandle.__gt__c C s$ t |t�r | j|jkp | �|�S tS r0 rE rB r! r! r" �__ge__� rH zTimerHandle.__ge__c C s> t |t�r:| j|jko8| j|jko8| j|jko8| j|jkS tS r0 )r@ r r: r r r rA rB r! r! r" rF � s
�
�
�zTimerHandle.__eq__c s | j s| j�| � t� �� d S r0 )r r �_timer_handle_cancelledr; r. r- r= r! r" r. � s zTimerHandle.cancelc C r/ r0 )r: r- r! r! r" r< � � zTimerHandle.whenr0 )r' r6 r7 r8 r# r* r> rC rG rI rJ rF r. r< Z
__classcell__r! r! r= r" r b s r c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dS )r c C � t �d S r0 �ZNotImplementedErrorr- r! r! r" �close� � zAbstractServer.closec C rM r0 rN r- r! r! r" �get_loop� rP zAbstractServer.get_loopc C rM r0 rN r- r! r! r" �
is_serving� rP zAbstractServer.is_servingc � rM r0 rN r- r! r! r" �
start_serving� rL z AbstractServer.start_servingc � rM r0 rN r- r! r! r" �
serve_forever� � z AbstractServer.serve_foreverc � rM r0 rN r- r! r! r" � wait_closed� rP zAbstractServer.wait_closedc � s | S r0 r! r- r! r! r" �
__aenter__� r1 zAbstractServer.__aenter__c � s | � � | �� I d H d S r0 )rO rV )r r4 r! r! r" � __aexit__� s zAbstractServer.__aexit__N) r' r6 r7 rO rQ rR rS rT rV rW rX r! r! r! r" r � s r c @ sZ e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d �d d �Zd!d"� Zd#d$� Zd%d&� Zd'd'd'd'd(�d)d*�Zdvd+d,�Zdwd d'd'd'd d d d d d d-�
d.d/�Zdxejejd d0d d d d d1d2� d3d4�Zdyd1d5�d6d7�Z d8d d d9�d:d;�Z dzd d d d d<�d=d>�Z d{d d0d d d1d?�d@dA�Z d|d'd'd'd d d d dB�dCdD�Z dEdF� Z!dGdH� Z"e#j$e#j$e#j$dI�dJdK�Z%e#j$e#j$e#j$dI�dLdM�Z&dNdO� Z'dPdQ� Z(dRdS� Z)dTdU� Z*dVdW� Z+dXdY� Z,dZd[� Z-d\d]� Z.d^d_� Z/d}d d5�d`da�Z0dbdc� Z1ddde� Z2dfdg� Z3dhdi� Z4djdk� Z5dldm� Z6dndo� Z7dpdq� Z8drds� Z9dtdu� Z:d S )~r c C rM r0 rN r- r! r! r" � run_forever� rP z AbstractEventLoop.run_foreverc C rM r0 rN )r Zfuturer! r! r" �run_until_complete� rU z$AbstractEventLoop.run_until_completec C rM r0 rN r- r! r! r" �stop� rL zAbstractEventLoop.stopc C rM r0 rN r- r! r! r" �
is_running� rP z AbstractEventLoop.is_runningc C rM r0 rN r- r! r! r" � is_closed� rP zAbstractEventLoop.is_closedc C rM r0 rN r- r! r! r" rO � � zAbstractEventLoop.closec � rM r0 rN r- r! r! r" �shutdown_asyncgens� rP z$AbstractEventLoop.shutdown_asyncgensc � rM r0 rN r- r! r! r" �shutdown_default_executor� rP z+AbstractEventLoop.shutdown_default_executorc C rM r0 rN )r r2 r! r! r" rK rP z)AbstractEventLoop._timer_handle_cancelledc G s | j d|g|�R � S )Nr )�
call_later�r r r r! r! r" � call_soon r1 zAbstractEventLoop.call_soonc G rM r0 rN )r Zdelayr r r! r! r" ra r1 z AbstractEventLoop.call_laterc G rM r0 rN )r r< r r r! r! r" �call_at r1 zAbstractEventLoop.call_atc C rM r0 rN r- r! r! r" �time r1 zAbstractEventLoop.timec C rM r0 rN r- r! r! r" �
create_future r1 z AbstractEventLoop.create_futureN)�namec C rM r0 rN )r Zcororg r! r! r" � create_task r1 z AbstractEventLoop.create_taskc G rM r0 rN rb r! r! r" �call_soon_threadsafe r1 z&AbstractEventLoop.call_soon_threadsafec G rM r0 rN )r �executorZfuncr r! r! r" �run_in_executor r1 z!AbstractEventLoop.run_in_executorc C rM r0 rN )r rj r! r! r" �set_default_executor! r1 z&AbstractEventLoop.set_default_executorr )�family�type�proto�flagsc � rM r0 rN )r �host�portrm rn ro rp r! r! r" � getaddrinfo& rP z AbstractEventLoop.getaddrinfoc � rM r0 rN )r Zsockaddrrp r! r! r" � getnameinfo* r1 z AbstractEventLoop.getnameinfo)
�sslrm ro rp �sock�
local_addr�server_hostname�ssl_handshake_timeout�happy_eyeballs_delay�
interleavec
� rM r0 rN )r �protocol_factoryrq rr ru rm ro rp rv rw rx ry rz r{ r! r! r" �create_connection- � z#AbstractEventLoop.create_connectionid T) rm rp rv �backlogru �
reuse_address�
reuse_portry rS c
� rM r0 rN )
r r| rq rr rm rp rv r ru r� r� ry rS r! r! r" �
create_server6 s 3z AbstractEventLoop.create_server)�fallbackc � rM r0 rN )r � transport�file�offset�countr� r! r! r" �sendfilek rL zAbstractEventLoop.sendfileF)� server_siderx ry c � rM r0 rN )r r� ZprotocolZ
sslcontextr� rx ry r! r! r" � start_tlss r^ zAbstractEventLoop.start_tls)ru rv rx ry c � rM r0 rN )r r| �pathru rv rx ry r! r! r" �create_unix_connection~ rU z(AbstractEventLoop.create_unix_connection)rv r ru ry rS c � rM r0 rN )r r| r� rv r ru ry rS r! r! r" �create_unix_server� s z$AbstractEventLoop.create_unix_server)rm ro rp r� r� �allow_broadcastrv c � rM r0 rN ) r r| rw Z remote_addrrm ro rp r� r� r� rv r! r! r" �create_datagram_endpoint� s !z*AbstractEventLoop.create_datagram_endpointc � rM r0 rN �r r| Zpiper! r! r" �connect_read_pipe� � z#AbstractEventLoop.connect_read_pipec � rM r0 rN r� r! r! r" �connect_write_pipe� r� z$AbstractEventLoop.connect_write_pipe)�stdin�stdout�stderrc � rM r0 rN )r r| Zcmdr� r� r� �kwargsr! r! r" �subprocess_shell� rU z"AbstractEventLoop.subprocess_shellc � rM r0 rN )r r| r� r� r� r r� r! r! r" �subprocess_exec� rU z!AbstractEventLoop.subprocess_execc G rM r0 rN �r �fdr r r! r! r" �
add_reader� r1 z AbstractEventLoop.add_readerc C rM r0 rN �r r� r! r! r" �
remove_reader� r1 z AbstractEventLoop.remove_readerc G rM r0 rN r� r! r! r" �
add_writer� r1 z AbstractEventLoop.add_writerc C rM r0 rN r� r! r! r" �
remove_writer r1 z AbstractEventLoop.remove_writerc � rM r0 rN )r rv Znbytesr! r! r" � sock_recv r1 zAbstractEventLoop.sock_recvc � rM r0 rN )r rv Zbufr! r! r" �sock_recv_into r1 z AbstractEventLoop.sock_recv_intoc � rM r0 rN )r rv Zdatar! r! r" � sock_sendall r1 z AbstractEventLoop.sock_sendallc � rM r0 rN )r rv Zaddressr! r! r" � sock_connect r1 z AbstractEventLoop.sock_connectc � rM r0 rN )r rv r! r! r" � sock_accept r1 z AbstractEventLoop.sock_acceptc � rM r0 rN )r rv r� r� r� r� r! r! r" �
sock_sendfile rP z AbstractEventLoop.sock_sendfilec G rM r0 rN )r �sigr r r! r! r" �add_signal_handler r1 z$AbstractEventLoop.add_signal_handlerc C rM r0 rN )r r� r! r! r" �remove_signal_handler r1 z'AbstractEventLoop.remove_signal_handlerc C rM r0 rN )r Zfactoryr! r! r" �set_task_factory" r1 z"AbstractEventLoop.set_task_factoryc C rM r0 rN r- r! r! r" �get_task_factory% r1 z"AbstractEventLoop.get_task_factoryc C rM r0 rN r- r! r! r" �get_exception_handler* r1 z'AbstractEventLoop.get_exception_handlerc C rM r0 rN )r Zhandlerr! r! r" �set_exception_handler- r1 z'AbstractEventLoop.set_exception_handlerc C rM r0 rN �r r r! r! r" �default_exception_handler0 r1 z+AbstractEventLoop.default_exception_handlerc C rM r0 rN r� r! r! r" r3 3 r1 z(AbstractEventLoop.call_exception_handlerc C rM r0 rN r- r! r! r" r 8 r1 zAbstractEventLoop.get_debugc C rM r0 rN )r Zenabledr! r! r" � set_debug; r1 zAbstractEventLoop.set_debug)r �NNr� �r Nr0 r0 r� r� );r' r6 r7 rY rZ r[ r\ r] rO r_ r` rK rc ra rd re rf rh ri rk rl rs rt r} �socketZ AF_UNSPECZ
AI_PASSIVEr� r� r� r� r� r� r� r� �
subprocessZPIPEr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r3 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 rM r0 rN r- r! r! r" r B s z&AbstractEventLoopPolicy.get_event_loopc C rM r0 rN �r r r! r! r" r L rP z&AbstractEventLoopPolicy.set_event_loopc C rM r0 rN r- r! r! r" r P s z&AbstractEventLoopPolicy.new_event_loopc C rM r0 rN r- r! r! r" r
X rP z)AbstractEventLoopPolicy.get_child_watcherc C rM r0 rN )r �watcherr! r! r" r \ rP z)AbstractEventLoopPolicy.set_child_watcherN)r' r6 r7 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' r6 r7 r � _set_calledr! r! r! r" �_Localp s r� c C s | � � | _d S r0 )r� �_localr- r! r! r" r# t r1 z#BaseDefaultEventLoopPolicy.__init__c C sX | j jd u r2| j js2t�� t�� u r2| �| �� � | j jd u rPtdt�� j ��| j jS )Nz,There is no current event loop in thread %r.)
r� r r� � threadingZcurrent_threadZ main_threadr r � RuntimeErrorrg r- r! r! r" r w s �� �z)BaseDefaultEventLoopPolicy.get_event_loopc C s d| j _|| j _d S r, )r� r� r r� r! r! r" r � s z)BaseDefaultEventLoopPolicy.set_event_loopc C s | � � S r0 )�
_loop_factoryr- r! r! r" r � rL z)BaseDefaultEventLoopPolicy.new_event_loop) r' r6 r7 r� r� �localr� r# r r r r! r! r! r" r� a s
r� c @ s e Zd ZdZdS )� _RunningLoopr� N)r' r6 r7 �loop_pidr! r! r! r" r� � s r� c C s t � } | d u rtd��| S )Nzno running event loop)r r� �r r! r! r" r
� s r
c C s& t j\} }| d ur"|t�� kr"| S d S r0 )�
_running_loopr� �os�getpid)Z running_loopZpidr! r! r" r � s
r c C s | t �� ft_d S r0 )r� r� r� r� r� r! r! r" r � r~ r c C sB t �* td u r ddlm} | � aW d � n1 s40 Y d S )Nr ��DefaultEventLoopPolicy)�_lock�_event_loop_policy� r� r� r! r! r" �_init_event_loop_policy� s r� c C s t d u rt� t S r0 )r� r� r! r! r! r" r � s r c C s | a d S r0 )r� )Zpolicyr! r! r" r � rL r c C s t � } | d ur| S t� �� S r0 )r r r )Z current_loopr! r! r" r � s
r c C s t � �| � d S r0 )r r r� r! r! r" r � rP r c C �
t � �� S r0 )r r r! r! r! r" r � rP r c C r� r0 )r r
r! r! r! r" r
� rP r
c C s t � �| �S r0 )r r )r� r! r! r" r s r )r r r
r )*Z__all__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_asyncioZ ImportErrorZ_c__get_running_loopZ_c__set_running_loopZ_c_get_running_loopZ_c_get_event_loopr! r! r! r" Z<module> sT J@* u"9