]R' @ s d d l m Z d d d d d d g Z Gd d d Z Gd d d e Z Gd
d d e Z Gd d d e e Z Gd d d e Z Gd
d d e Z Gd d d e Z d S) )compat
BaseTransport
ReadTransportWriteTransport TransportDatagramTransportSubprocessTransportc @ s^ e Z d Z d d d Z d d d Z d d Z d d Z d
d Z d d
Z d S)r Nc C s | d k r i } | | _ d S)N)_extra)selfextra r //opt/alt/python35/lib64/python3.5/transports.py__init__
s zBaseTransport.__init__c C s | j j | | S)N)r get)r
namedefaultr r r
get_extra_info s z BaseTransport.get_extra_infoc C s
t d S)N)NotImplementedError)r
r r r
is_closing s zBaseTransport.is_closingc C s
t d S)N)r )r
r r r
close s zBaseTransport.closec C s
t d S)N)r )r
protocolr r r
set_protocol$ s zBaseTransport.set_protocolc C s
t d S)N)r )r
r r r
get_protocol( s zBaseTransport.get_protocol) __name__
__module__ __qualname__r r r r r r r r r r
r
s
c @ s( e Z d Z d d Z d d Z d S)r c C s
t d S)N)r )r
r r r
pause_reading0 s zReadTransport.pause_readingc C s
t d S)N)r )r
r r r
resume_reading8 s z ReadTransport.resume_readingN)r r r r r r r r r
r - s c @ sj e Z d Z d d d d Z d d Z d d Z d d Z d
d Z d d
Z d d Z d S)r Nc C s
t d S)N)r )r
highlowr r r
set_write_buffer_limitsD s z&WriteTransport.set_write_buffer_limitsc C s
t d S)N)r )r
r r r
get_write_buffer_sizeY s z$WriteTransport.get_write_buffer_sizec C s
t d S)N)r )r
datar r r
write] s zWriteTransport.writec C s t j | } | j | d S)N)r Zflatten_list_bytesr# )r
Z list_of_datar" r r r
writelinese s zWriteTransport.writelinesc C s
t d S)N)r )r
r r r
write_eofn s zWriteTransport.write_eofc C s
t d S)N)r )r
r r r
can_write_eofw s z WriteTransport.can_write_eofc C s
t d S)N)r )r
r r r
abort{ s zWriteTransport.abort)
r r r r r! r# r$ r% r& r' r r r r
r A s c @ s e Z d Z d S)r N)r r r r r r r
r s c @ s+ e Z d Z d d d Z d d Z d S)r Nc C s
t d S)N)r )r
r" addrr r r
sendto s zDatagramTransport.sendtoc C s
t d S)N)r )r
r r r
r' s zDatagramTransport.abort)r r r r) r' r r r r
r s
c @ sX e Z d Z d d Z d d Z d d Z d d Z d d
Z d d Z d
S)r c C s
t d S)N)r )r
r r r
get_pid s zSubprocessTransport.get_pidc C s
t d S)N)r )r
r r r
get_returncode s z"SubprocessTransport.get_returncodec C s
t d S)N)r )r
fdr r r
get_pipe_transport s z&SubprocessTransport.get_pipe_transportc C s
t d S)N)r )r
signalr r r
send_signal s z SubprocessTransport.send_signalc C s
t d S)N)r )r
r r r
terminate s z SubprocessTransport.terminatec C s
t d S)N)r )r
r r r
kill s zSubprocessTransport.killN) r r r r* r+ r- r/ r0 r1 r r r r
r s c s| e Z d Z d d f d d Z d d Z d d Z d d Z d d d
d Z d d d d
Z d d Z S)_FlowControlMixinNc s0 t j | | | _ d | _ | j d S)NF)superr _loop_protocol_paused_set_write_buffer_limits)r
r Zloop) __class__r r
r s z_FlowControlMixin.__init__c C s | j } | | j k r d S| j s d | _ y | j j WnP t k
r } z0 | j j d d d | d | d | j i WYd d } ~ Xn Xd S)NTmessagez protocol.pause_writing() failed exception transportr )r! _high_waterr5 _protocolZ
pause_writing Exceptionr4 call_exception_handler)r
sizeexcr r r
_maybe_pause_protocol s z'_FlowControlMixin._maybe_pause_protocolc C s | j r | j | j k r d | _ y | j j WnP t k
r } z0 | j j d d d | d | d | j i WYd d } ~ Xn Xd S)NFr8 z protocol.resume_writing() failedr9 r: r )r5 r!
_low_waterr< Zresume_writingr= r4 r> )r
r@ r r r
_maybe_resume_protocol s z(_FlowControlMixin._maybe_resume_protocolc C s | j | j f S)N)rB r; )r
r r r
get_write_buffer_limits s z)_FlowControlMixin.get_write_buffer_limitsc C s | d k r+ | d k r! d } n
d | } | d k rA | d } | | k oX d k n ss t d | | f | | _ | | _ d S)N@ i r z*high (%r) must be >= low (%r) must be >= 0i )
ValueErrorr; rB )r
r r r r r
r6 s
z*_FlowControlMixin._set_write_buffer_limitsc C s$ | j d | d | | j d S)Nr r )r6 rA )r
r r r r r
r - s z)_FlowControlMixin.set_write_buffer_limitsc C s
t d S)N)r )r
r r r
r! 1 s z'_FlowControlMixin.get_write_buffer_size)
r r r r rA rC rD r6 r r! r r )r7 r
r2 s r2 N)
Zasyncior __all__r r r r r r r2 r r r r
<module> s #D4