← Back
Editing: tuntap.cpython-38.pyc
U ��W[�0 � @ s� d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z m Z ddl m Z m Z mZ ddlmZmZ ddlmZ ddlmZ dd lmZ dd lmZ dd lmZm Z m Z m Z m Z dd l m!Z!m"Z" d ddgZ#dZ$dZ%dZ&dZ'G dd � d e �Z(ee j)�G dd� deee*��Z+G dd� dedd��Z,G dd� de �Z-G dd � d e*�Z.ee j/�G d d� dej0��Z1eed d dd�e1j2�e1j3�e1_3dS ) zc Support for Linux ethernet and IP tunnel devices. @see: U{https://en.wikipedia.org/wiki/TUN/TAP} � N)� namedtuple)�Flags� FlagConstant)� Attribute� Interface� implementer)� FancyEqMixin� FancyStrMixin)�Version)�fullyQualifiedName)� deprecated)�log)�abstract�error�task� interfaces�defer)�ethernet�raw� TunnelFlags� TunnelAddress� TuntapPort� i�T@l �T s /dev/net/tunc @ sp e Zd ZdZed�Zed�Zed�Zed�Zed�Z ed�Z ed�Z ed �Z ed �Z ed �Zed �Zed �ZdS )r a~ 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 � �@ � � i i � i @ i � N)�__name__� __module__� __qualname__�__doc__r �IFF_TUN�IFF_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_EXCL� r' r' �5/usr/lib/python3/dist-packages/twisted/pair/tuntap.pyr ( s c @ s@ e Zd ZdZdZddd� fdfZedd� �Zd d � Zd d � Z d S )r zU A L{TunnelAddress} represents the tunnel to which a L{TuntapPort} is bound. )� _typeValue�name�typec C s | j S �N)r* )�flagr' r' r( �<lambda>O � zTunnelAddress.<lambda>r* c C s | j jS )z� Return the integer value of the C{type} attribute. Used to produce correct results in the equality implementation. )r+ �value��selfr' r' r( r) Q s zTunnelAddress._typeValuec C s || _ || _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* )r2 r+ r* r' r' r( �__init__[ s zTunnelAddress.__init__c C s t jdtdd� d| 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)�warnings�warn�DeprecationWarningr* )r2 �indexr' r' r( � __getitem__g s �zTunnelAddress.__getitem__N) r r! r" r# ZcompareAttributesZshowAttributes�propertyr) r3 r: r' r' r' r( r I s c @ s e Zd ZdZdS )�_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< s s r< z fileno namec @ sd e Zd ZdZed�Zed�Zed�Zddd�Zdd d �Z d d � Z d d� Z dd� Z dd� Z dd� 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}� c C s dS )z" @see: L{os.open} Nr' )�filenamer- �moder' r' r( �open� s z_IInputOutputSystem.openNc C s dS )z& @see: L{fcntl.ioctl} Nr' )�fdZopt�argZ mutate_flagr' r' r( �ioctl� s z_IInputOutputSystem.ioctlc C s dS )z" @see: L{os.read} Nr' )rB �limitr' r' r( �read� s z_IInputOutputSystem.readc C s dS )z# @see: L{os.write} Nr' )rB �datar' r' r( �write� s z_IInputOutputSystem.writec C s dS )z# @see: L{os.close} Nr' )rB r' r' r( �close� s z_IInputOutputSystem.closec C s dS )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' )�datagramZaddressr' r' r( �sendUDP� s z_IInputOutputSystem.sendUDPc C s dS )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' )�filenoZhostZportr' r' r( � receiveUDP� s z _IInputOutputSystem.receiveUDP)r> )NN)r r! r" r# r �O_RDWR� O_NONBLOCK� O_CLOEXECrA rD rF rH rI rK rM r' r' r' r( r= � s r= c @ sZ e Zd ZdZeej�Zeej�Zeej�Zeej �Z ee j �Z ej Z ej Z eedd�ZdS )� _RealSystemz� An interface to the parts of the operating system which L{TuntapPort} relies on. This is most of an implementation of L{_IInputOutputSystem}. rP i N)r r! r" r# � staticmethod�osrA rF rH rI �fcntlrD rN rO �getattrrP r' r' r' r( rQ � s rQ c @ s� e Zd ZdZdZd!dd�Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zd"dd �Zd d � Zd d � ZdS )#r zH A Port that reads and writes packets from/to a TUN/TAP-device. i r Nc C s� t j�|�r d| _ tj| _n d| _ tj| _tj�|�s:t �|d krHt � }|| _ t j �| |� || _|| _|| _| �| j�}d|| jjf | _d S )Nr r z%s (%s))r ZIEthernetProtocolZ providedByr r% �_moder$ r ZIRawPacketProtocol�AssertionErrorrQ �_systemr �FileDescriptorr3 � interface�protocol� maxPacketSizeZ _getLogPrefixr* �logstr)r2 rZ �protor\ �reactor�system� logPrefixr' r' r( r3 � s zTuntapPort.__init__c C s@ t | jj�f}| jr |d }n|d }|| jj| jf }d| S )N)� )znot z<%s %slistening on %s/%s>)r r[ � __class__� connectedrV r* rZ )r2 �argsr' r' r( �__repr__� s zTuntapPort.__repr__c C s | � � | 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)� _bindSocketr[ ZmakeConnectionZ startReadingr1 r' r' r( �startListening s zTuntapPort.startListeningc C sd | j j| j jB | j jB }t�dtf ||j�}| j �t |�}| j � |t |�}t ||dt� � d��S )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� )rX rN rP rO �structZpack� _IFNAMSIZr0 rA � _TUN_KO_PATHrD � _TUNSETIFFr< �strip)r2 r* r@ �flagsZconfigrL �resultr' r' r( � _openTunnel s ��zTuntapPort._openTunnelc C s� t jd| jj| jd� z | �| j| jtjB �\}}W n6 t t fk rj } zt � d| j|��W 5 d}~X Y nX || _|| _ d| _dS )z" Open the tunnel. z&%(protocol)s starting on %(interface)s)�formatr[ rZ Nr )r �msgr[ rc rZ rq rV r r& �IOError�OSErrorr ZCannotListenError�_filenord )r2 rL rZ �er' r' r( rg ( s � � "zTuntapPort._bindSocketc C s | j S r, )rv r1 r' r' r( rL < s zTuntapPort.filenoc C s� d}|| j k r�z| j�| j| j�}W nP tk rh } z&|jtjtjtj fkrVW Y � dS � W 5 d}~X Y n � Y nX |t |�7 }z| j j |dd� W q t | j j�}t�dd|f � Y qX qdS )z= Called when my socket is ready for reading. r N)�partialz,Unhandled exception from %s.datagramReceived)� maxThroughputrX rF rv r\ �EnvironmentError�errnoZ EWOULDBLOCKZEAGAIN�EINTR�lenr[ ZdatagramReceivedr rc r �err)r2 rF rG rw �clsr' r' r( �doRead@ s& �zTuntapPort.doReadc C sZ z| j �| j|�W S tk rT } z$|jtjkrB| �|� W Y �S � W 5 d}~X Y nX dS )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)rX rH rv rt r{ r| )r2 rJ rw r' r' r( rH Z s zTuntapPort.writec C s | � d�|�� dS )z� Write a datagram constructed from a L{list} of L{bytes}. @param datagram: The data that will make up the complete datagram to be written. @type seq: L{list} of L{bytes} r/ N)rH �join)r2 �seqr' r' r( � writeSequencej s zTuntapPort.writeSequencec C sH | � � | jr| jS | jr:t�| jd| j�| _d| _| jS t� d�S dS )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. r TN) Z stopReadingZ disconnectingZ_stoppedDeferredrd r Z deferLaterr_ �connectionLostr Zsucceedr1 r' r' r( � stopListeningu s �zTuntapPort.stopListeningc C s | � � �tj� dS )zN Close this tunnel. Use L{TuntapPort.stopListening} instead. N)r� Z addErrbackr r~ r1 r' r' r( �loseConnection� s zTuntapPort.loseConnectionc C sF t �d| j � tj�| |� | j�� d| _| j � | j � d| _ dS )zY Cleans up my socket. @param reason: Ignored. Do not use this. z(Tuntap %s Closed)r ���N) r rs rZ r rY r� r[ ZdoStoprd rX rI rv )r2 �reasonr' r' r( r� � s zTuntapPort.connectionLostc C s | j S )zK Returns the name of my class, to prefix log entries with. )r] r1 r' r' r( ra � s zTuntapPort.logPrefixc C s t | j| j�S )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} )r rV rZ r1 r' r' r( �getHost� s zTuntapPort.getHost)r NN)N)r r! r" r# ry r3 rf rh rq rg rL r� rH r� r� r� r� ra r� r' r' r' r( r � s$ � ZTwisted� )4r# rS rT r{ rj r6 � collectionsr Z constantlyr r Zzope.interfacer r r Ztwisted.python.utilr r Z incrementalr Ztwisted.python.reflectr Ztwisted.python.deprecater Ztwisted.pythonr Ztwisted.internetr r r r r Z twisted.pairr r �__all__rk rm Z _TUNGETIFFrl r ZIAddress�objectr r< r= rQ ZIListeningPortrY r r� r� r' r' r' r( �<module> sL �!) L P ��
Save File
Cancel