U
e5d4f @ sx d Z ddlZddlZddlZddlZddlZddlZddlmZ ddlm Z G dd dZ
G dd d e
Z G d
d d Z G d d
d
Z
G dd dZG dd deZdae ZG dd dejZe 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 )+)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_helpers)
exceptionsc @ 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 krt }|| _|| _|| _|| _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.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 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 k r| j S | }dd|S )Nz<{}> )r r2 formatjoin)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 exceptionhandleZsource_traceback) r runr r
SystemExitKeyboardInterrupt
BaseExceptionr r/ r r call_exception_handler)r! exccbmsgr% 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 fddZdd Zd
d Zd d
Zdd Z dd 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( 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 | jS 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 |tr:| 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 d1d2Zdwd/d3d4d5Zd6ddd7d8d9Z dxddddd:d;d<Z dydd.ddd/d=d>d?Z dzd%d%d%ddddd@dAdBZ dCdD Z dEdF Z!e"j#e"j#e"j#dGdHdIZ$e"j#e"j#e"j#dGdJdKZ%dLdM Z&dNdO Z'dPdQ Z(dRdS Z)dTdU Z*dVdW Z+dXdY Z,dZd[ Z-d\d] Z.d{dd3d^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_laterr! 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! executorfuncr# 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 )familytypeprotoflagsc s t d S r; rb )r! hostportr 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_addrserver_hostnamessl_handshake_timeouthappy_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_connectiond 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! transportfileoffsetcountr 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)stdinstdoutstderrc 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
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; 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 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' _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 tjr2| | | 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 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 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