← Back
Editing: udp.cpython-38.pyc
U ��W[�H � @ s� d Z ddlmZmZ ddlZddlZddlZddlZddlm Z ddl m Z e dkr�ddl m Z ddl mZmZmZ dd l mZmZmZ dd l mZ dd l mZ ee eegZeeeegZeZeZe ZeZ n8dd l m Z m Z mZmZmZ dd l mZ ee e gZegZddl m Z m Z m!Z! ddl"m#Z#m$Z$ ddl%m&Z& ddl m'Z'm(Z(m)Z) e e)j*e)j+e)j,�G dd� de j-��Z.e&G dd� d��Z/e e)j0�G dd� de/e.��Z1dS )a� Various asynchronous UDP classes. Please do not use this module directly. @var _sockErrReadIgnore: list of symbolic error constants (from the C{errno} module) representing socket errors where the error is temporary and can be ignored. @var _sockErrReadRefuse: list of symbolic error constants (from the C{errno} module) representing socket errors that indicate connection refused. � )�division�absolute_importN)� implementer)� platformTypeZwin32)�WSAEWOULDBLOCK)�WSAEINTR� WSAEMSGSIZE� WSAETIMEDOUT)�WSAECONNREFUSED� WSAECONNRESET� WSAENETRESET)�WSAEINPROGRESS)�WSAENOPROTOOPT)� EWOULDBLOCK�EINTR�EMSGSIZE� ECONNREFUSED�EAGAIN)� ENOPROTOOPT)�base�defer�address)�log�failure)� _oldStyle)�abstract�error� interfacesc @ s� e Zd ZdZejZejZdZ dZ dZ d0dd�Z e dd � �Zd d � Zd d � Zdd� Zdd� Zdd� Zdd� Zd1dd�Zdd� Zdd� Zd d � Zd d � Zd d!� Zd2d"d#�Zd$d%� Z d&d'� Z d(d)� Z d*d+� Z d,d-� Z d.d/� Z!dS )3�Porta� UDP port, listening for packets. @ivar maxThroughput: Maximum number of bytes read in one event loop iteration. @ivar addressFamily: L{socket.AF_INET} or L{socket.AF_INET6}, depending on whether this port is listening on an IPv4 address or an IPv6 address. @ivar _realPortNumber: Actual port number being listened on. The value will be L{None} until this L{Port} is listening. @ivar _preexistingSocket: If not L{None}, a L{socket.socket} instance which was created and initialized outside of the reactor and will be used to listen for connections (instead of a new socket being created by this L{Port}). i N� � c C s@ t j�| |� || _|| _|| _|| _| �� d| _| � � dS )a @param port: A port number on which to listen. @type port: L{int} @param proto: A C{DatagramProtocol} instance which will be connected to the given C{port}. @type proto: L{twisted.internet.protocol.DatagramProtocol} @param interface: The local IPv4 or IPv6 address to which to bind; defaults to '', ie all IPv4 addresses. @type interface: L{str} @param maxPacketSize: The maximum packet size to accept. @type maxPacketSize: L{int} @param reactor: A reactor which will notify this C{Port} when its socket is ready for reading or writing. Defaults to L{None}, ie the default global reactor. @type reactor: L{interfaces.IReactorFDSet} N) r �BasePort�__init__�port�protocol� maxPacketSize� interface� setLogStr�_connectedAddr�_setAddressFamily)�selfr# �protor& r% �reactor� r- �6/usr/lib/python3/dist-packages/twisted/internet/udp.pyr" Y s z Port.__init__c C s8 t �||| j�}|�� d }| d||||d�}||_|S )a� Create a new L{Port} based on an existing listening I{SOCK_DGRAM} socket. @param reactor: A reactor which will notify this L{Port} when its socket is ready for reading or writing. Defaults to L{None}, ie the default global reactor. @type reactor: L{interfaces.IReactorFDSet} @param fd: An integer file descriptor associated with a listening socket. The socket must be in non-blocking mode. Any additional attributes desired, such as I{FD_CLOEXEC}, must also be set already. @type fd: L{int} @param addressFamily: The address family (sometimes called I{domain}) of the existing socket. For example, L{socket.AF_INET}. @param addressFamily: L{int} @param protocol: A C{DatagramProtocol} instance which will be connected to the C{port}. @type proto: L{twisted.internet.protocol.DatagramProtocol} @param maxPacketSize: The maximum packet size to accept. @type maxPacketSize: L{int} @return: A new instance of C{cls} wrapping the socket given by C{fd}. @rtype: L{Port} r N)r& r, r% )�socketZfromfd� socketType� getsockname�_preexistingSocket) �clsr, �fd� addressFamilyr$ r% r# r& r* r- r- r. �_fromListeningDescriptorx s �z Port._fromListeningDescriptorc C s. | j d k r d| jj| j f S d| jjf S d S )Nz <%s on %s>z<%s not connected>)�_realPortNumberr$ � __class__�r* r- r- r. �__repr__� s z Port.__repr__c C s | j S )z) Return a socket object. )r/ r9 r- r- r. � getHandle� s zPort.getHandlec C s | � � | �� dS )z� Create and bind my socket, and begin listening on it. This is called on unserialization, and must be called after creating a server to begin listening on the specified port. N)� _bindSocket�_connectToProtocolr9 r- r- r. �startListening� s zPort.startListeningc C s� | j dkrbz | �� }|�| j| jf� W qn tjk r^ } zt�| j| j|��W 5 d}~X Y qnX n | j }d| _ |�� d | _ t � d| � | j �| j f � d| _|| _| jj| _dS )aJ Prepare and assign a L{socket.socket} instance to C{self.socket}. Either creates a new SOCK_DGRAM L{socket.socket} bound to C{self.interface} and C{self.port} or takes an existing L{socket.socket} provided via the L{interfaces.IReactorSocket.adoptDatagramPort} interface. N� z%s starting on %s)r2 �createInternetSocketZbindr& r# r/ r ZCannotListenErrorr1 r7 r �msg� _getLogPrefixr$ � connected�fileno�r* Zskt�ler- r- r. r< � s & �zPort._bindSocketc C s | j �| � | �� d S �N)r$ ZmakeConnectionZ startReadingr9 r- r- r. r= � s zPort._connectToProtocolc C s� d}|| j k r�z| j�| j�\}}W nd tjk r� } zD|jd }|tkrTW Y �,dS |tkrv| jrl| j � � W Y � dS � W 5 d}~X Y qX |t |�7 }| j tj kr�|dd� }z| j �||� W q t�� Y qX qdS )z= Called when my socket is ready for reading. r N� )� maxThroughputr/ Zrecvfromr% r �args�_sockErrReadIgnore�_sockErrReadRefuser( r$ �connectionRefused�lenr5 �AF_INET6ZdatagramReceivedr �err)r* �read�data�addr�se�nor- r- r. �doRead� s( z Port.doReadc C s� | j r�|d| j fkst�z| j�|�W S tjk r� } zR|jd }|tkr^| �|� W Y �0S |tkrrt� d��n|t kr�| j � � n� W 5 d}~X Y nX �n:|dks�t�t �|d �s�t �|d �s�|d dkr�t�|d d��t �|d ��s |d dk�r | jtjk�r t�|d d��t �|d ��rL| jtjk�rLt�|d d��z| j�||�W S tjk �r� } zX|jd }|tk�r�| �||� W Y �2S |tk�r�t� d��n|t k�r�W Y � dS � W 5 d}~X Y nX dS )az Write a datagram. @type datagram: L{bytes} @param datagram: The datagram to be sent. @type addr: L{tuple} containing L{str} as first element and L{int} as second element, or L{None} @param addr: A tuple of (I{stringified IPv4 or IPv6 address}, I{integer port number}); can be L{None} in connected mode. Nr zmessage too longz <broadcast>z0write() only accepts IP addresses, not hostnamesz7IPv6 port write() called with IPv4 or broadcast addressz*IPv4 port write() called with IPv6 address)r( �AssertionErrorr/ �sendr rJ r �writer ZMessageLengthErrorr r$ rM r � isIPAddress� isIPv6Address�InvalidAddressErrorr5 rO �AF_INETZsendto)r* ZdatagramrS rT rU r- r- r. rY � s` � �� �� � � z Port.writec C s | � d�|�|� dS )a� Write a datagram constructed from an iterable of L{bytes}. @param seq: The data that will make up the complete datagram to be written. @type seq: an iterable of L{bytes} @type addr: L{tuple} containing L{str} as first element and L{int} as second element, or L{None} @param addr: A tuple of (I{stringified IPv4 or IPv6 address}, I{integer port number}); can be L{None} in connected mode. � N)rY �join)r* �seqrS r- r- r. � writeSequence: s zPort.writeSequencec C sL | j rtd��t�|�s.t�|�s.t�|d��||f| _ | j�||f� dS )z- 'Connect' to remote server. z:already connected, reconnecting is not currently supported� not an IPv4 or IPv6 address.N) r( � RuntimeErrorr rZ r[ r r\ r/ �connect)r* Zhostr# r- r- r. rd J s � z Port.connectc C s" | � � | jr | j�d| j� d S )Nr )Z stopReadingrC r, Z callLater�connectionLostr9 r- r- r. �_loseConnectionW s zPort._loseConnectionc C s& | j rt�� }| _nd }| �� |S rG )rC r ZDeferred�drf )r* �resultr- r- r. � stopListening] s zPort.stopListeningc C s t jdtdd� | �� d S )Nz-Please use stopListening() to disconnect portrH )� stacklevel)�warnings�warn�DeprecationWarningri r9 r- r- r. �loseConnectionf s zPort.loseConnectionc C sd t �d| j � d| _d| _tj�| |� | j�� | j � � | ` | ` t | d�r`| j �d� | ` dS )z& Cleans up my socket. z(UDP Port %s Closed)N���rg )r rA r7 rI r r! re r$ ZdoStopr/ �closerD �hasattrrg �callback)r* �reasonr- r- r. re k s zPort.connectionLostc C s | � | j�}d| | _dS )zP Initialize the C{logstr} attribute to be used by C{logPrefix}. z%s (UDP)N)rB r$ �logstr)r* � logPrefixr- r- r. r' | s zPort.setLogStrc C sD t �| j�rtj| _n*t �| j�r,tj| _n| jr@t� | jd��dS )z8 Resolve address family for the socket. rb N) r r[ r& r/ rO r5 rZ r] r r\ r9 r- r- r. r) � s �zPort._setAddressFamilyc C s | j S )z0 Return the prefix to log with. )rt r9 r- r- r. ru � s zPort.logPrefixc C sJ | j �� }| jt jkr$tjd|�� S | jt jkrFtjd|dd� �� S dS )z� Return the local address of the UDP connection @returns: the local address of the UDP connection @rtype: L{IPv4Address} or L{IPv6Address} �UDPNrH )rv )rv )r/ r1 r5 r] r Z IPv4AddressrO Z IPv6Address�r* rS r- r- r. �getHost� s z Port.getHostc C s | j �t jt j|� dS )z� Set whether this port may broadcast. This is disabled by default. @param enabled: Whether the port may broadcast. @type enabled: L{bool} N)r/ � setsockopt� SOL_SOCKET� SO_BROADCAST)r* �enabledr- r- r. �setBroadcastAllowed� s �zPort.setBroadcastAllowedc C s t �| j�tjtj��S )z� Checks if broadcast is currently allowed on this port. @return: Whether this port may broadcast. @rtype: L{bool} )�operator�truthr/ � getsockoptrz r{ r9 r- r- r. �getBroadcastAllowed� s �zPort.getBroadcastAllowed)r r N)N)N)"�__name__� __module__� __qualname__�__doc__r/ r] r5 Z SOCK_DGRAMr0 rI r7 r2 r" � classmethodr6 r: r; r> r< r= rV rY ra rd rf ri rn re r' r) ru rx r} r� r- r- r- r. r < s8 & "! < r c @ sl e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z ddd�Z dd� Z dd� Z ddd�ZdS ) �MulticastMixinz, Implement multicast functionality. c C s$ | j �t jt j�}t �t�d|��S )Nz@i)r/ r� � IPPROTO_IP�IP_MULTICAST_IFZ inet_ntoa�struct�pack)r* �ir- r- r. �getOutgoingInterface� s z#MulticastMixin.getOutgoingInterfacec C s | j �|��| j�S )z Returns Deferred of success.)r, �resolve� addCallback� _setInterfacerw r- r- r. �setOutgoingInterface� s z#MulticastMixin.setOutgoingInterfacec C s" t �|�}| j �t jt j|� dS )Nr? )r/ � inet_atonry r� r� )r* rS r� r- r- r. r� � s z MulticastMixin._setInterfacec C s | j �t jt j�S rG )r/ r� r� �IP_MULTICAST_LOOPr9 r- r- r. �getLoopbackMode� s z MulticastMixin.getLoopbackModec C s* t �dt�|��}| j�tjtj|� d S )N�b)r� r� r~ r r/ ry r� r� )r* �moder- r- r. �setLoopbackMode� s z MulticastMixin.setLoopbackModec C s | j �t jt j�S rG )r/ r� r� �IP_MULTICAST_TTLr9 r- r- r. �getTTL� s zMulticastMixin.getTTLc C s$ t �d|�}| j�tjtj|� d S )N�B)r� r� r/ ry r� r� )r* Zttlr- r- r. �setTTL� s zMulticastMixin.setTTLr c C s | j �|��| j|d�S )z4Join a multicast group. Returns Deferred of success.r? �r, r� r� � _joinAddr1�r* rS r& r- r- r. � joinGroup� s zMulticastMixin.joinGroupc C s | j �|��| j||�S rG )r, r� r� � _joinAddr2)r* rS r& r_ r- r- r. r� � s zMulticastMixin._joinAddr1c C s� t �|�}t �|�}|r t j}nt j}z| j �t j||| � W nB t jk r� } z"t�tj ||f|j �� � W Y �S d }~X Y nX d S rG ) r/ r� ZIP_ADD_MEMBERSHIPZIP_DROP_MEMBERSHIPry r� r r ZFailureZMulticastJoinErrorrJ )r* r& rS r_ �cmd�er- r- r. r� � s zMulticastMixin._joinAddr2c C s | j �|��| j|d�S )z2Leave multicast group, return Deferred of success.r r� r� r- r- r. � leaveGroup� s zMulticastMixin.leaveGroupN)r )r )r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r- r- r- r. r� � s r� c @ s" e Zd ZdZd dd�Zdd � ZdS ) � MulticastPortz. UDP Port that supports multicasting. r r NFc C s t �| |||||� || _dS )zX @see: L{twisted.internet.interfaces.IReactorMulticast.listenMulticast} N)r r" �listenMultiple)r* r# r+ r& r% r, r� r- r- r. r" s zMulticastPort.__init__c C sz t �| �}| jrv|�tjtjd� ttd�rvz|�tjtjd� W n2 tj k rt } z|j t krbn� W 5 d }~X Y nX |S )Nr? � SO_REUSEPORT) r r@ r� ry r/ rz Z SO_REUSEADDRrq r� r �errnor rE r- r- r. r@ s z"MulticastPort.createInternetSocket)r r NF)r� r� r� r� r" r@ r- r- r- r. r� s � r� )2r� Z __future__r r r/ r~ r� rk Zzope.interfacer Ztwisted.python.runtimer r� r r r r r r r r r r rK rL r r r r r Ztwisted.internetr r r Ztwisted.pythonr r Ztwisted.python._oldstyler r r r ZIListeningPortZ IUDPTransportZ ISystemHandler! r r� ZIMulticastTransportr� r- r- r- r. �<module> sT � � C
Save File
Cancel