U P|j1@sdZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z m Z mZddlmZmZddlmZddlmZmZmZmZmZdd lmZmZdd lmZdd lm Z dd l!m"Z"dd l#m$Z$m%Z%dddgZ&dZ'e(dkse()dse()dr"dZ*dZ+ndZ*dZ+dZ,GdddeZ-eej.Gddde%e$Z/GdddeddZ0Gdd d e Z1Gd!d"d"Z2eej3Gd#ddej4Z5dS)$zc Support for Linux ethernet and IP tunnel devices. @see: U{https://en.wikipedia.org/wiki/TUN/TAP} N) namedtuple)Tuple) Attribute Interface implementer) FlagConstantFlags)Version)abstractdefererror interfacestask)ethernetraw)log) deprecated)fullyQualifiedName) FancyEqMixin FancyStrMixin TunnelFlags TunnelAddress TuntapPortZpariscppcZsparclTiT@iT@lTs /dev/net/tunc@speZdZdZedZedZedZedZedZ edZ edZ ed Z ed Z ed Zed Zed ZdS)ra~ L{TunnelFlags} defines more flags which are used to configure the behavior of a tunnel device. @cvar IFF_TUN: This indicates a I{tun}-type device. This type of tunnel carries IP datagrams. This flag is mutually exclusive with C{IFF_TAP}. @cvar IFF_TAP: This indicates a I{tap}-type device. This type of tunnel carries ethernet frames. This flag is mutually exclusive with C{IFF_TUN}. @cvar IFF_NO_PI: This indicates the I{protocol information} header will B{not} be included in data read from the tunnel. @see: U{https://www.kernel.org/doc/Documentation/networking/tuntap.txt} r @ii i@iN)__name__ __module__ __qualname____doc__rIFF_TUNIFF_TAPZ TUN_FASYNCZTUN_NOCHECKSUMZ TUN_NO_PIZ TUN_ONE_QUEUEZ TUN_PERSISTZ TUN_VNET_HDR IFF_NO_PIZ IFF_ONE_QUEUEZ IFF_VNET_HDRZ IFF_TUN_EXCLr)r)7/tmp/pip-unpacked-wheel-audpp6lv/twisted/pair/tuntap.pyr6sc@s@eZdZdZdZdddfdfZeddZd d Zd d Z d S)rzU A L{TunnelAddress} represents the tunnel to which a L{TuntapPort} is bound. ) _typeValuenametypecCs|jSN)r,)flagr)r)r*^zTunnelAddress.r,cCs|jjS)z Return the integer value of the C{type} attribute. Used to produce correct results in the equality implementation. )r-valueselfr)r)r*r+`szTunnelAddress._typeValuecCs||_||_dS)z @param type: Either L{TunnelFlags.IFF_TUN} or L{TunnelFlags.IFF_TAP}, representing the type of this tunnel. @param name: The system name of the tunnel. @type name: L{bytes} N)r-r,)r4r-r,r)r)r*__init__iszTunnelAddress.__init__cCstjdtddd|jf|S)zS Deprecated accessor for the tunnel name. Use attributes instead. zUTunnelAddress.__getitem__ is deprecated since Twisted 14.0.0 Use attributes instead.r)category stacklevelZTUNTAP)warningswarnDeprecationWarningr,)r4indexr)r)r* __getitem__ts zTunnelAddress.__getitem__N) r"r#r$r%ZcompareAttributesZshowAttributespropertyr+r5r<r)r)r)r*rWs  c@seZdZdZdS)_TunnelDescriptionz Describe an existing tunnel. @ivar fileno: the file descriptor associated with the tunnel @type fileno: L{int} @ivar name: the name of the tunnel @type name: L{bytes} N)r"r#r$r%r)r)r)r*r>sr>z fileno namec@sdeZdZdZedZedZedZdddZdd d Z d d Z d dZ ddZ ddZ ddZdS)_IInputOutputSystemz An interface for performing some basic kinds of I/O (particularly that I/O which might be useful for L{twisted.pair.tuntap}-using code). z@see: L{os.O_RDWR}z@see: L{os.O_NONBLOCK}z@see: L{os.O_CLOEXEC}cCsdS)z" @see: L{os.open} Nr))filenamer/moder)r)r*opensz_IInputOutputSystem.openNcCsdS)z& @see: L{fcntl.ioctl} Nr))fdoptargZ mutate_flagr)r)r*ioctlsz_IInputOutputSystem.ioctlcCsdS)z" @see: L{os.read} Nr))rDlimitr)r)r*readsz_IInputOutputSystem.readcCsdS)z# @see: L{os.write} Nr))rDdatar)r)r*writesz_IInputOutputSystem.writecCsdS)z# @see: L{os.close} Nr))rDr)r)r*closesz_IInputOutputSystem.closecCsdS)a Send a datagram to a certain address. @param datagram: The payload of a UDP datagram 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 local address from which the datagram was sent. @rtype: L{tuple} of (L{bytes}, L{int}) Nr))datagramaddressr)r)r*sendUDPsz_IInputOutputSystem.sendUDPcCsdS)af Return a socket which can be used to receive datagrams sent to the given address. @param fileno: A file descriptor representing a tunnel device which the datagram was either sent via or will be received via. @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. Nr))filenohostportr)r)r* receiveUDPsz_IInputOutputSystem.receiveUDP)r@)NN)r"r#r$r%rO_RDWR O_NONBLOCK O_CLOEXECrCrGrIrKrLrOrSr)r)r)r*r?s  r?c@sZeZdZdZeejZeejZeejZeej Z ee j Z ej Z ej Z eeddZdS) _RealSystemz An interface to the parts of the operating system which L{TuntapPort} relies on. This is most of an implementation of L{_IInputOutputSystem}. rViN)r"r#r$r% staticmethodosrCrIrKrLfcntlrGrTrUgetattrrVr)r)r)r*rWs     rWc@seZdZdZdZd%ddZeddd Zd d Zd d Z ddZ ddZ ddZ ddZ ddZddZeeddddeddZd&dd Zd!d"Zd#d$ZdS)'rzH A Port that reads and writes packets from/to a TUN/TAP-device. ir!NcCstj|rd|_tj|_nd|_tj|_tj|s:t |dkrHt }||_ t j ||||_||_||_||j}|d|jjd|_dS)Nrrz ())rZIEthernetProtocolZ providedByrr'_moder&rZIRawPacketProtocolAssertionErrorrW_systemr FileDescriptorr5 interfaceprotocol maxPacketSizeZ _getLogPrefixr,logstr)r4raprotorcreactorsystem logPrefixr)r)r*r5s   zTuntapPort.__init__)returncCs@t|jjf}|jr|d}n|d}||jj|jf}d|S)N))znot z<%s %slistening on %s/%s>)rrb __class__ connectedr]r,ra)r4argsr)r)r*__repr__s  zTuntapPort.__repr__cCs ||j||dS)z Create and bind my socket, and begin listening on it. This must be called after creating a server to begin listening on the specified tunnel. N) _bindSocketrbZmakeConnectionZ startReadingr3r)r)r*startListening s zTuntapPort.startListeningcCsd|jj|jjB|jjB}tdtf||j}|jt |}|j |t |}t ||dt dS)af Open the named tunnel using the given mode. @param name: The name of the tunnel to open. @type name: L{bytes} @param mode: Flags from L{TunnelFlags} with exactly one of L{TunnelFlags.IFF_TUN} or L{TunnelFlags.IFF_TAP} set. @return: A L{_TunnelDescription} representing the newly opened tunnel. z%dsHN)r_rTrVrUstructpack _IFNAMSIZr2rC _TUN_KO_PATHrG _TUNSETIFFr>strip)r4r,rBflagsconfigrPresultr)r)r* _openTunnels zTuntapPort._openTunnelc Cs~tjd|jj|jdz||j|jtjB\}}Wn2t k rf}zt d|j|W5d}~XYnX||_||_ d|_ dS)z" Open the tunnel. z&%(protocol)s starting on %(interface)s)formatrbraNr)rmsgrbrkrar{r]rr(OSErrorr ZCannotListenError_filenorl)r4rPraer)r)r*ro)s "zTuntapPort._bindSocketcCs|jSr.)rr3r)r)r*rP>szTuntapPort.filenoc Csd}||jkrz|j|j|j}WnXtk rh}z&|jtjtjtj fkrVWY dSW5d}~XYnt k r|YnX|t |7}z|j j |ddWqt k rt|j j}tdd|dYqXqdS)z= Called when my socket is ready for reading. rN)partialzUnhandled exception from z.datagramReceived) maxThroughputr_rIrrcr~errno EWOULDBLOCKEAGAINEINTR BaseExceptionlenrbZdatagramReceivedrrkrerr)r4rIrJrclsr)r)r*doReadAs     zTuntapPort.doReadc CsZz|j|j|WStk rT}z$|jtjkrB||WYSW5d}~XYnXdS)z Write the given data as a single datagram. @param datagram: The data that will make up the complete datagram to be written. @type datagram: L{bytes} N)r_rKrr~rr)r4rMrr)r)r*rKXs  zTuntapPort.writecCs|d|dS)z Write a datagram constructed from a L{list} of L{bytes}. @param seq: The data that will make up the complete datagram to be written. @type seq: L{list} of L{bytes} r1N)rKjoin)r4seqr)r)r* writeSequencegszTuntapPort.writeSequencecCsH||jr|jS|jr:t|jd|j|_d|_|jSt dSdS)z Stop accepting connections on this port. This will shut down my socket and call self.connectionLost(). @return: A L{Deferred} that fires when this port has stopped. rTN) Z stopReadingZ disconnectingZ_stoppedDeferredrlrZ deferLaterrfconnectionLostr Zsucceedr3r)r)r* stopListeningqszTuntapPort.stopListeningZTwistedrcCs|tjdS)zN Close this tunnel. Use L{TuntapPort.stopListening} instead. N)rZ addErrbackrrr3r)r)r*loseConnectionszTuntapPort.loseConnectioncCsFtd|jtj|||jd|_|j |j d|_ dS)zY Cleans up my socket. @param reason: Ignored. Do not use this. z(Tuntap %s Closed)rN) rr}rar r`rrbZdoStoprlr_rLr)r4reasonr)r)r*rs  zTuntapPort.connectionLostcCs|jS)zK Returns the name of my class, to prefix log entries with. )rdr3r)r)r*rhszTuntapPort.logPrefixcCst|j|jS)z Get the local address of this L{TuntapPort}. @return: A L{TunnelAddress} which describes the tunnel device to which this object is bound. @rtype: L{TunnelAddress} )rr]rar3r)r)r*getHostszTuntapPort.getHost)r!NN)N)r"r#r$r%rr5strrnrpr{rorPrrKrrrr rrrhrr)r)r)r*rs"      )6r%rrZrYplatformrrr8 collectionsrtypingrZzope.interfacerrrZ constantlyrr incrementalr Ztwisted.internetr r r r rZ twisted.pairrrZtwisted.pythonrZtwisted.python.deprecaterZtwisted.python.reflectrZtwisted.python.utilrr__all__rtmachine startswithrvZ _TUNGETIFFrurZIAddressrr>r?rWZIListeningPortr`rr)r)r)r*sR         !) F