+ jhC2Rt^RIt^RIt^RIHt^RIHtHtHtH t H t H t H t H t ^RIHt^RIHt^RIHt^RIHt^RIHt^R IHt^R IHtHtHtHt^R IH t ^t!R t"R t#Rt$Rt%Rt&!RR4t'Rt(]!]4!RR44t)!RR4t*R#)zD Tools for automated testing of L{twisted.pair}-based applications. N)deque)EAGAINEBADFEINTREINVALENOBUFSENOSYSEPERM EWOULDBLOCKwraps) implementer)DatagramProtocol)EthernetProtocol) IPProtocol)RawUDPProtocol) _IFNAMSIZ _TUNSETIFF TunnelFlags_IInputOutputSystem) nativeStringc0\P!RV4#)z Pack an integer into a network-order two-byte string. @param n: The integer to pack. Only values that fit into 16 bits are supported. @return: The packed representation of the integer. @rtype: L{bytes} z>H)structpack)ns&6/usr/lib/python3/dist-packages/twisted/pair/testing.py_Hrs ;;tQ c@W,\V4,V,#)a Construct an ethernet frame. @param src: The source ethernet address, encoded. @type src: L{bytes} @param dst: The destination ethernet address, encoded. @type dst: L{bytes} @param protocol: The protocol number of the payload of this datagram. @type protocol: L{int} @param payload: The content of the ethernet frame (such as an IP datagram). @type payload: L{bytes} @return: The full ethernet frame. @rtype: L{bytes} )rsrcdstprotocolpayloads&&&&r _ethernetr%.s& 9r(| #g --rc:R\^\V4,4,R,\^4,\P!\P\ V44,\P!\P\ V44,p\ \P!RV44pV^, pVR,V,pVR, pVR,\P!RV4,VR,,pW2,#)a Construct an IP datagram with the given source, destination, and application payload. @param src: The source IPv4 address as a dotted-quad string. @type src: L{bytes} @param dst: The destination IPv4 address as a dotted-quad string. @type dst: L{bytes} @param payload: The content of the IP datagram (such as a UDP datagram). @type payload: L{bytes} @return: An IP datagram header and payload. @rtype: L{bytes} sEs@z!10Hi:N Nz!H: NN) rlensocket inet_ptonAF_INETrsumrunpackr)r!r"r$ipHeader checksumStep1carry checksumStep2 checksumStep3s&&& r_ipr4Ds&  R#g,    &  & Q%    6>><+< = >   6>><+< = > " fh78M R E"V+u4M!F*M }v{{4??(3-OH  rc\V4\V4,\\V4^,4,\^4,pW2,#)aR Construct a UDP datagram with the given source, destination, and application payload. @param src: The source port number. @type src: L{int} @param dst: The destination port number. @type dst: L{int} @param payload: The content of the UDP datagram. @type payload: L{bytes} @return: A UDP datagram header and payload. @rtype: L{bytes} )rr))r!r"r$ udpHeaders&&& r_udpr7vsM& 3 S'  S\A     Q%    rca]tRt^toRtRt]!]R4t] !] R4t ]!] R4t ]tRtRt]R4t]R 4tR tR tR tR tVtR#)Tunnelz An in-memory implementation of a tun or tap device. @cvar _DEVICE_NAME: A string representing the conventional filesystem entry for the tunnel factory character special device. @type _DEVICE_NAME: C{bytes} s /dev/net/tunz Resource temporarily unavailablezOperation would blockzInterrupted function callic WnW nRVnRVnRVn\ 4Vn\ 4Vn\ 4VnR#)z @param system: An L{_IInputOutputSystem} provider to use to perform I/O. @param openFlags: Any flags to apply when opening the tunnel device. See C{os.O_*}. @type openFlags: L{int} @param fileMode: ignored N) system openFlags tunnelMode requestedNamenamer readBuffer writeBufferpendingSignals)selfr;r<fileModes&&&&r__init__Tunnel.__init__sC #! ' 7#grc ZVPVPP,'*#)z` If the file descriptor for this tunnel is open in blocking mode, C{True}. C{False} otherwise. )r<r; O_NONBLOCKrCs&rblockingTunnel.blockings NNT[[%;%;;<? ? )8}r)r?r<rBr@r>r;r=rAN)__name__ __module__ __qualname____firstlineno____doc__ _DEVICE_NAMEIOErrorr EAGAIN_STYLErfr EWOULDBLOCK_STYLEr EINTR_STYLEr`rgrEpropertyrJrOrXrcrh__static_attributes____classdictcell__ __classdict__s@rr9r9s#L6#EFL -DE%!<=K ,&.==<<)"!1Frr9c0a\S4V3Rl4pV#)a` Wrap a L{MemoryIOSystem} method with permission-checking logic. The returned function will check C{self.permissions} and raise L{IOError} with L{errno.EPERM} if the function name is not listed as an available permission. @param original: The L{MemoryIOSystem} instance to wrap. @return: A wrapper around C{original} that applies permission checks. cr<SPVP9d\\R4hS!V.VO5/VB#)zOperation not permitted)rj permissionsrfr )rCargskwargsoriginals&*,rpermissionChecker&_privileged..permissionChecker+s:   D$4$4 4%!:; ;.t.v..rr )r~rsf r _privilegedrs# 8_// rca]tRtRtoRtRt^t^t^tRt Rt Rt ] RRl4t R tR tR t] R 4tR tRtRtVtR#)MemoryIOSystemi4z An in-memory implementation of basic I/O primitives, useful in the context of unit testing as a drop-in replacement for parts of the C{os} module. @ivar _devices: @ivar _openFiles: @ivar permissions: @ivar _counter: i c4/Vn/VnRR0VnR#)openioctlN_devices _openFilesr{rIs&rrEMemoryIOSystem.__init__Gs "G,rc DVPVP4,#)a  Get the L{Tunnel} object associated with the given L{TuntapPort}. @param port: A L{TuntapPort} previously initialized using this L{MemoryIOSystem}. @return: The tunnel object created by a prior use of C{open} on this object on the tunnel special device file. @rtype: L{Tunnel} )rfileno)rCports&&r getTunnelMemoryIOSystem.getTunnelLst{{}--rc "W PV&R#)z Specify a class which will be used to handle I/O to a device of a particular name. @param name: The filesystem path name of the device. @type name: L{bytes} @param cls: A class (like L{Tunnel}) to instantiated whenever this device is opened. N)r)rCr?clss&&&rregisterSpecialDevice$MemoryIOSystem.registerSpecialDeviceYs" drNc WP9dOVPpV;P^, unVPV,!WV4VPV&V#\\R4h)a~ A replacement for C{os.open}. This initializes state in this L{MemoryIOSystem} which will be reflected in the behavior of the other file descriptor-related methods (eg L{MemoryIOSystem.read}, L{MemoryIOSystem.write}, etc). @param name: A string giving the name of the file to open. @type name: C{bytes} @param flags: The flags with which to open the file. @type flags: C{int} @param mode: The mode with which to open the file. @type mode: C{int} @raise OSError: With C{ENOSYS} if the file is not a recognized special device file. @return: A file descriptor associated with the newly opened file description. @rtype: L{int} zFunction not implemented)r_counterrrfr)rCr?flagsmodefds&&&& rrMemoryIOSystem.openfsV0 == B MMQ M"&--"5d4"HDOOB If899rc VPV,PV4# \d\\R4hi;i)z Try to read some bytes out of one of the in-memory buffers which may previously have been populated by C{write}. @see: L{os.read} Bad file descriptor)rrcKeyErrorrfr)rCrras&&&rrcMemoryIOSystem.reads> 8??2&++E2 2 8%!67 7 8 !$Ac VPV,PV4# \d\\R4hi;i)zr Try to add some bytes to one of the in-memory buffers to be accessed by a later C{read} call. @see: L{os.write} r)rrhrrfr)rCrdatas&&&rrhMemoryIOSystem.writes> 8??2&,,T2 2 8%!67 7 8rc `VPVR# \d\\R4hi;i)zj Discard the in-memory buffer and other in-memory state for the given file descriptor. @see: L{os.close} rN)rrrfr)rCrs&&rcloseMemoryIOSystem.closes0 8# 8%!67 7 8s -c VPV,pT\8wd\\ R4h\ P!R\3,T4wrVYdn YTn TR\^, R,Tn \ P!R\3,TPT4# \d\\R4hi;i)zo Perform some configuration change to the in-memory state for the given file descriptor. @see: L{fcntl.ioctl} rzRequest or args is not valid.z%dsHNs123) rrrfrrrrr.rr=r>r?r)rCrrequestr|tunnelr?rs&&&& rrMemoryIOSystem.ioctls 8__R(F j &"AB B]]6YL#8$?  #?Y]+f4 {{6YL0&++tDD 8%!67 7 8s B++Cc  RpRp\VV^,\WB^,VR7R7p\VPP 44pV^,P V4W43#)a Write an ethernet frame containing an ip datagram containing a udp datagram containing the given payload, addressed to the given address, to a tunnel device previously opened on this I/O system. @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: A two-tuple giving the address from which gives the address from which the datagram was sent. @rtype: L{tuple} of (L{bytes}, L{int}) z10.1.2.3iaS)r!r"r$)r4r7listrvaluesrX)rCrWaddresssrcIPsrcPort serialized openFiless&&& rsendUDPMemoryIOSystem.sendUDPsd" W!*hG //12 ! $$Z0rc \W4#)a Get a socket-like object which can be used to receive a datagram sent from the given address. @param fileno: A file descriptor representing a tunnel device which the datagram will be received via. @type fileno: L{int} @param host: The IPv4 address to which the datagram was sent. @type host: L{bytes} @param port: The UDP port number to which the datagram was sent. received. @type port: L{int} @return: A L{socket.socket}-like object which can be used to receive the specified datagram. ) _FakePort)rCrhostrs&&&&r receiveUDPMemoryIOSystem.receiveUDPs&&&rrN)rjrkrlrmrnrO_RDWRrHrNrErrrrrcrhrrrrrurvrws@rrr4sw H FJI- . "::< 8 8 8EE, >''rrc0a]tRtRtoRtRtRtRtVtR#)riz A socket-like object which can be used to read UDP datagrams from tunnel-like file descriptors managed by a L{MemoryIOSystem}. cWnW nR#r)_system_fileno)rCr;rs&&&rrE_FakePort.__init__s   rc a a VPPVP,PP 4p.o \ 4pV 3RlpWCn\4pVPRV4\4o S P^V4VPPVP,PpV\PP,'d*\4pVPRS 4VP pMV 3RlpV\PP,'*p V 'd V\ RpV!V4S ^,RV#)a' Receive a datagram sent to this port using the L{MemoryIOSystem} which created this object. This behaves like L{socket.socket.recv} but the data being I{sent} and I{received} only passes through various memory buffers managed by this object and L{MemoryIOSystem}. @see: L{socket.socket.recv} c*<SPV4R#r)rU)rWr datagramss&&rcapture_FakePort.recv..captures   X &ri90rc.<SPVRRRR4#r)datagramReceived)rips&r _FakePort.recv.. sB,?,?dD$-rN)rrrrAr^rrraddProtorr=rrRrSrr\r]) rCnbytesrreceiverrudpretherr dataHasPIrrs && @@rrecv_FakePort.recvs||&&t||4@@HHJ #% '%,! UH% \ B||&&t||4?? +%%++ + +$&E NN5" %$55    5 5 ; ;;<  ?D|GV$$r)rrN) rjrkrlrmrnrErrurvrws@rrrs ,%,%rr)+rnr*r collectionsrerrnorrrrrrr r functoolsr zope.interfacer twisted.internet.protocolrtwisted.pair.ethernetrtwisted.pair.iprtwisted.pair.rawudprtwisted.pair.tuntaprrrrtwisted.python.compatrr]rrTr%r4r7r9rrrrrrs SSS&62&.WW.    .,/d