3
\� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd dlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ d
gZd Zd Ze e e fZ e ed
�Z!d(Z"dd� Z#dd� Z$dd� Z%dd� Z&dd� Z'dd� Z(d ej)d d d �d d �Z*e ed ��rNd d!� Z+nd"d!� Z+d#d$� Z,G d%d&� d&ej-�Z.G d'd
� d
ej/�Z0dS ))� N� )�compat)�
coroutines)�events)�futures)�tasks)� coroutine)�logger�
BaseEventLoop�d g �?�AF_INET6� i c C s0 | j }tt|dd �tj�r$t|j�S t| �S d S )N�__self__)Z _callback�
isinstance�getattrr �Task�reprr �str)�handle�cb� r �+/usr/lib64/python3.6/asyncio/base_events.py�_format_handle? s
r c C s( | t jkrdS | t jkr dS t| �S d S )Nzz)�
subprocess�PIPE�STDOUTr )�fdr r r � _format_pipeH s
r c C sL t td�std��n4y| jtjtjd� W n tk
rF td��Y nX d S )N� SO_REUSEPORTz)reuse_port not supported by socket moduler zTreuse_port not supported by socket module, SO_REUSEPORT defined but not implemented.)�hasattr�socket�
ValueError�
setsockopt�
SOL_SOCKETr �OSError)�sockr r r �_set_reuseportQ s
r& c C s& t td�r| d@ tjkS | tjkS d S )N�
SOCK_NONBLOCK� )r r � SOCK_STREAM)� sock_typer r r �_is_stream_socket\ s
r+ c C s& t td�r| d@ tjkS | tjkS d S )Nr' r( )r r �
SOCK_DGRAM)r* r r r �_is_dgram_socketh s
r- c C sv t td�sd S |dtjtjhks(| d kr,d S t|�rt|t�r�|dkr�d}n&y t |�}W n t
t fk
r� d S X |tj kr�tj
g}tr�|jtj� n|g}t| t�r�| jd�} d| k�r d S xp|D ]h}yJtj|| � t�r@|tjk�r@|||d| |ddffS |||d| |ffS W n tk
�rj Y nX �qW d S )N� inet_ptonr � � Zidna�%)r r � IPPROTO_TCPZ IPPROTO_UDPr+ r- r �bytesr �int� TypeErrorr! � AF_UNSPEC�AF_INET� _HAS_IPv6�appendr �decoder. r$ )�host�port�family�type�protoZafs�afr r r � _ipaddr_infop sL
rA )r= r> r? �flagsc
C sZ | d d� \}}t |||||�}|d k r@|j� } | j|g� | S |j||||||d�S d S )N� )r= r> r? rB )rA �
create_future�
set_result� getaddrinfo)
�addressr= r> r? rB �loopr; r< �info�futr r r �_ensure_resolved� s rK � TCP_NODELAYc C s> | j tjtjhkr:t| j�r:| jtjkr:| jtjtj d� d S )Nr )
r= r r7 r r+ r> r? r2 r" rL )r% r r r � _set_nodelay� s
rM c C s d S )Nr )r% r r r rM � s c C s. | j }t|t�r t|t� r d S | jj� d S )N)Z
_exceptionr �
BaseException� Exception�_loop�stop)rJ �excr r r �_run_until_complete_cb� s
rS c @ sH e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Ze d
d� �Z
dS )�Serverc C s || _ || _d| _g | _d S )Nr )rP �sockets�
_active_count�_waiters)�selfrH rU r r r �__init__� s zServer.__init__c C s d| j j| jf S )Nz<%s sockets=%r>)� __class__�__name__rU )rX r r r �__repr__� s zServer.__repr__c C s | j d7 _ d S )Nr )rV )rX r r r �_attach� s zServer._attachc C s. | j d8 _ | j dkr*| jd kr*| j� d S )Nr r )rV rU �_wakeup)rX r r r �_detach� s zServer._detachc C sH | j }|d krd S d | _ x|D ]}| jj|� q W | jdkrD| j� d S )Nr )rU rP Z
_stop_servingrV r^ )rX rU r% r r r �close� s
z Server.closec C s0 | j }d | _ x |D ]}|j� s|j|� qW d S )N)rW �donerE )rX �waiters�waiterr r r r^ � s
zServer._wakeupc c s< | j d ks| jd krd S | jj� }| jj|� |E d H d S )N)rU rW rP rD r9 )rX rc r r r � wait_closed� s
zServer.wait_closedN) r[ �
__module__� __qualname__rY r\ r] r_ r` r^ r rd r r r r rT � s
rT c
@ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd�d
d
d�dd�Z d�dd
d
d
d�dd�Z
d�dd�Z d�dd�Z d�dd�Z
ed�dd ��Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zed'd(� �Zd)d*� Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zej � r�d3d4� Z d5d6� Z d7d8� Z d9d:� Z d;d<� Z!d=d>� Z"d?d@� Z#dAdB� Z$dCdD� Z%dEdF� Z&dGdH� Z'dIdJ� Z(dKdL� Z)dMdMdMdMdN�dOdP�Z*d�dQdR�Z+ed�d
dMdMdMd
d
d
dS�dTdU��Z,ed�dVdW��Z-ed�dMdMdMd
d
d
d
dX�dYdZ��Z.ed[d\� �Z/ed�e0j1e0j2d
d]d
d
d
d^�d_d`��Z3ed
da�dbdc��Z4eddde� �Z5edfdg� �Z6dhdi� Z7ee8j9e8j9e8j9ddjdMdk�dldm��Z:ee8j9e8j9e8j9dddMdk�dndo��Z;dpdq� Zdvdw� Z?dxdy� Z@dzd{� ZAd|d}� ZBd~d� ZCd�d�� ZDd�d�� ZEd�d�� ZFd
S )�r
c C s� d| _ d| _d| _tj� | _g | _d | _d| _d | _ t
j d�j | _
d | _| jtjj odttjjd��� d| _d | _d | _d| _ttd�r�t j � | _ nd | _ d| _ d S )Nr F� monotonicZPYTHONASYNCIODEBUGg�������?�get_asyncgen_hooks) �_timer_cancelled_count�_closed� _stopping� collections�deque�_ready�
_scheduled�_default_executorZ
_internal_fds�
_thread_id�timeZget_clock_infoZ
resolution�_clock_resolution�_exception_handler� set_debug�sysrB �ignore_environment�bool�os�environ�get�slow_callback_duration�_current_handle�
_task_factory�_coroutine_wrapper_setr �weakref�WeakSet�
_asyncgens�_asyncgens_shutdown_called)rX r r r rY � s(
zBaseEventLoop.__init__c C s d| j j| j� | j� | j� f S )Nz"<%s running=%s closed=%s debug=%s>)rZ r[ �
is_running� is_closed� get_debug)rX r r r r\ s zBaseEventLoop.__repr__c C s t j| d�S )N)rH )r ZFuture)rX r r r rD % s zBaseEventLoop.create_futurec C s@ | j � | jd kr0tj|| d�}|jr<|jd= n | j| |�}|S )N)rH r �����)�
_check_closedr~ r r �_source_traceback)rX �coroZtaskr r r � create_task) s
zBaseEventLoop.create_taskc C s$ |d k rt |� rtd��|| _d S )Nz'task factory must be a callable or None)�callabler5 r~ )rX �factoryr r r �set_task_factory7 s
z BaseEventLoop.set_task_factoryc C s | j S )N)r~ )rX r r r �get_task_factoryE s z BaseEventLoop.get_task_factoryN)�extra�serverc C s t �d S )N)�NotImplementedError)rX r% �protocolrc r� r� r r r �_make_socket_transportI s z$BaseEventLoop._make_socket_transportF)� server_side�server_hostnamer� r� c C s t �d S )N)r� ) rX Zrawsockr� �
sslcontextrc r� r� r� r� r r r �_make_ssl_transportN s z!BaseEventLoop._make_ssl_transportc C s t �d S )N)r� )rX r% r� rG rc r� r r r �_make_datagram_transportT s z&BaseEventLoop._make_datagram_transportc C s t �d S )N)r� )rX �piper� rc r� r r r �_make_read_pipe_transportY s z'BaseEventLoop._make_read_pipe_transportc C s t �d S )N)r� )rX r� r� rc r� r r r �_make_write_pipe_transport^ s z(BaseEventLoop._make_write_pipe_transportc
K s t �d S )N)r� )
rX r� �args�shell�stdin�stdout�stderr�bufsizer� �kwargsr r r �_make_subprocess_transportc s z(BaseEventLoop._make_subprocess_transportc C s t �d S )N)r� )rX r r r �_write_to_selfj s z BaseEventLoop._write_to_selfc C s t �d S )N)r� )rX �
event_listr r r �_process_eventss s z BaseEventLoop._process_eventsc C s | j rtd��d S )NzEvent loop is closed)rj � RuntimeError)rX r r r r� w s zBaseEventLoop._check_closedc C s* | j j|� | j� s&| j| j|j� � d S )N)r� �discardr� �call_soon_threadsafer� �aclose)rX �agenr r r �_asyncgen_finalizer_hook{ s z&BaseEventLoop._asyncgen_finalizer_hookc C s, | j r tjdj|�t| d� | jj|� d S )NzNasynchronous generator {!r} was scheduled after loop.shutdown_asyncgens() call)�source)r� �warnings�warn�format�ResourceWarningr� �add)rX r� r r r �_asyncgen_firstiter_hook� s
z&BaseEventLoop._asyncgen_firstiter_hookc c s� d| _ | jd ks t| j� r d S t| j�}| jj� tjdd� |D �d| d��}|E d H }x8t||�D ]*\}}t|t �rf| j
dj |�||d�� qfW d S )NTc S s g | ] }|j � �qS r )r� )�.0Zagr r r �
� s z4BaseEventLoop.shutdown_asyncgens..)Zreturn_exceptionsrH z?an error occurred during closing of asynchronous generator {!r})�message� exceptionZasyncgen) r� r� �len�list�clearr �gather�zipr rO �call_exception_handlerr� )rX Z
closing_agensZ
shutdown_coroZresults�resultr� r r r �shutdown_asyncgens� s"
z BaseEventLoop.shutdown_asyncgensc C s� | j � | j� rtd��tj� d k r,td��| j| j� tj� | _ | j
d k rft j � }t j
| j| jd� z$tj| � x| j� | jrtP qtW W d d| _d | _ tjd � | jd� | j
d k r�t j
|� X d S )Nz"This event loop is already runningz7Cannot run the event loop while another loop is running)� firstiter� finalizerF)r� r� r� r Z_get_running_loop�_set_coroutine_wrapper�_debug� threading� get_identrq r� rv rh �set_asyncgen_hooksr� r� Z_set_running_loop� _run_oncerk )rX Zold_agen_hooksr r r � run_forever� s0
zBaseEventLoop.run_foreverc C s� | j � tj|� }tj|| d�}|r,d|_|jt� z>y | j� W n, |rj|j � rj|j
� rj|j � � Y nX W d |j t� X |j � s�t
d��|j� S )N)rH Fz+Event loop stopped before Future completed.)r� r Zisfuturer Z
ensure_futureZ_log_destroy_pendingZadd_done_callbackrS r� ra Z cancelledr� Zremove_done_callbackr� r� )rX ZfutureZnew_taskr r r �run_until_complete� s
z BaseEventLoop.run_until_completec C s
d| _ d S )NT)rk )rX r r r rQ � s zBaseEventLoop.stopc C sj | j � rtd��| jrd S | jr,tjd| � d| _| jj� | jj� | j }|d k rfd | _ |j
dd� d S )Nz!Cannot close a running event loopzClose %rTF)�wait) r� r� rj r� r �debugrn r� ro rp Zshutdown)rX �executorr r r r` � s
zBaseEventLoop.closec C s | j S )N)rj )rX r r r r� s zBaseEventLoop.is_closedc C s0 | j � s,tjd| t| d� | j� s,| j� d S )Nzunclosed event loop %r)r� )r� r� r� r� r� r` )rX r r r �__del__ s
zBaseEventLoop.__del__c C s
| j d k S )N)rq )rX r r r r� s zBaseEventLoop.is_runningc C s t j� S )N)rr rg )rX r r r rr s zBaseEventLoop.timec G s, | j | j� | |f|�� }|jr(|jd= |S )Nr r� )�call_atrr r� )rX Zdelay�callbackr� �timerr r r �
call_later s zBaseEventLoop.call_laterc G sX | j � | jr"| j� | j|d� tj|||| �}|jr@|jd= tj| j |� d|_ |S )Nr� r Tr� )
r� r� �
_check_thread�_check_callbackr Z TimerHandler� �heapq�heappushro )rX �whenr� r� r� r r r r� 5 s zBaseEventLoop.call_atc G s@ | j � | jr"| j� | j|d� | j||�}|jr<|jd= |S )N� call_soonr r� )r� r� r� r� �
_call_soonr� )rX r� r� r r r r r� E s
zBaseEventLoop.call_soonc C s> t j|�st j|�r"tdj|���t|�s:tdj||���d S )Nz#coroutines cannot be used with {}()z0a callable object was expected by {}(), got {!r})r Z iscoroutineZiscoroutinefunctionr5 r� r� )rX r� �methodr r r r� X s
z BaseEventLoop._check_callbackc C s, t j||| �}|jr |jd= | jj|� |S )Nr r� )r ZHandler� rn r9 )rX r� r� r r r r r� c s
zBaseEventLoop._call_soonc C s, | j d krd S tj� }|| j kr(td��d S )NzMNon-thread-safe operation invoked on an event loop other than the current one)rq r� r� r� )rX Z thread_idr r r r� j s
zBaseEventLoop._check_threadc G s@ | j � | jr| j|d� | j||�}|jr4|jd= | j� |S )Nr� r r� )r� r� r� r� r� r� )rX r� r� r r r r r� { s z"BaseEventLoop.call_soon_threadsafec G sZ | j � | jr| j|d� |d kr@| j}|d kr@tjj� }|| _tj|j|f|�� | d�S )N�run_in_executor)rH ) r� r� r� rp �
concurrentr ZThreadPoolExecutorZ wrap_futureZsubmit)rX r� �funcr� r r r r� � s
z BaseEventLoop.run_in_executorc C s
|| _ d S )N)rp )rX r� r r r �set_default_executor� s z"BaseEventLoop.set_default_executorc C s� d||f g}|r |j d| � |r2|j d| � |rD|j d| � |rV|j d| � dj|�}tjd|� | j� }tj||||||�} | j� | }
d||
d | f }|
| jkr�tj|� n
tj|� | S )
Nz%s:%rz family=%rztype=%rzproto=%rzflags=%rz, zGet address info %sz(Getting address info %s took %.3f ms: %rg @�@) r9 �joinr r� rr r rF r| rI ) rX r; r< r= r> r? rB �msg�t0Zaddrinfo�dtr r r �_getaddrinfo_debug� s(
z BaseEventLoop._getaddrinfo_debugr )r= r> r? rB c C s> | j r | jd | j||||||�S | jd tj||||||�S d S )N)r� r� r� r rF )rX r; r< r= r> r? rB r r r rF � s
zBaseEventLoop.getaddrinfoc C s | j d tj||�S )N)r� r � getnameinfo)rX ZsockaddrrB r r r r� � s zBaseEventLoop.getnameinfo)�sslr= r? rB r% �
local_addrr� c # s |
d k r| rt d��|
d kr2|r2|s.t d��|}
|d k sD|d k �r�|d k rTt d��t||f|tj||| d�} | g} | d k r�t| |tj||| d�}
| j|
� nd }
tj| | d�E d H | j� }|s�td��|
d k r�|
j� }|s�td��g }�x�|D �]B\}}}}}y�tj|||d�}|j d� |
d k �r�x�|D ]j\}}}}}y|j
|� P W nH tk
�r� } z*t|j d j ||j
j� ��}|j|� W Y d d }~X nX �q.W |j� d }w�| j�r�tjd
||� | j||�E d H W n^ tk
�r } z"|d k �r�|j� |j|� W Y d d }~X q� |d k �r,|j� � Y q�X P q�W t|�d k�rR|d �nJt|d �� t� fd
d�|D ���r~|d �tdj djdd� |D �����n,|d k�r�t d��t|j��s�t dj |���| j||||
�E d H \}}| j�r
|jd�}tjd|||||� ||fS )Nz+server_hostname is only meaningful with sslz:You must set server_hostname when using ssl without a hostz8host/port and sock can not be specified at the same time)r= r> r? rB rH )rH z!getaddrinfo() returned empty list)r= r> r? Fz2error while attempting to bind on address {!r}: {}zconnect %r to %rr r c 3 s | ]}t |�� kV qd S )N)r )r� rR )�modelr r � s z2BaseEventLoop.create_connection..zMultiple exceptions: {}z, c s s | ]}t |�V qd S )N)r )r� rR r r r r� # s z5host and port was not specified and no sock specifiedz&A Stream Socket was expected, got {!r}r z %r connected to %s:%r: (%r, %r)) r! rK r r) r9 r r� r� r$ � setblocking�bind�errnor� �strerror�lowerr` r� r r� � sock_connectr� r �allr� r+ r> � _create_connection_transport�get_extra_info)rX �protocol_factoryr; r< r� r= r? rB r% r� r� �f1�fs�f2�infosZ laddr_infos�
exceptionsr> ZcnamerG �_ZladdrrR � transportr� r )r� r �create_connection� s�
"
z BaseEventLoop.create_connectionc
c s� |j d� |� }| j� }|rFt|t�r*d n|}| j||||||d�} n| j|||�} y|E d H W n | j� � Y nX | |fS )NF)r� r� )r� rD r rx r� r� r` )
rX r% r� r� r� r� r� rc r� r� r r r r� = s
z*BaseEventLoop._create_connection_transport)r= r? rB �
reuse_address�
reuse_port�allow_broadcastr% c # s8 |
d k r�t |
j�s tdj|
���� s@�s@|s@|s@|s@|s@|s@| r~t� �|||||| d�} djdd� | j� D ��} tdj| ���|
jd� d }
�n*� p��s�|dkr�td ��||fdff}n�tj � }x�d� fd
�ffD ]~\}}|d k r�t
||t j ||| d �E d H }|�s t
d ��xB|D ]:\}}}}}||f}||k�r>d d g||< ||| |< �qW q�W � �fd
d�|j� D �}|�sztd��g }|d k�r�tjdk�o�tjdk}�x|D �]\\}}\}}d }
d }
y�t j |t j |d�}
|�r�|
jt jt jd
� |�r�t|
� | �r|
jt jt jd
� |
jd� � �r,|
j|� ��rH| j|
|�E d H |}
W n^ t
k
�r� } z"|
d k �rp|
j� |j|� W Y d d }~X n" |
d k �r�|
j� � Y nX P �q�W |d �|� } | j� } | j |
| |
| �} | j �r
� �r�t j d� �| | � nt j d�| | � y| E d H W n | j� � Y nX | | fS )Nz#A UDP Socket was expected, got {!r})r� � remote_addrr= r? rB r� r� r� z, c s s" | ]\}}|rd j ||�V qdS )z{}={}N)r� )r� �k�vr r r r� i s z9BaseEventLoop.create_datagram_endpoint..zNsocket modifier keyword arguments can not be used when sock is specified. ({})Fr zunexpected address familyr )r= r> r? rB rH z!getaddrinfo() returned empty listc s8 g | ]0\}}� r |d dkp*�o*|d dks||f�qS )r Nr r )r� �keyZ addr_pair)r� r� r r r� � s z:BaseEventLoop.create_datagram_endpoint..z can not get address information�posix�cygwin)r= r> r? z@Datagram endpoint local_addr=%r remote_addr=%r created: (%r, %r)z2Datagram endpoint remote_addr=%r created: (%r, %r))NN)!r- r> r! r� �dictr� �itemsr� rl � OrderedDictrK r r, r$ ry �namerv �platformr" r# � SO_REUSEADDRr& Z SO_BROADCASTr� r� r` r9 rD r� r� r rI r� ) rX r� r� r� r= r? rB r� r� r� r% ZoptsZproblemsZr_addrZaddr_pairs_infoZ
addr_infos�idxZaddrr� Zfamr� ZprorG r r� Z
local_addressZremote_addressrR r� rc r� r )r� r� r �create_datagram_endpointU s�
z&BaseEventLoop.create_datagram_endpointc c s4 t ||f|tj|| d�E d H }|s0tdj|���|S )N)r= r> rB rH z%getaddrinfo({!r}) returned empty list)rK r r) r$ r� )rX r; r< r= rB r� r r r �_create_server_getaddrinfo� s
z(BaseEventLoop._create_server_getaddrinfor )r= rB r% �backlogr� r� r� c # s� t |t�rtd��|d k s$�d k �r|d k r4td��| d krPtjdkoNtjdk} g } |dkrdd g} n$t |t�s|t |t j
� r�|g} n|} � ���fdd�| D �}
t j |
d�i�E d H }t
tjj|��}d }�z �x|D �]
}|\}}}}}ytj|||�}W n6 tjk
�r2 �j�r,tjd
|||d d � w�Y nX | j|� | �rV|jtjtjd � |
�rdt|� t�r�|tj k�r�t td
��r�|jtj tj d � y|j |� W q� t!k
�r� } z t!|j"d||j#j$� f ��W Y d d }~X q�X q�W d }W d |�s x| D ]}|j%� �q�W X n2|d k�r"td��t&|j'��s.rH Fz:create_server() failed to create socket.socket(%r, %r, %r)T)�exc_info� IPPROTO_IPV6z0error while attempting to bind on address %r: %sz)Neither host/port nor sock were specifiedz&A Stream Socket was expected, got {!r}z
%r is serving).r rx r5 r! ry r rv r r rl �Iterabler r� �set� itertools�chain�
from_iterabler �errorr� r �warningr9 r" r# r r& r8 r r r Z IPV6_V6ONLYr� r$ r� r� r� r` r+ r> r� rT Zlistenr� Z_start_servingrI )rX r� r; r< r= rB r% r
r� r� r� rU Zhostsr� r� Z completed�resr@ Zsocktyper? Z canonnameZsa�errr� r )r= rB r< rX r �
create_server� s�
(
zBaseEventLoop.create_server)r� c c s^ t |j�stdj|���| j|||ddd�E d H \}}| jrV|jd�}tjd|||� ||fS )Nz&A Stream Socket was expected, got {!r}r0 T)r� r z%r handled: (%r, %r)) r+ r> r! r� r� r� r� r r� )rX r� r% r� r� r� r r r �connect_accepted_socketA s
z%BaseEventLoop.connect_accepted_socketc c sd |� }| j � }| j|||�}y|E d H W n |j� � Y nX | jr\tjd|j� ||� ||fS )Nz Read pipe %r connected: (%r, %r))rD r� r` r� r r� �fileno)rX r� r� r� rc r� r r r �connect_read_pipeX s z BaseEventLoop.connect_read_pipec c sd |� }| j � }| j|||�}y|E d H W n |j� � Y nX | jr\tjd|j� ||� ||fS )Nz!Write pipe %r connected: (%r, %r))rD r� r` r� r r� r )rX r� r� r� rc r� r r r �connect_write_pipei s z BaseEventLoop.connect_write_pipec C s� |g}|d k r |j dt|� � |d k rF|tjkrF|j dt|� � n4|d k r`|j dt|� � |d k rz|j dt|� � tjdj|�� d S )Nzstdin=%szstdout=stderr=%sz stdout=%sz stderr=%s� )r9 r r r r r� r� )rX r� r� r� r� rI r r r �_log_subprocessz s z BaseEventLoop._log_subprocessT)r� r� r� �universal_newlinesr� r� c
k s� t |ttf�std��|r"td��|s.td��|dkr>td��|� }
d } | jrfd| } | j| |||� | j|
|d||||f| �E d H } | jr�| d k r�tjd| | � | |
fS ) Nzcmd must be a stringz universal_newlines must be Falsezshell must be Truer zbufsize must be 0zrun shell command %rTz%s: %r) r r3 r r! r� r r� r rI )
rX r� �cmdr� r� r� r r� r� r� r� � debug_logr� r r r �subprocess_shell� s$ z BaseEventLoop.subprocess_shellc o s� |r t d��|rt d��|dkr(t d��|f| } x,| D ]$} t| ttf�s8tdt| �j ��q8W |� }
d }| jr�d| }| j||||� | j |
| d||||f|
�E d H }| jr�|d k r�t
j d||� ||
fS ) Nz universal_newlines must be Falsezshell must be Falser zbufsize must be 0z8program arguments must be a bytes or text string, not %szexecute program %rFz%s: %r) r! r r r3 r5 r> r[ r� r r� r rI )rX r� Zprogramr� r� r� r r� r� r� r� Z
popen_args�argr� r" r� r r r �subprocess_exec� s,
z BaseEventLoop.subprocess_execc C s | j S )N)rt )rX r r r �get_exception_handler� s z#BaseEventLoop.get_exception_handlerc C s* |d k r t |� r tdj|���|| _d S )Nz/A callable object or None is expected, got {!r})r� r5 r� rt )rX Zhandlerr r r �set_exception_handler� s z#BaseEventLoop.set_exception_handlerc C s |j d�}|sd}|j d�}|d k r6t|�||jf}nd}d|kr`| jd k r`| jjr`| jj|d< |g}x�t|�D ]�}|d
kr~qp|| }|dkr�djtj|��}d}||j � 7 }n2|dkr�djtj|��}d }||j � 7 }nt
|�}|j d
j ||�� qpW t
jd j|�|d � d S )Nr� z!Unhandled exception in event loopr� FZsource_tracebackZhandle_tracebackr0 z+Object created at (most recent call last):
z+Handle created at (most recent call last):
z{}: {}�
)r > r� r� )r{ r> �
__traceback__r} r� �sortedr� � traceback� format_list�rstripr r9 r� r r ) rX �contextr� r� r Z log_linesr �value�tbr r r �default_exception_handler� s6
z'BaseEventLoop.default_exception_handlerc C s� | j d kr>y| j|� W q� tk
r: tjddd� Y q�X nny| j | |� W n\ tk
r� } z@y| jd||d�� W n" tk
r� tjddd� Y nX W Y d d }~X nX d S )Nz&Exception in default exception handlerT)r z$Unhandled error in exception handler)r� r� r. zeException in default exception handler while handling an unexpected error in custom exception handler)rt r1 rO r r )rX r. rR r r r r� s"
z$BaseEventLoop.call_exception_handlerc C s |j r
d S | jj|� d S )N)�
_cancelledrn r9 )rX r r r r �
_add_callback9 s zBaseEventLoop._add_callbackc C s | j |� | j� d S )N)r3 r� )rX r r r r �_add_callback_signalsafeA s
z&BaseEventLoop._add_callback_signalsafec C s |j r| jd7 _d S )Nr )ro ri )rX r r r r �_timer_handle_cancelledF s z%BaseEventLoop._timer_handle_cancelledc C s� t | j�}|tkrd| j| tkrdg }x&| jD ] }|jr>d|_q,|j|� q,W tj|� || _d| _n8x6| jr�| jd jr�| jd8 _tj | j�}d|_qfW d }| j
s�| j r�d}n*| jr�| jd j }t
td|| j� �t�}| jo�|dk�r�| j� }| jj|�}| j� | }|dk�r tj} ntj} t |�}
|d k�rLtj| d|d |
� nD|
�rntj| d|d |d |
� n"|dk�r�tj| d|d |d � n | jj|�}| j|� | j� | j } xD| j�r�| jd }|j | k�r�P tj | j�}d|_| j
j|� �q�W t | j
�} x�t| �D ]|}
| j
j � }|j�r*�q| j�r�zD|| _ | j� }|j � | j� | }|| j k�rttj d t!|�|� W d d | _ X n|j � �qW d }d S )
NFr r g �?z poll took %.3f ms: %s eventsg @�@z$poll %.3f ms took %.3f ms: %s eventsz"poll %.3f ms took %.3f ms: timeoutz Executing %s took %.3f seconds)"r� ro � _MIN_SCHEDULED_TIMER_HANDLESri �%_MIN_CANCELLED_TIMER_HANDLES_FRACTIONr2 r9 r� �heapify�heappoprn rk Z_when�min�maxrr �MAXIMUM_SELECT_TIMEOUTr� Z _selectorZselect�logging�INFO�DEBUGr �logr� rs �range�popleftr} Z_runr| r r )rX Z sched_countZ
new_scheduledr Ztimeoutr� r� r� r� �levelZneventZend_timeZntodo�ir r r r� K s�
zBaseEventLoop._run_oncec C s� yt j}t j}W n tk
r$ d S X t|�}| j|kr sT
;
/