���]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).�AbstractEventLoopPolicy�AbstractEventLoop�AbstractServer�Handle� TimerHandle�get_event_loop_policy�set_event_loop_policy�get_event_loop�set_event_loop�new_event_loop�get_child_watcher�set_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 ZPY34�inspectZunwrap�hasattrr Z
isfunction�__code__� co_filename�co_firstlineno�
isinstance� functools�partial�_get_function_source�func�
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)�reprlib�repr)�.0�argr 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" �k�vr r r r$ 2 s �(z, �))�extend�items�join)�args�kwargsr+ 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_stack�sys� _getframer> )�self�callbackr- �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 �info�framer 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� exception�handleZsource_traceback)r: r; � Exceptionr9 r% r> r= �call_exception_handler)rG �exc�cb�msg�contextr 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_executor�familyr �type�proto�flagsc C s
t � d S)N)ru )rG �host�portr� 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.getnameinfoN�ssl�sock�
local_addr�server_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_connection�backlog�d �
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_server�allow_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_pipe�stdin�stdout�stderrc 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� �
subprocess�PIPEr� 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 � threading�current_thread� _MainThreadr r
� RuntimeError�name)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� �os�getpid)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