Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/pair/__pycache__/tuntap.cpython-39.pyc
Ðазад
a k�h�0 � @ sl d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z ddl m Z m Z m Z ddlmZmZ ddlmZ ddlmZmZmZmZmZ dd lmZmZ dd l m Z dd l m Z dd l m!Z! dd l"m#Z#m$Z$ g d�Z%dZ&dZ'dZ(dZ)G dd� de�Z*e ej+�G dd� de$e#��Z,G dd� dedd��Z-G dd� de �Z.G d d � d �Z/e ej0�G d d � d ej1��Z2dS ) zc Support for Linux ethernet and IP tunnel devices. @see: U{https://en.wikipedia.org/wiki/TUN/TAP} � N)� namedtuple)�Tuple)� Attribute� Interface� implementer)� FlagConstant�Flags)�Version)�abstract�defer�error� interfaces�task)�ethernet�raw)�log)� deprecated)�fullyQualifiedName)� FancyEqMixin� FancyStrMixin)� 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( ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/pair/tuntap.pyr , s r 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>T � 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* V 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+ )r3 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+ )r3 �indexr( r( r) � __getitem__j s �zTunnelAddress.__getitem__N) r! r" r# r$ ZcompareAttributesZshowAttributes�propertyr* r4 r; r( r( r( r) r M s r 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= w 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( )�fd�opt�argZ mutate_flagr( r( r) �ioctl� s z_IInputOutputSystem.ioctlc C s dS )z" @see: L{os.read} Nr( )rC �limitr( r( r) �read� s z_IInputOutputSystem.readc C s dS )z# @see: L{os.write} Nr( )rC �datar( r( r) �write� s z_IInputOutputSystem.writec C s dS )z# @see: L{os.close} Nr( )rC 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( )�datagram�addressr( 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( )�fileno�host�portr( r( r) � receiveUDP� s z _IInputOutputSystem.receiveUDP)r? )NN)r! r" r# r$ r �O_RDWR� O_NONBLOCK� O_CLOEXECrB rF rH rJ rK rN rR 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}. rU i N)r! r" r# r$ � staticmethod�osrB rH rJ rK �fcntlrF rS rT �getattrrU r( r( r( r) rV � s rV c @ s� e Zd ZdZdZd%dd�Zed�dd �Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zeeddd d �e�d d � �Zd&d d �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:J �|d u rHt � }|| _ t j � | |� || _|| _|| _| �| j�}|� d| jj� d�| _d S )Nr r z (�))r ZIEthernetProtocolZ providedByr r& �_moder% r ZIRawPacketProtocolrV �_systemr �FileDescriptorr4 � interface�protocol� maxPacketSizeZ _getLogPrefixr+ �logstr)r3 r_ �protora �reactor�system� logPrefixr( r( r) r4 � s zTuntapPort.__init__)�returnc C s@ t | jj�f}| jr |d }n|d }|| jj| jf }d| S )N)� )znot z<%s %slistening on %s/%s>)r r` � __class__� connectedr\ r+ r_ )r3 �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 startReadingr2 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� )r] rS rU rT �struct�pack� _IFNAMSIZr1 rB � _TUN_KO_PATHrF � _TUNSETIFFr= �strip)r3 r+ rA �flags�configrO �resultr( r( r) � _openTunnel s zTuntapPort._openTunnelc C s� t jd| jj| jd� z | �| j| jtjB �\}}W n4 t yh } z t � d| j|��W Y d}~n d}~0 0 || _|| _ d| _ dS )z" Open the tunnel. z&%(protocol)s starting on %(interface)s)�formatr` r_ Nr )r �msgr` ri r_ ry r\ r r' �OSErrorr ZCannotListenError�_filenorj )r3 rO r_ �er( r( r) rm s �� &zTuntapPort._bindSocketc C s | j S r- )r} r2 r( r( r) rO 4 s zTuntapPort.filenoc C s� d}|| j k r�z| j�| j| j�}W n\ tyn } z2|jtjtjtj fv rXW Y d}~dS � W Y d}~n d}~0 t y� � Y n0 |t |�7 }z| j j |dd� W q t y� t| j j�}t�dd|� d�� Y q0 qdS )z= Called when my socket is ready for reading. r N)�partialzUnhandled exception from z.datagramReceived)� maxThroughputr] rH r} ra r| �errno� EWOULDBLOCK�EAGAIN�EINTR� BaseException�lenr` ZdatagramReceivedr ri r �err)r3 rH rI r~ �clsr( r( r) �doRead7 s zTuntapPort.doReadc C s` z| j �| j|�W S tyZ } z0|jtjkrD| �|�W Y d}~S � W Y d}~n d}~0 0 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)r] rJ r} r| r� r� )r3 rL r~ r( r( r) rJ N s zTuntapPort.writec C s | � 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} r0 N)rJ �join)r3 �seqr( r( r) � writeSequence] 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_stoppedDeferredrj r Z deferLaterrd �connectionLostr Zsucceedr2 r( r( r) � stopListeningg s �zTuntapPort.stopListeningZTwisted� r c C s | � � �tj� dS )zN Close this tunnel. Use L{TuntapPort.stopListening} instead. N)r� Z addErrbackr r� r2 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 r{ r_ r r^ r� r` ZdoStoprj r] rK r} )r3 �reasonr( r( r) r� � s zTuntapPort.connectionLostc C s | j S )zK Returns the name of my class, to prefix log entries with. )rb r2 r( r( r) rf � 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 r\ r_ r2 r( r( r) �getHost� s zTuntapPort.getHost)r NN)N)r! r" r# r$ r� r4 �strrl rn ry rm rO r� rJ r� r� r r r� r� rf r� r( r( r( r) r � s" r )3r$ r� rY rX rp r7 � collectionsr �typingr Zzope.interfacer r r Z constantlyr r � incrementalr Ztwisted.internetr r r r r Z twisted.pairr r Ztwisted.pythonr Ztwisted.python.deprecater Ztwisted.python.reflectr Ztwisted.python.utilr r �__all__rr rt Z _TUNGETIFFrs r ZIAddressr r= r> rV ZIListeningPortr^ r r( r( r( r) �<module> s: !) F
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка