+ j&Rt^RIHt^RIHt^RIHt^RIHt]!]P4!RR]P 44t R#)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)logca]tRt^toRt]!4tRtRRltV3RlRlt V3RlRlt Rt R t R t R tR tR tRtRtRtRtRtRtRtRtRtRtRtRtV3RltRtVtR#) 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} NcT;'gRVnVPVnT;'gRVnW0nW@n^VnWPnW`nWpnRVn RVn .Vn ^Vn ^Vn ^VnRVnR#)iiN)localWindowSizelocalWindowLeftlocalMaxPacketremoteWindowLeftremoteMaxPacket areWritingconndataavatar specificDatabufextBufclosing localClosed remoteClosedid)self localWindowr remoteWindowrrrrs&&&&&&&&;/usr/lib/python3/dist-packages/twisted/conch/ssh/channel.py__init__SSHChannel.__init__9s +44f#33,55 ,.     r c <V^8dQhRS[/#return)str)format __classdict__s"r __annotate__SSHChannel.__annotate__Ts000r c@VP4PR4#)ascii) __bytes__decoders&r__str__SSHChannel.__str__Ts~~&&w//r c <V^8dQhRS[/#r!bytes)r%r&s"rr'r(Ws   5  r c nVPpV'gRpRVVPVP3,#)z4 Return a byte string representation of the channel sNones)namer r )rr4s& rr+SSHChannel.__bytes__Ws<yyD/    ! !3   r cVPRJ;'d\VP4;'gRpVP'dVPPR4pMRpRV RV RVPP 4 2#)Nunknownr*Nonez SSHChannel z (z) on )rr$r4r,r logPrefix)rrr4s& rr9SSHChannel.logPrefixesqggT!22c$''l @ @y 99999##G,DDTF"RDdii.A.A.C-DEEr c <VPPR4R#)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 c @VPPRVR7R#)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)r=error)rrBs&&r openFailedSSHChannel.openFailedvs CFSr c VPV,VnVP'g*VP'gRVnVP4VP'd%VPpRVnVP V4VP 'd2VP p.VnVFwr1VPW14K R#R#)zt Called when bytes are added to the remote window. By default it clears the data buffers. @type data: L{bytes} Tr N)r rr startWritingrwriter writeExtended)rrbtypes&& raddWindowBytesSSHChannel.addWindowBytess!% 5 5 <t|||"DO     888ADH JJqM ;;; ADK ""4.  r c VPRR4PR4p\VRV,R4pV'd V!V4#VPP RVR7^#)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}) requestType)replacer,getattrr=r>)rrRrfoofs&&& rrequestReceivedSSHChannel.requestReceivedsX!!$-44W= D*s*D 1 T7N <+Vr c @VPPRVR7R#)z4 Called when we receive data. @type data: L{bytes} zgot data {data})rNr=debugrrs&&r dataReceivedSSHChannel.dataReceiveds )5r c @VPPRWR7R#)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})dataTyperNrZrr`rs&&&r extReceivedSSHChannel.extReceiveds  3h  r c <VPPR4R#)z4 Called when the other side will send no more data. z remote eofNr<r-s&r eofReceivedSSHChannel.eofReceiveds |$r c \VPPR4VP4R#)z4 Called when the other side has closed the channel. z remote closeN)r=r>loseConnectionr-s&r closeReceivedSSHChannel.closeReceiveds  ~& r c <VPPR4R#)zp Called when the channel is closed. This means that both our side and the remote side have closed the channel. closedNr<r-s&rrlSSHChannel.closeds x r c RVP'dV;PV, unR#\V4pW P8dFVRVPWPRuqn^VnVP 4VPpVP pVP Pp\^W#4pVFpV!WWfV,4K V;PV,unVP'd'VP'gVP4R#R#R#)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} N) rlenr r stopWritingrrsendDatarangerrh)rrtoprmprHroffsets&& rrHSSHChannel.writes 888 HH H $i && &,t,,-**,- D( DO    ''C"" "" !S F $Vsl3 4 $ <<<    !!)R>R7S T,,./D  ! !T%9%9 9 !  II & &tt <  ! !SY . ! <<<    ! r c FVPRPV44R#)zj Part of the Transport interface. Write a list of strings to the channel. @type data: C{list} of L{str} r N)rHjoinr\s&&r writeSequenceSSHChannel.writeSequence s 388D>"r c ^VnVP'g2VP'gVPP V4R#R#R#)zZ Close the channel if there is no buferred data. Otherwise, note the request and return. N)rrrr sendCloser-s&rrhSSHChannel.loseConnections5  xxx II   %!,xr c JVPPP4#)zm See: L{ITransport.getPeer} @return: The remote address of this connection. @rtype: L{SSHTransportAddress}. )r transportgetPeerr-s&rrSSHChannel.getPeeryy""**,,r c JVPPP4#)zy See: L{ITransport.getHost} @return: An address describing this side of the connection. @rtype: L{SSHTransportAddress}. )rrgetHostr-s&rrSSHChannel.getHost%rr c R#)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&rrpSSHChannel.stopWriting.r c R#)zM Called when the remote buffer has more room, as a hint to continue writing. Nrr-s&rrGSSHChannel.startWriting4rr c&<V^8dQh/S[;R&#)r"r4r1)r%r&s"rr'r(sF Gr )rrrrrrrrrr r r rrr r)rrrNNN) __name__ __module__ __qualname____firstlineno____doc__rr=r4rr.r+r9r?rDrLrWr]rbrerirlrHrIrrhrrrprG__annotate_func____static_attributes____classdictcell__)r&s@rrrs@ 8DD600   F'T/*$6  % !":"@#&--  A r rN) rzope.interfacertwisted.internetrtwisted.loggerrtwisted.pythonr ITransportrrr rrsE ''! Z " "#c c $c r