YfN @ s_ d Z d g 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 Gd d
d
e
j
e
j Z Gd d d e e
j Z Gd d d e e
j Z Gd d d e Z Gd d d e e e
j Z Gd d d e e e
j Z Gd d d e j Z d S)zEvent loop using a proactor and related classes.
A proactor is a "notify-on-completion" multiplexer. Currently a
proactor is only implemented on Windows with IOCP.
BaseProactorEventLoop N ) base_events)compat) constants)futures)sslproto)
transports)loggerc s e Z d Z d Z d d d f d d Z d d Z d d Z d d
Z d d Z d
d Z d d Z
e j r d d Z
d d d Z d d Z d d Z d d Z S) _ProactorBasePipeTransportz*Base class for pipe and socket transports.Nc s t j | | | j | | | _ | | _ | | _ d | _ d | _ d | _ d | _ d | _
d | _ d | _ | j d k r | j j
| j j | j j | | d k r | j j t j | d d S)Nr F)super__init__
_set_extra_sock _protocol_server_buffer _read_fut
_write_fut_pending_write
_conn_lost_closing _eof_writtenZ_attach_loop call_soonZconnection_mader Z _set_result_unless_cancelled)selfloopsockprotocolwaiterextraserver) __class__ ) r" __name__r appendr filenor r r lenr join)r infobufsizer# r# r$ __repr__/ s"
z#_ProactorBasePipeTransport.__repr__c C s | | j d r ) rV rW rX r r r\ ExceptionrB r r] r )r ro rD r# r# r$ r s
z(BaseProactorEventLoop._loop_self_readingc C s | j j d d S)Ns )r rm )r r# r# r$ _write_to_self s z$BaseProactorEventLoop._write_to_selfd c s5 d f d d j d S)Nc s y | d k r | j \ } } j r@ t j d | | } d k r j | | d d d d | i d n" j | | d d | i d j r d S j j } Wn t k
rL} zb j
d k r j d d d
| d i j n j r:t j d d
d WYd d } ~ Xn? t
j k
rj j Yn! X| j j
<| j d S)Nz#%r got a new connection from %r: %rr Tr r| r! r r= zAccept failed on a socketr> rH zAccept failed on socket %rr< )rV Z_debugr
rA r r r rW r r[ r* rB r7 r r\ r r] )ro ZconnZaddrr rD )r protocol_factoryr r! r r r# r$ r s>
z2BaseProactorEventLoop._start_serving..loop)r )r r r r r! Zbacklogr# )r r r r! r r r$ _start_serving s $$z$BaseProactorEventLoop._start_servingc C s d S)Nr# )r Z
event_listr# r# r$ _process_events s z%BaseProactorEventLoop._process_eventsc C s5 x! | j j D] } | j q W| j j d S)N)r valuesr6 clear)r Zfuturer# r# r$ r s z*BaseProactorEventLoop._stop_accept_futuresc C s( | j | j j | | j d S)N)r rW
_stop_servingr7 )r r r# r# r$ r # s
z#BaseProactorEventLoop._stop_serving)r( rK rL r
r r r r r r7 r r r r r r r r r r r r r r# r# )r" r$ r { s4
( )rM __all__rH r8 r r r r r r logr
Z_FlowControlMixinZ
BaseTransportr Z
ReadTransportrN ZWriteTransportr` rs Z Transportry r{ Z
BaseEventLoopr r# r# r# r$ s0 M T