f) dZGddZGddeZGddeZGddeeZGd d eZGd d eZGd deZdS)) BaseTransport ReadTransportWriteTransport TransportDatagramTransportSubprocessTransportc<eZdZ dZd dZd dZdZdZdZdZ dS) r_extraNc|i}||_dSNr )selfextras 9/opt/alt/python311/lib64/python3.11/asyncio/transports.py__init__zBaseTransport.__init__s =E c: |j||Sr )r get)r namedefaults rget_extra_infozBaseTransport.get_extra_infos1{tW---rc tr NotImplementedErrorr s r is_closingzBaseTransport.is_closings @!!rc tr rrs rclosezBaseTransport.close "!rc tr r)r protocols r set_protocolzBaseTransport.set_protocol%s !!!rc tr rrs r get_protocolzBaseTransport.get_protocol)s *!!rr ) __name__ __module__ __qualname__ __slots__rrrrr!r#rrrr s$I ....""""""""""""""rrc&eZdZ dZdZdZdZdS)rr(c tr rrs r is_readingzReadTransport.is_reading3s 8!!rc tr rrs r pause_readingzReadTransport.pause_reading7 "!rc tr rrs rresume_readingzReadTransport.resume_reading?r.rN)r$r%r&r'r+r-r0r(rrrr.sI-I"""""""""""rrcFeZdZ dZd dZdZdZdZdZdZ d Z d Z dS) rr(Nc tr rr highlows rset_write_buffer_limitsz&WriteTransport.set_write_buffer_limitsMs $"!rc tr rrs rget_write_buffer_sizez$WriteTransport.get_write_buffer_sizebs :!!rc tr rrs rget_write_buffer_limitsz&WriteTransport.get_write_buffer_limitsfs %"!rc tr r)r datas rwritezWriteTransport.writelr.rc\ d|}||dS)Nr)joinr=)r list_of_datar<s r writelineszWriteTransport.writelinests2 xx %% 4rc tr rrs r write_eofzWriteTransport.write_eof} "!rc tr rrs r can_write_eofzWriteTransport.can_write_eofs O!!rc tr rrs rabortzWriteTransport.abortrDrNN) r$r%r&r'r6r8r:r=rArCrFrHr(rrrrHs.I""""*"""""" """"""""""""""rrceZdZ dZdS)rr(N)r$r%r&r'r(rrrrs(IIIrrc"eZdZ dZddZdZdS)rr(Nc tr r)r r<addrs rsendtozDatagramTransport.sendtorrc tr rrs rrHzDatagramTransport.abortrDrr )r$r%r&r'rNrHr(rrrrs?2I"""""""""rrc6eZdZdZdZdZdZdZdZdZ dS) rr(c tr rrs rget_pidzSubprocessTransport.get_pids  !!rc tr rrs rget_returncodez"SubprocessTransport.get_returncoder.rc tr r)r fds rget_pipe_transportz&SubprocessTransport.get_pipe_transports 4!!rc tr r)r signals r send_signalzSubprocessTransport.send_signalr.rc tr rrs r terminatezSubprocessTransport.terminates "!rc tr rrs rkillzSubprocessTransport.kills "!rN) r$r%r&r'rRrTrWrZr\r^r(rrrrssI"""""""""""" " " " " " " " "rrcNeZdZ dZd fd ZdZdZdZd dZd dZ d Z xZ S) _FlowControlMixin)_loop_protocol_paused _high_water _low_waterNct|||_d|_|dS)NF)superrrarb_set_write_buffer_limits)r rloop __class__s rrz_FlowControlMixin.__init__sB  % %%'''''rc6|}||jkrdS|jspd|_ |jdS#t t f$rt$r/}|j d|||jdYd}~dSd}~wwxYwdS)NTzprotocol.pause_writing() failedmessage exception transportr ) r8rcrb _protocol pause_writing SystemExitKeyboardInterrupt BaseExceptionracall_exception_handler)r sizeexcs r_maybe_pause_protocolz'_FlowControlMixin._maybe_pause_protocols))++ 4# # # F$ $(D ! ,,..... 12        11@!$!% $ 33   sA B'$BBc2|jr||jkrrd|_ |jdS#t t f$rt$r/}|j d|||jdYd}~dSd}~wwxYwdSdS)NFz protocol.resume_writing() failedrk) rbr8rdroresume_writingrqrrrsrart)r rvs r_maybe_resume_protocolz(_FlowControlMixin._maybe_resume_protocol's  ! **,,??$)D ! --///// 12        11A!$!% $ 33   ??sAB#$B  Bc|j|jfSr )rdrcrs rr:z)_FlowControlMixin.get_write_buffer_limits7s!122rc| |d}nd|z}||dz}||cxkrdksntd|d|d||_||_dS)Nizhigh (z) must be >= low (z) must be >= 0) ValueErrorrcrdr3s rrgz*_FlowControlMixin._set_write_buffer_limits:s <{ 3w ;!)CsaHHH3HHHJJ J rc\||||dS)N)r4r5)rgrwr3s rr6z)_FlowControlMixin.set_write_buffer_limitsJs3 %%4S%999 ""$$$$$rctr rrs rr8z'_FlowControlMixin.get_write_buffer_sizeNs!!rrI) r$r%r&r'rrwrzr:rgr6r8 __classcell__)ris@rr`r`s KI(((((($ 333 %%%%"""""""rr`N)__all__rrrrrrr`r(rrrsT  """"""""""""""""J"""""M"""4I"I"I"I"I"]I"I"I"X ~0""""" """23"3"3"3"3"-3"3"3"lT"T"T"T"T" T"T"T"T"T"r