View file File name : base_events.cpython-36.opt-2.pyc Content :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 )Nz<pipe>z<stdout>)� 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|�r<tj}nt|�rLtj}nd S |d kr^d}nVt|t�rv|dkrvd}n>t|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� Z<drds� Z=dtdu� Z>dvdw� 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 � <listcomp>� s z4BaseEventLoop.shutdown_asyncgens.<locals>.<listcomp>)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 � <genexpr> s z2BaseEventLoop.create_connection.<locals>.<genexpr>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.<locals>.<genexpr>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.<locals>.<listcomp>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<tdj(|���|g} t)�| �}x4| D ],}|j*|� |j+d � �j,|||||� �qRW �j�r�tj-d|� |S )Nz*ssl argument must be an SSLContext or Nonez8host/port and sock can not be specified at the same timer r r0 c s g | ]}�j |�� �d ��qS ))r= rB )r )r� r; )r= rB r< rX r r r� s z/BaseEventLoop.create_server.<locals>.<listcomp>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<d S tj}|� }|rz|d |fkrjtj d| t � q�||� d| _n,|d |fkr�tj d| t � n|d � d| _d S )Nz[loop.set_debug(True): cannot set debug coroutine wrapper; another wrapper is already set %rTzWloop.set_debug(False): cannot unset debug coroutine wrapper; another wrapper was set %rF) rv �set_coroutine_wrapper�get_coroutine_wrapper�AttributeErrorrx r r Z debug_wrapperr� r� �RuntimeWarning)rX �enabledZ set_wrapperZ get_wrapper�wrapperZcurrent_wrapperr r r r� � s. z$BaseEventLoop._set_coroutine_wrapperc C s | j S )N)r� )rX r r r r� � s zBaseEventLoop.get_debugc C s || _ | j� r| j|� d S )N)r� r� r� )rX rI r r r ru � s zBaseEventLoop.set_debug)N)N)NNN)NN)NN)N)r )NN)F)NN)NN)Gr[ re rf rY r\ rD r� r� r� r� r� r� r� r� r r� r� r� r� r� r� r� r� r� rQ r` r� r ZPY34r� r� rr r� r� r� r� r� r� r� r� r� r� rF r� r� r� r r r r6 Z AI_PASSIVEr r r r r r r r# r% r& r' r1 r� r3 r4 r5 r� r� r� ru r r r r r � s� ! % u ` 12c!i�Q )1rl Zconcurrent.futuresr� r� �inspectr r= ry r r r� rr r+ rv r� r� r0 r r r r r r r@ r �__all__r6 r7 �BrokenPipeError�ConnectionResetError�ConnectionAbortedErrorZ_FATAL_ERROR_IGNOREr r8 r< r r r& r+ r- rA r) rK rM rS ZAbstractServerrT ZAbstractEventLoopr r r r r �<module> sT ; /