]TY @ s d d d d d d d d d d d
d d d
g Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l
m Z d d Z d d Z
d d d Z d d Z Gd d d Z Gd d d e Z Gd d d Z Gd d d Z Gd d d Z Gd d d e Z d a e j Z Gd! d" d" e j Z 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# d, d
Z$ d- d Z% d S).AbstractEventLoopPolicyAbstractEventLoopAbstractServerHandle TimerHandleget_event_loop_policyset_event_loop_policyget_event_loopset_event_loopnew_event_loopget_child_watcherset_child_watcher_set_running_loop_get_running_loop N)compatc C s t j r t j | } n t | d r3 | j } t j | r[ | j } | j | j f St
| t j rz t
| j St j r t
| t j r t
| j Sd S)N __wrapped__)r ZPY34inspectZunwraphasattrr Z
isfunction__code__ co_filenameco_firstlineno
isinstance functoolspartial_get_function_sourcefunc
partialmethod)r code r +/opt/alt/python35/lib64/python3.5/events.pyr s
r c C sa g } | r& | j d d | D | rL | j d d | j D d d j | d S)Nc s s | ] } t j | Vq d S)N)reprlibrepr).0argr r r <genexpr>0 s z*_format_args_and_kwargs.<locals>.<genexpr>c s s0 | ]& \ } } d j | t j | Vq d S)z{}={}N)formatr r! )r" kvr r r r$ 2 s (z, ))extenditemsjoin)argskwargsr+ r r r _format_args_and_kwargs( s r/ c C s t | t j rA t | | | } t | j | j | j | St | d rb t | d } n- t | d r t | d } n t
| } | t | | 7} | r | | 7} | S)N __qualname____name__) r r r r/ _format_callbackr r- keywordsr getattrr! )r r- r. suffix func_reprr r r r3 7 s
r3 c C s6 t | | d } t | } | r2 | d | 7} | S)Nz at %s:%s)r3 r )r r- r7 sourcer r r _format_callback_sourceH s
r9 c @ sR e Z d Z d Z d d Z d
d Z d d
Z d d Z d d Z d S)r _callback_args
_cancelled_loop_source_traceback_repr __weakref__c C sg | | _ | | _ | | _ d | _ d | _ | j j rZ t j t j d | _
n d | _
d S)NF ) r= r: r; r< r? get_debug traceback
extract_stacksys _getframer> )selfcallbackr- loopr r r __init__V s zHandle.__init__c C s | j j g } | j r% | j d | j d k rP | j t | j | j | j r | j d } | j d | d | d f | S)N cancelledrA zcreated at %s:%sr ) __class__r2 r< appendr: r9 r; r> )rG infoframer r r
_repr_infoa s
zHandle._repr_infoc C s3 | j d k r | j S| j } d d j | S)Nz<%s> )r? rQ r, )rG rO r r r __repr__l s zHandle.__repr__c C sF | j sB d | _ | j j r0 t | | _ d | _ d | _ d S)NT)r< r= rB r! r? r: r; )rG r r r cancelr s z
Handle.cancelc C s y | j | j Wn t k
r } zg t | j | j } d j | } d | d | d | i } | j r{ | j | d <| j j | WYd d } ~ Xn Xd } d S)NzException in callback {}message exceptionhandleZsource_traceback)r: r; Exceptionr9 r% r> r= call_exception_handler)rG exccbmsgcontextr r r _run} s
#z Handle._runN)r: r; r< r= r> r? r@ ) r2
__module__r1 __slots__rJ rQ rS rT r^ r r r r r P s c s e Z d Z d d g Z f d d Z f d d Z d d Z d d
Z d d Z d
d Z d d Z
d d Z d d Z f d d Z
S)r
_scheduled_whenc s? t j | | | | j r) | j d =| | _ d | _ d S)NrA FrL )superrJ r> rb ra )rG whenrH r- rI )rM r r rJ s
zTimerHandle.__init__c s? t j } | j r d n d } | j | d | j | S)N rA zwhen=%s)rc rQ r< insertrb )rG rO pos)rM r r rQ s zTimerHandle._repr_infoc C s
t | j S)N)hashrb )rG r r r __hash__ s zTimerHandle.__hash__c C s | j | j k S)N)rb )rG otherr r r __lt__ s zTimerHandle.__lt__c C s# | j | j k r d S| j | S)NT)rb __eq__)rG rj r r r __le__ s zTimerHandle.__le__c C s | j | j k S)N)rb )rG rj r r r __gt__ s zTimerHandle.__gt__c C s# | j | j k r d S| j | S)NT)rb rl )rG rj r r r __ge__ s zTimerHandle.__ge__c C sY t | t rU | j | j k oT | j | j k oT | j | j k oT | j | j k St S)N)r r rb r: r; r< NotImplemented)rG rj r r r rl s zTimerHandle.__eq__c C s$ | j | } | t k r t S| S)N)rl rp )rG rj Zequalr r r __ne__ s zTimerHandle.__ne__c s* | j s | j j | t j d S)N)r< r= _timer_handle_cancelledrc rT )rG )rM r r rT s zTimerHandle.cancel)r2 r_ r1 r` rJ rQ ri rk rm rn ro rl rq rT r r )rM r r s c @ s( e Z d Z d d Z d d Z d S)r c C s t S)N)rp )rG r r r close s zAbstractServer.closec C s t S)N)rp )rG r r r wait_closed s zAbstractServer.wait_closedN)r2 r_ r1 rs rt r r r r r s c @ sC e Z d 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
d d 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 d# d$ d% d$ d& d$ d' d$ d( d) Z d$ d* d+ Z d, d, d- d, d# d$ d& d$ d' d$ d. d, d/ d, d0 d, d1 d2 Z d, d, d# e j d' e j d. d, d3 d4 d- d, d5 d, d6 d, d7 d8 Z d- d, d. d, d0 d, d9 d: Z d. d, d3 d4 d- d, d; d< Z d, d, d# d$ d& d$ d' d$ d5 d, d6 d, d= d, d. d, d> d? Z d@ dA Z dB dC Z dD e j! dE e j! dF e j! dG dH Z" dD e j! dE e j! dF e j! dI dJ Z# dK dL Z$ dM dN Z% dO dP Z& dQ dR Z' dS dT Z( dU dV Z) dW dX Z* dY dZ Z+ d[ d\ Z, d] d^ Z- d_ d` Z. da db Z/ dc dd Z0 de df Z1 dg dh Z2 di dj Z3 dk dl Z4 dm dn Z5 d, S)or c C s
t d S)N)NotImplementedError)rG r r r run_forever s z AbstractEventLoop.run_foreverc C s
t d S)N)ru )rG futurer r r run_until_complete s z$AbstractEventLoop.run_until_completec C s
t d S)N)ru )rG r r r stop s zAbstractEventLoop.stopc C s
t d S)N)ru )rG r r r
is_running s z AbstractEventLoop.is_runningc C s
t d S)N)ru )rG r r r is_closed s zAbstractEventLoop.is_closedc C s
t d S)N)ru )rG r r r rs s zAbstractEventLoop.closec C s
t d S)N)ru )rG r r r shutdown_asyncgens s z$AbstractEventLoop.shutdown_asyncgensc C s
t d S)N)ru )rG rW r r r rr s z)AbstractEventLoop._timer_handle_cancelledc G s | j d | | S)Nr )
call_later)rG rH r- r r r call_soon s zAbstractEventLoop.call_soonc G s
t d S)N)ru )rG delayrH r- r r r r}
s z AbstractEventLoop.call_laterc G s
t d S)N)ru )rG rd rH r- r r r call_at
s zAbstractEventLoop.call_atc C s
t d S)N)ru )rG r r r time s zAbstractEventLoop.timec C s
t d S)N)ru )rG r r r
create_future s z AbstractEventLoop.create_futurec C s
t d S)N)ru )rG coror r r create_task s z AbstractEventLoop.create_taskc G s
t d S)N)ru )rG rH r- r r r call_soon_threadsafe s z&AbstractEventLoop.call_soon_threadsafec G s
t d S)N)ru )rG executorr r- r r r run_in_executor s z!AbstractEventLoop.run_in_executorc C s
t d S)N)ru )rG r r r r set_default_executor# s z&AbstractEventLoop.set_default_executorfamilyr typeprotoflagsc C s
t d S)N)ru )rG hostportr r r r r r r getaddrinfo( s z AbstractEventLoop.getaddrinfoc C s
t d S)N)ru )rG Zsockaddrr r r r getnameinfo+ s z AbstractEventLoop.getnameinfoNsslsock
local_addrserver_hostnamec C s
t d S)N)ru ) rG protocol_factoryr r r r r r r r r r r r create_connection. s z#AbstractEventLoop.create_connectionbacklogd
reuse_address
reuse_portc C s
t d S)N)ru ) rG r r r r r r r r r r r r r
create_server3 s 'z AbstractEventLoop.create_serverc C s
t d S)N)ru )rG r pathr r r r r r create_unix_connection\ s z(AbstractEventLoop.create_unix_connectionc C s
t d S)N)ru )rG r r r r r r r r create_unix_servera s z$AbstractEventLoop.create_unix_serverallow_broadcastc C s
t d S)N)ru ) rG r r Z remote_addrr r r r r r r r r r create_datagram_endpointv s !z*AbstractEventLoop.create_datagram_endpointc C s
t d S)N)ru )rG r piper r r connect_read_pipe s z#AbstractEventLoop.connect_read_pipec C s
t d S)N)ru )rG r r r r r connect_write_pipe s z$AbstractEventLoop.connect_write_pipestdinstdoutstderrc K s
t d S)N)ru )rG r cmdr r r r. r r r subprocess_shell s z"AbstractEventLoop.subprocess_shellc O s
t d S)N)ru )rG r r r r r- r. r r r subprocess_exec s z!AbstractEventLoop.subprocess_execc G s
t d S)N)ru )rG fdrH r- r r r
add_reader s z AbstractEventLoop.add_readerc C s
t d S)N)ru )rG r r r r
remove_reader s z AbstractEventLoop.remove_readerc G s
t d S)N)ru )rG r rH r- r r r
add_writer s z AbstractEventLoop.add_writerc C s
t d S)N)ru )rG r r r r
remove_writer s z AbstractEventLoop.remove_writerc C s
t d S)N)ru )rG r nbytesr r r sock_recv s zAbstractEventLoop.sock_recvc C s
t d S)N)ru )rG r datar r r sock_sendall s z AbstractEventLoop.sock_sendallc C s
t d S)N)ru )rG r addressr r r sock_connect s z AbstractEventLoop.sock_connectc C s
t d S)N)ru )rG r r r r sock_accept s z AbstractEventLoop.sock_acceptc G s
t d S)N)ru )rG sigrH r- r r r add_signal_handler s z$AbstractEventLoop.add_signal_handlerc C s
t d S)N)ru )rG r r r r remove_signal_handler s z'AbstractEventLoop.remove_signal_handlerc C s
t d S)N)ru )rG factoryr r r set_task_factory s z"AbstractEventLoop.set_task_factoryc C s
t d S)N)ru )rG r r r get_task_factory s z"AbstractEventLoop.get_task_factoryc C s
t d S)N)ru )rG r r r get_exception_handler s z'AbstractEventLoop.get_exception_handlerc C s
t d S)N)ru )rG handlerr r r set_exception_handler s z'AbstractEventLoop.set_exception_handlerc C s
t d S)N)ru )rG r] r r r default_exception_handler s z+AbstractEventLoop.default_exception_handlerc C s
t d S)N)ru )rG r] r r r rY s z(AbstractEventLoop.call_exception_handlerc C s
t d S)N)ru )rG r r r rB s zAbstractEventLoop.get_debugc C s
t d S)N)ru )rG Zenabledr r r set_debug s zAbstractEventLoop.set_debug)6r2 r_ r1 rv rx ry rz r{ rs r| rr r~ r} r r r r r r r r r r socket AF_UNSPEC
AI_PASSIVEr r r r r r
subprocessPIPEr r r r r r r r r r r r r r r r r rY rB r r r r r r sv $ & !
c @ sL e Z d Z d d Z d d Z d d Z d d Z d d
Z d S) r c C s
t d S)N)ru )rG r r r r s z&AbstractEventLoopPolicy.get_event_loopc C s
t d S)N)ru )rG rI r r r r s z&AbstractEventLoopPolicy.set_event_loopc C s
t d S)N)ru )rG r r r r
s z&AbstractEventLoopPolicy.new_event_loopc C s
t d S)N)ru )rG r r r r s z)AbstractEventLoopPolicy.get_child_watcherc C s
t d S)N)ru )rG watcherr r r r " s z)AbstractEventLoopPolicy.set_child_watcherN)r2 r_ r1 r r r
r r r r r r r s
c @ s_ e Z d Z d Z Gd d d e j Z d d Z d d Z d d Z d
d Z
d S) BaseDefaultEventLoopPolicyNc @ s e Z d Z d Z d Z d S)z!BaseDefaultEventLoopPolicy._LocalNF)r2 r_ r1 r= _set_calledr r r r _Local6 s r c C s | j | _ d S)N)r _local)rG r r r rJ : s z#BaseDefaultEventLoopPolicy.__init__c C s | j j d k rJ | j j rJ t t j t j rJ | j | j | j j d k ru t d t j j
| j j S)Nz,There is no current event loop in thread %r.) r r= r r threadingcurrent_thread _MainThreadr r
RuntimeErrorname)rG r r r r = s
z)BaseDefaultEventLoopPolicy.get_event_loopc C s d | j _ | | j _ d S)NT)r r r= )rG rI r r r r K s z)BaseDefaultEventLoopPolicy.set_event_loopc C s
| j S)N)
_loop_factory)rG r r r r
Q s z)BaseDefaultEventLoopPolicy.new_event_loop) r2 r_ r1 r r localr rJ r r r
r r r r r ' s
r c @ s e Z d Z d Z d Z d S) _RunningLoopN)r2 r_ r1 r= _pidr r r r r e s r c C s2 t j } | d k r. t j t j k r. | Sd S)N)
_running_loopr= r osgetpid)Z running_loopr r r r m s !c C s t j t _ | t _ d S)N)r r r r r= )rI r r r r
x s c C s7 t * t d k r, d d l m } | a Wd QRXd S)NrA )DefaultEventLoopPolicy)_lock_event_loop_policyr0 r )r r r r _init_event_loop_policy s r c C s t d k r t 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 | St j S)N)r r r )Z current_loopr r r r s c C s t j | d S)N)r r )rI 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 )&__all__r r r r r r rE r rC Zasyncior r r/ r3 r9 r r r r r r r Lockr r r r r r
r r r r r r
r r r r r r <module> sR >8 4"7