+ j <Rt^RIt^RIHtHt^RIHtHt^RIH t H t !RR]P4t !RR]P4t!R R ]4t!R R ]4t!R R]P4tRt!RR]P&4tRt]tRt]tRtRtR#)z This module contains the implementation of the TCP forwarding, which allows clients and servers to forward arbitrary TCP data across the connection. Maintainer: Paul Swartz N)channelcommon)protocolreactor)HostnameEndpointconnectProtocolc,a]tRt^toRtRtRtVtR#)SSHListenForwardingFactoryc*WnW nW0nR#Nconnhostportklass)self connectionrrs&&&&>/usr/lib/python3/dist-packages/twisted/conch/ssh/forwarding.py__init__#SSHListenForwardingFactory.__init__s   cVPVPR7p\V4pW2nVPVP 3p\ VPV4pVPPW%4V#))r ) rr SSHForwardingClientclienthostportpackOpen_direct_tcpipr openChannel)raddrrr addrTuplechannelOpenDatas&& r buildProtocol(SSHListenForwardingFactory.buildProtocols^**$))*,$W-YY * / yI g7 rr N)__name__ __module__ __qualname____firstlineno__rr __static_attributes____classdictcell__ __classdict__s@rr r s rr c>a]tRt^#toRtRtRtRtRtRt Vt R#)SSHListenForwardingChannelcVPPRVPR7\VPP 4^8d/VPP R,pVP V4RVPnR#)zopened forwarding channel {id}idNNrN)_loginfor.lenrbufwrite)r specificDatabs&& r channelOpen&SSHListenForwardingChannel.channelOpen$sX 7DGGD t{{ ! # #A JJqM rc&VP4R#r )closedrreasons&&r openFailed%SSHListenForwardingChannel.openFailed+s  rcPVPPPV4R#r )r transportr5rdatas&&r dataReceived'SSHListenForwardingChannel.dataReceived.s ##D)rcNVPPP4R#r )rrAloseConnectionrs&r eofReceived&SSHListenForwardingChannel.eofReceived1s ,,.rc\VR4'dPVPPRVPR7VPP P 4V=R#R#)rz%closing local forwarding channel {id}r-N)hasattrr1r2r.rrArGrHs&rr;!SSHListenForwardingChannel.closed4sH 4 " " IINNBtwwN O KK ! ! 0 0 2  #rN) r"r#r$r%r8r>rDrIr;r&r'r(s@rr+r+#s#*/rr+c]tRt^;tRtRtR#) SSHListenClientForwardingChannels direct-tcpiprNNr"r#r$r%namer&rNrrrPrP;s DrrPc]tRt^?tRtRtR#) SSHListenServerForwardingChannelsforwarded-tcpiprNNrQrNrrrTrT?s DrrTcLa]tRt^CtoRt]tRtRtRt Rt Rt Rt Rt VtR #) SSHConnectForwardingChannela Channel used for handling server side forwarding request. It acts as a client for the remote forwarding destination. @ivar hostport: C{(host, port)} requested by client as forwarding destination. @type hostport: L{tuple} or a C{sequence} @ivar client: Protocol connected to the forwarding destination. @type client: L{protocol.Protocol} @ivar clientBuf: Data received while forwarding channel is not yet connected. @type clientBuf: L{bytes} @var _reactor: Reactor used for TCP connections. @type _reactor: A reactor. @ivar _channelOpenDeferred: Deferred used in testing to check the result of C{channelOpen}. @type _channelOpenDeferred: L{twisted.internet.defer.Deferred} cv\PP!V.VO5/VBWnRVnRVnR#)Nr)r SSHChannelrrr clientBuf)rrargskws&&*,rr$SSHConnectForwardingChannel.__init__]s3##D64626  rc zVPPRVP^,VP^,R7\VPVP^,VP^,4p\ V\ V44pVPVPVP4W0n R#) See: L{channel.SSHChannel} zconnecting to {host}:{port}rrN) r1r2rr_reactorrr addCallbacks _setClient_close_channelOpenDeferred)rr6epds&& rr8'SSHConnectForwardingChannel.channelOpencs  ) a0@t}}UVGW  dmmT]]1-=t}}Q?O P B 3D 9 : t 4$%!rc WnVPPRVP^,VP^,R7VP'd7VPP P VP4RVnVPPR,'d-VP VPPR,4RVPnR#)z Called when the connection was established to the forwarding destination. @param client: Client protocol connected to the forwarding destination. @type client: L{protocol.Protocol} zconnected to {host}:{port}r_Nr/r)rr1r2rrYrAr5r4)rrs&&rrb&SSHConnectForwardingChannel._setClientos   (t}}Q/?dmmTUFV   >>> KK ! ! ' ' 7!DN ;;??2   JJt{{r* + rc VPPRVP^,VP^,VR7VP4R#)z Called when failed to connect to the forwarding destination. @param reason: Reason why connection failed. @type reason: L{twisted.python.failure.Failure} z,failed to connect to {host}:{port}: {reason})rrr=N)r1errorrrGr<s&&rrc"SSHConnectForwardingChannel._closesE  :q!q!  rc VP'd(VPPPV4R#V;PV, unR#)r^N)rrAr5rYrBs&&rrD(SSHConnectForwardingChannel.dataReceiveds3 ;;; KK ! ! ' ' - NNd "Nrc VP'd|VPPRVPR7VPP'dVP 4VPP P 4V=R#R#)r^z%closed remote forwarding channel {id}r-N)rr1r2r.rrGrArHs&rr;"SSHConnectForwardingChannel.closedsb ;;; IINNBtwwN O{{"""##% KK ! ! 0 0 2 r)rdrrYrN)r"r#r$r%__doc__rr`rr8rbrcrDr;r&r'r(s@rrVrVCs4.H && #  rrVc:\V4wrE\VVVVR7#)) remoteWindowremoteMaxPacketavatar)unpackOpen_direct_tcpiprV)rsrtrCruremoteHPorigHPs&&&& ropenConnectForwardingClientrys(.t4H &!'  rc2a]tRt^toRtRtRtRtVtR#)rc WnRVnR#)N)rr4)rrs&&rrSSHForwardingClient.__init__s rcVP'dV;PV, unR#VPPV4R#r )r4rr5rBs&&rrD SSHForwardingClient.dataReceiveds+ 888 HH H LL  t $rcpVP'd$VPP4RVnR#R#r )rrGr<s&&rconnectionLost"SSHForwardingClient.connectionLosts' <<< LL ' ' )DL r)r4rN) r"r#r$r%rrDrr&r'r(s@rrrs%   rrcVwr#VwrE\V\4'dVPR4p\V\4'dVPR4p\P!V4\ P !RV4,p\P!V4\ P !RV4,pWg,#)z Pack the data suitable for sending in a CHANNEL_OPEN packet. @type destination: L{tuple} @param destination: A tuple of the (host, port) of the destination host. @type source: L{tuple} @param source: A tuple of the (host, port) of the source host. utf-8>L) isinstancestrencoderNSstructpack) destinationsourceconnHostconnPortorigHostorigPortr origs&& rrrs'X!X(C  ??7+(C  ??7+ 99X T8!< rs-.H !1!1  !3!30'A'A`'"4"4`F (++ "*1 655r