3
2aR' @ s d dl mZ ddddddgZG dd dZG d d deZG d
d deZG d d deeZG d d deZG d
d deZG dd deZ dS ) )compat
BaseTransport
ReadTransportWriteTransport TransportDatagramTransportSubprocessTransportc @ s@ e Zd ZdddZdddZdd Zdd Zd
d Zd d
ZdS )r Nc C s |d kr i }|| _ d S )N)_extra)selfextra r //opt/alt/python36/lib64/python3.6/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)N)N) __name__
__module__ __qualname__r r r r r r r r r r
r
s
c @ s e Zd Zdd Zdd ZdS )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 @ sF e Zd ZdddZdd Zdd Zdd Zd
d Zd d
Zdd Z dS )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)NN)
r r r r r! r# r$ r% r& r' r r r r
r A s
c @ s e Zd ZdS )r N)r r r r r r r
r s c @ s e Zd ZdddZdd ZdS )r Nc C s t d S )N)r )r
r" Zaddrr r r
sendto s zDatagramTransport.sendtoc C s t d S )N)r )r
r r r
r' s zDatagramTransport.abort)N)r r r r( r' r r r r
r s
c @ s< e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
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. r/ r0 r r r r
r s c sR e Zd Zd fdd Zdd Zdd Zdd Zdd
d Zdd d
Zdd Z Z
S )_FlowControlMixinNc s$ 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 sp | j }|| jkrd S | jsld| _y| jj W n: tk
rj } z | jjd|| | jd W Y d d }~X nX d S )NTz protocol.pause_writing() failed)message exception transportr )r! _high_waterr4 _protocolZ
pause_writing Exceptionr3 call_exception_handler)r
sizeexcr r r
_maybe_pause_protocol s
z'_FlowControlMixin._maybe_pause_protocolc C sh | j rd| j | jkrdd| _ y| jj W n: tk
rb } z | jjd|| | jd W Y d d }~X nX d S )NFz protocol.resume_writing() failed)r7 r8 r9 r )r4 r!
_low_waterr; Zresume_writingr< r3 r= )r
r? r r r
_maybe_resume_protocol s z(_FlowControlMixin._maybe_resume_protocolc C s | j | jfS )N)rA r: )r
r r r
get_write_buffer_limits s z)_FlowControlMixin.get_write_buffer_limitsc C sf |d kr |d krd}nd| }|d kr.|d }|| ko@dkn sVt d||f || _|| _d S )N@ i r z*high (%r) must be >= low (%r) must be >= 0i )
ValueErrorr: rA )r
r r r r r
r5 s z*_FlowControlMixin._set_write_buffer_limitsc C s | j ||d | j d S )N)r r )r5 r@ )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)NN)NN)NN) r r r r r@ rB rC r5 r r!
__classcell__r r )r6 r
r1 s
r1 N)
Zasyncior __all__r r r r r r r1 r r r r
s
#D4