]
@ 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
BaseEventLoopd g ?c C sH | j } t j | r: t | j t j r: t | j St | Sd S)N) _callbackinspectZismethod
isinstance__self__r Taskreprstr)handlecb 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>)
subprocessPIPESTDOUTr )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.)hasattrsocket
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
rYqXqWd S)N inet_ptonr AF_INET6Zidna%)r r IPPROTO_TCP IPPROTO_UDPr' r) r bytesr int TypeErrorr AF_UNSPECAF_INETappendr. decoder+ r# )hostportfamilyr& protoZafsafr 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: infofutr 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_loopstop)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 waiterswaiterr 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 rd5 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 collectionsdeque_ready
_scheduled_default_executorZ
_internal_fds
_thread_idtimeget_clock_infoZ
resolution_clock_resolution_exception_handler set_debugsysr? ignore_environmentboolosenvirongetslow_callback_duration_current_handle
_task_factory_coroutine_wrapper_setr weakrefWeakSet
_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_factoryNextraserverc 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_sideFserver_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 argsshellstdinstdoutstderrbufsizer 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() callsource)r warningswarnformatResourceWarningr 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 lenlistclearr gatherzipr rK call_exception_handlerr )rT Z
closing_agensZ
shutdown_cororesultsresultr 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_pendingadd_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 %rTwaitF) 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 delaycallbackr 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 heapqheappushrk )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)Ncall_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)Nrun_in_executorrE ) r r r rl
concurrentr ThreadPoolExecutorZ wrap_futuresubmit)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? msgt0Zaddrinfodtr 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.getnameinfosslr$
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
| PWqt k
rI} z9 t | j d j | | j
j } | j | WYd d } ~ XqXqW| 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 qt | d t f d d | D r[| d t d j d j d d | D n9 | d k rt d t | st 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# setblockingbinderrnor strerrorlowerr\ r r r sock_connectr r allr r( _create_connection_transportget_extra_info)rT protocol_factoryr9 r: r r; r< r? r$ r r f1fsf2infosZ 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_portallow_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} | st d xS | D]K \ } } } } } | | f } | | k rd d g | | <| | | | <qWqDW 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 | rt |
| 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 kvr 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 informationposixcygwinz@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_infosidxaddrr 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_getaddrinfobacklogr 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 rt j d | | | d
d w=Yn X| j | | r| j t j t j d |
rt | | | 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 | sx | D] } | j$ qWXnB | d k rt d t% | st 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 itertoolschain
from_iterableerrorr 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 completedresr= socktyper< canonnamesaerrr 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_argsargr 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_listrstripr r7 r r r ) rT contextr r r Z log_linesr valuetbr 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 rt j } n t j } t | }
| d k rt j | d | d |
q+|
rt 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 rq| j rTz[ | | _ | j } | j | j | } | | j k rCt j d t | | Wd d | _ Xq| j qWd } 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 heapifyheappoprj rg Z_whenmaxrn r _selectorselectloggingINFODEBUGr logr rp rangepopleftrz Z_runry r r )rT Z sched_countZ
new_scheduledr timeoutr r r r levelZneventend_timeZntodoir 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_wrapperget_coroutine_wrapperAttributeErrorru r| r Z
debug_wrapperr r RuntimeWarning)rT enabledZ set_wrapperZ get_wrapperwrapperZcurrent_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 BrokenPipeErrorConnectionResetErrorConnectionAbortedErrorZ_FATAL_ERROR_IGNOREr r r% r( r* r> r' rH rO ZAbstractServerrP ZAbstractEventLoopr
r r r r <module> sJ =
/