3
\�[ � @ s| d ddddddddd d
d d d
gZ ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
m Z ddl
m Z dd� Z
dd� Zd2dd�Zdd� Zd3d d �ZG d d� d�ZG d d� de�ZG d d� d�ZG d!d� d�ZG d"d � d �ZG d#d$� d$e�Zdaej� ZG d%d&� d&ej�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%d0d
� Z&d1d � Z'dS )4�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� )�compat)� constantsc C st t jrtj| �} nt| d�r"| j} tj| �r>| j}|j|j fS t
| t j �rTt
| j�S t jrpt
| t j�rpt
| j�S d 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 �&/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)�reprlib�repr)�.0�argr r r! � 1 s z*_format_args_and_kwargs..c s s$ | ] \}}d j |tj|��V qdS )z{}={}N)�formatr" r# )r$ �k�vr r r! r& 3 s �(z, �))�extend�items�join)�args�kwargsr- r r r! �_format_args_and_kwargs) s
r1 � c C s� t | tj�r.t||�| }t| j| j| j|�S t| d�rF| j rF| j }n t| d�r^| 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� _getframe�f_backr ZDEBUG_STACK_DEPTH� traceback� StackSummary�extract�
walk_stack�reverse)�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 )�self�callbackr/ �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 �info�framer 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 exception�handleZsource_traceback)rH rI � Exceptionr: r' rL rK �call_exception_handler)rP �exc�cb�msg�contextr 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� fdd�Z� fdd�Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z � fdd�Z
� 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 | j�S )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 |t�r:| 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/d0�Zd)d)d)d1�d2d3�Zd)d-d)d4�d5d6�Z djd#d#d#d)d)d)d)d7�d8d9�Z d:d;� Z d�d?d@�Z"e j!e j!e j!d>�dAdB�Z#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 )�family�type�proto�flagsc C s t �d S )N)r} )rP �host�portr� 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_addr�server_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_connection�d )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)�stdin�stdout�stderrc 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� �
subprocess�PIPEr� 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� dej�Zdd� 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� tj�r4| 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
� RuntimeError�name)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� �os�getpid)Z running_loop�pidr 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