ÿØÿà JFIF      ÿÛ „ 	 ( %!1!%)+//.383,7(-.+



-%%-////---/-.+/--+------/------/--0+--/-/-----.-----ÿÀ  ¥2" ÿÄ               ÿÄ J  	     ! 1AQ"aq2‘#BR‚¡ÁÑ3br’¢±Âð$CSƒ²á4c“%DsÓñÿÄ              ÿÄ *        !1AQa‘"2q3±ð#b¡ÿÚ   ? ¼QxJQaÍuò¸Zö Úü8,ÐÚú
"SSn<rçù–´âE—^ªBÖ9À\†¸ÔÁT­ÃÛ5
ëd´³Í#Ý;Þ38œî ¶H£M:wÎ3…³…âpÔF&‚FK¸9„â4àGEõªfÿ ‘ñ(ßw­pŽF|È¥ù®häðÍÑ¶¹‘[ÒinÙW¶ùñY˜Q{›K"išÒ[Ú8žë\F¹@-?v"ÔU”,ìöžkÿ {I‡£šÍ?e
ríV
..............................................................................................................................................................................
.............................................................................                                                  
                                                                                                                                                                                     ÿØÿà JFIF      ÿÛ „ 	 ( %!1!%)+//.383,7(-.+



-%%-////---/-.+/--+------/------/--0+--/-/-----.-----ÿÀ  ¥2" ÿÄ               ÿÄ J  	     ! 1AQ"aq2‘#BR‚¡ÁÑ3br’¢±Âð$CSƒ²á4c“%DsÓñÿÄ              ÿÄ *        !1AQa‘"2q3±ð#b¡ÿÚ   ? ¼QxJQaÍuò¸Zö Úü8,ÐÚú
"SSn<rçù–´âE—^ªBÖ9À\†¸ÔÁT­ÃÛ5
ëd´³Í#Ý;Þ38œî ¶H£M:wÎ3…³…âpÔF&‚FK¸9„â4àGEõªfÿ ‘ñ(ßw­pŽF|È¥ù®häðÍÑ¶¹‘[ÒinÙW¶ùñY˜Q{›K"išÒ[Ú8žë\F¹@-?v"ÔU”,ìöžkÿ {I‡£šÍ?e
ríV
..............................................................................................................................................................................
.............................................................................                                                  
                                                                                                                                                                                     U
    e5d4f                     @   sx  d 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lm	Z	 G dd dZ
G dd	 d	e
ZG d
d dZG dd dZG dd dZG dd deZdae ZG d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(d) Z eZ!eZ"eZ#eZ$zdd*l%mZmZmZmZ W n e&k
rb   Y nX eZ'eZ(eZ)e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_get_running_loop    N   )format_helpers)
exceptionsc                   @   sB   e Zd ZdZdd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___contextNc                 C   s\   |d krt  }|| _|| _|| _|| _d| _d | _| j rRt	
td| _nd | _d S )NFr   )contextvarsZcopy_contextr   r   r   r   r   r   	get_debugr   extract_stacksys	_getframer   )selfcallbackargsloopcontext r&   &/usr/lib64/python3.8/asyncio/events.py__init__    s    
zHandle.__init__c                 C   sl   | j jg}| jr|d | jd k	r:|t| j| j | jrh| jd }|d|d  d|d   |S )N	cancelledzcreated at r   :r   )		__class____name__r   appendr   r   _format_callback_sourcer   r   )r!   infoframer&   r&   r'   
_repr_info/   s    


 
zHandle._repr_infoc                 C   s(   | j d k	r| j S |  }dd|S )Nz<{}> )r   r2   formatjoin)r!   r0   r&   r&   r'   __repr__;   s    
zHandle.__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    zHandle.cancelledc              
   C   s   z| j j| jf| j  W n| ttfk
r4    Y nd tk
r } zFt| j| j}d| }||| d}| j	rz| j	|d< | j
| W 5 d }~X Y nX d } d S )NzException in callback )messageZ	exceptionhandleZsource_traceback)r   runr   r   
SystemExitKeyboardInterruptBaseExceptionr   r/   r   r   call_exception_handler)r!   exccbmsgr%   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 Zd ZddgZd 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dd Z  ZS )r   
_scheduled_whenNc                    s0   t  |||| | jr | jd= || _d| _d S )Nr*   F)superr(   r   rK   rJ   )r!   whenr"   r#   r$   r%   r,   r&   r'   r(   h   s
    zTimerHandle.__init__c                    s0   t   }| jrdnd}||d| j  |S )N   r   zwhen=)rL   r2   r   insertrK   )r!   r0   posrN   r&   r'   r2   p   s    
zTimerHandle._repr_infoc                 C   s
   t | jS r;   )hashrK   r9   r&   r&   r'   __hash__v   s    zTimerHandle.__hash__c                 C   s   | j |j k S r;   rK   r!   otherr&   r&   r'   __lt__y   s    zTimerHandle.__lt__c                 C   s   | j |j k rdS | |S r7   rK   __eq__rU   r&   r&   r'   __le__|   s    zTimerHandle.__le__c                 C   s   | j |j kS r;   rT   rU   r&   r&   r'   __gt__   s    zTimerHandle.__gt__c                 C   s   | j |j krdS | |S r7   rX   rU   r&   r&   r'   __ge__   s    zTimerHandle.__ge__c                 C   s>   t |tr:| j|jko8| j|jko8| j|jko8| j|jkS tS r;   )
isinstancer   rK   r   r   r   NotImplementedrU   r&   r&   r'   rY      s    



zTimerHandle.__eq__c                 C   s   |  |}|tkrtS | S r;   )rY   r^   )r!   rV   Zequalr&   r&   r'   __ne__   s    
zTimerHandle.__ne__c                    s    | j s| j|  t   d S r;   )r   r   _timer_handle_cancelledrL   r:   r9   rN   r&   r'   r:      s    zTimerHandle.cancelc                 C   s   | j S r;   rT   r9   r&   r&   r'   rM      s    zTimerHandle.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 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S )r   c                 C   s   t d S r;   NotImplementedErrorr9   r&   r&   r'   close   s    zAbstractServer.closec                 C   s   t d S r;   rb   r9   r&   r&   r'   get_loop   s    zAbstractServer.get_loopc                 C   s   t d S r;   rb   r9   r&   r&   r'   
is_serving   s    zAbstractServer.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    zAbstractServer.wait_closedc                    s   | S r;   r&   r9   r&   r&   r'   
__aenter__   s    zAbstractServer.__aenter__c                    s   |    |  I d H  d S r;   )rd   ri   )r!   rC   r&   r&   r'   	__aexit__   s    zAbstractServer.__aexit__N)r-   rG   rH   rd   re   rf   rg   rh   ri   rj   rk   r&   r&   r&   r'   r      s   r   c                   @   sR  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ddZdd  Zd!d" Zd#d$ Zd%d%d%d%d&d'd(Zdtd)d*Zdudd%d%d%ddddddd+
d,d-Zdvejejdd.ddddd/d0	d1d2Zdwd/d3d4d5Zd6ddd7d8d9Zdxddddd:d;d<Zdydd.ddd/d=d>d?Zdzd%d%d%ddddd@dAdBZdCdD Z dEdF Z!e"j#e"j#e"j#dGdHdIZ$e"j#e"j#e"j#dGdJdKZ%dLdM Z&dNdO Z'dPdQ Z(dRdS Z)dTdU Z*dVdW Z+dXdY Z,dZd[ Z-d\d] Z.d{dd3d^d_Z/d`da Z0dbdc Z1ddde Z2dfdg Z3dhdi Z4djdk Z5dldm Z6dndo Z7dpdq Z8drds Z9dS )|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!   Zfuturer&   r&   r'   run_until_complete   s    z$AbstractEventLoop.run_until_completec                 C   s   t d S r;   rb   r9   r&   r&   r'   stop   s    zAbstractEventLoop.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    zAbstractEventLoop.is_closedc                 C   s   t d S r;   rb   r9   r&   r&   r'   rd      s    	zAbstractEventLoop.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_laterr!   r"   r#   r&   r&   r'   	call_soon  s    zAbstractEventLoop.call_soonc                 G   s   t d S r;   rb   )r!   Zdelayr"   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    zAbstractEventLoop.call_atc                 C   s   t d S r;   rb   r9   r&   r&   r'   time  s    zAbstractEventLoop.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!   executorfuncr#   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   )familytypeprotoflagsc                   s   t d S r;   rb   )r!   hostportr   r   r   r   r&   r&   r'   getaddrinfo#  s    zAbstractEventLoop.getaddrinfoc                    s   t d S r;   rb   )r!   Zsockaddrr   r&   r&   r'   getnameinfo'  s    zAbstractEventLoop.getnameinfo)
sslr   r   r   sock
local_addrserver_hostnamessl_handshake_timeouthappy_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!   	transportfileoffsetcountr   r&   r&   r'   sendfileh  s    zAbstractEventLoop.sendfileF)server_sider   r   c                   s   t d S r;   rb   )r!   r   ZprotocolZ
sslcontextr   r   r   r&   r&   r'   	start_tlsp  s    	zAbstractEventLoop.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)stdinstdoutstderrc                   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    zAbstractEventLoop.sock_recvc                    s   t d S r;   rb   )r!   r   Zbufr&   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   Zaddressr&   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!   Zhandlerr&   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    zAbstractEventLoop.get_debugc                 C   s   t d S r;   rb   )r!   Zenabledr&   r&   r'   	set_debug8  s    zAbstractEventLoop.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   
subprocessPIPEr   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 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 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 Zd ZdZG d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)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 jd kr2| j js2tt tjr2| |   | j jd krPt	dt j
 | j jS )Nz,There is no current event loop in thread %r.)r   r   r   r]   	threadingZcurrent_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 Zd ZdZdS )_RunningLoop)NNN)r-   rG   rH   loop_pidr&   r&   r&   r'   r     s   r   c                  C   s   t  } | d krtd| S )Nzno running event loop)r   r   r$   r&   r&   r'   r     s    r   c                  C   s&   t j\} }| d k	r"|t kr"| S d S r;   )_running_loopr   osgetpid)Zrunning_looppidr&   r&   r'   r     s    
r   c                 C   s   | t  ft_d S r;   )r   r   r   r   r   r&   r&   r'   r     s    r   c               	   C   s.   t   td kr ddlm}  |  aW 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 krt  t S r;   )r   r   r&   r&   r&   r'   r     s    r   c                 C   s   | a d S r;   )r   )Zpolicyr&   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   ZLockr   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'   <module>   sV   J@*  q"9
	