U ¹êW[‰Hã@sœdZddlmZmZddlZddlZddlZddlZddlm Z ddl m Z e dkrÊddl m Z ddl mZmZmZdd l mZmZmZdd l mZdd l mZee eegZeeeegZeZeZe ZeZn8dd l mZmZmZmZmZdd l mZeeegZegZddlmZm Z m!Z!ddl"m#Z#m$Z$ddl%m&Z&ddlm'Z'm(Z(m)Z)e e)j*e)j+e)j,ƒGdd„dej-ƒƒZ.e&Gdd„dƒƒZ/e e)j0ƒGdd„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ÚeZdZdZejZejZdZ dZ dZ d0dd„Z e dd „ƒZd d „Zd d „Zdd„Zdd„Zdd„Zdd„Zd1dd„Zdd„Zdd„Zdd„Zdd„Zd d!„Zd2d"d#„Zd$d%„Zd&d'„Zd(d)„Zd*d+„Zd,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}). iNÚé cCs@tj ||¡||_||_||_||_| ¡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"Ysz Port.__init__c Cs8t |||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} rN)r&r,r%)ÚsocketZfromfdÚ socketTypeÚ getsocknameÚ_preexistingSocket) Úclsr,ÚfdÚ addressFamilyr$r%r#r&r*r-r-r.Ú_fromListeningDescriptorxs  ÿzPort._fromListeningDescriptorcCs.|jdk rd|jj|jfSd|jjfSdS)Nz <%s on %s>z<%s not connected>)Ú_realPortNumberr$Ú __class__©r*r-r-r.Ú__repr__Ÿs z Port.__repr__cCs|jS)z) Return a socket object. )r/r9r-r-r.Ú getHandle¥szPort.getHandlecCs| ¡| ¡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Ú_connectToProtocolr9r-r-r.ÚstartListening«szPort.startListeningc Cs²|jdkrbz| ¡}| |j|jf¡Wqntjk r^}zt |j|j|¡‚W5d}~XYqnXn |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/rZCannotListenErrorr1r7rÚmsgÚ _getLogPrefixr$Ú connectedÚfileno©r*ZsktÚler-r-r.r<¶s & ÿzPort._bindSocketcCs|j |¡| ¡dS©N)r$ZmakeConnectionZ startReadingr9r-r-r.r=Øs zPort._connectToProtocolc CsÜd}||jkrØz|j |j¡\}}Wndtjk rˆ}zD|jd}|tkrTWY¢,dS|tkrv|jrl|j   ¡WY¢ dS‚W5d}~XYqX|t |ƒ7}|j tj kr®|dd…}z|j  ||¡Wqt ¡YqXqdS)z= Called when my socket is ready for reading. rNé)Ú 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 CsÜ|jrž|d|jfkst‚z|j |¡WStjk r˜}zR|jd}|tkr^| |¡WY¢0S|tkrrt  d¡‚n|t kr†|j   ¡n‚W5d}~XYnXn:|dksªt‚t  |d¡sât  |d¡sâ|ddkrât |dd¡‚t  |d¡s|ddkr|jtjkrt |dd¡‚t  |d¡rL|jtjkrLt |dd¡‚z|j ||¡WStjk rÖ}zX|jd}|tkrš| ||¡WY¢2S|tkr°t  d¡‚n|t krÄWY¢ dS‚W5d}~XYnXdS)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. Nrzmessage 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(ÚAssertionErrorr/ÚsendrrJrÚwriterZMessageLengthErrorrr$rMrÚ isIPAddressÚ isIPv6AddressÚInvalidAddressErrorr5rOÚAF_INETZsendto)r*ZdatagramrSrTrUr-r-r.rYþs`      ÿ þþ ÿþ ÿÿ      z Port.writecCs| 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*ÚseqrSr-r-r.Ú writeSequence:s zPort.writeSequencecCsL|jrtdƒ‚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(Ú RuntimeErrorrrZr[rr\r/Úconnect)r*Zhostr#r-r-r.rdJsÿ z Port.connectcCs"| ¡|jr|j d|j¡dS)Nr)Z stopReadingrCr,Z callLaterÚconnectionLostr9r-r-r.Ú_loseConnectionWszPort._loseConnectioncCs&|jrt ¡}|_nd}| ¡|SrG)rCrZDeferredÚdrf)r*Úresultr-r-r.Ú stopListening]s zPort.stopListeningcCstjdtdd| ¡dS)Nz-Please use stopListening() to disconnect portrH)Ú stacklevel)ÚwarningsÚwarnÚDeprecationWarningrir9r-r-r.ÚloseConnectionfszPort.loseConnectioncCsdt 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)rrAr7rIrr!rer$ZdoStopr/ÚcloserDÚhasattrrgÚcallback)r*Úreasonr-r-r.reks    zPort.connectionLostcCs| |j¡}d||_dS)zP Initialize the C{logstr} attribute to be used by C{logPrefix}. z%s (UDP)N)rBr$Úlogstr)r*Ú logPrefixr-r-r.r'|s zPort.setLogStrcCsDt |j¡rtj|_n*t |j¡r,tj|_n|jr@t  |jd¡‚dS)z8 Resolve address family for the socket. rbN) rr[r&r/rOr5rZr]rr\r9r-r-r.r)„s    ÿzPort._setAddressFamilycCs|jS)z0 Return the prefix to log with. )rtr9r-r-r.ru‘szPort.logPrefixcCsJ|j ¡}|jtjkr$tjd|žŽS|jtjkrFtjd|dd…žŽSdS)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/r1r5r]rZ IPv4AddressrOZ IPv6Address©r*rSr-r-r.ÚgetHost˜s    z Port.getHostcCs|j tjtj|¡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.setBroadcastAllowedcCst |j tjtj¡¡S)z“ Checks if broadcast is currently allowed on this port. @return: Whether this port may broadcast. @rtype: L{bool} )ÚoperatorÚtruthr/Ú getsockoptrzr{r9r-r-r.ÚgetBroadcastAllowed±sÿzPort.getBroadcastAllowed)rr N)N)N)"Ú__name__Ú __module__Ú __qualname__Ú__doc__r/r]r5Z SOCK_DGRAMr0rIr7r2r"Ú classmethodr6r:r;r>r<r=rVrYrardrfrirnrer'r)rurxr}rr-r-r-r.r<s8  & "! <     rc@sleZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z ddd„Z dd„Z dd„Z ddd„ZdS)ÚMulticastMixinz, Implement multicast functionality. cCs$|j tjtj¡}t t d|¡¡S)Nz@i)r/r€Ú IPPROTO_IPÚIP_MULTICAST_IFZ inet_ntoaÚstructÚpack)r*Úir-r-r.ÚgetOutgoingInterfaceÃsz#MulticastMixin.getOutgoingInterfacecCs|j |¡ |j¡S)zReturns Deferred of success.)r,ÚresolveÚ addCallbackÚ _setInterfacerwr-r-r.ÚsetOutgoingInterfaceÈsz#MulticastMixin.setOutgoingInterfacecCs"t |¡}|j tjtj|¡dS)Nr?)r/Ú inet_atonryrˆr‰)r*rSrŒr-r-r.rÍs zMulticastMixin._setInterfacecCs|j tjtj¡SrG)r/r€rˆÚIP_MULTICAST_LOOPr9r-r-r.ÚgetLoopbackModeÓszMulticastMixin.getLoopbackModecCs*t dt |¡¡}|j tjtj|¡dS)NÚb)rŠr‹r~rr/ryrˆr“)r*Úmoder-r-r.ÚsetLoopbackMode×szMulticastMixin.setLoopbackModecCs|j tjtj¡SrG)r/r€rˆÚIP_MULTICAST_TTLr9r-r-r.ÚgetTTLÜszMulticastMixin.getTTLcCs$t d|¡}|j tjtj|¡dS)NÚB)rŠr‹r/ryrˆr˜)r*Zttlr-r-r.ÚsetTTLàs zMulticastMixin.setTTLrcCs|j |¡ |j|d¡S)z4Join a multicast group. Returns Deferred of success.r?©r,rŽrÚ _joinAddr1©r*rSr&r-r-r.Ú joinGroupåszMulticastMixin.joinGroupcCs|j |¡ |j||¡SrG)r,rŽrÚ _joinAddr2)r*rSr&r_r-r-r.rêszMulticastMixin._joinAddr1c Csˆt |¡}t |¡}|r tj}ntj}z|j tj|||¡WnBtjk r‚}z"t tj ||f|j žŽ¡WY¢Sd}~XYnXdSrG) r/r’ZIP_ADD_MEMBERSHIPZIP_DROP_MEMBERSHIPryrˆrrZFailureZMulticastJoinErrorrJ)r*r&rSr_ÚcmdÚer-r-r.r îs  zMulticastMixin._joinAddr2cCs|j |¡ |j|d¡S)z2Leave multicast group, return Deferred of success.rrœržr-r-r.Ú leaveGroupûszMulticastMixin.leaveGroupN)r)r)r‚rƒr„r…rr‘rr”r—r™r›rŸrr r£r-r-r-r.r‡½s  r‡c@s"eZdZdZd dd„Zdd „ZdS) Ú MulticastPortz. UDP Port that supports multicasting. rr NFcCst ||||||¡||_dS)zX @see: L{twisted.internet.interfaces.IReactorMulticast.listenMulticast} N)rr"ÚlistenMultiple)r*r#r+r&r%r,r¥r-r-r.r"szMulticastPort.__init__c Cszt |¡}|jrv| tjtjd¡ttdƒrvz| tjtjd¡Wn2tj k rt}z|j t krbn‚W5d}~XYnX|S)Nr?Ú SO_REUSEPORT) rr@r¥ryr/rzZ SO_REUSEADDRrqr¦rÚerrnorrEr-r-r.r@s   z"MulticastPort.createInternetSocket)rr NF)r‚rƒr„r…r"r@r-r-r-r.r¤s ÿ r¤)2r…Z __future__rrr/r~rŠrkZzope.interfacerZtwisted.python.runtimerr§rrrr r r r r rrrKrLrrrrrZtwisted.internetrrrZtwisted.pythonrrZtwisted.python._oldstylerrrrZIListeningPortZ IUDPTransportZ ISystemHandler!rr‡ZIMulticastTransportr¤r-r-r-r.ÚsT       ÿ   þC