B
n\?Q?J @ s| d Z ddlZddlZddlZddlZddlZddlZddlmZ G dd de Z
G dd dZ G d d
d
e Z G d d d Z
G d
d dZG dd dZG dd deZdae ZG dd dejZe Zdd Zdd Zdd Zdd Zd d Zd d Z d!d" Z d#d$ Z d%d& Z d'd( Z d)d* Z!eZ"eZ#eZ$e Z%y dd+l&mZmZmZm Z W n e'k
rf Y nX eZ(eZ)eZ*e Z+dS ),)AbstractEventLoopPolicyAbstractEventLoopAbstractServerHandle TimerHandleSendfileNotAvailableErrorget_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 @ s e Zd ZdS )r N)__name__
__module__ __qualname__ r r 3/opt/alt/python37/lib64/python3.7/asyncio/events.pyr s r c @ 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 )selfcallbackargsloopcontextr r r __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__r r appendr r _format_callback_sourcer r )r& infoframer r r
_repr_info6 s
zHandle._repr_infoc C s( | j d k r| j S | }dd|S )Nz<{}> )r r4 formatjoin)r& r2 r r r __repr__B 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 cancelH s
z
Handle.cancelc C s | j S )N)r )r& r r r r, S s zHandle.cancelledc
C s y| j j| jf| j W nd tk
r~ } zFt| j| j}d| }||| d}| jrb| j|d< | j | W d d }~X Y nX d } d S )NzException in callback )messageZ exceptionhandleZsource_traceback)
r runr r Exceptionr r1 r r call_exception_handler)r& exccbmsgr* r r r _runV s
z Handle._run)N)
r r r __slots__r+ r4 r8 r: r, rC 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 rF rE )r& whenr' r( r) r* )r/ r r r+ m s
zTimerHandle.__init__c s0 t }| jrdnd}||d| j |S )N r zwhen=)rG r4 r insertrF )r& r2 pos)r/ r r r4 u s
zTimerHandle._repr_infoc C s
t | jS )N)hashrF )r& r r r __hash__{ s zTimerHandle.__hash__c C s | j |j k S )N)rF )r& otherr r r __lt__~ s zTimerHandle.__lt__c C s | j |j k rdS | |S )NT)rF __eq__)r& rN r r r __le__ s zTimerHandle.__le__c C s | j |j kS )N)rF )r& rN r r r __gt__ s zTimerHandle.__gt__c C s | j |j krdS | |S )NT)rF rP )r& rN r r r __ge__ s zTimerHandle.__ge__c C s> t |tr:| j|jko8| j|jko8| j|jko8| j|jkS tS )N)
isinstancer rF r r r NotImplemented)r& rN r r r rP s
zTimerHandle.__eq__c C s | |}|tkrtS | S )N)rP rU )r& rN Zequalr r r __ne__ s
zTimerHandle.__ne__c s | j s| j| t d S )N)r r _timer_handle_cancelledrG r: )r& )r/ r r r: s zTimerHandle.cancelc C s | j S )N)rF )r& r r r rH s zTimerHandle.when)N)r r r rD r+ r4 rM rO rQ rR rS rP rV r: rH
__classcell__r r )r/ r r h 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 )N)NotImplementedError)r& r r r close s zAbstractServer.closec C s t d S )N)rY )r& r r r get_loop s zAbstractServer.get_loopc C s t d S )N)rY )r& r r r
is_serving s zAbstractServer.is_servingc s t d S )N)rY )r& r r r
start_serving s z AbstractServer.start_servingc s t d S )N)rY )r& r r r
serve_forever s z AbstractServer.serve_foreverc s t d S )N)rY )r& r r r wait_closed s zAbstractServer.wait_closedc s | S )Nr )r& r r r
__aenter__ s zAbstractServer.__aenter__c s | | I d H d S )N)rZ r_ )r& r@ r r r __aexit__ s zAbstractServer.__aexit__N) r r r rZ r[ r\ r] r^ r_ r` ra r r r r r s r c @ sH 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 Zd d Zd!d" Zd#d#d#d#d$d%d&Zdsd'd(Zdtd)d#d#d#d)d)d)d)d*d+d,Zduejejd)d-d)d)d)d)d.d/ d0d1Zdvd.d2d3d4Zd5d)d)d6d7d8Z dwd)d)d)d)d9d:d;Z dxd)d-d)d)d.d<d=d>Z dyd#d#d#d)d)d)d)d?d@dAZ dBdC Z dDdE Z!e"j#e"j#e"j#dFdGdHZ$e"j#e"j#e"j#dFdIdJZ%dKdL Z&dMdN Z'dOdP Z(dQdR Z)dSdT Z*dUdV Z+dWdX Z,dYdZ Z-d[d\ Z.dzd)d2d]d^Z/d_d` Z0dadb Z1dcdd Z2dedf Z3dgdh Z4didj Z5dkdl Z6dmdn Z7dodp Z8dqdr Z9d)S ){r c C s t d S )N)rY )r& r r r run_forever s z AbstractEventLoop.run_foreverc C s t d S )N)rY )r& Zfuturer r r run_until_complete s z$AbstractEventLoop.run_until_completec C s t d S )N)rY )r& r r r stop s zAbstractEventLoop.stopc C s t d S )N)rY )r& r r r
is_running s z AbstractEventLoop.is_runningc C s t d S )N)rY )r& r r r is_closed s zAbstractEventLoop.is_closedc C s t d S )N)rY )r& r r r rZ s zAbstractEventLoop.closec s t d S )N)rY )r& r r r shutdown_asyncgens s z$AbstractEventLoop.shutdown_asyncgensc C s t d S )N)rY )r& r< r r r rW 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 )N)rY )r& Zdelayr' r( r r r rh
s z AbstractEventLoop.call_laterc G s t d S )N)rY )r& rH r' r( r r r call_at
s zAbstractEventLoop.call_atc C s t d S )N)rY )r& r r r time s zAbstractEventLoop.timec C s t d S )N)rY )r& r r r
create_future s z AbstractEventLoop.create_futurec C s t d S )N)rY )r& coror r r create_task s z AbstractEventLoop.create_taskc G s t d S )N)rY )r& r' r( r r r call_soon_threadsafe s z&AbstractEventLoop.call_soon_threadsafec s t d S )N)rY )r& executorfuncr( r r r run_in_executor s z!AbstractEventLoop.run_in_executorc C s t d S )N)rY )r& rp r r r set_default_executor# s z&AbstractEventLoop.set_default_executorr )familytypeprotoflagsc s t d S )N)rY )r& hostportrt ru rv rw r r r getaddrinfo( s z AbstractEventLoop.getaddrinfoc s t d S )N)rY )r& Zsockaddrrw r r r getnameinfo, s z AbstractEventLoop.getnameinfoN)sslrt rv rw sock
local_addrserver_hostnamessl_handshake_timeoutc s t d S )N)rY ) r& protocol_factoryrx ry r| rt rv rw r} r~ r r r r r create_connection/ s z#AbstractEventLoop.create_connectiond T) rt rw r} backlogr|
reuse_address
reuse_portr r] c
s t d S )N)rY )
r& r rx ry rt rw r} r r| r r r r] r r r
create_server7 s 3z AbstractEventLoop.create_server)fallbackc s t d S )N)rY )r& transportfileoffsetcountr r r r sendfilel s zAbstractEventLoop.sendfileF) server_sider r c s t d S )N)rY )r& r ZprotocolZ
sslcontextr r r r r r start_tlst s zAbstractEventLoop.start_tls)r| r} r r c s t d S )N)rY )r& r pathr| r} r r r r r create_unix_connection s z(AbstractEventLoop.create_unix_connection)r} r r| r r] c s t d S )N)rY )r& r r r} r r| r r] r r r create_unix_server s z$AbstractEventLoop.create_unix_server)rt rv rw r r allow_broadcastr} c s t d S )N)rY ) r& r r~ Z remote_addrrt rv rw r r r r} r r r create_datagram_endpoint s !z*AbstractEventLoop.create_datagram_endpointc s t d S )N)rY )r& r piper r r connect_read_pipe s z#AbstractEventLoop.connect_read_pipec s t d S )N)rY )r& r r r r r connect_write_pipe s z$AbstractEventLoop.connect_write_pipe)stdinstdoutstderrc s t d S )N)rY )r& r cmdr r r kwargsr r r subprocess_shell s z"AbstractEventLoop.subprocess_shellc s t d S )N)rY )r& r r r r r( r r r r subprocess_exec s z!AbstractEventLoop.subprocess_execc G s t d S )N)rY )r& fdr' r( r r r
add_reader s z AbstractEventLoop.add_readerc C s t d S )N)rY )r& r r r r
remove_reader s z AbstractEventLoop.remove_readerc G s t d S )N)rY )r& r r' r( r r r
add_writer s z AbstractEventLoop.add_writerc C s t d S )N)rY )r& r r r r
remove_writer s z AbstractEventLoop.remove_writerc s t d S )N)rY )r& r} nbytesr r r sock_recv s zAbstractEventLoop.sock_recvc s t d S )N)rY )r& r} bufr r r sock_recv_into s z AbstractEventLoop.sock_recv_intoc s t d S )N)rY )r& r} datar r r sock_sendall s z AbstractEventLoop.sock_sendallc s t d S )N)rY )r& r} Zaddressr r r sock_connect s z AbstractEventLoop.sock_connectc s t d S )N)rY )r& r} r r r sock_accept s z AbstractEventLoop.sock_acceptc s t d S )N)rY )r& r} r r r r r r r
sock_sendfile s z AbstractEventLoop.sock_sendfilec G s t d S )N)rY )r& sigr' r( r r r add_signal_handler s z$AbstractEventLoop.add_signal_handlerc C s t d S )N)rY )r& r r r r remove_signal_handler s z'AbstractEventLoop.remove_signal_handlerc C s t d S )N)rY )r& factoryr r r set_task_factory# s z"AbstractEventLoop.set_task_factoryc C s t d S )N)rY )r& r r r get_task_factory& s z"AbstractEventLoop.get_task_factoryc C s t d S )N)rY )r& r r r get_exception_handler+ s z'AbstractEventLoop.get_exception_handlerc C s t d S )N)rY )r& Zhandlerr r r set_exception_handler. s z'AbstractEventLoop.set_exception_handlerc C s t d S )N)rY )r& r* r r r default_exception_handler1 s z+AbstractEventLoop.default_exception_handlerc C s t d S )N)rY )r& r* r r r r? 4 s z(AbstractEventLoop.call_exception_handlerc C s t d S )N)rY )r& r r r r" 9 s zAbstractEventLoop.get_debugc C s t d S )N)rY )r& Zenabledr r r set_debug< s zAbstractEventLoop.set_debug)r )NN)NN)r N)N)N)NN)r N):r r r rb rc rd re rf rZ rg rW ri rh rj rk rl rn ro rr rs rz 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 r? r" r r r r r r s
/ !
r c @ s4 e Zd Zdd Zdd Zdd Zdd Zd d
Zd S ) r c C s t d S )N)rY )r& r r r r C s z&AbstractEventLoopPolicy.get_event_loopc C s t d S )N)rY )r& r) r r r r
M s z&AbstractEventLoopPolicy.set_event_loopc C s t d S )N)rY )r& r r r r Q s z&AbstractEventLoopPolicy.new_event_loopc C s t d S )N)rY )r& r r r r Y s z)AbstractEventLoopPolicy.get_child_watcherc C s t d S )N)rY )r& watcherr r r r
] s z)AbstractEventLoopPolicy.set_child_watcherN)r r r 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 r r r _set_calledr r r r _Localq s r c C s | | _d S )N)r _local)r& r r r r+ u 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 rT threadingZcurrent_threadZ _MainThreadr
r RuntimeErrorname)r& r r r r x s z)BaseDefaultEventLoopPolicy.get_event_loopc C s d| j _|| j _d S )NT)r r r )r& r) r r r r
s z)BaseDefaultEventLoopPolicy.set_event_loopc C s | S )N)
_loop_factory)r& r r r r s z)BaseDefaultEventLoopPolicy.new_event_loop) r r r r r localr r+ r r
r r r r r r b s
r c @ s e Zd ZdZdS ) _RunningLoop)NNN)r r r 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 )N)
_running_loopr osgetpid)Z running_looppidr r r r s
r c C s | t ft_d S )N)r r r r )r) r r r r s r c C s. t td kr ddlm} | aW d 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 )N)r r r r r r r s r c C s | a d S )N)r )Zpolicyr r r r s r c C s t } | d k r| S t S )N)r r r )Z current_loopr r r r s
r c C s t | d S )N)r r
)r) r r r r
s r
c C s
t S )N)r r r r r r r s r c C s
t S )N)r r r r r r r s r c C s t | S )N)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 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
H@* p"9