<1DM d Z G d d Z G d de Z G d de Z G d dee Z G d d
e Z G d d e Z G d
de ZdS ))
BaseTransport
ReadTransportWriteTransport TransportDatagramTransportSubprocessTransportc < e Zd Z dZd dZd dZd Zd Zd Zd Z dS )
r _extraNc |i }|| _ d S Nr )selfextras 9/opt/alt/python311/lib64/python3.11/asyncio/transports.py__init__zBaseTransport.__init__ s =E c : | j || S r )r
get)r
namedefaults r get_extra_infoz BaseTransport.get_extra_info s 1{tW---r c t r NotImplementedErrorr
s r
is_closingzBaseTransport.is_closing s @!!r c t r r r s r closezBaseTransport.close "!r c t r r )r
protocols r set_protocolzBaseTransport.set_protocol% s !!!r c t r r r s r get_protocolzBaseTransport.get_protocol) s *!!r r )
__name__
__module__ __qualname__ __slots__r r r r r! r# r r r r s $I
. . . ." " "" " "" " "" " " " "r r c & e Zd Z dZd Zd Zd ZdS )r r( c t r r r s r
is_readingzReadTransport.is_reading3 s 8!!r c t r r r s r
pause_readingzReadTransport.pause_reading7
"!r c t r r r s r resume_readingz ReadTransport.resume_reading? r. r N)r$ r% r& r' r+ r- r0 r( r r r r . sI -I" " "" " "" " " " "r r c F e Zd Z dZd dZd Zd Zd Zd Zd Z d Z
d
Z dS ) r r( Nc t r r r
highlows r set_write_buffer_limitsz&WriteTransport.set_write_buffer_limitsM s $ "!r c t r r r s r get_write_buffer_sizez$WriteTransport.get_write_buffer_sizeb s :!!r c t r r r s r get_write_buffer_limitsz&WriteTransport.get_write_buffer_limitsf s % "!r c t r r )r
datas r writezWriteTransport.writel r. r c \ d | }| | d S )Nr )joinr= )r
list_of_datar< s r
writelineszWriteTransport.writelinest s2
xx %%
4r c t r r r s r write_eofzWriteTransport.write_eof} "!r c t r r r s r
can_write_eofz WriteTransport.can_write_eof s O!!r c t r r r s r abortzWriteTransport.abort rD r NN) r$ r% r& r' r6 r8 r: r= rA rC rF rH r( r r r r H s .I" " " "*" " "" " " " " " " " "" " "" " " " "r r c e Zd Z dZdS )r r( N)r$ r% r& r' r( r r r r s ( IIIr r c " e Zd Z dZddZd ZdS )r r( Nc t r r )r
r< addrs r sendtozDatagramTransport.sendto r r c t r r r s r rH zDatagramTransport.abort rD r r )r$ r% r& r' rN rH r( r r r r s? 2I" " " "" " " " "r r c 6 e Zd ZdZd Zd Zd Zd Zd Zd Z dS ) r r( c t r r r s r get_pidzSubprocessTransport.get_pid s !!r c t r r r s r get_returncodez"SubprocessTransport.get_returncode r. r c t r r )r
fds r get_pipe_transportz&SubprocessTransport.get_pipe_transport s 4!!r c t r r )r
signals r send_signalz SubprocessTransport.send_signal r. r c t r r r s r terminatez SubprocessTransport.terminate s
"!r c t r r r s r killzSubprocessTransport.kill s "!r N)
r$ r% r& r' rR rT rW rZ r\ r^ r( r r r r ss I" " "" " "" " "" " " " " " " " " " "r r c N e Zd Z dZd
fd Zd Zd Zd Zd
dZd
dZ d Z
xZ S ) _FlowControlMixin)_loop_protocol_paused _high_water
_low_waterNc t | || _ d| _ | d S )NF)superr ra rb _set_write_buffer_limits)r
r loop __class__s r r z_FlowControlMixin.__init__ sB
% %%'''''r c 6 | }|| j k rd S | j spd| _ | j d S # t
t f$ r t $ r/}| j d|| | j d Y d }~d S d }~ww xY wd S )NTz protocol.pause_writing() failedmessage exception transportr )
r8 rc rb _protocol
pause_writing
SystemExitKeyboardInterrupt
BaseExceptionra call_exception_handler)r
sizeexcs r _maybe_pause_protocolz'_FlowControlMixin._maybe_pause_protocol s ))++ 4# # # F$ $(D !
,,..... 12
11 @!$!% $ 3 3
s A B'$BBc 2 | j r| | j k rrd| _ | j d S # t
t f$ r t $ r/}| j d|| | j d Y d }~d S d }~ww xY wd S d S )NFz protocol.resume_writing() failedrk )
rb r8 rd ro resume_writingrq rr rs ra rt )r
rv s r _maybe_resume_protocolz(_FlowControlMixin._maybe_resume_protocol' s !
**,,??$)D !
--///// 12
11 A!$!% $ 3 3
??s A B#$B
Bc | j | j fS r )rd rc r s r r: z)_FlowControlMixin.get_write_buffer_limits7 s !122r c |
|d}nd|z }||dz }||cxk rdk sn t d|d|d || _ || _ d S )Ni zhigh (z) must be >= low (z) must be >= 0)
ValueErrorrc rd r3 s r rg z*_FlowControlMixin._set_write_buffer_limits: s <{ 3w ;!)Cs a HHH3HHHJ J
J r c \ | || | d S )N)r4 r5 )rg rw r3 s r r6 z)_FlowControlMixin.set_write_buffer_limitsJ s3 %%4S%999 ""$$$$$r c t r r r s r r8 z'_FlowControlMixin.get_write_buffer_sizeN s !!r rI ) r$ r% r& r' r rw rz r: rg r6 r8
__classcell__)ri s @r r` r` s KI( ( ( ( ( ( $ 3 3 3 % % % %" " " " " " "r r` N)__all__r r r r r r r` r( r r