h&SrSSKJr SSKJr SSKJr SSKJr \"\R5"SS\R 55r g) z The parent class for all the SSH Channels. Currently implemented channels are session, direct-tcp, and forwarded-tcp. Maintainer: Paul Swartz ) implementer) interfaces)Logger)logc\rSrSr%Sr\"5rSr\\ S'SSjr S\ 4Sjr S\4Sjr S rS rS rS rS rSrSrSrSrSrSrSrSrSrSrSrSrSrSr g) SSHChannelaF A class that represents a multiplexed channel over an SSH connection. The channel has a local window which is the maximum amount of data it will receive, and a remote which is the maximum amount of data the remote side will accept. There is also a maximum packet size for any individual data packet going each way. @ivar name: the name of the channel. @type name: L{bytes} @ivar localWindowSize: the maximum size of the local window in bytes. @type localWindowSize: L{int} @ivar localWindowLeft: how many bytes are left in the local window. @type localWindowLeft: L{int} @ivar localMaxPacket: the maximum size of packet we will accept in bytes. @type localMaxPacket: L{int} @ivar remoteWindowLeft: how many bytes are left in the remote window. @type remoteWindowLeft: L{int} @ivar remoteMaxPacket: the maximum size of a packet the remote side will accept in bytes. @type remoteMaxPacket: L{int} @ivar conn: the connection this channel is multiplexed through. @type conn: L{SSHConnection} @ivar data: any data to send to the other side when the channel is requested. @type data: L{bytes} @ivar avatar: an avatar for the logged-in user (if a server channel) @ivar localClosed: True if we aren't accepting more data. @type localClosed: L{bool} @ivar remoteClosed: True if the other side isn't accepting more data. @type remoteClosed: L{bool} NnamecU=(d SUlURUlU=(d SUlX0lX@lSUlXPlX`lXplSUl SUl /Ul SUl SUl SUlSUlg)Niir)localWindowSizelocalWindowLeftlocalMaxPacketremoteWindowLeftremoteMaxPacket areWritingconndataavatar specificDatabufextBufclosing localClosed remoteClosedid)self localWindowr remoteWindowrrrrs `/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/conch/ssh/channel.py__init__SSHChannel.__init__9s +4f#33,5 ,.     r returnc@UR5RS5$)Nascii) __bytes__decoders r!__str__SSHChannel.__str__Ts~~&&w//r cdURnU(dSnSUURUR4-$)z4 Return a byte string representation of the channel sNones)r rr)rr s r!r'SSHChannel.__bytes__Ws<yyD/    ! !3   r c URSL=(a [UR5=(d SnUR(aURRS5nOSnSUSUSURR 53$)Nunknownr&Nonez SSHChannel z (z) on )rstrr r(r logPrefix)rrr s r!r2SSHChannel.logPrefixesiggT!2c$''l @y 9999##G,DDTF"RDdii.A.A.C-DEEr c:URRS5 g)z Called when the channel is opened. specificData is any data that the other side sent us when opening the channel. @type specificData: L{bytes} z channel openN_loginfo)rrs r! channelOpenSSHChannel.channelOpenms ~&r c8URRSUS9 g)z Called when the open failed for some reason. reason.desc is a string descrption, reason.code the SSH error code. @type reason: L{error.ConchError} z(other side refused open reason: {reason})reasonN)r6error)rr;s r! openFailedSSHChannel.openFailedvs CFSr cURU-UlUR(d(UR(dSUlUR5 UR(a$URnSUlUR U5 UR (a0UR n/UlUHup1URX15 M gg)zt Called when bytes are added to the remote window. By default it clears the data buffers. @type data: L{bytes} Tr N)rrr startWritingrwriter writeExtended)rrbtypes r!addWindowBytesSSHChannel.addWindowBytess!% 5 5 <t||"DO     88ADH JJqM ;; ADK ""4.  r cURSS5RS5n[USU-S5nU(aU"U5$URR SUS9 g) a  Called when a request is sent to this channel. By default it delegates to self.request_. If this function returns true, the request succeeded, otherwise it failed. @type requestType: L{bytes} @type data: L{bytes} @rtype: L{bool} -_r&request_Nz#unhandled request for {requestType}) requestTyper)replacer(getattrr6r7)rrKrfoofs r!requestReceivedSSHChannel.requestReceivedsX!!$-44W= D*s*D 1 T7N <+Vr c8URRSUS9 g)z4 Called when we receive data. @type data: L{bytes} zgot data {data})rNr6debugrrs r! dataReceivedSSHChannel.dataReceiveds )5r c8URRSXS9 g)zo Called when we receive extended data (usually standard error). @type dataType: L{int} @type data: L{str} z%got extended data {dataType} {data!r})dataTyperNrSrrYrs r! extReceivedSSHChannel.extReceiveds  3h  r c:URRS5 g)z4 Called when the other side will send no more data. z remote eofNr5r)s r! eofReceivedSSHChannel.eofReceiveds |$r cZURRS5 UR5 g)z4 Called when the other side has closed the channel. z remote closeN)r6r7loseConnectionr)s r! closeReceivedSSHChannel.closeReceiveds  ~& r c:URRS5 g)zp Called when the channel is closed. This means that both our side and the remote side have closed the channel. closedNr5r)s r!reSSHChannel.closeds x r c*UR(aU=RU- slg[U5nX R:aEUSURXRSsolSUlUR 5 URnUR nUR Rn[SX#5nUHnU"XXfU-5 M U=RU-slUR(a#UR(dUR5 ggg)z Write some data to the channel. If there is not enough remote window available, buffer until it is. Otherwise, split the data into packets of length remoteMaxPacket and send them. @type data: L{bytes} Nr) rlenrr stopWritingrrsendDatarangerra)rrtoprmprAroffsets r!rASSHChannel.writes 88 HH H $i && &,t,,-**,- D( DO    ''C"" "" !S F $Vsl3 4 $ <<    !!)R>R7S T,,./D  ! !T%9%9 9 !$i$...  II & &tt <  ! !SY . ! <<    ! r cDURSRU55 g)zj Part of the Transport interface. Write a list of strings to the channel. @type data: C{list} of L{str} r N)rAjoinrUs r! writeSequenceSSHChannel.writeSequence s 388D>"r cSUlUR(d.UR(dURR U5 ggg)zZ Close the channel if there is no buferred data. Otherwise, note the request and return. r N)rrrr sendCloser)s r!raSSHChannel.loseConnections1  xx II   %!,xr cJURRR5$)zm See: L{ITransport.getPeer} @return: The remote address of this connection. @rtype: L{SSHTransportAddress}. )r transportgetPeerr)s r!rSSHChannel.getPeeryy""**,,r cJURRR5$)zy See: L{ITransport.getHost} @return: An address describing this side of the connection. @rtype: L{SSHTransportAddress}. )rr~getHostr)s r!rSSHChannel.getHost%rr cg)zo Called when the remote buffer is full, as a hint to stop writing. This can be ignored, but it can be helpful. Nr)s r!riSSHChannel.stopWriting.r cg)zM Called when the remote buffer has more room, as a hint to continue writing. Nrr)s r!r@SSHChannel.startWriting4rr )rrrrrrrrrrrrrrrr)rrrrNNN)!__name__ __module__ __qualname____firstlineno____doc__rr6r bytes__annotations__r"r1r*r'r2r8r=rErPrVr[r^rbrerArBrxrarrrir@__static_attributes__rr r!rrs@ 8DD%  600  5  F'T/*$6  % !":"@#&--  r rN) rzope.interfacertwisted.internetrtwisted.loggerrtwisted.pythonr ITransportrrr r!rsE ''! Z " "#c c $c r