VhBdZddlmZddlZddlZddlmZddlmZddl m Z ddl m Z ddl mZdd lmZed k(r3dd lmZdd lmZdd lmZmZmZmZmZmZmZeeeegZeeeegZeZeZeZ eZ!nddlm Z mZm!Z!mZmZm"Z"e e!e"gZegZddl#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)ddl*m+Z+ee)jXe)jZe)j\Gdde&j^Z0ee)jbGdde e0Z2y)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. ) annotationsN)Optional) implementer)MulticastMixin)IReactorMulticast)AbstractDatagramProtocol) platformTypewin32)WSAEINPROGRESS)WSAEWOULDBLOCK)WSAECONNREFUSED WSAECONNRESETWSAEINTR WSAEMSGSIZE WSAENETRESETWSAENOPROTOOPT WSAETIMEDOUT)EAGAIN ECONNREFUSEDEINTREMSGSIZE ENOPROTOOPT EWOULDBLOCK)abstractaddressbasedefererror interfaces)logceZdZUdZej Zded<ejZ ded<dZ dZ ded <dZ dd Z ed Zd d Zd ZdZdZdZdZd!dZdZdZdZdZdZd!dZdZdZdZdZ dZ!dZ"y)"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}). zsocket.AddressFamily addressFamilyzsocket.SocketKind socketTypeiNz Optional[int]_realPortNumberctjj||||_||_||_||_|jd|_|jy)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) rBasePort__init__portprotocol maxPacketSize interface setLogStr_connectedAddr_setAddressFamily)selfr)protor,r+reactors D/home/dcms/DCMS/lib/python3.12/site-packages/twisted/internet/udp.pyr(z Port.__init__]sS* tW-  *" "  ctj|||j}|jd}|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} rN)r,r2r+)socketfromfdr$ getsockname_preexistingSocket) clsr2fdr#r*r+r)r,r0s r3_fromListeningDescriptorzPort._fromListeningDescriptor{sV@}}R?$$&q)   '  #' r4c|j'd|jjd|jdSd|jjdS)Nz not connected>)r%r* __class__r0s r3__repr__z Port.__repr__sO    +t}}../tD4H4H3IK Kt}}../? ?r4c|jS)z) Return a socket object. )r6rAs r3 getHandlezPort.getHandle{{r4cD|j|jy)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_connectToProtocolrAs r3startListeningzPort.startListenings  !r4c(|j9 |j}|j|j|jfn|j}d|_|jd|_ tj|j|jd|jd|_||_|jj |_y#t $r0}t j|j|j|d}~wwxYw)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. Nz starting on )r9createInternetSocketbindr,r)OSErrorrCannotListenErrorr8r%r msg _getLogPrefixr* connectedr6filenor0sktles r3rGzPort._bindSockets  " " * M//1$..$))45 ))C&*D # #03 !!$--0$2F2F H  kk(( % M--dnndiiLL Ms7C D!+D  DcZ|jj||jyN)r*makeConnection startReadingrAs r3rHzPort._connectToProtocols  $$T* r4c<d}||jkr |jj|j\}}|t |z }|j tj k(r|dd} |jj||||jkryy#t$rtjY1wxYw#t$rU}|jd}|tvrYd}~y|tvr+|j r|jj#Yd}~yd}~wwxYw)z= Called when my socket is ready for reading. rN) maxThroughputr6recvfromr+lenr#AF_INET6r*datagramReceived BaseExceptionr errrNargs_sockErrReadIgnore_sockErrReadRefuser.connectionRefused)r0readdataaddrsenos r3doReadz Port.doReadsT''' ![[11$2D2DE dD !%%8 8DMM224>/T'''0%GGI+ WWQZ++++** 779 s5(B=,BB:9B:= DD".DDDc|jr.|d|jfvsJ |jj|S|dk7sJtj|ds9tj|ds!|ddk7rtj |ddtj|ds|ddk(r6|j"tj$k(rtj |ddtj|dr6|j"tj&k(rtj |dd |jj)||S#t$r{}|jd}|t k(r|j |cYd}~S|tk(rtjd|tk(r|jjnYd}~yd}~wwxYw#t$ra}|jd}|t k(r|j ||cYd}~S|tk(rtjd|tk(rYd}~yd}~wwxYw)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.r6sendrNrdrwriterrMessageLengthErrorrr*rgr isIPAddress isIPv6AddressInvalidAddressErrorr#r`AF_INETsendto)r0datagramrjrkrls r3rpz Port.writes   D$"5"566 66 {{''114< <((a1 ..tAw7G},//GO$$T!W-aM1I$$7//GV%%d1g.43E3E3W//GI {{))(D99? WWQZ;::h//8^223EFF<'MM3356 @ WWQZ;::h558^223EFF<' sNE8G G(GG AGG I$)I I'I?IIcF|jdj||y)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. r4N)rpjoin)r0seqrjs r3 writeSequencezPort.writeSequenceBs 388C=$'r4c|jr tdtj|s+tj|st j |d||f|_|jj||fy)z- 'Connect' to remote server. z:already connected, reconnecting is not currently supportednot an IPv4 or IPv6 address.N) r. RuntimeErrorrrrrsrrtr6connect)r0hostr)s r3rz Port.connectQsp   L ##D)(2H2H2N++D2PQ Q#Tl T4L)r4c|j|jr'|jjd|jyy)Nr) stopReadingrRr2 callLaterconnectionLostrAs r3_loseConnectionzPort._loseConnection^s4  >> LL " "1d&9&9 : r4cz|jrtjx}|_nd}|j |SrX)rRrDeferreddr)r0results r3 stopListeningzPort.stopListeningcs2 >>#nn. .FTVF  r4c\tjdtd|jy)Nz-Please use stopListening() to disconnect portr\) stacklevel)warningswarnDeprecationWarningrrAs r3loseConnectionzPort.loseConnectionks% ;  r4chtjd|jzd|_d|_tj j |||jj|jj|` |` t|dr|jjd|` yy)z& Cleans up my socket. z(UDP Port %s Closed)Nr)r rPr%r]rr'rr*doStopr6closerShasattrrcallback)r0reasons r3rzPort.connectionLostss &)=)==># $$T62   K K 4  FFOOD ! r4cN|j|j}d|z|_y)zP Initialize the C{logstr} attribute to be used by C{logPrefix}. z%s (UDP)N)rQr*logstr)r0 logPrefixs r3r-zPort.setLogStrs$&&t}}5  9, r4c0tj|jrtj|_ytj |jrtj|_y|jr tj|jdy)z8 Resolve address family for the socket. r}N) rrsr,r6r`r#rrrurrtrAs r3r/zPort._setAddressFamilysi  ! !$.. 1!'D   ! !$.. 1!'D  ^^++ > r4c|jS)z0 Return the prefix to log with. )rrAs r3rzPort.logPrefixrEr4c |jj}|jtjk(rt j dg|S|jtj k(rt jdg|ddSy)z Return the local address of the UDP connection @returns: the local address of the UDP connection @rtype: L{IPv4Address} or L{IPv6Address} UDPNr\)r6r8r#rur IPv4Addressr` IPv6Address)r0rjs r3getHostz Port.getHostsq{{&&(    /&&u4t4 4   6?? 2&&u:Ra: :3r4cv|jjtjtj|y)z Set whether this port may broadcast. This is disabled by default. @param enabled: Whether the port may broadcast. @type enabled: L{bool} N)r6 setsockopt SOL_SOCKET SO_BROADCAST)r0enableds r3setBroadcastAllowedzPort.setBroadcastAlloweds& v00&2E2EwOr4ct|jjtjtjS)z Checks if broadcast is currently allowed on this port. @return: Whether this port may broadcast. @rtype: L{bool} )boolr6 getsockoptrrrAs r3getBroadcastAllowedzPort.getBroadcastAlloweds,DKK**6+<+Q>QRSSr4) N)returnstrrX)#__name__ __module__ __qualname____doc__r6rur#__annotations__ SOCK_DGRAMr$r]r%r9r( classmethodr<rBrDrIrGrHrmrpr{rrrrrr-r/rrrrr4r3r"r"@s$+1..M'8$*$5$5J!5M%)O])!<))V@  "!)F@<| ( *;  -  ;PTr4r"cDeZdZdZ d ddZddZy) MulticastPortz. UDP Port that supports multicasting. NcFtj||||||||_y)zX @see: L{twisted.internet.interfaces.IReactorMulticast.listenMulticast} N)r"r(listenMultiple)r0r)r1r,r+r2rs r3r(zMulticastPort.__init__s" dD%M7K,r4ctj|}|jrq|jtj tj dttdr2 |jtj tjd|S|S#t$r }|jtk(rnYd}~|Sd}~wwxYw)z Override L{Port.createInternetSocket} to configure the socket to honor the C{listenMultiple} argument to L{IReactorMulticast.listenMultiple}. rK SO_REUSEPORTN) r"rLrrr6r SO_REUSEADDRrrrNerrnorrTs r3rLz"MulticastPort.createInternetSockets ''-    NN6,,f.A.A1 Ev~.NN6#4#4f6I6I1M s xx;. s"/B B>B99B>)rrNF)r)intr1rr,rr+rr2zIReactorMulticast | NonerrrNone)rz socket.socket)rrrrr(rLrr4r3rrsc!,0$ - -( - -  - * - -  -r4r)3r __future__rr6rtypingrzope.interfacertwisted.internet._multicastrtwisted.internet.interfacesrtwisted.internet.protocolrtwisted.python.runtimer rr r r rrrrrrrrerfrrrrrtwisted.internetrrrrrrtwisted.pythonr IListeningPort IUDPTransport ISystemHandler'r"IMulticastTransportrrr4r3rs #&69>/7$$#NKP)=, UH"L F EUU %5&ON z779Q9QwT4==wTwTt  Z + +,%ND%-%r4