+ Dfj aRQtn0tRt^RIt^RIt^RIt^RIHt^RIHtH t H t H t H t H t Ht^RIHt^RIHt^RIHt^RIHt^RIHtHt]^k]!R 4Rt^R IHtHt^R IH t ^R I!H"t"^RI#H$t$H%t%H&t&^RI'H(t(H)t)H*t*^RI+H,t,^RI-H.t.^RI/H0t0^RI1H2t2^RI3H4t4^RI5H6t6^RI7H8t8H9t9H:t:^RIH;t;^RIt>]?t@]tA]'g(^RIBHCtCHDtDHEtEHFtFHGtGHHtHHItIHJtJ^RIKHLtLHMtMHNtNHOtOHPtPHAtAH@t@M]tQ]!]&4!RR44tR] !]&]R!44!RR],]R4tS!RR 4tT!R!R"4tU!R#R$]>4tV!R%R&4tW!R'R(4tX!R)R*]X]W]>4tY]Z!]YR+]U!]YP]YPR,R-74!R.R/]X]W]>4t]]Z!]]R+]U!]YP]YPR0R-74!R1R2]X]W]>4t^]Z!]^R+]T!]^P]^P44]!]A4!R3R4]@44t_!R5R64t`!R7R8]`]W]>4ta!R9R:]`]W]>4tb!R;R<]>4tc!R=R>4td!R?R@]>4te!RARB]>4tf]!]24!RCRD](44tg!RERF]d]>4th!RGRH].4ti!RIRJ]d]>4tj!RKRL4tk!RMRN]k]>]X4tl!RORP]k]>]`4tmR# ]]3dR tELgi;i)Rz# Tests for L{twisted.pair.tuntap}. N)deque)EAGAINEBADFEINVALENODEVENOENTEPERM EWOULDBLOCK)cycle) randrange)SIGINT)Optional)ObjectNotFoundnamedAnyz fcntl.ioctlz'Platform is missing fcntl/ioctl support) Interface implementer) verifyObject)CannotListenError)IAddressIListeningPort IReactorFDSet)AbstractDatagramProtocolDatagramProtocolFactory)Clock)EthernetProtocol) IPProtocol)IRawPacketProtocol)RawUDPProtocol) iterbytes) addObserverremoveObservertextFromEventDict)fullyQualifiedName)SkipTestSynchronousTestCase)_H_PI_SIZEMemoryIOSystemTunnel _ethernet_ip_IPv4_udp) _IFNAMSIZ _TUNSETIFF TunnelAddress TunnelFlags TuntapPort_IInputOutputSystem _RealSystemcHa]tRt^RtoRtRtRtRtRtRt Rt Rt Vt R #) ReactorFDSeta An implementation of L{IReactorFDSet} which only keeps track of which descriptors have been registered for reading and writing. This implementation isn't actually capable of determining readability or writeability and generates no events for the descriptors registered with it. @ivar _readers: A L{set} of L{IReadDescriptor} providers which the reactor is supposedly monitoring for read events. @ivar _writers: A L{set} of L{IWriteDescriptor} providers which the reactor is supposedly monitoring for write events. c\4Vn\4VnVPPVnVPPVnR#N)set_readers_writersadd addReader addWriterselfs&?/usr/lib/python3/dist-packages/twisted/pair/test/test_tuntap.py__init__ReactorFDSet.__init__cs6  ****c<VPPV4R#r8)r:discard)r@readers&&rA removeReaderReactorFDSet.removeReaderi f%rDc<VPPV4R#r8)r;rF)r@writers&&rA removeWriterReactorFDSet.removeWriterlrJrDc,\VP4#r8)iterr:r?s&rA getReadersReactorFDSet.getReadersoDMM""rDc,\VP4#r8)rPr;r?s&rA getWritersReactorFDSet.getWritersrrSrDc\VPVP,4\4Vn\4Vn# \4Tn\4Tni;ir8)listr:r;r9r?s&rA removeAllReactorFDSet.removeAllusD "  56EDMEDM EDMEDMs %A A&)r:r;r=r>N) __name__ __module__ __qualname____firstlineno____doc__rBrHrMrQrUrY__static_attributes____classdictcell__ __classdict__s@rAr6r6Rs- + &&##""rDr6c*a]tRt^toRtRtRtVtR#) FSSetClockzA An L{FSSetClock} is a L{IReactorFDSet} and an L{IReactorClock}. c\\P!V4\PV4R#r8)rrBr6r?s&rArBFSSetClock.__init__s td#rDN)r[r\r]r^r_rBr`rarbs@rAreres$$rDrecFa]tRt^toRt]R4tRtRtRt Rt Vt R#) TunHelperzE A helper for tests of tun-related functionality (ip-level tunnels). cL\P\P,#r8)r1IFF_TUN IFF_NO_PIr?s&rA TUNNEL_TYPETunHelper.TUNNEL_TYPEs""[%:%:::rDc WnW nR#)a? @param tunnelRemote: The source address for UDP datagrams originated from this helper. This is an IPv4 dotted-quad string. @type tunnelRemote: L{bytes} @param tunnelLocal: The destination address for UDP datagrams originated from this helper. This is an IPv4 dotted-quad string. @type tunnelLocal: L{bytes} N) tunnelRemote tunnelLocal)r@rqrrs&&&rArBTunHelper.__init__s)&rDc  \\VPVP\WVR7R7#)a Construct an ip datagram containing a udp datagram containing the given application-level payload. @param source: The source port for the UDP datagram being encapsulated. @type source: L{int} @param destination: The destination port for the UDP datagram being encapsulated. @type destination: L{int} @param payload: The application data to include in the udp datagram. @type payload: L{bytes} @return: An ethernet frame. @rtype: L{bytes} )srcdstpayload)r+rqrrr-)r@source destinationrws&&&&rA encapsulateTunHelper.encapsulates-$!!  VgF  rDc aa.o\4pV3RlpW!n\4pVPRV4\ 4oSP^V4VV3RlpV#)a Get a function for parsing a datagram read from a I{tun} device. @return: A function which accepts a datagram exactly as might be read from a I{tun} device. The datagram is expected to ultimately carry a UDP datagram. When called, it returns a L{list} of L{tuple}s. Each tuple has the UDP application data as the first element and the sender address as the second element. c*<SPV4R#r8appendargs datagramss*rAcapture!TunHelper.parser..capture   T "rD90c2<SPVRRRR4S#)FN)datagramReceived)datarips&rAparseTunHelper.parser..parses!   eT4 > rD)rrraddProtor)r@receiverrudprrrs& @@rAparserTunHelper.parsersV #% #%,! UH% \ B   rD)rrrqN r[r\r]r^r_propertyrnrBrzrr`rarbs@rArjrjs2;; ' 0rDrjcFa]tRt^toRt]R4tRtRtRt Rt Vt R#) TapHelperzK A helper for tests of tap-related functionality (ethernet-level tunnels). cx\PpVP'gV\P,pV#r8)r1IFF_TAPpirm)r@flags& rArnTapHelper.TUNNEL_TYPEs+""www K)) )D rDc *WnW nW0nR#)a @param tunnelRemote: The source address for UDP datagrams originated from this helper. This is an IPv4 dotted-quad string. @type tunnelRemote: L{bytes} @param tunnelLocal: The destination address for UDP datagrams originated from this helper. This is an IPv4 dotted-quad string. @type tunnelLocal: L{bytes} @param pi: A flag indicating whether this helper will generate and consume a protocol information (PI) header. @type pi: L{bool} N)rqrrr)r@rqrrrs&&&&rArBTapHelper.__init__s)&rDc \VPVP4pVPWV4p\ RR\ VR7pVP 'd+\ p^p\V4\V4,V,pV#)a Construct an ethernet frame containing an ip datagram containing a udp datagram containing the given application-level payload. @param source: The source port for the UDP datagram being encapsulated. @type source: L{int} @param destination: The destination port for the UDP datagram being encapsulated. @type destination: L{int} @param payload: The application data to include in the udp datagram. @type payload: L{bytes} @return: An ethernet frame. @rtype: L{bytes} ss)rurvprotocolrw)rjrqrrrzr*r,rr&) r@rxryrwtunrframerflagss &&&& rArzTapHelper.encapsulatess$))4+;+;< __V' :++   777HEuI8 ,u4E rDc aaa.o\4pV3RlpW!n\4pVPRV4\ 4pVP^V4\ 4oSPRV4VVV3RlpV#)a Get a function for parsing a datagram read from a I{tap} device. @return: A function which accepts a datagram exactly as might be read from a I{tap} device. The datagram is expected to ultimately carry a UDP datagram. When called, it returns a L{list} of L{tuple}s. Each tuple has the UDP application data as the first element and the sender address as the second element. c*<SPV4R#r8r~rs*rAr!TapHelper.parser..capture'rrDric`<SP'd V\RpSPV4S#r8)rr'r)datagramretherr@s&rAr TapHelper.parser..parser5s0www#HI.  " "8 , rD)rrrrrr)r@rrrrrrrsf @@rArTapHelper.parsersl #% #%,! UH% \ B " ub!  rD)rrrrqNrrbs@rArrs3 $ D&&rDrc*a]tRtRtoRtRtRtVtR#) TunnelTestsiCzg L{Tunnel} is mostly tested by other test cases but some tests don't fit there. Those tests are here. c \\4\PR4pVP \ VP R4R#)zw Blocking reads are not implemented by L{Tunnel.read}. Attempting one results in L{NotImplementedError} being raised. N)r)r(osO_RDONLY assertRaisesNotImplementedErrorreadr@tunnels& rAtest_blockingReadTunnelTests.test_blockingReadIs0 ("++t< -v{{DArDrhN)r[r\r]r^r_rr`rarbs@rArrCs BBrDrc`a]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tVtR#)TunnelDeviceTestsMixiniRzN A mixin defining tests that apply to L{_IInputOutputSystem} implementations. c VP4VnVPPR\P\P ,4VnVPVPPVP 4VPPp\P!R\3,VPVP4pVPP!VP \"V4R#)zS Create the L{_IInputOutputSystem} provider under test and open a tunnel using it. /dev/net/tunz%dsHN) createSystemsystemopenrO_RDWR O_NONBLOCKfileno addCleanupclosehelperrnstructpackr._TUNNEL_DEVICEvalueioctlr/)r@modeconfigs& rAsetUpTunnelDeviceTestsMixin.setUpXs '') kk&& BMM8QR   ))4;;7{{&&Vyl2D4G4GT $++z6:rDc XVP\\VP44R#)z8 The object under test provides L{_IInputOutputSystem}. N) assertTruerr3rr?s&rAtest_interface%TunnelDeviceTestsMixin.test_interfacees  %8$++FGrDc VPPR\P4pVPP V4V#)a Get an invalid file descriptor. @return: An integer which is not a valid file descriptor at the time of this call. After any future system call which allocates a new file descriptor, there is no guarantee the returned file descriptor will still be invalid. r)rrrrr)r@fds& rA_invalidFileDescriptor-TunnelDeviceTestsMixin._invalidFileDescriptorks5[[  oryy 9 " rDc VP4pVP\VPPVR4pVP \ VP4R#)z The device's C{read} implementation raises L{OSError} with an errno of C{EBADF} when called on a file descriptor which is not valid (ie, which has no associated file description). rN)rrOSErrorrr assertEqualrerrnor@rexcs& rAtest_readEBADF%TunnelDeviceTestsMixin.test_readEBADFxsF  ( ( *)9)92tD  *rDc VP4pVP\VPPVR4pVP \ VP4R#)z The device's C{write} implementation raises L{OSError} with an errno of C{EBADF} when called on a file descriptor which is not valid (ie, which has no associated file description). sbytesN)rrrrwriterrrrs& rAtest_writeEBADF&TunnelDeviceTestsMixin.test_writeEBADFsF  ( ( *):):BI  *rDc VP4pVP\VPPV4pVP \ VP4R#)z The device's C{close} implementation raises L{OSError} with an errno of C{EBADF} when called on a file descriptor which is not valid (ie, which has no associated file description). N)rrrrrrrrrs& rAtest_closeEBADF&TunnelDeviceTestsMixin.test_closeEBADFsD  ( ( *):):B?  *rDc VP4pVP\VPPV\ R4pVP \VP4R#)z The device's C{ioctl} implementation raises L{OSError} with an errno of C{EBADF} when called on a file descriptor which is not valid (ie, which has no associated file description). stap0N) rrIOErrorrrr/rrrrs& rAtest_ioctlEBADF&TunnelDeviceTestsMixin.test_ioctlEBADFsH  ( ( *):):B GT  *rDc RpVP\VPPVPVR4pVP \ VP4R#)z The device's C{ioctl} implementation raises L{IOError} with an errno of C{EINVAL} when called with a request (second argument) which is not a supported operation. l>[=sgarbageN)rrrrrrrr)r@requestrs& rAtest_ioctlEINVAL'TunnelDeviceTestsMixin.test_ioctlEINVALsH T[[&& Wj  +rDc 0VPP4pRp\^d4Fp\R 4pRV3,pVPP WPP R34p\^d4FApVPPVPR4pV!V4p WV3V 9dRpMV RKC V'gKM V'gVPR4R#R# \d)p T P\\39dRp ? KXhRp ? ii;i) zv If a UDP datagram is sent to an address reachable by the tunnel device then it can be read out of the tunnel device. Fhello world:%drrT:NNNNz$Never saw probe UDP packet on tunnel)rrranger rsendUDP_TUNNEL_REMOTErrrrrr fail) r@rfoundikeymessagerxjpacketres & rA test_receive#TunnelDeviceTestsMixin.test_receives  ""$sAE"C'3&0G[[((3F3F2NOF 3Z %![[--dkk4@F !&f I(I5 $!!  u-0 II< =ww6;"77s6&C"" D-DDDc \R4pRV3,pVP\P\P!44\P!^x4VP P VPVPR4pVPPRRV4pVP PVPV4VPR4pVPW$4R#)zm If a UDP datagram is written the tunnel device then it is received by the network to which it is addressed. rriPrNr)r rsocketsetdefaulttimeoutgetdefaulttimeoutr receiveUDPr _TUNNEL_LOCALrrzrrecvr)r@rrportrs& rA test_send TunnelDeviceTestsMixin.test_sends#sf, 00&2J2J2LM  %{{%%dkk43E3EuM((w? $++v.4 )rD)rrN)r[r\r]r^r_rrrrrrrrrrr`rarbs@rArrRsC ;H ++++ ,$>L$*$*rDrc6a]tRtRtoRtRtRtRtRtRt Vt R#) FakeDeviceTestsMixiniz Define a mixin for use with test cases that require an L{_IInputOutputSystem} provider. This mixin hands out L{MemoryIOSystem} instances as the provider of that interface. stap-twistedtests 172.16.2.1s 172.16.2.2c b\4pVP\P\4V#)z Create and return a brand new L{MemoryIOSystem}. The L{MemoryIOSystem} knows how to open new tunnel devices. @return: The newly created I/O system object. @rtype: L{MemoryIOSystem} )r(registerSpecialDevicer) _DEVICE_NAMEr@rs& rAr!FakeDeviceTestsMixin.createSystems' !$$V%8%8&A rDrhN) r[r\r]r^r_rrrrr`rarbs@rArrs% (N!M"N  rDrc]tRtRtRtRtR#)FakeTapDeviceTestsizI Run various tap-type tunnel unit tests against an in-memory I/O system. rhNr[r\r]r^r_r`rhrDrArrrDrrFrc]tRtRtRtRtR#)FakeTapDeviceWithPITestsi%zd Run various tap-type tunnel unit tests against an in-memory I/O system with the PI header enabled. rhNrrhrDrArr%srDrTc]tRtRtRtRtR#)FakeTunDeviceTestsi7zI Run various tun-type tunnel unit tests against an in-memory I/O system. rhNrrhrDrArr7rrDrcNaa]tRtRtoRtV3RltV3RltRtRtRt Vt V;t #)TestRealSystemiFz Add extra skipping logic so tests that try to create real tunnel devices on platforms where those are not supported automatically get skipped. c <\SV`!V.VO5/VB# \d4pTP\\ 39dTR8Xd \ R4hhRp?ii;i)z Attempt an open, but if the file is /dev/net/tun and it does not exist, translate the error into L{SkipTest} so that tests that require platform support for tuntap devices are skipped instead of failed. rzPlatform lacks /dev/net/tunN)superrrrrrr$)r@filenamerkwargsr __class__s&&*, rArTestRealSystem.openMsZ  7<:4:6: : ww66**x?/J<==   s A.AAc <\SV`!V/VB# \d'p\TP8Xd \ R4hhRp?ii;i)z Attempt an ioctl, but translate permission denied errors into L{SkipTest} so that tests that require elevated system privileges and do not have them are skipped instead of failed. z%Permission to configure device deniedN)rrrrrr$)r@rrrrs&*, rArTestRealSystem.ioctl\sG  7=$1&1 1 FGG  s A!?Ac \P!\P\P4pVPR4VP W4VP 4#)ae Use the platform network stack to send a datagram to the given address. @param datagram: A UDP datagram payload to send. @type datagram: L{bytes} @param address: The destination to which to send the datagram. @type address: L{tuple} of (L{bytes}, L{int}) @return: The address from which the UDP datagram was sent. @rtype: L{tuple} of (L{bytes}, L{int}) )z 172.16.0.1)rAF_INET SOCK_DGRAMbindsendto getsockname)r@raddressss&&& rArTestRealSystem.sendUDPisC MM&..&*;*; <  ! #}}rDc \P!\P\P4pVPW#34V#)a Use the platform network stack to receive a datagram sent to the given address. @param fileno: The file descriptor of the tunnel used to send the datagram. This is ignored because a real socket is used to receive the datagram. @type fileno: L{int} @param host: The IPv4 address at which the datagram will be received. @type host: L{bytes} @param port: The UDP port number at which the datagram will be received. @type port: L{int} @return: A L{socket.socket} which can be used to receive the specified datagram. )rr#r$r%)r@rhostrr)s&&&& rArTestRealSystem.receiveUDP{s1( MM&..&*;*; < |rDrh) r[r\r]r^r_rrrrr`ra __classcell__)rrcs@@rArrFs#  $rDrc.a]tRtRtoRt]tRtRtVt R#)RealDeviceTestsMixiniz Define a mixin for use with test cases that require an L{_IInputOutputSystem} provider. This mixin hands out L{TestRealSystem} instances as the provider of that interface. c \4#)z Create a real I/O system that can be used to open real tunnel device provided by the underlying system and previously configured. @return: The newly created I/O system object. @rtype: L{TestRealSystem} )rr?s&rAr!RealDeviceTestsMixin.createSystems rDrhN) r[r\r]r^r_ platformSkipskiprr`rarbs@rAr0r0s D  rDr0c<]tRtRtRtRtRtRt]!]]RR7t Rt R #) &RealDeviceWithProtocolInformationTestsizp Run various tap-type tunnel unit tests, with "protocol information" (PI) turned on, against a real I/O system. s tap-twtest-pis 172.16.1.1s 172.16.1.2TrrhN r[r\r]r^r_rrrrrr`rhrDrAr6r6s( &N!M"N ~} >FrDr6c<]tRtRtRtRtRtRt]!]]RR7t Rt R #) )RealDeviceWithoutProtocolInformationTestsizq Run various tap-type tunnel unit tests, with "protocol information" (PI) turned off, against a real I/O system. s tap-twtests 172.16.0.1s 172.16.0.2FrrhNr7rhrDrAr9r9s& #N!M"N ~} ?FrDr9c0a]tRtRtoRtRtRtRtVtR#)TuntapPortTestsizJ Tests for L{TuntapPort} behavior that is independent of the tunnel type. c l\R\44pVP\\V44R#)z6 A L{TuntapPort} instance provides L{IListeningPort}. deviceN)r2rrrrr@rs& rArTuntapPortTests.test_interfaces')%5%78  ^T:;rDc n\R\44pVPVP\4R#)zO When not initialized with an I/O system, L{TuntapPort} uses a L{_RealSystem}. r=N)r2rassertIsInstance_systemr4r>s& rAtest_realSystemTuntapPortTests.test_realSystems( )%5%78 dllK8rDrhN) r[r\r]r^r_rrCr`rarbs@rAr;r;s<99rDr;ca]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRt Rt!R t"R!t#R"t$R#t%R$t&R%t'R&t(Vt)R'#)(TunnelTestsMixiniz A mixin defining tests for L{TuntapPort}. These tests run against L{MemoryIOSystem} (proven equivalent to the real thing by the tests above) to avoid performing any real I/O. c RVn\4VnVPP\P \4VP P\VPPVP44Vn \4Vn \VPVPVPVPR7VnR#)zG Create an in-memory I/O system and set up a L{TuntapPort} against it. tun0)reactorrN)namer(rr r)r factory buildProtocolr0rrnrrerIr2rr?s&rArTunnelTestsMixin.setUps $&  ))&*=*=vF 22 $++11499 =  "|  IIt}}dll4;;  rDc ZV\P\P,,#)z Mask off any flags except for L{TunnelType.IFF_TUN} and L{TunnelType.IFF_TAP}. @param flags: Flags from L{TunnelType} to mask. @type flags: L{FlagConstant} @return: The flags given by C{flags} except the two type flags. @rtype: L{FlagConstant} )r1rlr)r@rs&&rA_tunnelTypeOnly TunnelTestsMixin._tunnelTypeOnlys  ++k.A.AABBrDc VPpVPP4VPPVP4pVPVP ,VP ,RR\\R4, ,,VPPRR3pVPVPVPVPVP3pVPW44R#)z L{TuntapPort.startListening} opens the tunnel factory character special device C{"/dev/net/tun"} and configures it as a I{tun} tunnel. rHFTN)rrstartListening getTunnelr O_CLOEXECrr.len interface openFlags requestedNamerJblocking closeOnExecr)r@rrexpectedactuals& rAtest_startListeningOpensDevice/TunnelTestsMixin.test_startListeningOpensDevices    "&&tyy1 MMF,, ,v/@/@ @ gS\!9: : II           KK OO      *rDc VPP4VPVPP4R#)zO L{TuntapPort.startListening} sets C{connected} on the port object to C{True}. N)rrSr connectedr?s&rA test_startListeningSetsConnected1TunnelTestsMixin.test_startListeningSetsConnecteds*   "  ++,rDc VPP4VPVPVPP4R#)z L{TuntapPort.startListening} calls C{makeConnection} on the protocol the port was initialized with, passing the port as an argument. N)rrSassertIsr transportr?s&rA#test_startListeningConnectsProtocol4TunnelTestsMixin.test_startListeningConnectsProtocol%s0   " dii!8!89rDc VPP4VPVPVPP 44R#)z L{TuntapPort.startListening} passes the port instance to the reactor's C{addReader} method to begin watching the port's file descriptor for data to read. N)rrSassertInrIrQr?s&rA test_startListeningStartsReading1TunnelTestsMixin.test_startListeningStartsReading-s3   " dii!8!8!:;rDc VPPPR4VP\VP P 4R#)zx L{TuntapPort.startListening} raises L{CannotListenError} if opening the tunnel factory character special device fails. rNr permissionsremoverrrrSr?s&rA%test_startListeningHandlesOpenFailure6TunnelTestsMixin.test_startListeningHandlesOpenFailure6s7 &&v. +TYY-E-EFrDc VPPPR4VP\VP P 4R#)zu L{TuntapPort.startListening} raises L{CannotListenError} if the C{ioctl} call to configure the tunnel device fails. rNrnr?s&rA*test_startListeningHandlesConfigureFailure;TunnelTestsMixin.test_startListeningHandlesConfigureFailure>s7 &&w/ +TYY-E-EFrDc VP4pVPWPP44VPP ^4VP VP V44R#)a  Verify that the C{stopListening} method of an L{IListeningPort} removes that port from the reactor's "readers" set and also that the L{Deferred} returned by that method fires with L{None}. @param port: The port object to stop. @type port: L{IListeningPort} provider N) stopListening assertNotInrIrQadvance assertIsNonesuccessResultOf)r@rstoppeds&& rA _stopPortTunnelTestsMixin._stopPortFsX$$& ||6689 Q $..w78rDc VPP4VPP4pVPVP4VP WP P 4R#)z L{TuntapPort.stopListening} returns a L{Deferred} which fires after the port has been removed from the reactor's reader list by passing it to the reactor's C{removeReader} method. N)rrSrr}rxr _openFiles)r@rs& rAtest_stopListeningStopsReading/TunnelTestsMixin.test_stopListeningStopsReadingUsN   "!!# tyy! !7!78rDc VPP4VPVP4VPVPP4R#)z After the L{Deferred} returned by L{TuntapPort.stopListening} fires, the C{connected} attribute of the port object is set to C{False}. N)rrSr} assertFalserar?s&rA!test_stopListeningUnsetsConnected2TunnelTestsMixin.test_stopListeningUnsetsConnectedas<   " tyy! ,,-rDc VPP4VPVP4VPVPP 4R#)z\ L{TuntapPort.stopListening} calls C{doStop} on the protocol the port was initialized with. N)rrSr}rzrrfr?s&rAtest_stopListeningStopsProtocol0TunnelTestsMixin.test_stopListeningStopsProtocoljs<   " tyy! $--112rDc zVPP4pVPVPV44R#)z~ L{TuntapPort.stopListening} returns a L{Deferred} which succeeds immediately if it is called when the port is not listening. N)rrwrzr{)r@r|s& rAtest_stopListeningWhenStopped.TunnelTestsMixin.test_stopListeningWhenStoppedss/ ))))+ $..w78rDc VPP4VPP4VPP4pVPP ^4VP VP V44R#)z It is safe and a no-op to call L{TuntapPort.stopListening} more than once with no intervening L{TuntapPort.startListening} call. N)rrSrwrIryrzr{)r@seconds& rAtest_multipleStopListening+TunnelTestsMixin.test_multipleStopListening{sa   " !((* Q $..v67rDc VPP4VPP4VPP ^4VP VPP 4VPVP.4pVP\V^,R,4VPRV^,R,4VP^\V44R#)z@ L{TuntapPort.loseConnection} stops the port and is deprecated. categoryztwisted.pair.tuntap.TuntapPort.loseConnection was deprecated in Twisted 14.0.0; please use twisted.pair.tuntap.TuntapPort.stopListening insteadrN) rrSloseConnectionrIryrra flushWarningstest_loseConnectionrDeprecationWarningrV)r@warningss& rAr$TunnelTestsMixin.test_loseConnections   "   " Q ,,-%%t'?'?&@A +Xa[-DE  $ QK "  CM*rDc VPP4VPPVP4pWnVPP 4VP .VPP4R#)a0 Test that L{TuntapPort.doRead} has no side-effects under a certain exception condition. @param style: An exception instance to arrange for the (python wrapper around the) underlying platform I{read} call to fail with. @raise C{self.failureException}: If there are any observable side-effects. N) rrSrrTnonBlockingExceptionStyledoReadrrreceived)r@stylers&& rA_stopsReadingTest"TunnelTestsMixin._stopsReadingTests\   "&&tyy1+0(  T]]334rDc DVP\P4R#)zZ Once L{TuntapPort.doRead} encounters an I{EAGAIN} errno from a C{read} call, it returns. N)rr) EAGAIN_STYLEr?s&rAtest_eagainStopsReading(TunnelTestsMixin.test_eagainStopsReadings v223rDc DVP\P4R#)z_ Once L{TuntapPort.doRead} encounters an I{EWOULDBLOCK} errno from a C{read} call, it returns. N)rr)EWOULDBLOCK_STYLEr?s&rAtest_ewouldblockStopsReading-TunnelTestsMixin.test_ewouldblockStopsReadings v778rDc DVP\P4R#)zY Once L{TuntapPort.doRead} encounters an I{EINTR} errno from a C{read} call, it returns. N)rr) EINTR_STYLEr?s&rAtest_eintrblockStopsReading,TunnelTestsMixin.test_eintrblockStopsReadings v112rDc f!RR\4pVPWPV!44R#)z If L{Tuntap.doRead} encounters any exception other than one explicitly handled by the code, the exception propagates to the caller. c]tRtRtRtR#)ETunnelTestsMixin.test_unhandledReadError..UnexpectedExceptionirhN)r[r\r]r^r`rhrDrAUnexpectedExceptionrs rDrN) Exceptionrr)r@rs& rAtest_unhandledReadError(TunnelTestsMixin.test_unhandledReadErrors-  )   !7!79L9N rDc dVP\VP\\R44R#)z Just like C{test_unhandledReadError}, but for the case where the exception that is not explicitly handled happens to be of type C{EnvironmentError} (C{OSError} or C{IOError}). zOperation not permittedN)rrrrr?s&rA"test_unhandledEnvironmentReadError3TunnelTestsMixin.test_unhandledEnvironmentReadErrors'  T++WU?@ ii---   T&\DII,C,CC D YY,, ,E   "&&tyy1  +  !FG  MM$:$:;rDc 2VPP4VPPVP4PP R4RVP nVPP4VP\4#)z Deliver some data to a L{TuntapPort} hooked up to an application protocol that raises an exception from its C{datagramReceived} method. @return: Whatever L{AttributeError} exceptions are logged. spingN) rrSrrTrrrrrflushLoggedErrorsAttributeErrorr?s&rA_datagramReceivedException+TunnelTestsMixin._datagramReceivedExceptionsj   " dii(33::7C"&  %%n55rDc \VP4pVP^\V44R#)z\ If the protocol's C{datagramReceived} method raises an exception, the exception is logged. N)rrrV)r@errorss& rAtest_datagramReceivedException/TunnelTestsMixin.test_datagramReceivedExceptions& 002 CK(rDc `.p\VP4VP\VP4VP 4\ RV44p\ V4pVPR\VPP4: R2VP4^,4R#)zj The exception raised by C{datagramReceived} is logged with a message identifying the offending protocol. c3F"TFqR,'gKVxK R#5i)isErrorNrh).0ms& rA TTunnelTestsMixin.test_datagramReceivedExceptionIdentifiesProtocol..'s91iLLQQs! !zUnhandled exception from z.datagramReceivedN) r rrr!rrr"rr#rr splitlines)r@messageserrorrs& rA0test_datagramReceivedExceptionIdentifiesProtocolATunnelTestsMixin.test_datagramReceivedExceptionIdentifiesProtocols HOO$ 8 '')999#E* !$--"9"9: =     # rDc RpVPP4VPPV4VPVPP VP4P \V.44R#)z7 L{TuntapPort.write} sends a datagram into the tunnel. s a b c d e f gN)rrSrrrrT writeBufferrr@rs& rA test_writeTunnelTestsMixin.test_write/s\$   " !  KK ! !$)) , 8 8% :K rDc DVPP4VPPVP4pVPP \ 4VPPR4VP\R.4VP4R#)z If the platform write call is interrupted (causing the Python wrapper to raise C{IOError} with errno set to C{EINTR}), the write is re-tried. s hello, worldN) rrSrrTpendingSignalsrr rrrrrs& rAtest_interruptedWrite&TunnelTestsMixin.test_interruptedWrite:sn   "&&tyy1$$V, ( 0163E3EFrDc VPP4VPPVP4pVP \ VPP RVP,R,4R#)zc Any exception raised by the underlying write call, except for EINTR, is propagated to the caller. rrN)rrSrrTrrrSEND_BUFFER_SIZErs& rAtest_unhandledWriteError)TunnelTestsMixin.test_unhandledWriteErrorEsY   "&&tyy1  TYY__dV-D-D&Dt&K rDc (.ROpVPP4VPPV4VPVPP VP4P \RPV4.44R#)zz L{TuntapPort.writeSequence} sends a datagram into the tunnel by concatenating the byte strings in the list passed to it. rDN)abcd) rrS writeSequencerrrTrrjoinrs& rAtest_writeSequence#TunnelTestsMixin.test_writeSequencePsh ,   " )  KK ! !$)) , 8 8%(AS@T:U rDc FVPP4VPP4pVP\ VP VP P4VPPVP4P4V4R#)zX L{TuntapPort.getHost} returns a L{TunnelAddress} including the tunnel's type and name. N) rrSgetHostrr0rOrrnrrTrJ)r@r(s& rA test_getHostTunnelTestsMixin.test_getHost\su   "))##%  $$T[[%<%<= %%dii055    rDc VPP4VP\VP4\ VP P 44RPVPVPP4PVPPVP4P4pVP\VP4PV4R8g4R#) The string representation of a L{TuntapPort} instance includes the tunnel type and interface and the protocol associated with the port. z listening on {}/{}>N)rrS assertRegexstrr#rrformatrOrrnrJrrTrfindr@r\s& rAtest_listeningString%TunnelTestsMixin.test_listeningStringks   " TYY);DMM > KK ! !$)) , 1 1  DII++H5;Nr) rrrr#rrrrOrrnrJrrrs& rAtest_unlisteningString'TunnelTestsMixin.test_unlisteningStringys TYY);DMM > II  DII++H5;N)rreprr0r1rlr?s&rA test_reprTunnelAddressTests.test_reprs*  {22C D 8 rDrhN) r[r\r]r^r_rrrr`rarbs@rAr r s +(  rDr cfa]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tRtVtR#)TunnelAddressEqualityTestsizR Tests for the implementation of equality (C{==} and C{!=}) for L{TunnelAddress}. c(\\PR4Vn\\P\P,R4Vn\\P R4Vn\\PR4VnR#)r=stap1stun1N)r0r1rlfirstrr variedType variedNamer?s&rAr TunnelAddressEqualityTests.setUpsd";#6#6 B $   +"5"5 5y  ( (;(;WE' (;(;WErDc VVPVPVP8H4R#)z. A L{TunnelAddress} compares equal to itself. Nrrr?s&rAtest_selfComparesEqual1TunnelAddressEqualityTests.test_selfComparesEquals  djj01rDc VVPVPVP8g4R#)z9 A L{TunnelAddress} doesn't compare not equal to itself. Nrrr?s&rAtest_selfNotComparesNotEqual7TunnelAddressEqualityTests.test_selfNotComparesNotEquals tzz12rDc VVPVPVP8H4R#)zx Two L{TunnelAddress} instances with the same value for the C{type} and C{name} attributes compare equal to each other. N)rrrr?s&rA test_sameAttributesComparesEqual;TunnelAddressEqualityTests.test_sameAttributesComparesEquals  dkk12rDc VVPVPVP8g4R#)z Two L{TunnelAddress} instances with the same value for the C{type} and C{name} attributes don't compare not equal to each other. N)rrrr?s&rA&test_sameAttributesNotComparesNotEqualATunnelAddressEqualityTests.test_sameAttributesNotComparesNotEquals t{{23rDc VVPVPVP8H4R#)zo Two L{TunnelAddress} instances that differ only by the value of their type don't compare equal to each other. N)rrrr?s&rA"test_differentTypeComparesNotEqual=TunnelAddressEqualityTests.test_differentTypeComparesNotEqual t67rDc VVPVPVP8g4R#)zm Two L{TunnelAddress} instances that differ only by the value of their type compare not equal to each other. N)rrrr?s&rA"test_differentTypeNotComparesEqual=TunnelAddressEqualityTests.test_differentTypeNotComparesEqual  doo56rDc VVPVPVP8H4R#)zo Two L{TunnelAddress} instances that differ only by the value of their name don't compare equal to each other. N)rrrr?s&rA"test_differentNameComparesNotEqual=TunnelAddressEqualityTests.test_differentNameComparesNotEqualr1rDc VVPVPVP8g4R#)zm Two L{TunnelAddress} instances that differ only by the value of their name compare not equal to each other. N)rrrr?s&rA"test_differentNameNotComparesEqual=TunnelAddressEqualityTests.test_differentNameNotComparesEqualr5rDc BVPVPV8H4R#)zK A L{TunnelAddress} doesn't compare equal to an instance of another class. Nr%r?s&rA#test_differentClassNotComparesEqual>TunnelAddressEqualityTests.test_differentClassNotComparesEqual s t+,rDc BVPVPV8g4R#)zH A L{TunnelAddress} compares not equal to an instance of another class. Nr!r?s&rA#test_differentClassComparesNotEqual>TunnelAddressEqualityTests.test_differentClassComparesNotEquals  d*+rD)rrrrN)r[r\r]r^r_rr"r&r)r,r/r3r7r:r=r@r`rarbs@rArrsG F 2 3 348787-,,rDrc:a]tRtRtoRtRtRRltRtRtVt R#) IPRecordingProtocoli@ A protocol which merely records the datagrams delivered to it. c.VnR#r8rr?s&rA startProtocol!IPRecordingProtocol.startProtocol!  rDNc<VPPV4R#r8rr)r@rpartialdestrxrs&&&&&&rAr$IPRecordingProtocol.datagramReceived$s X&rDcR#r8rh)r@numprotos&&&rArIPRecordingProtocol.addProto)s rDrF)FNNN) r[r\r]r^r_rGrrr`rarbs@rArCrCs'   rDrCcH]tRtRtRt]!4t]]n] !RR4t Rt R#)TunTestsi.zB Tests for L{TuntapPort} when used to open a Linux I{tun} tunnel. Nrh) r[r\r]r^r_rrKrCrrjrr`rhrDrArTrT.s$iG*G tT "FrDrTc4a]tRtRtoRtRtRRltRtVtR#)EthernetRecordingProtocoli9rDc.VnR#r8rFr?s&rArG'EthernetRecordingProtocol.startProtocol>rIrDc<VPPV4R#r8rK)r@rrLs&&&rAr*EthernetRecordingProtocol.datagramReceivedAs X&rDrFN)F) r[r\r]r^r_rGrr`rarbs@rArVrV9s''rDrVcL]tRtRtRt]!4t]]n] !RRRR7t Rt R#)TapTestsiEzB Tests for L{TuntapPort} when used to open a Linux I{tap} tunnel. NFrrh) r[r\r]r^r_rrKrVrrrr`rhrDrAr\r\Es&iG0G tTe ,FrDr\c*a]tRtRtoRtRtRtVtR#)IOSystemTestsMixiniPz@ Tests that apply to any L{_IInputOutputSystem} implementation. c VP4pVP\VPR\P 4R#)z\ L{_IInputOutputSystem.open} raises L{OSError} when called with a non-existent device path. s!/dev/there-is-no-such-device-everN)rrrrrrr s& rAtest_noSuchDevice$IOSystemTestsMixin.test_noSuchDeviceUs2 ""$  V[["F  rDrhN)r[r\r]r^r_r`r`rarbs@rAr^r^Ps  rDr^c]tRtRtRtRtR#)MemoryIOSystemTestsi`zD General L{_IInputOutputSystem} tests applied to L{MemoryIOSystem}. rhNrrhrDrArcrc`rrDrcc]tRtRtRtRtR#)RealIOSystemTestsihzA General L{_IInputOutputSystem} tests applied to L{_RealSystem}. rhNrrhrDrArerehsrDrecVV^8dQh/^\9d\\,;R&#)r3)__conditional_annotations__r r)rs"rA __annotate__ris""hsm#rD)orhr_rrr collectionsrrrrrrrrr itertoolsr randomr signalr typingr twisted.python.reflectrrr3rzope.interfacerrzope.interface.verifyrtwisted.internet.errorrtwisted.internet.interfacesrrrtwisted.internet.protocolrrrtwisted.internet.taskrtwisted.pair.ethernetrtwisted.pair.iprtwisted.pair.rawrtwisted.pair.rawudprtwisted.python.compatrtwisted.python.logr r!r"r#twisted.trial.unittestr$r%objectr4r3twisted.pair.testingr&r'r(r)r*r+r,r-twisted.pair.tuntapr.r/r0r1r2r4r6rerjrrrrrsetattrrrrrrr0r6r9r;rFr rrCrTrVr\r^rcreri)rhs@rArs  KKK; ]L1.4OO (2&/.+MM5@       D ]'"'"'"T ]LN+$ $MM`ffR B% Bf*f*R202E  ))+=+K+KPU02E  ))+=+K+KPT02E   //1C1Q1QR !J[J"JZ  (?02E?& @02E @ 9)9*r r j ) ,) XW,!4W,t   2 ! $#!4# ' 0 '-!4-   +-A*,?AUa* '=