+ DfjBRt^RIHt^RIt^RIt^RIHt^RIHt^RI H t ^RI H t ^RI Ht^RIHt]R 8Xd4^R IHt^R IHt^R IHtHtHtHtHtHtHt]]]].t]]]].t]t]t]t ]t!M^R IH t HtH!t!HtHtH"t"] ]!]".t].t^RI#H$t$H%t%H&t&H't'H(t(H)t)^RI*H+t+]!])PX])PZ])P\4!RR]&P^44t0]!])Pb4!RR] ]044t2R#)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)logc]tRt^@t$Rt]P tR]R&]Pt R]R&R t Rt R]R&Rt R!R lt]R 4tR R ltR tRtRtRtRtR"RltRtRtRtRtRtR"RltRtRtRt Rt!Rt"Rt#Rt$R#)#Portay 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 socketTypeNz Optional[int]_realPortNumberc \PPW4WnW nW@nW0nVP4RVnVP4R#)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&&&&&&6/usr/lib/python3/dist-packages/twisted/internet/udp.pyr' Port.__init__]sI* t-  *" "  c \P!W#VP4pVP4^,pV!RVVVVR7pWhnV#)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} N)r+r1r*)socketfromfdr# getsockname_preexistingSocket) clsr1fdr"r)r*r(r+r/s &&&&&& r2_fromListeningDescriptorPort._fromListeningDescriptor{sR@}}R?$$&q)   '  #' r4cV^8dQhRR/#)returnstr)formats"r2 __annotate__Port.__annotate__s@@#@r4c VPe(RVPP RVP R2#RVPP R2#)Nz not connected>)r$r) __class__r/s&r2__repr__ Port.__repr__sO    +t}}../tD4H4H3IK Kt}}../? ?r4c VP#)z Return a socket object. )r6rJs&r2 getHandlePort.getHandle{{r4c FVP4VP4R#)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_connectToProtocolrJs&r2startListeningPort.startListenings  !r4c @VPf:VP4pVPVPVP34MVPpRVnVP4^,Vn \P!VPVP4: RVP: 24^VnWnVPP VnR# \ d2p\ P!TPTPT4hRp?ii;i)a 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$rmsg _getLogPrefixr) connectedr6filenor/sktles& r2rRPort._bindSockets  " " * M//1$..$))45 ))C&*D # #03 !!$--0$2F2F H  kk(( % M--dnndiiLL Ms7C!! D,,DDc \VPPV4VP4R#N)r)makeConnection startReadingrJs&r2rSPort._connectToProtocols  $$T* r4c b^pWP8dVPPVP4wr#V\ V4, pVP \P 8Xd VR,pVPPW#4KR# \d\P!4Ki;i \dhpTP^,pT\9dRp?R#T\9d3TP 'dTPP#4Rp?R#hRp?ii;i)z- Called when my socket is ready for reading. Nr?NN) maxThroughputr6recvfromr*lenr"AF_INET6r)datagramReceived BaseExceptionrerrrYargs_sockErrReadIgnore_sockErrReadRefuser-connectionRefused)r/readdataaddrsenos& r2doRead Port.doReads''' ![[11$2D2DE D !%%8 8DMM224>/(0%GGI+ WWQZ++++*** 779 s;'B<6B B98B9< D.D)+D)D)(D))D.c nVP'd2VRVP39gQhVPPV4#VR8wgQh\P!V^,4'gP\P!V^,4'g-V^,R8wd\P !V^,R4h\P!V^,4'gV^,R8Xd>VP"\P$8Xd\P !V^,R4h\P!V^,4'd>VP"\P&8Xd\P !V^,R4hVPP)W4# \dpTP^,pT\ 8XdTP T4uRp?#T\8Xd\P!R4hT\8Xd!TPP4Rp?R#hRp?ii;i \dmpTP^,pT\ 8XdTP Y4uRp?#T\8Xd\P!R4hT\8XdRp?R#hRp?ii;i)a: 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. Nzmessage 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-r6sendrYrqrwriterrMessageLengthErrorrr)rtr isIPAddress isIPv6AddressInvalidAddressErrorr"rmAF_INETsendto)r/datagramrwrxrys&&& r2r~ Port.writes    D$"5"566 66 {{''114< <((a11 ..tAw77G},//GO$$T!W--aM1I$$7//GV%%d1g..43E3E3W//GI {{))(99? WWQZ;::h//8^223EFF<'MM3355 @ WWQZ;::h558^223EFF<' sTF)H=) H:4.H5"H:(AH54H55H:= J4.J/6J4<,J/.J//J4c HVPRPV4V4R#)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)r~join)r/seqrws&&&r2 writeSequencePort.writeSequenceBs 388C=$'r4c &VP'd \R4h\P!V4'g4\P!V4'g\ P !VR4hW3VnVPPW34R#)z 'Connect' to remote server. z:already connected, reconnecting is not currently supportednot an IPv4 or IPv6 address.N) r- RuntimeErrorrrrrrr6connect)r/hostr(s&&&r2r Port.connectQsu    L ##D))(2H2H2N2N++D2PQ Q#l TL)r4c VP4VP'd)VPP^VP4R#R#)N) stopReadingr]r1 callLaterconnectionLostrJs&r2_loseConnectionPort._loseConnection^s6  >>> LL " "1d&9&9 : r4c VP'd\P!4;qnMRpVP 4V#rd)r]rDeferreddr)r/results& r2 stopListeningPort.stopListeningcs2 >>>#nn. .FVF  r4c `\P!R\^R7VP4R#)z-Please use stopListening() to disconnect port) stacklevelN)warningswarnDeprecationWarningrrJs&r2loseConnectionPort.loseConnectionks% ;  r4c \P!RVP,4RVnRVn\P P W4VPP4VPP4V= V= \VR4'd VPPR4V= R#R#)z Cleans up my socket. z(UDP Port %s Closed)Nr)rr[r$rjrr&rr)doStopr6closer^hasattrrcallback)r/reasons&&r2rPort.connectionLostss &)=)==># $$T2   K K 4   FFOOD ! r4c XVPVP4pRV,VnR#)z@ Initialize the C{logstr} attribute to be used by C{logPrefix}. z%s (UDP)N)r\r)logstr)r/ logPrefixs& r2r,Port.setLogStrs$&&t}}5  9, r4c `\P!VP4'd\PVnR#\P !VP4'd\PVnR#VP'd"\P!VPR4hR#)z( Resolve address family for the socket. rN) rrr+r6rmr"rrrrrJs&r2r.Port._setAddressFamilysq  ! !$.. 1 1!'D   ! !$.. 1 1!'D  ^^^++ > r4c VP#)z Return the prefix to log with. )rrJs&r2rPort.logPrefixrPr4c $VPP4pVP\P8Xd\P !R.VO5!#VP\P 8Xd \P!R.VR,O5!#R#)z Return the local address of the UDP connection @returns: the local address of the UDP connection @rtype: L{IPv4Address} or L{IPv6Address} UDPriN)r6r8r"rr IPv4Addressrm IPv6Address)r/rws& r2getHost Port.getHostso{{&&(    /&&u4t4 4   6?? 2&&u:R: :3r4c xVPP\P\PV4R#)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)r/enableds&&r2setBroadcastAllowedPort.setBroadcastAlloweds& v00&2E2EwOr4c \VPP\P\P44#)zs Checks if broadcast is currently allowed on this port. @return: Whether this port may broadcast. @rtype: L{bool} )boolr6 getsockoptrrrJs&r2getBroadcastAllowedPort.getBroadcastAlloweds,DKK**6+<+Q>QRSSr4)r-r9r$r"r]rr^r+rr*rjr(r)r6i) Nrd)%__name__ __module__ __qualname____firstlineno____doc__r6rr"__annotations__ SOCK_DGRAMr#rjr$r9r' classmethodr<rKrNrTrRrSrzr~rrrrrrr,r.rrrr__static_attributes__rBr4r2r!r!@s$+1..M'8$*$5$5J!5M%)O])!<))V@  "!)F@<| ( *;  -  ;PTr4r!c6]tRtRtRtR RRlltRRltRtR#) MulticastPortiz& UDP Port that supports multicasting. Nc4V^8dQhRRRRRRRRRR R R R R /#)r?r(intr0rr+rAr*r1zIReactorMulticast | NonelistenMultiplerr@NonerB)rCs"r2rDMulticastPort.__annotate__sP - - -( - -  - * - -  -r4c @\PWW#WE4W`nR#)zH @see: L{twisted.internet.interfaces.IReactorMulticast.listenMulticast} N)r!r'r)r/r(r0r+r*r1rs&&&&&&&r2r'MulticastPort.__init__s d%MK,r4cV^8dQhRR/#)r?r@z socket.socketrB)rCs"r2rDrsmr4c \PV4pVP'dxVP\P \P ^4\\R4'd3VP\P \P^4V#V# \d"pTP\8XdRp?T#hRp?ii;i)z Override L{Port.createInternetSocket} to configure the socket to honor the C{listenMultiple} argument to L{IReactorMulticast.listenMultiple}. SO_REUSEPORTN) r!rWrrr6r SO_REUSEADDRrrrYerrnorr_s& r2rW"MulticastPort.createInternetSockets ''-     NN6,,f.A.A1 Ev~..NN6#4#4f6I6I1M s xx;.  s./B!! C ,CCC )r)rrNF)rrrrrr'rWrrBr4r2rrs -r4r)3r __future__rr6rtypingrzope.interfacertwisted.internet._multicastrtwisted.internet.interfacesrtwisted.internet.protocolrtwisted.python.runtimerrr r r r rrrrrrrrrsrrrrrtwisted.internetrrrrrrtwisted.pythonrIListeningPort IUDPTransport ISystemHandler&r!IMulticastTransportrrBr4r2rs #&69>/7$$#NKP)=, UH"L F EUU %5&ON z779Q9QwT4==wTwTt  Z + +,%ND%-%r4