a
iSg @ sj d Z ddlZddlZddlZddlZddlZddlZddlmZ G dd dZ G dd de Z
G d d
d
Z G d d d Z G d
d dZ
G dd de
Zdae ZG dd dejZe 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 )*)AbstractEventLoopPolicyAbstractEventLoopAbstractServerHandle TimerHandleget_event_loop_policyset_event_loop_policyget_event_loopset_event_loopnew_event_loopget_child_watcherset_child_watcher_set_running_loopget_running_loop_get_running_loop N )format_helpersc @ sB e Zd ZdZdddZdd Zdd Zd d
Zd d Zd
d Z dS )r ) _callback_args
_cancelled_loop_source_traceback_repr __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
extract_stacksys _getframer )selfcallbackargsloopcontext r% &/usr/lib64/python3.9/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 cancelledz created at r :r ) __class____name__r appendr r _format_callback_sourcer r )r infoframer% r% r&
_repr_info. s
zHandle._repr_infoc C s( | j d ur| j S | }dd|S )Nz<{}> )r r1 formatjoin)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 reprr r r r r% r% r& cancel@ s
z
Handle.cancelc C s | j S N)r r8 r% r% r& r( K s zHandle.cancelledc
C s z | j j| jg| jR 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 )message exceptionhandleZsource_traceback) r runr r
SystemExitKeyboardInterrupt
BaseExceptionr r. r r call_exception_handler)r exccbmsgr$ r% r% r& _runN s"
"z Handle._run)N)
r,
__module__ __qualname__ __slots__r' r1 r5 r9 r( rF r% r% r% r& r s
r c sv e Zd ZddgZd fdd Z fddZdd Zd
d Zd d
Zdd Z dd Z
dd Z fddZ 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' g s
zTimerHandle.__init__c s0 t }| jrdnd}||d| j |S )N r zwhen=)rL r1 r insertrK )r r/ posrN r% r& r1 o s
zTimerHandle._repr_infoc C s
t | jS r: )hashrK r8 r% r% r& __hash__u s zTimerHandle.__hash__c C s t |tr| j|jk S tS r:
isinstancer rK NotImplementedr otherr% r% r& __lt__x s
zTimerHandle.__lt__c C s$ t |tr | j|jk p | |S tS r: rU r rK __eq__rV rW r% r% r& __le__} s
zTimerHandle.__le__c C s t |tr| j|jkS tS r: rT rW r% r% r& __gt__ s
zTimerHandle.__gt__c C s$ t |tr | j|jkp | |S tS r: rZ rW r% r% r& __ge__ s
zTimerHandle.__ge__c C s> t |tr:| j|jko8| j|jko8| j|jko8| j|jkS tS r: )rU r rK r r r rV rW r% r% r& r[ s
zTimerHandle.__eq__c s | j s| j| t d S r: )r r _timer_handle_cancelledrL r9 r8 rN r% r& r9 s zTimerHandle.cancelc C s | j S r: )rK r8 r% r% r& rM s zTimerHandle.when)N)r, rG rH rI r' r1 rS rY r\ r] r^ r[ r9 rM
__classcell__r% r% rN 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 s t d S r: NotImplementedErrorr8 r% r% r& close s zAbstractServer.closec C s t d S r: ra r8 r% r% r& get_loop s zAbstractServer.get_loopc C s t d S r: ra r8 r% r% r&
is_serving s zAbstractServer.is_servingc s t d S r: ra r8 r% r% r&
start_serving s z AbstractServer.start_servingc s t d S r: ra r8 r% r% r&
serve_forever s z AbstractServer.serve_foreverc s t d S r: ra r8 r% r% r& wait_closed s zAbstractServer.wait_closedc s | S r: r% r8 r% r% r&
__aenter__ s zAbstractServer.__aenter__c s | | I d H d S r: )rc rh )r rC r% r% r& __aexit__ s zAbstractServer.__aexit__N) r, rG rH rc rd re rf rg rh ri rj 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 ddddZ ddddZ
ddddZdd Zd d Zdd d d!Zddd"d#Zd$d% Zd&d' Zd(d(d(d(d)d*d+Zdwd,d-Zdxdd(d(d(ddddddd.
d/d0Zdyejejdd1ddddd2d3 d4d5Zdzd2d6d7d8Z d9ddd:d;d<Z d{ddddd=d>d?Z d|dd1ddd2d@dAdBZ d}d(d(d(dddddCdDdEZ dFdG Z!dHdI Z"e#j$e#j$e#j$dJdKdLZ%e#j$e#j$e#j$dJdMdNZ&dOdP Z'dQdR Z(dSdT Z)dUdV Z*dWdX Z+dYdZ Z,d[d\ Z-d]d^ Z.d_d` Z/d~dd6dadbZ0dcdd Z1dedf Z2dgdh Z3didj Z4dkdl Z5dmdn Z6dodp Z7dqdr Z8dsdt Z9dudv Z:dS )r c C s t d S r: ra r8 r% r% r& run_forever s z AbstractEventLoop.run_foreverc C s t d S r: ra )r futurer% r% r& run_until_complete s z$AbstractEventLoop.run_until_completec C s t d S r: ra r8 r% r% r& stop s zAbstractEventLoop.stopc C s t d S r: ra r8 r% r% r&
is_running s z AbstractEventLoop.is_runningc C s t d S r: ra r8 r% r% r& is_closed s zAbstractEventLoop.is_closedc C s t d S r: ra r8 r% r% r& rc s zAbstractEventLoop.closec s t d S r: ra r8 r% r% r& shutdown_asyncgens s z$AbstractEventLoop.shutdown_asyncgensc s t d S r: ra r8 r% r% r& shutdown_default_executor s z+AbstractEventLoop.shutdown_default_executorc C s t d S r: ra )r r= r% r% r& r_ s z)AbstractEventLoop._timer_handle_cancelledN)r$ c G s | j d|g|R d|iS )Nr r$ )
call_laterr r! r$ r" r% r% r& call_soon s zAbstractEventLoop.call_soonc G s t d S r: ra )r delayr! r$ r" r% r% r& rs s z AbstractEventLoop.call_laterc G s t d S r: ra )r rM r! r$ r" r% r% r& call_at s zAbstractEventLoop.call_atc C s t d S r: ra r8 r% r% r& time s zAbstractEventLoop.timec C s t d S r: ra r8 r% r% r&
create_future s z AbstractEventLoop.create_future)namec C s t d S r: ra )r cororz r% r% r& create_task s z AbstractEventLoop.create_taskc G s t d S r: ra rt r% r% r& call_soon_threadsafe s z&AbstractEventLoop.call_soon_threadsafec G s t d S r: ra )r executorfuncr" r% r% r& run_in_executor s z!AbstractEventLoop.run_in_executorc C s t d S r: ra )r r~ r% r% r& set_default_executor! s z&AbstractEventLoop.set_default_executorr )familytypeprotoflagsc s t d S r: ra )r hostportr r r r r% r% r& getaddrinfo& s z AbstractEventLoop.getaddrinfoc s t d S r: ra )r Zsockaddrr r% r% r& getnameinfo* s z AbstractEventLoop.getnameinfo)
sslr r r sock
local_addrserver_hostnamessl_handshake_timeouthappy_eyeballs_delay
interleavec
s t d S r: ra )r protocol_factoryr r r r r r r r r r r r r% r% r& create_connection- s z#AbstractEventLoop.create_connectiond T) r r r backlogr
reuse_address
reuse_portr rf c
s t d S r: ra )
r r r r r r r r r r r r rf r% r% r&
create_server6 s 3z AbstractEventLoop.create_server)fallbackc s t d S r: ra )r transportfileoffsetcountr r% r% r& sendfilek s zAbstractEventLoop.sendfileF) server_sider r c s t d S r: ra )r r protocolZ
sslcontextr r r r% r% r& start_tlss s zAbstractEventLoop.start_tls)r r r r c s t d S r: ra )r r pathr r r r r% r% r& create_unix_connection~ s z(AbstractEventLoop.create_unix_connection)r r r r rf c s t d S r: ra )r r r r r r r rf 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: ra ) 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: ra r r piper% r% r& connect_read_pipe s z#AbstractEventLoop.connect_read_pipec s t d S r: ra r r% r% r& connect_write_pipe s z$AbstractEventLoop.connect_write_pipe)stdinstdoutstderrc s t d S r: ra )r r cmdr r r kwargsr% r% r& subprocess_shell s z"AbstractEventLoop.subprocess_shellc s t d S r: ra )r r r r r r" r r% r% r& subprocess_exec s z!AbstractEventLoop.subprocess_execc G s t d S r: ra r fdr! r" r% r% r&
add_reader s z AbstractEventLoop.add_readerc C s t d S r: ra r r r% r% r&
remove_reader s z AbstractEventLoop.remove_readerc G s t d S r: ra r r% r% r&
add_writer s z AbstractEventLoop.add_writerc C s t d S r: ra r r% r% r&
remove_writer s z AbstractEventLoop.remove_writerc s t d S r: ra )r r nbytesr% r% r& sock_recv s zAbstractEventLoop.sock_recvc s t d S r: ra )r r bufr% r% r& sock_recv_into s z AbstractEventLoop.sock_recv_intoc s t d S r: ra )r r datar% r% r& sock_sendall s z AbstractEventLoop.sock_sendallc s t d S r: ra )r r addressr% r% r& sock_connect s z AbstractEventLoop.sock_connectc s t d S r: ra )r r r% r% r& sock_accept s z AbstractEventLoop.sock_acceptc s t d S r: ra )r r r r r r r% r% r&
sock_sendfile s z AbstractEventLoop.sock_sendfilec G s t d S r: ra )r sigr! r" r% r% r& add_signal_handler s z$AbstractEventLoop.add_signal_handlerc C s t d S r: ra )r r r% r% r& remove_signal_handler s z'AbstractEventLoop.remove_signal_handlerc C s t d S r: ra )r factoryr% r% r& set_task_factory" s z"AbstractEventLoop.set_task_factoryc C s t d S r: ra r8 r% r% r& get_task_factory% s z"AbstractEventLoop.get_task_factoryc C s t d S r: ra r8 r% r% r& get_exception_handler* s z'AbstractEventLoop.get_exception_handlerc C s t d S r: ra )r handlerr% r% r& set_exception_handler- s z'AbstractEventLoop.set_exception_handlerc C s t d S r: ra r r$ r% r% r& default_exception_handler0 s z+AbstractEventLoop.default_exception_handlerc C s t d S r: ra r r% r% r& rB 3 s z(AbstractEventLoop.call_exception_handlerc C s t d S r: ra r8 r% r% r& r 8 s zAbstractEventLoop.get_debugc C s t d S r: ra )r Zenabledr% r% r& set_debug; s zAbstractEventLoop.set_debug)r )NN)NN)r N)N)N)NN)r N);r, rG rH rk rm rn ro rp rc rq rr r_ ru rs rw rx ry r| r} r r r r r socket AF_UNSPEC
AI_PASSIVEr r r r r r r r
subprocessPIPEr 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: ra r8 r% r% r& r B s z&AbstractEventLoopPolicy.get_event_loopc C s t d S r: ra r r# r% r% r& r L s z&AbstractEventLoopPolicy.set_event_loopc C s t d S r: ra r8 r% r% r& r
P s z&AbstractEventLoopPolicy.new_event_loopc C s t d S r: ra r8 r% r% r& r X s z)AbstractEventLoopPolicy.get_child_watcherc C s t d S r: ra )r watcherr% r% r& r \ 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 dejZdd Zdd Zdd Z d
d Z
dS ) BaseDefaultEventLoopPolicyNc @ s e Zd ZdZdZdS )z!BaseDefaultEventLoopPolicy._LocalNF)r, rG rH r _set_calledr% r% r% r& _Localp s r c C s | | _d S r: )r _localr8 r% r% r& r' t s 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 threadingcurrent_thread main_threadr r
RuntimeErrorrz r8 r% r% r& r w s z)BaseDefaultEventLoopPolicy.get_event_loopc C s d| j _|| j _d S r6 )r r r r r% r% r& r s z)BaseDefaultEventLoopPolicy.set_event_loopc C s | S r: )
_loop_factoryr8 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 a 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 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 r: )
_running_loopr osgetpid)Z running_looppidr% 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 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 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 ur| 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 Lockr 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& sT J@* u"9