\d1dZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z m Z mZddlmZmZddlmZddlmZmZmZmZmZdd lmZmZdd lmZdd lm Z dd l!m"Z"dd l#m$Z$m%Z%gdZ&dZ'ej(dksDej()ds"ej()drdZ*dZ+ndZ*dZ+dZ,GddeZ-eej.Gdde%e$Z/GddeddZ0Gdd e Z1Gd!d"Z2eej3Gd#d$ej4Z5dS)%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 TuntapPortpariscppcsparclTiT@iT@lTs /dev/net/tunceZdZdZedZedZedZedZedZ 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_TAP TUN_FASYNCTUN_NOCHECKSUM TUN_NO_PI TUN_ONE_QUEUE TUN_PERSIST TUN_VNET_HDR IFF_NO_PI IFF_ONE_QUEUE IFF_VNET_HDR IFF_TUN_EXCL3lib/python3.11/site-packages/twisted/pair/tuntap.pyrr6s l6""Gl6""Gf%%J!\&))N V$$I L((M,v&&K<''L V$$I L((M<''L<''LLLr7rcFeZdZdZdZddfdfZedZdZdZ d S) rzU A L{TunnelAddress} represents the tunnel to which a L{TuntapPort} is bound. ) _typeValuenametypec|jSN)r;)flags r8zTunnelAddress.^sDIr7r;c|jjS)z Return the integer value of the C{type} attribute. Used to produce correct results in the equality implementation. )r<valueselfs r8r:zTunnelAddress._typeValue`syr7c"||_||_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;)rDr<r;s r8__init__zTunnelAddress.__init__is  r7cXtjdtdd|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 stacklevelTUNTAP)warningswarnDeprecationWarningr;)rDindexs r8 __getitem__zTunnelAddress.__getitem__ts<   &'     $)$U++r7N) r&r'r(r)compareAttributesshowAttributespropertyr:rFrOr6r7r8rrWsp/556?N X    , , , , ,r7rceZdZdZdS)_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)r6r7r8rTrTsr7rTz fileno nameceZdZdZedZedZedZddZddZ d Z d Z d Z d Z d ZdS)_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}cdS)z" @see: L{os.open} Nr6)filenamer?modes r8openz_IInputOutputSystem.openr7NcdS)z& @see: L{fcntl.ioctl} Nr6)fdoptarg mutate_flags r8ioctlz_IInputOutputSystem.ioctlr\r7cdS)z" @see: L{os.read} Nr6)r^limits r8readz_IInputOutputSystem.readr\r7cdS)z# @see: L{os.write} Nr6)r^datas r8writez_IInputOutputSystem.writer\r7cdS)z# @see: L{os.close} Nr6)r^s r8closez_IInputOutputSystem.closer\r7cdS)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}) Nr6)datagramaddresss r8sendUDPz_IInputOutputSystem.sendUDPr\r7cdS)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. Nr6)filenohostports r8 receiveUDPz_IInputOutputSystem.receiveUDPr\r7)rW)NN)r&r'r(r)rO_RDWR O_NONBLOCK O_CLOEXECr[rbrerhrjrnrsr6r7r8rVrVs Y+ , ,F344J 122I                         r7rVceZdZdZeejZeejZeejZeej 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) staticmethodosr[rerhrjfcntlrbrtrugetattrrvr6r7r8rxrxs < D < D L " "E L " "E L % %E YFJK33IIIr7rxceZdZdZdZddZdefdZdZd Z d Z d Z d Z d Z dZdZeeddddedZddZdZdZdS)rzH A Port that reads and writes packets from/to a TUN/TAP-device. ir%Nctj|rd|_tj|_n9d|_tj|_tj|sJ|t}||_ tj ||||_||_||_||j}|d|jjd|_dS)Nrrz ())rIEthernetProtocol providedByrr+_moder*rIRawPacketProtocolrx_systemr FileDescriptorrF interfaceprotocol maxPacketSize _getLogPrefixr;logstr)rDrprotorreactorsystem logPrefixs r8rFzTuntapPort.__init__s  % 0 0 7 7 <DM$,DJJDM$,DJ)44U;; ; ; ; > ]]F ((w777" *&&t}55 "88djo888 r7returnct|jjf}|jr|dz}n|dz}||jj|jfz}d|zS)N))znot z<%s %slistening on %s/%s>)rr __class__ connectedrr;r)rDargss r8__repr__zTuntapPort.__repr__sV!3DM4K!L!L N > $%>Bc|jSr>)rrCs r8rpzTuntapPort.fileno>s |r7cd}||jkr |j|j|j}nM#t $r6}|jt jt jt j fvrYd}~dSd}~wt$rwxYw|t|z } |j |dnB#t$r5t|j j}t!jdd|dYnwxYw||jkdSdS)z= Called when my socket is ready for reading. rN)partialzUnhandled exception from z.datagramReceived) maxThroughputrrerrrerrno EWOULDBLOCKEAGAINEINTR BaseExceptionlenrdatagramReceivedrrrerr)rDrergrclss r8doReadzTuntapPort.doReadAs>T''' |((t7IJJ   7u0%, LLLFFFFF      CII D R ..tQ.????  R R R()@AAP#PPPQQQQQ RT'''''''s,%5 A?*A0/A00A?B22)r&r'r(r)rrFstrrrrrrprrhrrrr rrrrr6r7r8rrs<M9999*2#2222   MMM$*RRR.   """'''(Z 2q!,,m<<11=<1     99999r7r)6r)rr{rzplatformrrK collectionsrtypingrzope.interfacerrr constantlyrr incrementalr twisted.internetr r r rr twisted.pairrrtwisted.pythonrtwisted.python.deprecatertwisted.python.reflectrtwisted.python.utilrr__all__rmachine startswithr _TUNGETIFFrrIAddressrrTrVrxIListeningPortrrr6r7r8rs/    """"""<<<<<<<<<<********EEEEEEEEEEEEEE&&&&&&&&//////555555;;;;;;;;     H(""x$$U++#x$$W--# JJJJJ (((((%(((B Z !!&,&,&,&,&,M<&,&,"!&,R     $8-HH   C C C C C )C C C L44444444& Z &''@9@9@9@9@9(@9@9('@9@9@9r7