+ Dfj]Rt^RIHtHt^RIHt^RIHt^RIH t ^RI H t ^RI H t ^RIHt^RIHt!R R ] P$4t!R R ] P(4tR RltR#)z@ Protocol wrapper that provides HAProxy PROXY protocol support. )OptionalUnion) interfaces)_WrapperServerEndpoint)policies)_info)InvalidProxyHeader)V1Parser)V2Parsercxaa]tRt^toRtV3RlV3RlltV3RlRltV3RlRltV3RlR ltR t Vt V;t #) HAProxyProtocolWrapperz A Protocol wrapper that provides HAProxy support. This protocol reads the PROXY stream header, v1 or v2, parses the provided connection data, and modifies the behavior of getPeer and getHost to return the data provided by the PROXY header. cN<V^8dQhRS[PRS[P/#)factorywrappedProtocol)rWrappingFactoryr IProtocol)format __classdict__s"D/usr/lib/python3/dist-packages/twisted/protocols/haproxy/_wrapper.py __annotate__#HAProxyProtocolWrapper.__annotate__s)==//=BLBVBV=cB<\SV`W4RVnRVnR#N)super__init__ _proxyInfo_parser)selfrr __class__s&&&rrHAProxyProtocolWrapper.__init__s  2598< rc$<V^8dQhRS[RR/#)rdatareturnN)bytes)rrs"rrr$s"""4"rcVPeVPPV4#VPpVf\ V4^8dMVR,\ P 8Xd1\VR,4^,^ 8Xd\ 4;VnpMP\ V4^8d/VR,\P8Xd\4;VnpMVP4R#VPV4wVnpV'dVPPV4R#R# \dTP4R#i;i)N:N N:r' N:NN) rr dataReceivedrlenr PREFIXordr PROXYSTRloseConnectionfeedr)rr#parser remainings&& rr*#HAProxyProtocolWrapper.dataReceived$s ?? &''44T: : >D RI0U $z1T9(0 2 vTaDH0A0A$A(0 2 v##% ")/T): &DOY$$11)<! "    ! "s' D'D''EEc4<V^8dQhRS[P/#rr$rIAddress)rrs"rrr=((,,(rcVP'd3VPP'dVPP#VP'gQhVPP4#r)rsource transportgetPeerrs&rr<HAProxyProtocolWrapper.getPeer=sK ???t555??)) )~~~~~~%%''rc4<V^8dQhRS[P/#r5r6)rrs"rrrCr8rcVP'd3VPP'dVPP#VP'gQhVPP4#r)r destinationr;getHostr=s&rrBHAProxyProtocolWrapper.getHostCsK ???t:::??.. .~~~~~~%%''r)rr) __name__ __module__ __qualname____firstlineno____doc__rr*r<rB__static_attributes____classdictcell__ __classcell__)r rs@@rr r s7==""2(( (((rr c:a]tRt^JtoRt]tV3RlRltRtVt R#)HAProxyWrappingFactoryzD A Factory wrapper that adds PROXY protocol support to connections. c <V^8dQhRS[/#r5)str)rrs"rr#HAProxyWrappingFactory.__annotate__Qs & &3 &rc \PPVP4'dVPP 4pM VPP P pV R2#)zs Annotate the wrapped factory's log prefix with some text indicating the PROXY protocol is in use. @rtype: C{str} z (PROXY))rILoggingContext providedBywrappedFactory logPrefixr rD)rrUs& rrU HAProxyWrappingFactory.logPrefixQsY  % % 0 01D1D E E++557I++55>>IH%%rN) rDrErFrGrHr protocolrUrIrJ)rs@rrMrMJs&H & &rrMcDV^8dQhR\PR\/#)rwrappedEndpointr$)rIStreamServerEndpointr)rs"rrr_s&KK55KKrc"\V\4#)a Wrap an endpoint with PROXY protocol support, so that the transport's C{getHost} and C{getPeer} methods reflect the attributes of the proxied connection rather than the underlying connection. @param wrappedEndpoint: The underlying listening endpoint. @type wrappedEndpoint: L{IStreamServerEndpoint} @return: a new listening endpoint that speaks the PROXY protocol. @rtype: L{IStreamServerEndpoint} )rrM)rZs&r proxyEndpointr]_s "/3I JJrN)rHtypingrrtwisted.internetrtwisted.internet.endpointsrtwisted.protocolsrr _exceptionsr _v1parserr _v2parserr ProtocolWrapperr rrMr]rWrrrgsO #'=&+3(X553(l&X55&*Kr