/usr/lib/python3/dist-packages/twisted/internet/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/internet/__pycache__/udp.cpython-310.pyc (16584B)
o
bH @ s` d Z ddlZddlZddlZddlmZ ddlmZ ddlm Z e dkrWddl
m Z ddl
m Z dd l
m
Z
mZmZmZmZmZmZ ee ee gZe
eeegZeZe
Ze ZeZndd
l
mZmZmZmZmZmZ eeegZegZdd l m Z m Z m Z m Z m!Z!m"Z" dd l#m$Z$m%Z% ee"j&e"j'e"j(G d
d de j)Z*G dd dZ+ee"j,G dd de+e*Z-dS )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.
N)Optional) implementer) platformTypewin32)WSAEINPROGRESS)WSAEWOULDBLOCK)WSAECONNREFUSED
WSAECONNRESETWSAEINTR WSAEMSGSIZE WSAENETRESETWSAENOPROTOOPT WSAETIMEDOUT)EAGAIN ECONNREFUSEDEINTREMSGSIZE ENOPROTOOPT EWOULDBLOCK)abstractaddressbasedefererror
interfaces)failurelogc @ s e Zd ZU dZejZejZdZ dZ
e e e
d< dZd2ddZed d
Zd efd d
Zdd Zdd Zdd Zdd Zdd Zd3ddZdd Zd d Zd d Z d d! Z d"d# Z d3d$d%Z d&d' Z d(d) Z!d*d+ Z"d,d- Z#d.d/ Z$d0d1 Z%dS )4Porta
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_realPortNumber 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__portprotocol
maxPacketSize interface setLogStr_connectedAddr_setAddressFamily)selfr# protor& r% reactor r- 6/usr/lib/python3/dist-packages/twisted/internet/udp.pyr" [ 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}.
@type addressFamily: L{int}
@param protocol: A C{DatagramProtocol} instance which will be
connected to the C{port}.
@type protocol: 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% )socketfromfd
socketType getsockname_preexistingSocket) clsr, fd
addressFamilyr$ r% r# r& r* r- r- r. _fromListeningDescriptory s z Port._fromListeningDescriptorreturnc C s2 | j d urd| jj d| j dS d| jj dS )N
z not connected>)r r$ __class__r* r- r- r. __repr__ s
z
Port.__repr__c C | j S )z)
Return a socket object.
)r/ r< r- r- r. getHandle 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_connectToProtocolr< r- r- r. startListening s zPort.startListeningc
C s | j du r*z| }|| j| jf W n ty) } z t| j| j|d}~ww | 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)r3 createInternetSocketbindr& r# OSErrorr CannotListenErrorr2 r r msg
_getLogPrefixr$ connectedr/ filenor* sktler- r- r. rA s&
zPort._bindSocketc C s | j | | d S N)r$ makeConnection startReadingr< r- r- r. rB s zPort._connectToProtocolc
C s d}|| j k rsz | j| j\}}W n0 tyB } z$|jd }|tv r*W Y d}~dS |tv r=| jr6| j
W Y d}~dS d}~ww |t |7 }| j tj
krU|dd }z | j || W n
tyk t Y nw || j k sdS dS )z=
Called when my socket is ready for reading.
r N )
maxThroughputr/ recvfromr% rG args_sockErrReadIgnore_sockErrReadRefuser( r$ connectionRefusedlenr6 AF_INET6datagramReceived
BaseExceptionr err)r* readdataaddrsenor- r- r. doRead s0
z Port.doReadc
C s | j rO|d| j fv s J z| j|W S tyN } z/|jd }|tkr/| |W Y d}~S |tkr8t d|t
krB| j n W Y d}~dS d}~ww |dksUJ t
|d sqt
|d sq|d dkrqt|d dt
|d s~|d dkr| jtjkrt|d dt
|d r| jtjkrt|d dz| j||W S ty } z*|jd }|tkr| ||W Y d}~S |tkrt d|t
krW Y d}~dS d}~ww )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 z0write() only accepts IP addresses, not hostnamesz7IPv6 port write() called with IPv4 or broadcast addressz*IPv4 port write() called with IPv6 address)r( r/ sendrG rV r writer r MessageLengthErrorr r$ rY r isIPAddress
isIPv6AddressInvalidAddressErrorr6 r[ AF_INETsendto)r* datagramra rb rc r- r- r. rf sb
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)rf join)r* seqra r- r- r.
writeSequence@ s
zPort.writeSequencec C sL | j rtdt|st|st|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 rh ri r rj r/ connect)r* hostr# r- r- r. rt O s
z Port.connectc C s& | | jr| jd| j d S d S )Nr ) stopReadingrK r, callLaterconnectionLostr< r- r- r. _loseConnection\ s zPort._loseConnectionc C s& | j r t }| _nd }| |S rP )rK r Deferreddry )r* resultr- r- r.
stopListeninga s
zPort.stopListeningc C s t jdtdd | d S )Nz-Please use stopListening() to disconnect portrS )
stacklevel)warningswarnDeprecationWarningr} r< r- r- r. loseConnectioni s zPort.loseConnectionc C sh t d| j d| _d| _tj| | | j | j
| ` | ` t | dr2| j
d | `
dS dS )z&
Cleans up my socket.
z(UDP Port %s Closed)Nr{ )r rI r rT r r! rx r$ doStopr/ closerL hasattrr{ callback)r* reasonr- r- r. rx q s
zPort.connectionLostc C s | | j}d| | _dS )zP
Initialize the C{logstr} attribute to be used by C{logPrefix}.
z%s (UDP)N)rJ r$ logstr)r* logPrefixr- r- r. r' s zPort.setLogStrc C sH t | jr tj| _dS t | jrtj| _dS | jr"t | jddS )z8
Resolve address family for the socket.
rr N)
r ri r& r/ r[ r6 rh rk r rj r< r- r- r. r) s zPort._setAddressFamilyc C r> )z0
Return the prefix to log with.
)r r< r- r- r. r r@ zPort.logPrefixc C sR | j }| jt jkrtjdg|R S | jt jkr'tjdg|dd R 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}
UDPNrS )r/ r2 r6 rk r IPv4Addressr[ IPv6Addressr* ra 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 | jtjtjS )z
Checks if broadcast is currently allowed on this port.
@return: Whether this port may broadcast.
@rtype: L{bool}
)boolr/
getsockoptr r r< r- r- r. getBroadcastAllowed s zPort.getBroadcastAllowed)r r NrP )&__name__
__module__ __qualname____doc__r/ rk r6
SOCK_DGRAMr1 rT r r int__annotations__r3 r" classmethodr7 strr= r? rC rA rB rd rf rq rt ry r} r rx r' r) r r r r r- r- r- r. r > s:
+
#
>
r c @ sl e Zd ZdZdd Zdd Zdd Zdd Zd
d Zd d
Z dd Z
dddZ dd Z dd Z
dddZdS )MulticastMixinz,
Implement multicast functionality.
c C s$ | j t jt j}t td|S )Nz@i)r/ r
IPPROTO_IPIP_MULTICAST_IF inet_ntoastructpack)r* ir- r- r. getOutgoingInterface s z#MulticastMixin.getOutgoingInterfacec C s | j || jS )z Returns Deferred of success.)r, resolve addCallback
_setInterfacer r- r- r. setOutgoingInterface s z#MulticastMixin.setOutgoingInterfacec C s" t |}| j t jt j| dS )NrD )r/ inet_atonr r r )r* ra r r- r- r. r s
z MulticastMixin._setInterfacec C | j t jt jS rP )r/ r r IP_MULTICAST_LOOPr< r- r- r. getLoopbackMode z MulticastMixin.getLoopbackModec C s( t dt|}| jtjtj| d S )Nb)r r r r/ r r r )r* moder- r- r. setLoopbackMode s z MulticastMixin.setLoopbackModec C r rP )r/ r r IP_MULTICAST_TTLr< r- r- r. getTTL r zMulticastMixin.getTTLc C s$ t d|}| jtjtj| d S )NB)r r r/ r r r )r* ttlr- r- r. setTTL s zMulticastMixin.setTTLr c C | j || j|dS )z4Join a multicast group. Returns Deferred of success.rD r, r r
_joinAddr1r* ra r& r- r- r. joinGroup zMulticastMixin.joinGroupc C s | j || j||S rP )r, r r
_joinAddr2)r* ra r& ro r- r- r. r s zMulticastMixin._joinAddr1c
C s t |}t |}|rt j}nt j}z| j t j||| W d S tyA } ztt j
||g|j R W Y d }~S d }~ww rP ) r/ r IP_ADD_MEMBERSHIPIP_DROP_MEMBERSHIPr r rG r Failurer MulticastJoinErrorrV )r* r& ra ro cmder- r- r. r s
(zMulticastMixin._joinAddr2c C r )z2Leave multicast group, return Deferred of success.r r r r- r- r.
leaveGroup r zMulticastMixin.leaveGroupN)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 ZdZ d
ddZdd 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 s~ t | }| jr=|tjtjd ttdr=z |tjtjd W |S t y< } z|j
t kr0n W Y d }~|S d }~ww |S )NrD SO_REUSEPORT) r rE r r r/ r SO_REUSEADDRr r rG errnor rM r- r- r. rE s
z"MulticastPort.createInternetSocket)r r NF)r r r r r" rE r- r- r- r. r s
r ).r r/ r r typingr zope.interfacer twisted.python.runtimer r r r r r r
r r r
r r rW rX r r r r r twisted.internetr r r r r r twisted.pythonr r IListeningPort
IUDPTransport
ISystemHandler! r r IMulticastTransportr r- r- r- r. s> $
|8