j fN @ 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 e j
ru d
d Z n 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
n | j j | j j | | d k r | j j t j | d n 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 r5 )r r] r# r# r$ rs 8 s $ z(_ProactorWritePipeTransport._pipe_closed)r( rK rL r
rs r# r# )r" r$ rq 2 s rq c @ s. e Z d Z d Z d d Z d d Z d S) _ProactorDuplexPipeTransportzTransport for duplex pipes.c C s d S)NFr# )r r# r# r$ rn M s z*_ProactorDuplexPipeTransport.can_write_eofc C s
t d S)N)NotImplementedError)r r# r# r$ ro P s z&_ProactorDuplexPipeTransport.write_eofN)r( rK rL rM rn ro r# r# r# r$ rv H s rv c @ s: e Z d Z d Z d d Z d d Z d d Z d S) _ProactorSocketTransportz Transport for connected sockets.c C s | | j d
"z2BaseProactorEventLoop._start_serving..loop)r )r r r r r! r# )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~ valuesr4 clear)r Zfuturer# r# r$ r s z*BaseProactorEventLoop._stop_accept_futuresc C s( | j | j j | | j d S)N)r rW
_stop_servingr5 )r r r# r# r$ r # s
z#BaseProactorEventLoop._stop_serving)r( rK rL r
r r r r r r5 r r r r r r r r r r r r r r# r# )r" r$ r t s4
( )rM __all__rH r6 r r r r r r logr
Z_FlowControlMixinZ
BaseTransportr Z
ReadTransportrN ZWriteTransportr_ rq Z Transportrv rx Z
BaseEventLoopr r# r# r# r$ s0 z M S