관리-도구
편집 파일: base_events.cpython-35.opt-2.pyc
���]�� � @ s� 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 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 d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d g Z d Z d Z e e e f Z d d � Z d d � Z! d d � Z" d d � Z# d d � Z$ d d � Z% d d d e j& d d d d d d � Z' d d � Z( Gd! d" � d" e j) � Z* Gd# d � d e j+ � Z, d S)$� N� )�compat)� coroutines)�events)�futures)�tasks)� coroutine)�logger� BaseEventLoop�d g �?c C sH | j } t j | � r: t | j t j � r: t | j � St | � Sd S)N) � _callback�inspectZismethod� isinstance�__self__r �Task�repr�str)�handle�cb� r �0/opt/alt/python35/lib64/python3.5/base_events.py�_format_handle: s $ r c C s4 | t j k r d S| t j k r& d St | � Sd S)Nz<pipe>z<stdout>)� subprocess�PIPE�STDOUTr )�fdr r r � _format_pipeC s r c C s` t t d � s t d � � n> y | j t j t j d � Wn t k r[ t d � � Yn Xd 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_reuseportL s r% c C s | j t j @t j k S)N)�typer � SOCK_STREAM)r$ r r r �_is_stream_socketW s r( c C s | j t j @t j k S)N)r& r � SOCK_DGRAM)r$ r r r �_is_dgram_socket^ s r* c C s� t t d � s d S| d t j t j h k s: | d k r> d S| t j k rY t j } n | t j k rt t j } n d S| d k r� d } nw t | t � r� | d k r� d } nS t | t � r� | d k r� d } n/ y t | � } Wn t t f k rd SYn X| t j k rAt j g } t t d � rJ| j t j � n | g } t | t � rh| j d � } d | k rxd SxP | D]H } y- t j | | � | | | d | | f f SWqt k r�YqXqWd S)N� inet_ptonr � � �AF_INET6Zidna�%)r r � IPPROTO_TCP� IPPROTO_UDPr' r) r �bytesr �int� TypeErrorr � AF_UNSPEC�AF_INET�appendr. �decoder+ r# )�host�port�familyr& �protoZafs�afr r r � _ipaddr_infoe sH r> r; r& r< �flagsc C s� | d d � \ } } t | | | | | � } | d k rZ | j � } | j | g � | S| j | | d | d | d | d | �Sd S)N� r; r& r< r? )r> � create_future� set_result� getaddrinfo) �addressr; r& r< r? �loopr9 r: �info�futr r r �_ensure_resolved� s rH c C s= | j } t | t � r, t | t � r, d S| j j � d S)N)� _exceptionr � BaseException� Exception�_loop�stop)rG �excr r r �_run_until_complete_cb� s rO c @ sj e Z d Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z e d d � � Z d S)�Serverc C s( | | _ | | _ d | _ g | _ d S)Nr )rL �sockets� _active_count�_waiters)�selfrE rQ r r r �__init__� s zServer.__init__c C s d | j j | j f S)Nz<%s sockets=%r>)� __class__�__name__rQ )rT r r r �__repr__� s zServer.__repr__c C s | j d 7_ d S)Nr )rR )rT r r r �_attach� s zServer._attachc C s; | j d 8_ | j d k r7 | j d k r7 | j � d S)Nr r )rR rQ �_wakeup)rT r r r �_detach� s zServer._detachc C s` | j } | d k r d Sd | _ x | D] } | j j | � q) W| j d k r\ | j � d S)Nr )rQ rL Z _stop_servingrR rZ )rT rQ r$ r r r �close� s z Server.closec C s@ | j } d | _ x' | D] } | j � s | j | � q Wd S)N)rS �donerB )rT �waiters�waiterr r r rZ � s zServer._wakeupc c sN | j d k s | j d k r" d S| j j � } | j j | � | Ed Hd S)N)rQ rS rL rA r7 )rT r_ r r r � wait_closed� s zServer.wait_closedN) rW � __module__� __qualname__rU rX rY r[ r\ rZ r r` r r r r rP � s rP c @ s� e Z 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 �Z d d d d d d d d d d d �Z d d d d d � Z d d d d � Z d d d d � Z e d d d � � Z d d � Z d! d" � Z d# d$ � Z d% d& � Z d' d( � Z e d) d* � � Z d+ d, � Z d- d. � Z d/ d0 � Z d1 d2 � Z d3 d4 � Z e j r�d5 d6 � Z d7 d8 � Z d9 d: � Z d; d< � Z d= d> � Z! d? d@ � Z" dA dB � Z# dC dD � Z$ dE dF � Z% dG dH � Z& dI dJ � Z' dK dL � Z( dM dN � Z) dO dP dQ dP dR dP dS dP dT dU � Z* dP dV dW � Z+ e d d dX d dO dP dR dP dS dP dY d dZ d d d d[ d\ �� Z, e d d] d^ � � Z- e d d dO dP dR dP dS dP d_ d d` d da d dY d db dc �� Z. e dd de � � Z/ e d d dO e0 j1 dS e0 j2 dY d df dg dX d d_ d d` d dh di �� Z3 e dX d dj dk � � Z4 e dl dm � � Z5 e dn do � � Z6 dp dq � Z7 e dr e8 j9 ds e8 j9 dt e8 j9 du d dv dw dx dP dy dz � � Z: e dr e8 j9 ds e8 j9 dt e8 j9 du d dv d dx dP d{ d| � � Z; d} d~ � Z< d d� � Z= d� d� � Z> d� d� � Z? d� d� � Z@ d� d� � ZA d� d� � ZB d� d� � ZC d� d� � ZD d� d� � ZE d� d� � ZF d S)�r c C s� d | _ d | _ d | _ t j � | _ g | _ d | _ d | _ d | _ t j d � j | _ d | _ | j t j j o� t t j j d � � � d | _ d | _ d | _ d | _ t t d � r� t j � | _ n d | _ d | _ d S)Nr F� monotonicZPYTHONASYNCIODEBUGg�������?�get_asyncgen_hooks) �_timer_cancelled_count�_closed� _stopping� collections�deque�_ready� _scheduled�_default_executorZ _internal_fds� _thread_id�time�get_clock_infoZ resolution�_clock_resolution�_exception_handler� set_debug�sysr? �ignore_environment�bool�os�environ�get�slow_callback_duration�_current_handle� _task_factory�_coroutine_wrapper_setr �weakref�WeakSet� _asyncgens�_asyncgens_shutdown_called)rT r r r rU � s( zBaseEventLoop.__init__c C s, d | j j | j � | j � | j � f S)Nz"<%s running=%s closed=%s debug=%s>)rV rW � is_running� is_closed� get_debug)rT r r r rX s zBaseEventLoop.__repr__c C s t j d | � S)NrE )r �Future)rT r r r rA s zBaseEventLoop.create_futurec C sZ | j � | j d k rD t j | d | �} | j rV | j d =n | j | | � } | S)NrE r ���)� _check_closedr{ r r �_source_traceback)rT �coroZtaskr r r � create_task s zBaseEventLoop.create_taskc C s2 | d k r% t | � r% t d � � | | _ d S)Nz'task factory must be a callable or None)�callabler4 r{ )rT �factoryr r r �set_task_factory# s z BaseEventLoop.set_task_factoryc C s | j S)N)r{ )rT r r r �get_task_factory1 s z BaseEventLoop.get_task_factoryN�extra�serverc C s t � d S)N)�NotImplementedError)rT r$ �protocolr_ r� r� r r r �_make_socket_transport5 s z$BaseEventLoop._make_socket_transport� server_sideF�server_hostnamec C s t � d S)N)r� ) rT Zrawsockr� � sslcontextr_ r� r� r� r� r r r �_make_ssl_transport: s z!BaseEventLoop._make_ssl_transportc C s t � d S)N)r� )rT r$ r� rD r_ r� r r r �_make_datagram_transport@ s z&BaseEventLoop._make_datagram_transportc C s t � d S)N)r� )rT �piper� r_ r� r r r �_make_read_pipe_transportE s z'BaseEventLoop._make_read_pipe_transportc C s t � d S)N)r� )rT r� r� r_ r� r r r �_make_write_pipe_transportJ s z(BaseEventLoop._make_write_pipe_transportc K s t � d S)N)r� ) rT r� �args�shell�stdin�stdout�stderr�bufsizer� �kwargsr r r �_make_subprocess_transportO s z(BaseEventLoop._make_subprocess_transportc C s t � d S)N)r� )rT r r r �_write_to_selfV s z BaseEventLoop._write_to_selfc C s t � d S)N)r� )rT � event_listr r r �_process_events_ s z BaseEventLoop._process_eventsc C s | j r t d � � d S)NzEvent loop is closed)rf � RuntimeError)rT r r r r� c s zBaseEventLoop._check_closedc C s= | j j | � | j � s9 | j | j � � | j � d S)N)r �discardr� r� �acloser� )rT �agenr r r �_asyncgen_finalizer_hookg s z&BaseEventLoop._asyncgen_finalizer_hookc C s< | j r( t j d j | � t d | �| j j | � d S)NzNasynchronous generator {!r} was scheduled after loop.shutdown_asyncgens() call�source)r� �warnings�warn�format�ResourceWarningr �add)rT r� r r r �_asyncgen_firstiter_hooko s z&BaseEventLoop._asyncgen_firstiter_hookc c s� d | _ | j d k s( t | j � r, d St | j � } | j j � t j d d � | D� d d d | � } | Ed H} xT t | | � D]C \ } } t | t � r� | j d d j | � d | d | i � q� Wd S) NTc S s g | ] } | j � � q Sr )r� )�.0Zagr r r � <listcomp>� s z4BaseEventLoop.shutdown_asyncgens.<locals>.<listcomp>Zreturn_exceptionsrE �messagez?an error occurred during closing of asynchronous generator {!r}� exceptionZasyncgen) r� r �len�list�clearr �gather�zipr rK �call_exception_handlerr� )rT Z closing_agensZ shutdown_coro�results�resultr� r r r �shutdown_asyncgensx s" z BaseEventLoop.shutdown_asyncgensc C s | j � | j � r" t d � � t j � d k r@ t d � � | j | j � t j � | _ | j d k r� t j � } t j d | j d | j � z, t j | � x | j � | j r� Pq� WWd d | _ d | _ t j d � | j d � | j d k r t j | � Xd S)Nz"This event loop is already runningz7Cannot run the event loop while another loop is runningZ firstiter� finalizerF)r� r� r� r Z_get_running_loop�_set_coroutine_wrapper�_debug� threading� get_identrm r rs rd Zset_asyncgen_hooksr� r� Z_set_running_loop� _run_oncerg )rT Zold_agen_hooksr r r � run_forever� s0 zBaseEventLoop.run_foreverc C s� | j � t j | � } t j | d | �} | r> d | _ | j t � zI y | j � Wn4 | r� | j � r� | j � r� | j � � Yn XWd | j t � X| j � s� t d � � | j � S)NrE Fz+Event loop stopped before Future completed.)r� r Zisfuturer Z ensure_futureZ_log_destroy_pending�add_done_callbackrO r� r] � cancelledr� Zremove_done_callbackr� r� )rT �futureZnew_taskr r r �run_until_complete� s z BaseEventLoop.run_until_completec C s d | _ d S)NT)rg )rT r r r rM � s zBaseEventLoop.stopc C s� | j � r t d � � | j r% d S| j r> t j d | � d | _ | j j � | j j � | j } | d k r� d | _ | j d d � d S)Nz!Cannot close a running event loopzClose %rT�waitF) r� r� rf r� r �debugrj r� rk rl �shutdown)rT �executorr r r r\ � s zBaseEventLoop.closec C s | j S)N)rf )rT r r r r� � s zBaseEventLoop.is_closedc C s: | j � s6 t j d | t � | j � s6 | j � d S)Nzunclosed event loop %r)r� r� r� r� r� r\ )rT r r r �__del__� s zBaseEventLoop.__del__c C s | j d k S)N)rm )rT r r r r� s zBaseEventLoop.is_runningc C s t j � S)N)rn rc )rT r r r rn s zBaseEventLoop.timec G s6 | j | j � | | | � } | j r2 | j d =| S)Nr r� )�call_atrn r� )rT �delay�callbackr� �timerr r r � call_later s zBaseEventLoop.call_laterc G sx | j � | j r- | j � | j | d � t j | | | | � } | j rX | j d =t j | j | � d | _ | S)Nr� r Tr� ) r� r� � _check_thread�_check_callbackr Z TimerHandler� �heapq�heappushrk )rT �whenr� r� r� r r r r� # s zBaseEventLoop.call_atc G sV | j � | j r- | j � | j | d � | j | | � } | j rR | j d =| S)N� call_soonr r� )r� r� r� r� � _call_soonr� )rT r� r� r r r r r� 3 s zBaseEventLoop.call_soonc C s[ t j | � s t j | � r3 t d j | � � � t | � sW t d j | | � � � d S)Nz#coroutines cannot be used with {}()z0a callable object was expected by {}(), got {!r})r Z iscoroutineZiscoroutinefunctionr4 r� r� )rT r� �methodr r r r� F s z BaseEventLoop._check_callbackc C s< t j | | | � } | j r( | j d =| j j | � | S)Nr r� )r ZHandler� rj r7 )rT r� r� r r r r r� Q s zBaseEventLoop._call_soonc C s> | j d k r d St j � } | | j k r: t d � � d S)NzMNon-thread-safe operation invoked on an event loop other than the current one)rm r� r� r� )rT Z thread_idr r r r� X s zBaseEventLoop._check_threadc G sV | j � | j r# | j | d � | j | | � } | j rH | j d =| j � | S)N�call_soon_threadsafer r� )r� r� r� r� r� r� )rT r� r� r r r r r� i s z"BaseEventLoop.call_soon_threadsafec G s{ | j � | j r# | j | d � | d k r\ | j } | d k r\ t j j � } | | _ t j | j | | � d | �S)N�run_in_executorrE ) r� r� r� rl � concurrentr �ThreadPoolExecutorZ wrap_future�submit)rT r� �funcr� r r r r� t s z BaseEventLoop.run_in_executorc C s | | _ d S)N)rl )rT r� r r r �set_default_executor s z"BaseEventLoop.set_default_executorc C s d | | f g } | r* | j d | � | rA | j d | � | rX | j d | � | ro | j d | � d j | � } t j d | � | j � } t j | | | | | | � } | j � | } d | | d | f } | | j k r� t j | � n t j | � | S) Nz%s:%rz family=%rztype=%rzproto=%rzflags=%rz, zGet address info %sz(Getting address info %s took %.3f ms: %rg @�@) r7 �joinr r� rn r rC ry rF ) rT r9 r: r; r& r< r? �msg�t0Zaddrinfo�dtr r r �_getaddrinfo_debug� s( z BaseEventLoop._getaddrinfo_debugr; r r& r< r? c C sW | j r. | j d | j | | | | | | � S| j d t j | | | | | | � Sd S)N)r� r� r� r rC )rT r9 r: r; r& r< r? r r r rC � s zBaseEventLoop.getaddrinfoc C s | j d t j | | � S)N)r� r � getnameinfo)rT Zsockaddrr? r r r r� � s zBaseEventLoop.getnameinfo�sslr$ � local_addrc # s# | d k r | r t d � � | d k rI | rI | sC t d � � | } | d k sa | d k r�| d k ry t d � � t | | f d | d t j d | d | d | �} | g } | d k r� t | d | d t j d | d | d | �} | j | � n d } t j | d | �Ed H| j � } | s:t d � � | d k rd| j � } | sdt d � � g } xU| D]�\ } } } } } y t j d | d | d | � } | j d � | d k rax� | D]� \ } } } } } y | j | � PWq�t k rI} z9 t | j d j | | j j � � � } | j | � WYd d } ~ Xq�Xq�W| j � d } wq| j r}t j d | | � | j | | � Ed HWnh t k r�} z( | d k r�| j � | j | � WYd d } ~ Xqq| d k r�| j � � YqqXPqqWt | � d k r"| d � q�t | d � � t � f d d � | D� � r[| d � t d j d j d d � | D� � � � � n9 | d k r�t d � � t | � s�t d j | � � � | j | | | | � Ed H\ } } | j r| j d � } t j d | | | | | � | | f S)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 timer; r& r< r? rE z!getaddrinfo() returned empty listFz2error while attempting to bind on address {!r}: {}zconnect %r to %rr r c 3 s! | ] } t | � � k Vq d S)N)r )r� rN )�modelr r � <genexpr> s z2BaseEventLoop.create_connection.<locals>.<genexpr>zMultiple exceptions: {}z, c s s | ] } t | � Vq d S)N)r )r� rN 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 rH r r' r7 r r� r� r# � setblocking�bind�errnor� �strerror�lowerr\ r� r r� � sock_connectr� r �allr� r( � _create_connection_transport�get_extra_info)rT �protocol_factoryr9 r: r� r; r< r? r$ r� r� �f1�fs�f2�infosZ laddr_infos� exceptionsr& ZcnamerD �_�laddrrN � transportr� r )r� r �create_connection� s� $ % z BaseEventLoop.create_connectionc c s� | j d � | � } | j � } | rj t | t � r= d n | } | j | | | | d | d | �} n | j | | | � } y | Ed HWn | j � � Yn X| | f S)NFr� r� )r� rA r ru r� r� r\ ) rT r$ r� r� r� r� r� r_ r� r� r r r r� + s z*BaseEventLoop._create_connection_transport� reuse_address� reuse_port�allow_broadcastc # sT | d k r� t | � s- t d j | � � � � s] � s] | s] | s] | s] | s] | s] | r� t d � d � d | d | d | d | d | d | � } d j d d � | j � D� � } t d j | � � � | j d � d } n�� p� � s | d k rt d � � | | f d f f } nt j � } x� d � f d � f f D]� \ } } | d k rDt | d | d t j d | d | d | �Ed H} | s�t d � � xS | D]K \ } } } } } | | f } | | k r�d d g | | <| | | | <q�WqDW� � f d d � | j � D� } | s.t d � � g } | d k r^t j d k o[t j d k } xV| D]D\ \ } } \ } } d } d } y� t j d | d t j d | � } | r�| j t j t j d � | r�t | � | r�| j t j t j d � | j d � � r| j | � � r<| j | | � Ed H| } Wnh t k r�} z( | d k rh| j � | j | � WYd d } ~ Xqe| d k r�| j � � YqeXPqeW| d � | � } | j � } | j | | | | � } | j r%� rt j d � � | | � n t j d � | | � y | Ed HWn | j � � Yn X| | f S) Nz#A UDP Socket was expected, got {!r}r� � remote_addrr; r< r? r r r z, c s s- | ]# \ } } | r d j | | � Vq d S)z{}={}N)r� )r� �k�vr r r r� W s z9BaseEventLoop.create_datagram_endpoint.<locals>.<genexpr>zNsocket modifier keyword arguments can not be used when sock is specified. ({})Fr zunexpected address familyr r& rE z!getaddrinfo() returned empty listc sN g | ]D \ } } � r( | d d k p; � o; | d d k s | | f � q S)r Nr r )r� �keyZ addr_pair)r� r r r r� x s z:BaseEventLoop.create_datagram_endpoint.<locals>.<listcomp>z can not get address information�posix�cygwinz@Datagram endpoint local_addr=%r remote_addr=%r created: (%r, %r)z2Datagram endpoint remote_addr=%r created: (%r, %r))NN) r* r r� �dictr� �itemsr� rh � OrderedDictrH r r) r# rv �namers �platformr! r" � SO_REUSEADDRr% � SO_BROADCASTr� r� r\ r7 rA r� r� r rF r� ) rT r� r� r r; r< r? r r r r$ ZoptsZproblemsZr_addrZaddr_pairs_infoZ addr_infos�idx�addrr� Zfamr� ZprorD r r� Z local_addressZremote_addressrN r� r_ r� r )r� r r �create_datagram_endpointC s� % " z&BaseEventLoop.create_datagram_endpointc c sQ t | | f d | d t j d | d | �Ed H} | sM t d j | � � � | S)Nr; r& r? rE z%getaddrinfo({!r}) returned empty list)rH r r' r# r� )rT r9 r: r; r? r� r r r �_create_server_getaddrinfo� s z(BaseEventLoop._create_server_getaddrinfo�backlogr c # sd t | t � r t d � � | d k s3 � d k r�| d k rK t d � � t t d d � } | d k r� t j d k o� t j d k } g } | d k r� d g } n4 t | t � s� t | t j � r� | g } n | } � � � � f d d � | D� } t j | d � � Ed H} t t j j | � � } d } zWxJ| D]B} | \ } } } } } y t j | | | � } Wn= t j k r�� j r�t j d | | | d d �w=Yn X| j | � | r�| j t j t j d � | r�t | � | | k r!t t d � r!| j t j t j d � y | j | � Wq=t k r~} z* t | j! d | | j" j# � f � � WYd d } ~ Xq=Xq=Wd } Wd | s�x | D] } | j$ � q�WXnB | d k r�t d � � t% | � s�t d j& | � � � | g } t' � | � } xA | D]9 } | j( | � | j) d � � j* | | | | | � q W� j r`t j+ d | � | S)Nz*ssl argument must be an SSLContext or Nonez8host/port and sock can not be specified at the same timer. r r r r- c s. g | ]$ } � j | � d � d � �� q S)r; r? )r )r� r9 )r; r? r: rT r r r� � s z/BaseEventLoop.create_server.<locals>.<listcomp>rE Fz:create_server() failed to create socket.socket(%r, %r, %r)�exc_infoT� 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 ru r4 r �getattrr rv r rs r r rh �Iterabler r� �set� itertools�chain� from_iterable�errorr� r �warningr7 r! r" r r% r r � IPV6_V6ONLYr� r# r� r� r� r\ r( r� rP �listenr� Z_start_servingrF )rT r� r9 r: r; r? r$ r r� r r r. rQ Zhostsr� r� Z completed�resr= �socktyper< � canonname�sa�errr� r )r; r? r: rT r � create_server� s� 0 zBaseEventLoop.create_serverc c s� t | � s! t d j | � � � | j | | | d d d �Ed H\ } } | j rx | j d � } t j d | | | � | | f S)Nz&A Stream Socket was expected, got {!r}r- r� Tr z%r handled: (%r, %r))r( r r� r� r� r� r r� )rT r� r$ r� r� r� r r r �connect_accepted_socket. s # z%BaseEventLoop.connect_accepted_socketc c s~ | � } | j � } | j | | | � } y | Ed HWn | j � � Yn X| j rt t j d | j � | | � | | f S)Nz Read pipe %r connected: (%r, %r))rA r� r\ r� r r� �fileno)rT r� r� r� r_ r� r r r �connect_read_pipeE s z BaseEventLoop.connect_read_pipec c s~ | � } | j � } | j | | | � } y | Ed HWn | j � � Yn X| j rt t j d | j � | | � | | f S)Nz!Write pipe %r connected: (%r, %r))rA r� r\ r� r r� r( )rT r� r� r� r_ r� r r r �connect_write_pipeV s z BaseEventLoop.connect_write_pipec C s� | g } | d k r, | j d t | � � | d k ra | t j k ra | j d t | � � nF | d k r� | j d t | � � | d k r� | j d t | � � t j d j | � � d S)Nzstdin=%szstdout=stderr=%sz stdout=%sz stderr=%s� )r7 r r r r r� r� )rT r� r� r� r� rF r r r �_log_subprocessg s z BaseEventLoop._log_subprocessr� r� r� �universal_newlinesr� Tr� c k s� t | t t f � s! t d � � | r3 t d � � | sE t d � � | d k r] t d � � | � } | j r� d | } | j | | | | � | j | | d | | | | | � Ed H} | j r� t j d | | � | | f S) Nzcmd must be a stringz universal_newlines must be Falsezshell must be Truer zbufsize must be 0zrun shell command %rTz%s: %r) r r2 r r r� r, r� r rF ) rT r� �cmdr� r� r� r- r� r� r� r� � debug_logr� r r r �subprocess_shellt s" # z BaseEventLoop.subprocess_shellc o s | r t d � � | r$ t d � � | d k r< t d � � | f | } x< | D]4 } t | t t f � sP t d t | � j � � qP W| � } | j r� d | } | j | | | | � | j | | d | | | | | � Ed H} | j r� t j d | | � | | f S) 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 r2 r4 r& rW r� r, r� r rF )rT 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)rq )rT r r r �get_exception_handler� s z#BaseEventLoop.get_exception_handlerc C s; | d k r. t | � r. t d j | � � � | | _ d S)Nz/A callable object or None is expected, got {!r})r� r4 r� rq )rT �handlerr r r �set_exception_handler� s z#BaseEventLoop.set_exception_handlerc C s� | j d � } | s d } | j d � } | d k rQ t | � | | j f } n d } d | k r� | j d k r� | j j r� | j j | d <| g } x� t | � D]� } | d k r� q� | | } | d k r d j t j | � � } d } | | j � 7} nI | d k r=d j t j | � � } d } | | j � 7} n t | � } | j d j | | � � q� Wt j d j | � d | �d S)Nr� z!Unhandled exception in event loopr� FZsource_tracebackZhandle_tracebackr- z+Object created at (most recent call last): z+Handle created at (most recent call last): z{}: {}� r > r� r� )rx r& � __traceback__rz r� �sortedr� � traceback� format_list�rstripr r7 r� r r ) rT �contextr� r� r Z log_linesr �value�tbr r r �default_exception_handler� s6 z'BaseEventLoop.default_exception_handlerc C s� | j d k rK y | j | � Wq� t k rG t j d d d �Yq� Xn� y | j | | � Wnp t k r� } zP y# | j d d d | d | i � Wn% t k r� t j d d d �Yn XWYd d } ~ Xn Xd S) Nz&Exception in default exception handlerr Tr� z$Unhandled error in exception handlerr� r< zeException in default exception handler while handling an unexpected error in custom exception handler)rq r? rK r r )rT r< rN r r r r� � s" z$BaseEventLoop.call_exception_handlerc C s! | j r d S| j j | � d S)N)� _cancelledrj r7 )rT r r r r � _add_callback s zBaseEventLoop._add_callbackc C s | j | � | j � d S)N)rA r� )rT r r r r �_add_callback_signalsafe' s z&BaseEventLoop._add_callback_signalsafec C s | j r | j d 7_ d S)Nr )rk re )rT r r r r �_timer_handle_cancelled, s z%BaseEventLoop._timer_handle_cancelledc C sl t | j � } | t k r� | j | t k r� g } x3 | j D]( } | j rY d | _ q> | j | � q> Wt j | � | | _ d | _ nJ xG | j r� | j d j r� | j d 8_ t j | j � } d | _ q� Wd } | j s� | j r� d } n2 | j r)| j d j } t d | | j � � } | j r| d k r| j � } | j j | � } | j � | } | d k r�t j } n t j } t | � } | d k r�t j | d | d | � q+| r�t j | d | d | d | � q+| d k r+t j | d | d | d � n | j j | � } | j | � | j � | j } xU | j r�| j d } | j | k rtPt j | j � } d | _ | j j | � qNWt | j � } x� t | � D]� } | j j � } | j r�q�| j rTz[ | | _ | j � } | j � | j � | } | | j k rCt j d t | � | � Wd d | _ Xq�| j � q�Wd } 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� rk � _MIN_SCHEDULED_TIMER_HANDLESre �%_MIN_CANCELLED_TIMER_HANDLES_FRACTIONr@ r7 r� �heapify�heappoprj rg Z_when�maxrn r� � _selector�select�logging�INFO�DEBUGr �logr� rp �range�popleftrz Z_runry r r )rT Z sched_countZ new_scheduledr �timeoutr� r� r� r� �levelZnevent�end_timeZntodo�ir r r r� 1 s� zBaseEventLoop._run_oncec C s� y t j } t j } Wn t k r. d SYn Xt | � } | j | k rN d St j } | � } | r� | d | f k r� t j d | t � q� | | � d | _ n< | d | f k r� t j 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) rs �set_coroutine_wrapper�get_coroutine_wrapper�AttributeErrorru r| r Z debug_wrapperr� r� �RuntimeWarning)rT �enabledZ set_wrapperZ get_wrapper�wrapperZcurrent_wrapperr r r r� � s. z$BaseEventLoop._set_coroutine_wrapperc C s | j S)N)r� )rT r r r r� � s zBaseEventLoop.get_debugc C s& | | _ | j � r" | j | � d S)N)r� r� r� )rT rY r r r rr � s zBaseEventLoop.set_debug)GrW ra rb rU rX rA r� r� r� r� r� r� r� r� r r� r� r� r� r� r� r� r� r� rM r\ r� r ZPY34r� r� rn r� r� r� r� r� r� r� r� r� r� rC r� r� r� r r r r5 � AI_PASSIVEr& r' r) r* r, r r r0 r2 r3 r5 r? r� rA rB rC r� r� r� rr r r r r r � s� ! % ! � u _ , 2 c ! )-rh �concurrent.futuresr� r� r r rK rv r r r� rn r9 rs r� r} r- r r r r r r rN r �__all__rD rE �BrokenPipeError�ConnectionResetError�ConnectionAbortedErrorZ_FATAL_ERROR_IGNOREr r r% r( r* r> r' rH rO ZAbstractServerrP ZAbstractEventLoopr r r r r �<module> sJ = /