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
BaseEventLoopd g ?AF_INET6 i c C s0 | j }tt|dd tjr$t|jS t| S d S )N__self__)Z _callback
isinstancegetattrr Taskreprr str)handlecb 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)
subprocessPIPESTDOUTr )fdr r r _format_pipeH s
r c C sL t tdstdn4y| jtjtjd W n tk
rF tdY 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.)hasattrsocket
ValueError
setsockopt
SOL_SOCKETr OSError)sockr r r _set_reuseportQ s
r& c C s& t tdr| 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 tdr| d@ tjkS | tjkS d S )Nr' r( )r r
SOCK_DGRAM)r* r r r _is_dgram_socketh s
r- c C sv t tdsd S |dtjtjhks(| d kr,d S t|rt|tr|dkrd}n&y t |}W n t
t fk
r d S X |tj krtj
g}tr|jtj n|g}t| tr| jd} d| kr d S xp|D ]h}yJtj|| tr@|tjkr@|||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_UNSPECAF_INET _HAS_IPv6appendr decoder. r$ )hostportfamilytypeprotoZafsafr r r _ipaddr_infop sL
rA )r= r> r? flagsc
C sZ | d d \}}t |||||}|d k r@|j } | j|g | S |j||||||dS d S )N )r= r> r? rB )rA
create_future
set_result getaddrinfo)
addressr= r> r? rB loopr; r< infofutr r r _ensure_resolved s rK TCP_NODELAYc C s> | j tjtjhkr:t| jr:| 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|tr t|t r d S | jj d S )N)Z
_exceptionr
BaseException Exception_loopstop)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 waiterswaiterr 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 Zdd
d
dddZ ddd
d
d
dddZ
dddZ dddZ dddZ
eddd Zd d Zd d Zd!d" Zd#d$ Zd%d& Zed'd( Zd)d* Zd+d, Zd-d. Zd/d0 Zd1d2 Zej rd3d4 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)dMdMdMdMdNdOdPZ*ddQdRZ+edd
dMdMdMd
d
d
dSdTdUZ,eddVdWZ-eddMdMdMd
d
d
d
dXdYdZZ.ed[d\ Z/ede0j1e0j2d
d]d
d
d
d^d_d`Z3ed
dadbdcZ4eddde Z5edfdg Z6dhdi Z7ee8j9e8j9e8j9ddjdMdkdldmZ:ee8j9e8j9e8j9dddMdkdndoZ;dpdq Zdvdw Z?dxdy Z@dzd{ ZAd|d} ZBd~d ZCdd ZDdd ZEdd ZFd
S )r
c C s d| _ d| _d| _tj | _g | _d | _d| _d | _ t
j dj | _
d | _| jtjj odttjjd d| _d | _d | _d| _ttdrt j | _ nd | _ d| _ d S )Nr F monotonicZPYTHONASYNCIODEBUGg?get_asyncgen_hooks) _timer_cancelled_count_closed _stopping collectionsdeque_ready
_scheduled_default_executorZ
_internal_fds
_thread_idtimeZget_clock_infoZ
resolution_clock_resolution_exception_handler set_debugsysrB ignore_environmentboolosenvirongetslow_callback_duration_current_handle
_task_factory_coroutine_wrapper_setr weakrefWeakSet
_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| dS )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)extraserverc 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_sideserver_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 argsshellstdinstdoutstderrbufsizer 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 rtdd 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 warningswarnformatResourceWarningr 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 lenlistclearr gatherzipr rO call_exception_handlerr )rX Z
closing_agensZ
shutdown_coroZresultsresultr r r r shutdown_asyncgens s"
z BaseEventLoop.shutdown_asyncgensc C s | j | j rtdtj 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 rt 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 st
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 Zdelaycallbackr 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 heapqheappushro )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(tdd 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| | dS )Nrun_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 }|
| jkrtj| 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 msgt0Zaddrinfodtr 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 dt||f|tj||| d} | g} | d k rt| |tj||| d}
| j|
nd }
tj| | dE d H | j }|std|
d k r|
j }|stdg }x|D ]B\}}}}}ytj|||d}|j d |
d k rx|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| jrtjd
|| | 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 qX P qW t|d krR|d nJt|d t fd
d|D r~|d tdj djdd |D n,|d krt dt|jst dj || j||||
E d H \}}| jr
|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$ setblockingbinderrnor strerrorlowerr` r r r sock_connectr r allr r+ r> _create_connection_transportget_extra_info)rX protocol_factoryr; r< r r= r? rB r% r r f1fsf2infosZ laddr_infos
exceptionsr> ZcnamerG _ZladdrrR transportr r )r r create_connection s
"
z BaseEventLoop.create_connectionc
c s |j d | }| j }|rFt|tr*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_portallow_broadcastr% c # s8 |
d k rt |
js tdj|
s@s@|s@|s@|s@|s@|s@| r~t |||||| d} djdd | j D } tdj| |
jd d }
n* ps|dkrtd ||fdff}ntj }xd fd
ffD ]~\}}|d k rt
||t j ||| d E d H }|s t
d xB|D ]:\}}}}}||f}||kr>d d g||< ||| |< qW qW fd
d|j D }|sztdg }|d krtjdkotjdk}x|D ]\\}}\}}d }
d }
yt j |t j |d}
|r|
jt jt jd
|rt|
| 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 qW |d | } | j } | j |
| |
| } | j r
rt 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 kvr 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||fqS )r Nr r )r keyZ addr_pair)r r r r r s z:BaseEventLoop.create_datagram_endpoint..z can not get address informationposixcygwin)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_infosidxZaddrr 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|| dE 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 |trtd|d k s$d k r|d k r4td| d krPtjdkoNtjdk} g } |dkrdd g} n$t |ts|t |t j
r|g} n|} fdd| D }
t j |
diE d H }t
tjj|}d }z x|D ]
}|\}}}}}ytj|||}W n6 tjk
r2 jr,tjd
|||d d wY nX | j| | rV|jtjtjd |
rdt| tr|tj krt td
r|jtj tj d y|j | W q t!k
r } z t!|j"d||j#j$ f W Y d d }~X qX qW d }W d |s x| D ]}|j% qW X n2|d kr"tdt&|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 itertoolschain
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 completedresr@ Zsocktyper? Z canonnameZsaerrr r )r= rB r< rX r
create_server s
(
zBaseEventLoop.create_server)r c c s^ t |jstdj|| j|||dddE 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 |ttfstd|r"td|s.td|dkr>td| }
d } | jrfd| } | j| ||| | j|
|d||||f| E d H } | jr| d k rtjd| | | |
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| ttfs8tdt| j q8W | }
d }| jrd| }| j|||| | j |
| d||||f|
E d H }| jr|d k rt
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_argsargr 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}xt|D ]}|d
kr~qp|| }|dkrdjtj|}d}||j 7 }n2|dkrdjtj|}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_listrstripr r9 r r r ) rX contextr r r Z log_linesr valuetbr r r default_exception_handler s6
z'BaseEventLoop.default_exception_handlerc C s | j d kr>y| j| W q tk
r: tjddd Y qX 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 rd}n*| jr| jd j }t
td|| j t}| jo|dkr| j }| jj|}| j | }|dkr tj} ntj} t |}
|d krLtj| d|d |
nD|
rntj| d|d |d |
n"|dkrtj| d|d |d n | jj|}| j| | j | j } xD| jr| jd }|j | krP tj | j}d|_| j
j| qW t | j
} xt| D ]|}
| j
j }|jr*q| jrzD|| _ | j }|j | j | }|| j krttj 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 heapifyheappoprn rk Z_whenminmaxrr MAXIMUM_SELECT_TIMEOUTr Z _selectorZselectloggingINFODEBUGr logr rs rangepopleftr} Z_runr| r r )rX Z sched_countZ
new_scheduledr Ztimeoutr r r r levelZneventZend_timeZntodoir 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
;
/