]N @ sY 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)BaseProactorEventLoop N ) base_events)compat) constants)futures)sslproto)
transports)loggerc s e 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)_ProactorBasePipeTransportNc 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__ 4/opt/alt/python35/lib64/python3.5/proactor_events.pyr
s$
z#_ProactorBasePipeTransport.__init__c C s | j j g } | j d k r. | j d n | j rD | j d | j d k rm | j d | j j | j d k r | j d | j | j d k r | j d | j | j r t | j } | j d | | j
r | j d d d j | S)
Nclosedclosingzfd=%szread=%szwrite=%rzwrite_bufsize=%sz EOF writtenz<%s> ) r" __name__r appendr filenor r r lenr join)r infobufsizer# r# r$ __repr__/ s"
z#_ProactorBasePipeTransport.__repr__c C s | | j d r ) rU rV rW r r r[ ExceptionrB r r\ r )r rn rD r# r# r$ r s
z(BaseProactorEventLoop._loop_self_readingc C s | j j d d S)Ns )r rl )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< )rU Z_debugr
rA r r r rV r rZ r* rB r7 r r[ r r\ )rn connaddrr rD )r protocol_factoryr r! r r r# r$ r s>
z2BaseProactorEventLoop._start_serving..loop)r )r r r r r! backlogr# )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 futurer# r# r$ r s z*BaseProactorEventLoop._stop_accept_futuresc C s( | j | j j | | j d S)N)r rV
_stop_servingr7 )r r r# r# r$ r # s
z#BaseProactorEventLoop._stop_serving)r( rL rM 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
( )__all__rH r8 r r r r r r logr
Z_FlowControlMixinZ
BaseTransportr Z
ReadTransportrN ZWriteTransportr_ rr Z Transportry r{ Z
BaseEventLoopr r# r# r# r$ s. M T