hBSrSSKJr SSKrSSKrSSKJr SSKJr SSK J r SSK J r SSK Jr SS KJr \S :Xa3SS KJr SS KJr SS KJrJrJrJrJrJrJr \\\\/r\\\\/r\r\r\r \r!OSSKJ r JrJ!r!JrJrJ"r" \ \!\"/r\/rSSK#J$r$J%r%J&r&J'r'J(r(J)r) SSK*J+r+ \"\)RX\)RZ\)R\5"SS\&R^55r0\"\)Rb5"SS\ \055r2g)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 \rSrSr%Sr\R rS\S'\Rr S\S'Sr Sr S \S 'Sr S!S jr\S 5rS"S jrSrSrSrSrSrS#SjrSrSrSrSrSrS#SjrSrSrSr Sr!Sr"Sr#S r$g)$Port@ay 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]_realPortNumberc[RRX5 XlX lX@lX0lUR5 SUlUR5 g)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 [/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/internet/udp.pyr) Port.__init__]sI* t-  *" "  c[R"X#UR5nUR5SnU"SUUUUS9nXhlU$)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-r3r,)socketfromfdr% getsockname_preexistingSocket) clsr3fdr$r+r,r*r-r1s r4_fromListeningDescriptorPort._fromListeningDescriptor{sR@}}R?$$&q)   '  #' r6cURb'SURRSURS3$SURRS3$)Nz not connected>)r&r+ __class__r1s r4__repr__ Port.__repr__sO    +t}}../tD4H4H3IK Kt}}../? ?r6cUR$)z Return a socket object. )r8rDs r4 getHandlePort.getHandle{{r6cDUR5 UR5 g)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_connectToProtocolrDs r4startListeningPort.startListenings  !r6c2URc9UR5nURURUR45 OURnSUlUR5SUl [R"URUR5<SUR<35 SUlXlURR Ulg![ a1n[ R"URURU5eSnAff=f)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 )r;createInternetSocketbindr-r*OSErrorrCannotListenErrorr:r&r msg _getLogPrefixr+ connectedr8filenor1sktles r4rLPort._bindSockets  " " * M//1$..$))45 ))C&*D # #03 !!$--0$2F2F H  kk(( % M--dnndiiLL Ms7C D%,DDcZURRU5 UR5 gN)r+makeConnection startReadingrDs r4rMPort._connectToProtocols  $$T* r6cTSnXR:aURRUR5up#U[ U5- nUR [R :XaUSSnURRX#5 XR:aMgg![a [R"5 N4f=f![a^nURSnU[;aSnAgU[;a0UR (aURR#5 SnAgeSnAff=f)z- Called when my socket is ready for reading. rN) maxThroughputr8recvfromr,lenr$AF_INET6r+datagramReceived BaseExceptionr errrTargs_sockErrReadIgnore_sockErrReadRefuser/connectionRefused)r1readdataaddrsenos r4doRead Port.doReads''' ![[11$2D2DE D !%%8 8DMM224>/'''0%GGI+ WWQZ++++** 779 s5'B?,BB<;B<? D' D"'5D"!D""D'cUR(a0USUR4;deURRU5$US:wde[R"US5(dA[R"US5(d#USS:wa[R "USS5e[R"US5(d USS:Xa8UR"[R$:Xa[R "USS5e[R"US5(a8UR"[R&:Xa[R "USS5eURR)X5$![a~nURSnU[ :XaUR U5sSnA$U[:Xa[R"S5eU[:XaURR5 SnAgeSnAff=f![adnURSnU[ :XaUR X5sSnA$U[:Xa[R"S5eU[:XaSnAgeSnAff=f)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. 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/r8sendrTrlrwriterrMessageLengthErrorrr+ror isIPAddress isIPv6AddressInvalidAddressErrorr$rhAF_INETsendto)r1datagramrrrsrts r4ry 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<' sTE:H: H)G=-H3AG=<G==H I3)I.8I3>*I.-I..I3cFURSRU5U5 g)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. r6N)ryjoin)r1seqrrs r4 writeSequencePort.writeSequenceBs 388C=$'r6cUR(a [S5e[R"U5(d2[R"U5(d[ R "US5eX4UlURRX45 g)z 'Connect' to remote server. z:already connected, reconnecting is not currently supportednot an IPv4 or IPv6 address.N) r/ RuntimeErrorrr{r|rr}r8connect)r1hostr*s r4r Port.connectQsr   L ##D))(2H2H2N2N++D2PQ Q#l TL)r6cUR5 UR(a'URRSUR5 gg)Nr) stopReadingrXr3 callLaterconnectionLostrDs r4_loseConnectionPort._loseConnection^s4  >> LL " "1d&9&9 : r6cUR(a[R"5=olOSnUR 5 U$r_)rXrDeferreddr)r1results r4 stopListeningPort.stopListeningcs0 >>#nn. .FVF  r6cX[R"S[SS9 UR5 g)Nz-Please use stopListening() to disconnect portrd) stacklevel)warningswarnDeprecationWarningrrDs r4loseConnectionPort.loseConnectionks% ;  r6cr[R"SUR-5 SUlSUl[R R X5 URR5 URR5 U? U? [US5(aURRS5 U? gg)z Cleans up my socket. z(UDP Port %s Closed)Nr)r rVr&rerr(rr+doStopr8closerYhasattrrcallback)r1reasons r4rPort.connectionLostss &)=)==># $$T2   K K 4   FFOOD ! r6cNURUR5nSU-Ulg)z@ Initialize the C{logstr} attribute to be used by C{logPrefix}. z%s (UDP)N)rWr+logstr)r1 logPrefixs r4r.Port.setLogStrs$&&t}}5  9, r6cT[R"UR5(a[RUlg[R "UR5(a[RUlgUR(a![R"URS5eg)z( Resolve address family for the socket. rN) rr|r-r8rhr$r{r~rr}rDs r4r0Port._setAddressFamilyso  ! !$.. 1 1!'D   ! !$.. 1 1!'D  ^^++ > r6cUR$)z Return the prefix to log with. )rrDs r4rPort.logPrefixrJr6cURR5nUR[R:Xa[R "S/UQ76$UR[R :Xa[R"S/USSQ76$g)z Return the local address of the UDP connection @returns: the local address of the UDP connection @rtype: L{IPv4Address} or L{IPv6Address} UDPNrd)r8r:r$r~r IPv4Addressrh IPv6Address)r1rrs r4getHost Port.getHostsq{{&&(    /&&u4t4 4   6?? 2&&u:Ra: :3r6cvURR[R[RU5 g)z Set whether this port may broadcast. This is disabled by default. @param enabled: Whether the port may broadcast. @type enabled: L{bool} N)r8 setsockopt SOL_SOCKET SO_BROADCAST)r1enableds r4setBroadcastAllowedPort.setBroadcastAlloweds& v00&2E2EwOr6c[URR[R[R55$)zs Checks if broadcast is currently allowed on this port. @return: Whether this port may broadcast. @rtype: L{bool} )boolr8 getsockoptrrrDs r4getBroadcastAllowedPort.getBroadcastAlloweds,DKK**6+<+Q>QRSSr6)r/r;r&r$rXrrYr-rr,rer*r+r8) N)returnstrr_)%__name__ __module__ __qualname____firstlineno____doc__r8r~r$__annotations__ SOCK_DGRAMr%rer&r;r) classmethodr>rErHrNrLrMruryrrrrrrr.r0rrrr__static_attributes__r6r4r"r"@s$+1..M'8$*$5$5J!5M%)O])!<))V@  "!)F@<| ( *;  -  ;PTr6r"cR\rSrSrSrSSSjjrS SjrSrg) MulticastPortiz& UDP Port that supports multicasting. Nc>[RXX#XE5 X`lg)zH @see: L{twisted.internet.interfaces.IReactorMulticast.listenMulticast} N)r"r)listenMultiple)r1r*r2r-r,r3rs r4r)MulticastPort.__init__s d%MK,r6c[RU5nUR(avUR[R [R S5 [[S5(a2UR[R [RS5 U$U$![a nUR[:XaSnAU$eSnAff=f)z Override L{Port.createInternetSocket} to configure the socket to honor the C{listenMultiple} argument to L{IReactorMulticast.listenMultiple}. rQ SO_REUSEPORTN) r"rRrrr8r SO_REUSEADDRrrrTerrnorrZs r4rR"MulticastPort.createInternetSockets ''-    NN6,,f.A.A1 Ev~..NN6#4#4f6I6I1M s xx;.  s,/B C )CCC )r)rrNF)r*intr2rr-rr,rr3zIReactorMulticast | NonerrrNone)rz socket.socket)rrrrrr)rRrrr6r4rrsc!,0$ - -( - -  - * - -  -r6r)3r __future__rr8rtypingrzope.interfacertwisted.internet._multicastrtwisted.internet.interfacesrtwisted.internet.protocolrtwisted.python.runtimer rr r r rrrrrrrrmrnrrrrrtwisted.internetrrrrrrtwisted.pythonr IListeningPort IUDPTransport ISystemHandler(r"IMulticastTransportrrr6r4rs #&69>/7$$#NKP)=, UH"L F EUU %5&ON z779Q9QwT4==wTwTt  Z + +,%ND%-%r6