3
\[ @ s| d ddddddddd d
d d d
gZ ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
m Z ddl
m Z dd Z
dd Zd2ddZdd Zd3d d ZG d d dZG d d deZG d d dZG d!d dZG d"d d ZG d#d$ d$eZdaej ZG d%d& d&ejZ e Z d'd
Z d(d Z d)d* Z d+d Z!d,d Z"d-d Z#d.d Z$d/d Z%d0d
Z&d1d Z'dS )4AbstractEventLoopPolicyAbstractEventLoopAbstractServerHandle TimerHandleget_event_loop_policyset_event_loop_policyget_event_loopset_event_loopnew_event_loopget_child_watcherset_child_watcher_set_running_loop_get_running_loop N )compat) constantsc C st t jrtj| } nt| dr"| j} tj| r>| j}|j|j fS t
| t j rTt
| jS t jrpt
| t jrpt
| jS d S )N __wrapped__)r ZPY34inspectZunwraphasattrr Z
isfunction__code__ co_filenameco_firstlineno
isinstance functoolspartial_get_function_sourcefunc
partialmethod)r code r &/usr/lib64/python3.6/asyncio/events.pyr s
r c C sJ g }| r |j dd | D |r8|j dd |j D ddj| d S )Nc s s | ]}t j|V qd S )N)reprlibrepr).0argr r r! 1 s z*_format_args_and_kwargs..c s s$ | ] \}}d j |tj|V qdS )z{}={}N)formatr" r# )r$ kvr r r! r& 3 s (z, ))extenditemsjoin)argskwargsr- r r r! _format_args_and_kwargs) s
r1 c C s t | tjr.t||| }t| j| j| j|S t| drF| j rF| j }n t| dr^| j
r^| j
}nt | }|t||7 }|r||7 }|S )N __qualname____name__) r r r r1 _format_callbackr r/ keywordsr r3 r4 r# )r r/ r0 suffix func_reprr r r! r5 8 s r5 c C s( t | |d }t| }|r$|d| 7 }|S )Nz at %s:%s)r5 r )r r/ r8 sourcer r r! _format_callback_sourceI s
r: c C sD | d krt j j} |d kr tj}tjjtj| |dd}|j |S )NF)limit lookup_lines)
sys _getframef_backr ZDEBUG_STACK_DEPTH traceback StackSummaryextract
walk_stackreverse)fr; stackr r r!
extract_stackQ s
rG c @ s8 e Zd ZdZdd Zd
d Zd d
Zdd Zdd ZdS )r _callback_args
_cancelled_loop_source_traceback_repr __weakref__c C sD || _ || _|| _d| _d | _| j j r:ttjd| _ nd | _ d S )NFr )
rK rH rI rJ rM get_debugrG r= r> rL )selfcallbackr/ loopr r r! __init__h s
zHandle.__init__c C sf | j jg}| jr|jd | jd k r8|jt| j| j | jrb| jd }|jd|d |d f |S )NZ cancelledr zcreated at %s:%sr ) __class__r4 rJ appendrH r: rI rL )rP infoframer r r!
_repr_infos s
zHandle._repr_infoc C s& | j d k r| j S | j }ddj| S )Nz<%s> )rM rY r. )rP rW r r r! __repr__~ s
zHandle.__repr__c C s0 | j s,d| _ | jj r t| | _d | _d | _d S )NT)rJ rK rO r# rM rH rI )rP r r r! cancel s
z
Handle.cancelc C s| y| j | j W nb tk
rr } zFt| j | j}dj|}||| d}| jrV| j|d< | jj| W Y d d }~X nX d } d S )NzException in callback {})messageZ exceptionhandleZsource_traceback)rH rI Exceptionr: r' rL rK call_exception_handler)rP exccbmsgcontextr r r! _run s
z Handle._runN)rH rI rJ rK rL rM rN ) r4
__module__r3 __slots__rS rY r[ r\ re r r r r! r b s c st e Zd ZddgZ fddZ fddZdd Zd d
Zd d Zd
d Z dd Z
dd Z dd Z fddZ
ZS )r
_scheduled_whenc s. t j||| | jr | jd= || _d| _d S )Nr FrT )superrS rL ri rh )rP whenrQ r/ rR )rU r r! rS s
zTimerHandle.__init__c s. t j }| jrdnd}|j|d| j |S )N r zwhen=%s)rj rY rJ insertri )rP rW pos)rU r r! rY s
zTimerHandle._repr_infoc C s
t | jS )N)hashri )rP r r r! __hash__ s zTimerHandle.__hash__c C s | j |j k S )N)ri )rP otherr r r! __lt__ s zTimerHandle.__lt__c C s | j |j k rdS | j|S )NT)ri __eq__)rP rq r r r! __le__ s zTimerHandle.__le__c C s | j |j kS )N)ri )rP rq r r r! __gt__ s zTimerHandle.__gt__c C s | j |j krdS | j|S )NT)ri rs )rP rq r r r! __ge__ s zTimerHandle.__ge__c C s> t |tr:| j|jko8| j|jko8| j|jko8| j|jkS tS )N)r r ri rH rI rJ NotImplemented)rP rq r r r! rs s
zTimerHandle.__eq__c C s | j |}|tkrtS | S )N)rs rw )rP rq Zequalr r r! __ne__ s
zTimerHandle.__ne__c s | j s| jj| t j d S )N)rJ rK _timer_handle_cancelledrj r\ )rP )rU r r! r\ s zTimerHandle.cancel)r4 rf r3 rg rS rY rp rr rt ru rv rs rx r\
__classcell__r r )rU r! r s c @ s e Zd Zdd Zdd ZdS )r c C s t S )N)rw )rP r r r! close s zAbstractServer.closec C s t S )N)rw )rP r r r! wait_closed s zAbstractServer.wait_closedN)r4 rf r3 r{ r| r r r r! r s c @ s 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&Zdgd'd(Zdhd)d#d#d#d)d)d)d*d+d,Zdiejejd)d-d)d)d)d.d/d0Zd)d)d)d1d2d3Zd)d-d)d4d5d6Z djd#d#d#d)d)d)d)d7d8d9Z d:d; Z dd?d@Z"e j!e j!e j!d>dAdBZ#dCdD Z$dEdF Z%dGdH Z&dIdJ Z'dKdL Z(dMdN Z)dOdP Z*dQdR Z+dSdT Z,dUdV Z-dWdX Z.dYdZ Z/d[d\ Z0d]d^ Z1d_d` Z2dadb Z3dcdd Z4dedf Z5d)S )kr c C s t d S )N)NotImplementedError)rP r r r! run_forever s z AbstractEventLoop.run_foreverc C s t d S )N)r} )rP Zfuturer r r! run_until_complete s z$AbstractEventLoop.run_until_completec C s t d S )N)r} )rP r r r! stop s zAbstractEventLoop.stopc C s t d S )N)r} )rP r r r!
is_running s z AbstractEventLoop.is_runningc C s t d S )N)r} )rP r r r! is_closed s zAbstractEventLoop.is_closedc C s t d S )N)r} )rP r r r! r{ s zAbstractEventLoop.closec C s t d S )N)r} )rP r r r! shutdown_asyncgens s z$AbstractEventLoop.shutdown_asyncgensc C s t d S )N)r} )rP r^ r r r! ry s z)AbstractEventLoop._timer_handle_cancelledc G s | j d|f| S )Nr )
call_later)rP rQ r/ r r r! call_soon s zAbstractEventLoop.call_soonc G s t d S )N)r} )rP ZdelayrQ r/ r r r! r s z AbstractEventLoop.call_laterc G s t d S )N)r} )rP rk rQ r/ r r r! call_at s zAbstractEventLoop.call_atc C s t d S )N)r} )rP r r r! time" s zAbstractEventLoop.timec C s t d S )N)r} )rP r r r!
create_future% s z AbstractEventLoop.create_futurec C s t d S )N)r} )rP coror r r! create_task* s z AbstractEventLoop.create_taskc G s t d S )N)r} )rP rQ r/ r r r! call_soon_threadsafe/ s z&AbstractEventLoop.call_soon_threadsafec G s t d S )N)r} )rP executorr r/ r r r! run_in_executor2 s z!AbstractEventLoop.run_in_executorc C s t d S )N)r} )rP r r r r! set_default_executor5 s z&AbstractEventLoop.set_default_executorr )familytypeprotoflagsc C s t d S )N)r} )rP hostportr r r r r r r! getaddrinfo: s z AbstractEventLoop.getaddrinfoc C s t d S )N)r} )rP Zsockaddrr r r r! getnameinfo= s z AbstractEventLoop.getnameinfoN)sslr r r sock
local_addrserver_hostnamec C s t d S )N)r} ) rP protocol_factoryr r r r r r r r r r r r! create_connection@ s z#AbstractEventLoop.create_connectiond )r r r backlogr
reuse_address
reuse_portc C s t d S )N)r} ) rP r r r r r r r r r r r r r!
create_serverE s 'z AbstractEventLoop.create_server)r r r c C s t d S )N)r} )rP r pathr r r r r r! create_unix_connectionn s z(AbstractEventLoop.create_unix_connection)r r r c C s t d S )N)r} )rP r r r r r r r r! create_unix_servers s z$AbstractEventLoop.create_unix_server)r r r r r allow_broadcastr c C s t d S )N)r} ) rP r r Z remote_addrr r r r r r r r r r! create_datagram_endpoint s !z*AbstractEventLoop.create_datagram_endpointc C s t d S )N)r} )rP r piper r r! connect_read_pipe s z#AbstractEventLoop.connect_read_pipec C s t d S )N)r} )rP r r r r r! connect_write_pipe s z$AbstractEventLoop.connect_write_pipe)stdinstdoutstderrc K s t d S )N)r} )rP r cmdr r r r0 r r r! subprocess_shell s z"AbstractEventLoop.subprocess_shellc O s t d S )N)r} )rP r r r r r/ r0 r r r! subprocess_exec s z!AbstractEventLoop.subprocess_execc G s t d S )N)r} )rP fdrQ r/ r r r!
add_reader s z AbstractEventLoop.add_readerc C s t d S )N)r} )rP r r r r!
remove_reader s z AbstractEventLoop.remove_readerc G s t d S )N)r} )rP r rQ r/ r r r!
add_writer s z AbstractEventLoop.add_writerc C s t d S )N)r} )rP r r r r!
remove_writer s z AbstractEventLoop.remove_writerc C s t d S )N)r} )rP r nbytesr r r! sock_recv s zAbstractEventLoop.sock_recvc C s t d S )N)r} )rP r datar r r! sock_sendall s z AbstractEventLoop.sock_sendallc C s t d S )N)r} )rP r Zaddressr r r! sock_connect s z AbstractEventLoop.sock_connectc C s t d S )N)r} )rP r r r r! sock_accept s z AbstractEventLoop.sock_acceptc G s t d S )N)r} )rP sigrQ r/ r r r! add_signal_handler s z$AbstractEventLoop.add_signal_handlerc C s t d S )N)r} )rP r r r r! remove_signal_handler s z'AbstractEventLoop.remove_signal_handlerc C s t d S )N)r} )rP factoryr r r! set_task_factory s z"AbstractEventLoop.set_task_factoryc C s t d S )N)r} )rP r r r! get_task_factory s z"AbstractEventLoop.get_task_factoryc C s t d S )N)r} )rP r r r! get_exception_handler s z'AbstractEventLoop.get_exception_handlerc C s t d S )N)r} )rP Zhandlerr r r! set_exception_handler s z'AbstractEventLoop.set_exception_handlerc C s t d S )N)r} )rP rd r r r! default_exception_handler s z+AbstractEventLoop.default_exception_handlerc C s t d S )N)r} )rP rd r r r! r` s z(AbstractEventLoop.call_exception_handlerc C s t d S )N)r} )rP r r r! rO s zAbstractEventLoop.get_debugc C s t d S )N)r} )rP Zenabledr r r! set_debug s zAbstractEventLoop.set_debug)r )NN)NN)NN)6r4 rf r3 r~ r r r r r{ r ry r r r r r r r r r r r r socketZ AF_UNSPECZ
AI_PASSIVEr r r r r r
subprocessPIPEr r r r r r r r r r r r r r r r r r` rO r r r r r! r sr
'!
c @ s4 e Zd Zdd Zdd Zdd Zdd Zd d
Zd S ) r c C s t d S )N)r} )rP r r r! r s z&AbstractEventLoopPolicy.get_event_loopc C s t d S )N)r} )rP rR r r r! r $ s z&AbstractEventLoopPolicy.set_event_loopc C s t d S )N)r} )rP r r r! r
( s z&AbstractEventLoopPolicy.new_event_loopc C s t d S )N)r} )rP r r r! r 0 s z)AbstractEventLoopPolicy.get_child_watcherc C s t d S )N)r} )rP watcherr r r! r 4 s z)AbstractEventLoopPolicy.set_child_watcherN)r4 rf r3 r r r
r r r r r r! r s
c @ sB e Zd ZdZG dd dejZdd Zdd Zdd Z d
d Z
dS ) BaseDefaultEventLoopPolicyNc @ s e Zd ZdZdZdS )z!BaseDefaultEventLoopPolicy._LocalNF)r4 rf r3 rK _set_calledr r r r! _LocalH s r c C s | j | _d S )N)r _local)rP r r r! rS L s z#BaseDefaultEventLoopPolicy.__init__c C sZ | j jd kr4| j j r4ttj tjr4| j| j | j jd krRt dtj j
| j jS )Nz,There is no current event loop in thread %r.) r rK r r threadingZcurrent_threadZ _MainThreadr r
RuntimeErrorname)rP r r r! r O s
z)BaseDefaultEventLoopPolicy.get_event_loopc C s d| j _|| j _d S )NT)r r rK )rP rR r r r! r ] s z)BaseDefaultEventLoopPolicy.set_event_loopc C s | j S )N)
_loop_factory)rP r r r! r
c s z)BaseDefaultEventLoopPolicy.new_event_loop) r4 rf r3 r r localr rS r r r
r r r r! r 9 s
r c @ s e Zd ZdZdS ) _RunningLoopN)NN)r4 rf r3 loop_pidr r r r! r w s r c C s& t j\} }| d k r"|tj kr"| S d S )N)
_running_loopr osgetpid)Z running_looppidr r r! r ~ s
c C s | t j ft_d S )N)r r r r )rR r r r! r
s c C s. t td kr ddlm} | aW d Q R X d S )Nr )DefaultEventLoopPolicy)_lock_event_loop_policyr2 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 c C s | a d S )N)r )Zpolicyr r r! r s c C s t } | d k r| S t j S )N)r r r )Z current_loopr r r! r s c C s t j| d S )N)r r )rR r r r! r s c C s
t j S )N)r r
r r r r! r
s c C s
t j S )N)r r r r r r! r s c C s t j| S )N)r r )r r r r! r s )r2 )NN)(__all__r r r r" r r r= r r@ r2 r r r r1 r5 r: rG r r r r r r r ZLockr r r r r r
r r r r r r
r r r r r r! sX
>8 5"7