U
,a( @ sx d Z G dd dZG dd deZG dd deZG dd deeZG d d
d
eZG d d d eZG d
d deZdS ))
BaseTransport
ReadTransportWriteTransport TransportDatagramTransportSubprocessTransportc @ sD e Zd ZdZdddZdddZdd Zd d
Zd d Zd
d Z dS )r _extraNc C s |d kr i }|| _ d S Nr )selfextra r 7/opt/alt/python38/lib64/python3.8/asyncio/transports.py__init__ s zBaseTransport.__init__c C s | j ||S r )r get)r
namedefaultr r r
get_extra_info s z BaseTransport.get_extra_infoc C s t d S r NotImplementedErrorr
r r r
is_closing s zBaseTransport.is_closingc C s t d S r r r r r r
close s zBaseTransport.closec C s t d S r r )r
protocolr r r
set_protocol% s zBaseTransport.set_protocolc C s t d S r r r r r r
get_protocol) s zBaseTransport.get_protocol)N)N)
__name__
__module__ __qualname__ __slots__r r r r r r r r r r
r s
r c @ s( e Zd ZdZdd Zdd Zdd ZdS ) r r c C s t d S r r r r r r
is_reading3 s zReadTransport.is_readingc C s t d S r r r r r r
pause_reading7 s zReadTransport.pause_readingc C s t d S r r r r r r
resume_reading? s z ReadTransport.resume_readingN)r r r r r r r! r r r r
r . s r c @ sJ e Zd ZdZdddZdd Zdd Zd d
Zd d Zd
d Z dd Z
dS )r r Nc C s t d S r r r
highlowr r r
set_write_buffer_limitsM s z&WriteTransport.set_write_buffer_limitsc C s t d S r r r r r r
get_write_buffer_sizeb s z$WriteTransport.get_write_buffer_sizec C s t d S r r )r
datar r r
writef s zWriteTransport.writec C s d |}| | d S )N )joinr( )r
Z list_of_datar' r r r
writelinesn s
zWriteTransport.writelinesc C s t d S r r r r r r
write_eofw s zWriteTransport.write_eofc C s t d S r r r r r r
can_write_eof s z WriteTransport.can_write_eofc C s t d S r 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
r H s
r c @ s e Zd ZdZdS )r r N)r r r r r r r r
r s r c @ s" e Zd ZdZdddZdd ZdS )r r Nc C s t d S r r )r
r' Zaddrr r r
sendto s zDatagramTransport.sendtoc C s t d S r r r r r r
r. s zDatagramTransport.abort)N)r r r r r/ r. r r r r
r s
r c @ s@ e Zd ZdZdd Zdd Zdd Zdd Zd
d Zd d
Z dS )r r c C s t d S r r r r r r
get_pid s zSubprocessTransport.get_pidc C s t d S r r r r r r
get_returncode s z"SubprocessTransport.get_returncodec C s t d S r r )r
fdr r r
get_pipe_transport s z&SubprocessTransport.get_pipe_transportc C s t d S r r )r
signalr r r
send_signal s z SubprocessTransport.send_signalc C s t d S r r r r r r
terminate s z SubprocessTransport.terminatec C s t d S r r r r r r
kill s zSubprocessTransport.killN)
r r r r r0 r1 r3 r5 r6 r7 r r r r
r s r c sV e Zd ZdZd fdd Zdd Zdd Zd d
Zdd d Zdd
dZ dd Z
Z S )_FlowControlMixin)_loop_protocol_paused _high_water
_low_waterNc s$ t | || _d| _| d S )NF)superr r9 r: _set_write_buffer_limits)r
r Zloop __class__r r
r s z_FlowControlMixin.__init__c
C s | }|| jkrd S | jsd| _z| j W nR ttfk
rJ Y n: tk
r } z | j d|| | jd W 5 d }~X Y nX d S )NTz protocol.pause_writing() failedmessageZ exceptionZ transportr )
r& r; r: _protocolZ
pause_writing
SystemExitKeyboardInterrupt
BaseExceptionr9 call_exception_handler)r
sizeexcr r r
_maybe_pause_protocol s
z'_FlowControlMixin._maybe_pause_protocolc
C s | j r|| | jkr|d| _ z| j W nR ttfk
rB Y n: tk
rz } z | j d|| | jd W 5 d }~X Y nX d S )NFz protocol.resume_writing() failedrA )
r: r& r< rC Zresume_writingrD rE rF r9 rG )r
rI r r r
_maybe_resume_protocol! s z(_FlowControlMixin._maybe_resume_protocolc C s | j | jfS r )r< r; r r r r
get_write_buffer_limits1 s z)_FlowControlMixin.get_write_buffer_limitsc C sj |d kr |d krd}nd| }|d kr.|d }|| krBdksZn t d|d|d|| _|| _d S )Ni zhigh (z) must be >= low (z) must be >= 0)
ValueErrorr; r< r" r r r
r> 4 s z*_FlowControlMixin._set_write_buffer_limitsc C s | j ||d | d S )N)r# r$ )r> rJ r" r r r
r% D s z)_FlowControlMixin.set_write_buffer_limitsc C s t d S r r r r r r
r& H s z'_FlowControlMixin.get_write_buffer_size)NN)NN)NN) r r r r r rJ rK rL r> r% r&
__classcell__r r r? r
r8 s
r8 N)__all__r r r r r r r8 r r r r