]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 <d S)Npipe)_extra)r r r# r# r$ r B s z%_ProactorBasePipeTransport._set_extrac C s
| | _ d S)N)r )r r r# r# r$ set_protocolE s z'_ProactorBasePipeTransport.set_protocolc C s | j S)N)r )r r# r# r$ get_protocolH s z'_ProactorBasePipeTransport.get_protocolc C s | j S)N)r )r r# r# r$
is_closingK s z%_ProactorBasePipeTransport.is_closingc C s} | j r
d Sd | _ | j d 7_ | j rT | j d k rT | j j | j d | j d k ry | j j d | _ d S)NTr ) r r r r r r _call_connection_lostr cancel)r r# r# r$ closeN s
z _ProactorBasePipeTransport.closec C s1 | j d k r- t j d | t | j d S)Nzunclosed transport %r)r warningswarnResourceWarningr7 )r r# r# r$ __del__] s z"_ProactorBasePipeTransport.__del__z Fatal error on pipe transportc C sy t | t j r= | j j rh t j d | | d d n+ | j j d | d | d | d | j i | j | d S)Nz%r: %sexc_infoTmessage exceptionZ transportr )
isinstancer Z_FATAL_ERROR_IGNOREr get_debugr
debugcall_exception_handlerr _force_close)r excr= r# r# r$ _fatal_errorb s z'_ProactorBasePipeTransport._fatal_errorc C s | j r
d Sd | _ | j d 7_ | j rD | j j d | _ | j rc | j j d | _ d | _ d | _ | j j | j | d S)NTr r )
r r r r6 r r r r r r5 )r rD r# r# r$ rC o s
z'_ProactorBasePipeTransport._force_closec C s z | j j | Wd t | j d r< | j j t j | j j d | _ | j } | d k rz | j d | _ Xd S)Nshutdown)
r Zconnection_losthasattrr rF socket SHUT_RDWRr7 r Z_detach)r rD r! r# r# r$ r5 ~ s
z0_ProactorBasePipeTransport._call_connection_lostc C s/ | j } | j d k r+ | t | j 7} | S)N)r r r+ )r sizer# r# r$ get_write_buffer_size s z0_ProactorBasePipeTransport.get_write_buffer_size)r(
__module__ __qualname__r
r/ r r2 r3 r4 r7 r ZPY34r; rE rC r5 rK r# r# )r" r$ r s
r c sR e Z d Z d d d f d d Z d d Z d d Z d d d Z S)
_ProactorReadPipeTransportNc s? t j | | | | | | d | _ | j j | j d S)NF)r r
_pausedr r
_loop_reading)r r r r r r r! )r" r# r$ r
s z#_ProactorReadPipeTransport.__init__c C sV | j r t d | j r* t d d | _ | j j rR t j d | d S)Nz#Cannot pause_reading() when closingzAlready pausedTz%r pauses reading)r RuntimeErrorrO r r@ r
rA )r r# r# r$
pause_reading s z(_ProactorReadPipeTransport.pause_readingc C sg | j s t d d | _ | j r+ d S| j j | j | j | j j rc t j d | d S)Nz
Not pausedFz%r resumes reading)
rO rQ r r r rP r r@ r
rA )r r# r# r$ resume_reading s z)_ProactorReadPipeTransport.resume_readingc C s | j r
d Sd } zhyf | d k r: d | _ | j } | j rM d } d S| d k r] d S| j j j | j d | _ Wn t k
r } zC | j s | j | d n" | j j
r t j d d d WYd d } ~ Xn t
k
r} z | j | WYd d } ~ Xnh t k
rF} z | j | d WYd d } ~ Xn4 t j k
rf| j sb Yn X| j j | j Wd | r| j j | nJ | d k r| j j
rt j d | | j j } | s| j Xd S)N i z"Fatal read error on pipe transportz*Read error on pipe transport while closingr< Tz%r received EOF)rO r resultr r _proactorrecvr ConnectionAbortedErrorrE r@ r
rA ConnectionResetErrorrC OSErrorr CancelledErroradd_done_callbackrP r Z
data_receivedZ eof_receivedr7 )r futdatarD Z keep_openr# r# r$ rP sF " " z(_ProactorReadPipeTransport._loop_reading)r( rL rM r
rR rS rP r# r# )r" r$ rN s
rN c @ sR e Z d Z d d Z d d d d Z d d Z d d Z d
d Z d S) _ProactorBaseWritePipeTransportc C s t | t t t f s7 d t | j } t | | j rL t d | sV d S| j r | j t
j k r~ t j
d | j d 7_ d S| j d k r | j d t | n? | j s t | | _ | j n | j j | | j d S)Nz3data argument must be a bytes-like object, not '%s'zwrite_eof() already calledz socket.send() raised exception.r r^ )r? bytes bytearray
memoryviewtyper( TypeErrorr rQ r r Z!LOG_THRESHOLD_FOR_CONNLOST_WRITESr
warningr
_loop_writingr _maybe_pause_protocolextend)r r^ msgr# r# r$ write s(
z%_ProactorBaseWritePipeTransport.writeNc C sn yd | _ d | _ | r% | j | d k rC | j } d | _ | s | j rh | j j | j d | j r | j j
t j | j
no | j j j | j | | _ | j j s t | | _ | j j | j | j n | j j | j Wnf t k
r5} z | j | WYd d } ~ Xn5 t k
ri} z | j | d WYd d } ~ Xn Xd S)Nr z#Fatal write error on pipe transport)r r rU r r r r r5 r r rF rH SHUT_WRZ_maybe_resume_protocolrV senddoner+ r\ rf rg rY rC rZ rE )r fr^ rD r# r# r$ rf s0
z-_ProactorBaseWritePipeTransport._loop_writingc C s d S)NTr# )r r# r# r$
can_write_eof/ s z-_ProactorBaseWritePipeTransport.can_write_eofc C s | j d S)N)r7 )r r# r# r$ write_eof2 s z)_ProactorBaseWritePipeTransport.write_eofc C s | j d d S)N)rC )r r# r# r$ abort5 s z%_ProactorBaseWritePipeTransport.abort)r( rL rM rj rf ro rp rq r# r# r# r$ r_ s
$# r_ c s. e Z d Z f d d Z d d Z S)_ProactorWritePipeTransportc sH t j | | | j j j | j d | _ | j j | j d S)N ) r r
r rV rW r r r\ _pipe_closed)r argskw)r" r# r$ r
: s z$_ProactorWritePipeTransport.__init__c C sV | j r d S| j r d Sd | _ | j d k rH | j t n
| j d S)N) cancelledr r r rC BrokenPipeErrorr7 )r r] r# r# r$ rt ? s z(_ProactorWritePipeTransport._pipe_closed)r( rL rM r
rt r# r# )r" r$ rr 9 s rr c @ s( e Z d Z d d Z d d Z d S) _ProactorDuplexPipeTransportc C s d S)NFr# )r r# r# r$ ro T s z*_ProactorDuplexPipeTransport.can_write_eofc C s
t d S)N)NotImplementedError)r r# r# r$ rp W s z&_ProactorDuplexPipeTransport.write_eofN)r( rL rM ro rp r# r# r# r$ ry O s ry c @ s4 e Z d Z d d Z d d Z d d Z d S)_ProactorSocketTransportc C s | | j d <y | j | j d <Wn@ t j t f k
rf | j j rb t j d | d d Yn Xd | j k r y | j | j d <Wn@ t j t f k
r | j j r t j d | d d Yn Xd S)NrH Zsocknamezgetsockname() failed on %rr< Tpeernamezgetpeername() failed on %r)
r1 getsocknamerH errorAttributeErrorr r@ r
re getpeername)r r r# r# r$ r ` s
z#_ProactorSocketTransport._set_extrac C s d S)NTr# )r r# r# r$ ro p s z&_ProactorSocketTransport.can_write_eofc C sE | j s | j r d Sd | _ | j d k rA | j j t j d S)NT)r r r r rF rH rk )r r# r# r$ rp s s
z"_ProactorSocketTransport.write_eofN)r( rL rM r ro rp r# r# r# r$ r{ [ s r{ c sN e Z d Z f d d Z d d d d d Z d d d d d d d d
d d d Z d d d
d Z d d d d Z d d d d Z f d d Z d d Z
d d Z d d Z d d Z
d d Z d d Z d! d" Z d d# d$ Z d% d& Z d d d' d( d) Z d* d+ Z d, d- Z d. d/ Z S)0r c sb t j t j d | j j | | _ | | _ d | _ i | _ | j
| | j d S)NzUsing proactor: %s) r r
r
rA r" r( rV _selector_self_reading_future_accept_futuresZset_loop_make_self_pipe)r Zproactor)r" r# r$ r
} s
z BaseProactorEventLoop.__init__Nc C s t | | | | | | S)N)r{ )r r r r r r! r# r# r$ _make_socket_transport s z,BaseProactorEventLoop._make_socket_transport server_sideFserver_hostnamer r! c
C sY t j s t d t j | | | | | | } t | | | d | d | | j S)NzOProactor event loop requires Python 3.5 or newer (ssl.MemoryBIO) to support SSLr r! )r Z_is_sslproto_availablerz Z SSLProtocolr{ Z_app_transport)
r Zrawsockr
sslcontextr r r r r! Z ssl_protocolr# r# r$ _make_ssl_transport s
z)BaseProactorEventLoop._make_ssl_transportc C s t | | | | | S)N)ry )r r r r r r# r# r$ _make_duplex_pipe_transport s z1BaseProactorEventLoop._make_duplex_pipe_transportc C s t | | | | | S)N)rN )r r r r r r# r# r$ _make_read_pipe_transport s z/BaseProactorEventLoop._make_read_pipe_transportc C s t | | | | | S)N)rr )r r r r r r# r# r$ _make_write_pipe_transport s z0BaseProactorEventLoop._make_write_pipe_transportc sl | j r t d | j r( d S| j | j | j j d | _ d | _ t j d S)Nz!Cannot close a running event loop) Z
is_runningrQ is_closed_stop_accept_futures_close_self_piperV r7 r r )r )r" r# r$ r7 s
zBaseProactorEventLoop.closec C s | j j | | S)N)rV rW )r r nr# r# r$ sock_recv s z BaseProactorEventLoop.sock_recvc C s | j j | | S)N)rV rl )r r r^ r# r# r$ sock_sendall s z"BaseProactorEventLoop.sock_sendallc C s | j j | | S)N)rV connect)r r addressr# r# r$ sock_connect s z"BaseProactorEventLoop.sock_connectc C s | j j | S)N)rV accept)r r r# r# r$ sock_accept s z!BaseProactorEventLoop.sock_acceptc C s
t d S)N)rz )r r# r# r$ _socketpair s z!BaseProactorEventLoop._socketpairc C sd | j d k r% | j j d | _ | j j d | _ | j j d | _ | j d 8_ d S)Nr )r r6 _ssockr7 _csock
_internal_fds)r r# r# r$ r s
z&BaseProactorEventLoop._close_self_pipec C s[ | j \ | _ | _ | j j d | j j d | j d 7_ | j | j d S)NFr )r r r setblockingr r _loop_self_reading)r r# r# r$ r s
z%BaseProactorEventLoop._make_self_pipec C s y2 | d k r | j | j j | j d } Wn\ t j k
rM d SYn] t k
r } z$ | j d d d | d | i WYd d } ~ Xn X| | _ | j | j
d S)Ni r= z.Error on reading from the event loop self piper> 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.<locals>.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$ <module> s. M T