{|j) 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 Zy))
BaseTransport
ReadTransportWriteTransport TransportDatagramTransportSubprocessTransportc : e Zd Z dZd dZd dZd Zd Zd Zd Z y)
r _extraNc |i }|| _ y Nr )selfextras +/usr/lib64/python3.12/asyncio/transports.py__init__zBaseTransport.__init__ s =E c < | j 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 Zy)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 . s -I"""r r c D e Zd Z dZd dZd Zd Zd Zd Zd Z d Z
d
Z y) 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 J dj | }| j | y )Nr )joinr= )r
list_of_datar< s r
writelineszWriteTransport.writelinest s#
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 s2 .I"*"" """"r r c e Zd Z dZy)r r( N)r$ r% r& r' r( r r r r s ( Ir r c e Zd Z dZddZd Zy)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 4 e Zd ZdZd Zd Zd Zd Zd Zd Z y) 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 s% 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_waterc ` t | | || _ d| _ | j y )NF)superr ra rb _set_write_buffer_limits)r
r loop __class__s r r z_FlowControlMixin.__init__ s+
% %%'r c @ | j }|| j k ry | j s#d| _ | j j y y # t
t f$ r t $ r4}| j j d|| | j d Y d }~y d }~ww xY w)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## # $$$(D !
,,. % 12
11 @!$!% $ 3
s A B )*BB c < | j rA| j | j k r#d| _ | j j y y y # t
t f$ r t $ r4}| j j d|| | j d Y d }~y d }~ww xY w)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
s A B'*BBc 2 | j | j fS r )rd rc r s r r: z)_FlowControlMixin.get_write_buffer_limits7 s !1!122r c |
|d}nd|z }||dz }||cxk\ rdk\ sn t d|d|d || _ || _ y )Ni zhigh (z) must be >= low (z) must be >= 0)
ValueErrorrc rd r3 s r rg z*_FlowControlMixin._set_write_buffer_limits: sh <{ 3w ;!)Cs a 23' HJ
J r c J | j || | j y )N)r4 r5 )rg rw r3 s r r6 z)_FlowControlMixin.set_write_buffer_limitsJ s! %%4S%9 ""$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` s3 KI($ 3 %"r r` N)__all__r r r r r r r` r( r r