+ j.Rt^RIHt^RIHt^RIHt^RIHtRt ] RRRRR3R R llt ] RR R R R3RRllt ] RRRR3RRllt !RR]P4tR#)z7 Test cases for L{twisted.protocols.haproxy.V2Parser}. )address)unittest) _v2parser)InvalidProxyHeaders QUIT !s$s"clV^8dQhR\R\R\R\R\R\R\/#sigverComfamProto addrLengthaddrsportsreturnbytes)formats"N/usr/lib/python3/dist-packages/twisted/protocols/haproxy/test/test_v2parser.py __annotate__rW#@#@ #@ #@#@ #@  #@  #@ #@cJW,V,V,V,V,#)a  Construct a version 2 IPv6 header with custom bytes. @param sig: The protocol signature; defaults to valid L{V2_SIGNATURE}. @type sig: L{bytes} @param verCom: Protocol version and command. Defaults to V2 PROXY. @type verCom: L{bytes} @param famProto: Address family and protocol. Defaults to AF_INET6/STREAM. @type famProto: L{bytes} @param addrLength: Network-endian byte length of payload. Defaults to description of default addrs/ports. @type addrLength: L{bytes} @param addrs: Address payload. Defaults to C{::1} for source and destination. @type addrs: L{bytes} @param ports: Source and destination ports. Defaults to 8080 for source 8888 for destination. @type ports: L{bytes} @return: A packet with header, addresses, and ports. @rtype: L{bytes} r r r r rrs&&&&&&r_makeHeaderIPv6r!F <( "Z /% 7% ??rs sclV^8dQhR\R\R\R\R\R\R\/#rr)rs"rrr6rrcJW,V,V,V,V,#)a  Construct a version 2 IPv4 header with custom bytes. @param sig: The protocol signature; defaults to valid L{V2_SIGNATURE}. @type sig: L{bytes} @param verCom: Protocol version and command. Defaults to V2 PROXY. @type verCom: L{bytes} @param famProto: Address family and protocol. Defaults to AF_INET/STREAM. @type famProto: L{bytes} @param addrLength: Network-endian byte length of payload. Defaults to description of default addrs/ports. @type addrLength: L{bytes} @param addrs: Address payload. Defaults to 127.0.0.1 for source and destination. @type addrs: L{bytes} @param ports: Source and destination ports. Defaults to 8080 for source 8888 for destination. @type ports: L{bytes} @return: A packet with header, addresses, and ports. @rtype: L{bytes} rrs&&&&&&r_makeHeaderIPv4r 6rr1sc `V^8dQhR\R\R\R\R\R\/#)r r r r r rrr)rs"rrr\sD#8#8 #8 #8#8 #8  #8 #8rc<W,V,V,V,#)a Construct a version 2 IPv4 header with custom bytes. @param sig: The protocol signature; defaults to valid L{V2_SIGNATURE}. @type sig: L{bytes} @param verCom: Protocol version and command. Defaults to V2 PROXY. @type verCom: L{bytes} @param famProto: Address family and protocol. Defaults to AF_UNIX/STREAM. @type famProto: L{bytes} @param addrLength: Network-endian byte length of payload. Defaults to 108 bytes for 2 null terminated paths. @type addrLength: L{bytes} @param addrs: Address payload. Defaults to C{/home/tests/mysockets/sock} for source and destination paths. @type addrs: L{bytes} @return: A packet with header, addresses, and8 ports. @rtype: L{bytes} r)r r r r rs&&&&&r_makeHeaderUnixr$\sF <( "Z /% 77rca]tRt^toRtV3RlRltV3RlRltV3RlRltV3RlR ltV3R lR lt V3R lR lt V3RlRlt V3RlRlt V3RlRlt V3RlRltV3RlRltV3RlRltV3RlRltV3RlRltV3RlRltV3R lR!ltV3R"lR#ltV3R$lR%ltV3R&lR'ltV3R(lR)ltV3R*lR+ltV3R,lR-ltV3R.lR/ltV3R0lR1ltR2tVtR3#)4 V2ParserTestsz7 Test L{twisted.protocols.haproxy.V2Parser} behaviour. c<V^8dQhRR/#r rNr)r __classdict__s"rrV2ParserTests.__annotate__::D:rc v\4pVP\PP V44R#)z< Test if a well formed IPv4 header is parsed without error. N)r assertTruerV2Parserparseselfheaders& rtest_happyPathIPv4 V2ParserTests.test_happyPathIPv4)!"  **0089rc<V^8dQhRR/#r(r)rr)s"rrr*r+rc v\4pVP\PP V44R#)z< Test if a well formed IPv6 header is parsed without error. N)rr-rr.r/r0s& rtest_happyPathIPv6 V2ParserTests.test_happyPathIPv6r5rc<V^8dQhRR/#r(r)rr)s"rrr*r+rc v\4pVP\PP V44R#)z< Test if a well formed UNIX header is parsed without error. N)r$r-rr.r/r0s& rtest_happyPathUnix V2ParserTests.test_happyPathUnixr5rc<V^8dQhRR/#r(r)rr)s"rrr*s   t  rc |\RR7pVP\\PP V4R#)z> Test if an invalid signature block raises InvalidProxyError. )r Ns r assertRaisesrrr.r/r0s& rtest_invalidSignature#V2ParserTests.test_invalidSignatures1!\2      $ $  rc<V^8dQhRR/#r(r)rr)s"rrr*   T  rc |\RR7pVP\\PP V4R#)z6 Test if an invalid version raises InvalidProxyError. rr Nr@r0s& rtest_invalidVersion!V2ParserTests.test_invalidVersion1!0      $ $  rc<V^8dQhRR/#r(r)rr)s"rrr*rErc |\RR7pVP\\PP V4R#)z6 Test if an invalid command raises InvalidProxyError. #rGNr@r0s& rtest_invalidCommand!V2ParserTests.test_invalidCommandrJrc<V^8dQhRR/#r(r)rr)s"rrr*s   D  rc |\RR7pVP\\PP V4R#)z5 Test if an invalid family raises InvalidProxyError. @r Nr@r0s& rtest_invalidFamily V2ParserTests.test_invalidFamily1!'2      $ $  rc<V^8dQhRR/#r(r)rr)s"rrr*s   4  rc |\RR7pVP\\PP V4R#)z7 Test if an invalid protocol raises InvalidProxyError. $rSNr@r0s& rtest_invalidProtoV2ParserTests.test_invalidProtorVrc<V^8dQhRR/#r(r)rr)s"rrr*++t+rc \RR7p\PPV4pVP VP 4VP VP 4R#)zE Test that local does not return endpoint data for IPv4 connections.  rGNr rr.r/ assertFalsesource destinationr1r2infos& rtest_localCommandIpv4#V2ParserTests.test_localCommandIpv4J!0!!''/ % ))*rc<V^8dQhRR/#r(r)rr)s"rrr*r]rc \RR7p\PPV4pVP VP 4VP VP 4R#)zE Test that local does not return endpoint data for IPv6 connections. r_rGNrrr.r/rarbrcrds& rtest_localCommandIpv6#V2ParserTests.test_localCommandIpv6rhrc<V^8dQhRR/#r(r)rr)s"rrr*r]rc \RR7p\PPV4pVP VP 4VP VP 4R#)zE Test that local does not return endpoint data for UNIX connections. r_rGNr$rr.r/rarbrcrds& rtest_localCommandUnix#V2ParserTests.test_localCommandUnixrhrc<V^8dQhRR/#r(r)rr)s"rrr* E Et Erc p\RR7p\PPV4pVP VP 4VP VP \P4VP VP4VP VP\P4R#)z= Test that proxy returns endpoint data for IPv4 connections. rrGN) r rr.r/r-rbassertIsInstancer IPv4Addressrcrds& rtest_proxyCommandIpv4#V2ParserTests.test_proxyCommandIpv4|!0!!''/  $ dkk7+>+>? (() d..0C0CDrc<V^8dQhRR/#r(r)rr)s"rrr*rtrc p\RR7p\PPV4pVP VP 4VP VP \P4VP VP4VP VP\P4R#)z= Test that proxy returns endpoint data for IPv6 connections. rrGN) rrr.r/r-rbrvr IPv6Addressrcrds& rtest_proxyCommandIpv6#V2ParserTests.test_proxyCommandIpv6rzrc<V^8dQhRR/#r(r)rr)s"rrr*rtrc p\RR7p\PPV4pVP VP 4VP VP \P4VP VP4VP VP\P4R#)z= Test that proxy returns endpoint data for UNIX connections. rrGN) r$rr.r/r-rbrvr UNIXAddressrcrds& rtest_proxyCommandUnix#V2ParserTests.test_proxyCommandUnixrzrc<V^8dQhRR/#r(r)rr)s"rrr*r]rc \RR7p\PPV4pVP VP 4VP VP 4R#)F Test that UNSPEC does not return endpoint data for IPv4 connections. rSNr`rds& rtest_unspecFamilyIpv4#V2ParserTests.test_unspecFamilyIpv4J!'2!!''/ % ))*rc<V^8dQhRR/#r(r)rr)s"rrr*r]rc \RR7p\PPV4pVP VP 4VP VP 4R#)F Test that UNSPEC does not return endpoint data for IPv6 connections. rrSNrkrds& rtest_unspecFamilyIpv6#V2ParserTests.test_unspecFamilyIpv6rrc<V^8dQhRR/#r(r)rr)s"rrr*!r]rc \RR7p\PPV4pVP VP 4VP VP 4R#)F Test that UNSPEC does not return endpoint data for UNIX connections. rrSNrprds& rtest_unspecFamilyUnix#V2ParserTests.test_unspecFamilyUnix!rrc<V^8dQhRR/#r(r)rr)s"rrr**++d+rc \RR7p\PPV4pVP VP 4VP VP 4R#)rrSNr`rds& rtest_unspecProtoIpv4"V2ParserTests.test_unspecProtoIpv4*rrc<V^8dQhRR/#r(r)rr)s"rrr*3rrc \RR7p\PPV4pVP VP 4VP VP 4R#)rr_rSNrkrds& rtest_unspecProtoIpv6"V2ParserTests.test_unspecProtoIpv63rrc<V^8dQhRR/#r(r)rr)s"rrr*<rrc \RR7p\PPV4pVP VP 4VP VP 4R#)r0rSNrprds& rtest_unspecProtoUnix"V2ParserTests.test_unspecProtoUnix<rrc<V^8dQhRR/#r(r)rr)s"rrr*E . .4 .rc Rp\4V,p\P!4pVPV4wrEVP V4VP WQ4R#)zE Test that overflow bits are preserved during feed parsing for IPv4. TEST DATA TEST DATAN)r rr.feedr- assertEqualr1 testValuer2parserreoverflows& rtest_overflowIpv4V2ParserTests.test_overflowIpv4EN2  "Y.##%V,  -rc<V^8dQhRR/#r(r)rr)s"rrr*Prrc Rp\4V,p\P!4pVPV4wrEVP V4VP WQ4R#)zE Test that overflow bits are preserved during feed parsing for IPv6. rN)rrr.rr-rrs& rtest_overflowIpv6V2ParserTests.test_overflowIpv6Prrc<V^8dQhRR/#r(r)rr)s"rrr*[rrc Rp\4V,p\P!4pVPV4wrEVP V4VP WQ4R#)zE Test that overflow bits are preserved during feed parsing for Unix. rN)r$rr.rr-rrs& rtest_overflowUnixV2ParserTests.test_overflowUnix[rrc<V^8dQhRR/#r(r)rr)s"rrr*fs   d  rc vRp\P!4pVP\VPV4R#)z; Test that an initial payload of less than 16 bytes fails. s NEEDMOREDATAN)rr.rArr)r1rrs& rtest_segmentTooSmall"V2ParserTests.test_segmentTooSmallfs2$ ##%   KK  rrN)__name__ __module__ __qualname____firstlineno____doc__r3r8r<rBrHrNrTrZrfrlrqrxr~rrrrrrrrrrr__static_attributes____classdictcell__)r)s@rr&r&s::::::               ++++++ E E E E E E++++++++++++ . . . . . .   rr&Ns s/home/tests/mysockets/sock/home/tests/mysockets/sock)rtwisted.internetr twisted.trialrr _exceptionsr V2_SIGNATURErr r$TestCaser&rrrrs%",B #1& #@N#6& #@N# #8Ln H%%n r