h(TSrSSKJr SSKrSSKrSSKJr SSKJrJ r SSK J r J r J r SSKJr SSKJrJrJrJrJrJrJrJrJrJrJr SS KJrJr SS KJ r SS K!J"r"J#r# SS K$J%r%J&r& S SK'J(r(J)r)J*r*J+r+J,r, \ RZ"S5r.SSK/J0r1 \1r0SSK J3r4 \4r3\&S:Hr5Sr6\5(a SSK J7r7J8r8 Sr6\%Rr"5(aSSK:r:Sr6"SS5r;\ "\\\5"SS\;\55r<"SS5r=\ "\5"SS\=\;55r>\0c\3b \"\<\5 \5(a \"\<\\5 \6(a \"\<\5 \?"\SS5b \"\<\5 S/r@g!\2a Sr0Nf=f!\2a Sr3Nf=f!\2a Sr:Nf=f)z Posix reactor base class ) annotationsN)Sequence)classImplements implementer)errortcpudp) ReactorBase) IConnectorIHalfCloseableDescriptor IReactorFDSetIReactorMulticastIReactorProcessIReactorSocket IReactorSSL IReactorTCP IReactorUDP IReactorUNIXIReactorUNIXDatagram)CONNECTION_DONECONNECTION_LOST) ClientFactory)failurelog)platform platformType)SignalHandling_ChildSignalHandling_IWaker_MultiSignalHandling_WakerzFile descriptor lost)tls)sslposixF)processunixTc\rSrSrSr\R \R"\R "55\R\R"\R"5504Sjr Sr g)_DisconnectSelectableMixinPz6 Mixin providing the C{_disconnectSelectable} method. cURU5 URUR5nU(auU(aKUR[R:Xa-[ R "U5(aURU5 gURU5 URU5 gURU5 UR[R"U55 g)z Utility function for disconnecting a selectable. Supports half-close notification, isRead should be boolean indicating whether error resulted from doRead(). N) removeReaderget __class__rConnectionDoner providedByreadConnectionLost removeWriterconnectionLostrFailure)self selectablewhyisReadfaildictfs a/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/internet/posixbase.py_disconnectSelectable0_DisconnectSelectableMixin._disconnectSelectableUs *% LL ' MMU%9%99,77 CC--a0!!*-))!,   j )  % %gooc&: ;N) __name__ __module__ __qualname____firstlineno____doc__rr/rr4ConnectionLostr<__static_attributes__r?r>r;r)r)PsM  '//%2F2F2H"I  '//%2F2F2H"I r)c^\rSrSr%SrSrSSjrSrSU4SjjrS0SSSSS4S jr SS jr SS jr SS jr S S jr S!SjrS"Sjr\(a)\R$\R&\R(4rS\S'O\R$\R&4rSrSrS#SjrS$SjrS%S&SjjrS'SjrS$SjrSrSrU=r $)(PosixReactorBasevz A basis for reactors that use file descriptors. @ivar _childWaker: L{None} or a reference to the L{_SIGCHLDWaker} which is used to properly notice child process termination. Nc[5$N)r"r5s r; _wakerFactoryPosixReactorBase._wakerFactorys xr>cUR(dVUR5UlURRUR5 UR UR5 gg)z Install a `waker' to allow threads and signals to wake up the IO thread. We use the self-pipe trick (http://cr.yp.to/docs/selfpipe.html) to wake the reactor. On Windows we use a pair of sockets. N)wakerrM_internalReadersadd addReaderrLs r; installWakerPosixReactorBase.installWakersHzz++-DJ  ! ! % %djj 1 NN4:: &r>c>[TU]5n[S:Xa+[U[ UR UR 545$U$)zR Customize reactor signal handling to support child processes on POSIX platforms. r%)super_signalsFactoryrr!r_addInternalReader_removeInternalReader)r5 baseHandlingr.s r;rX PosixReactorBase._signalsFactorysS w.0 7 "'!(//22   r>r?rc [S:XaMU(a(U b [S5e[R"XX4XQXgU5 $[R"UUUUUUUUU 5 $[S:XafUb [S5eUb [S5eU(a [S5eU (a [S5e[ (aSS KJn U "XX#XE5$[S 5e[S 5e) Nr%z1Using childFDs is not supported with usePTY=True.win32z,Setting UID is unsupported on this platform.z,Setting GID is unsupported on this platform.z1The usePTY parameter is not supported on Windows.z1Customizing childFDs is not supported on Windows.r)Processz:spawnProcess not available since pywin32 is not installed.z0spawnProcess only available on Windows or POSIX.)r ValueErrorr& PTYProcessr_ win32processtwisted.internet._dumbwin32procNotImplementedError) r5processProtocol executableargsenvpathuidgidusePTYchildFDsr_s r; spawnProcessPosixReactorBase.spawnProcesss 7 "'$K))dRX#  W $ !OPP !OPP !TUU !TUU|CtjRR)P&B r>cV[R"XX4U5nUR5 U$)zwConnects a given L{DatagramProtocol} to the given numeric UDP port. @returns: object conforming to L{IListeningPort}. )r PortstartListening)r5portprotocol interface maxPacketSizeps r; listenUDPPosixReactorBase.listenUDPs' HHTYt D r>cV[R"XX4X5nUR5 U$)zConnects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL. @returns: object conforming to IListeningPort. )r MulticastPortrr)r5rsrtrurvlistenMultiplerws r;listenMulticast PosixReactorBase.listenMulticasts.    Id  r>cz[(dS5e[R"XX0U5nUR5 U$NUNIX support is not present) unixEnabledr' Connectorconnect)r5addressfactorytimeoutcheckPIDcs r; connectUNIXPosixReactorBase.connectUNIXs2{999{ NN7WH E r>cz[(dS5e[R"XX4X5nUR5 U$r)rr'rqrr)r5rrbacklogmodewantPIDrws r; listenUNIXPosixReactorBase.listenUNIXs5{999{ IIgt E r>cz[(dS5e[R"XX4U5nUR5 U$)z{ Connects a given L{DatagramProtocol} to the given path. EXPERIMENTAL. @returns: object conforming to L{IListeningPort}. r)rr' DatagramPortrr)r5rrtrvrrws r;listenUNIXDatagram#PosixReactorBase.listenUNIXDatagrams9{999{   gd K r>cz[(dS5e[R"XX4XP5nUR5 U$)zL Connects a L{ConnectedDatagramProtocol} instance to a path. EXPERIMENTAL. r)rr'ConnectedDatagramPortrr)r5rrtrvr bindAddressrws r;connectUNIXDatagram$PosixReactorBase.connectUNIXDatagrams>{999{  & & }K  r>zSequence[socket.AddressFamily]_supportedAddressFamiliesc0X R;a[R"U5e[(a5U[R :Xa![ RRXU5nO [RRXX#5nUR5 U$)a Create a new L{IListeningPort} from an already-initialized socket. This just dispatches to a suitable port implementation (eg from L{IReactorTCP}, etc) based on the specified C{addressFamily}. @see: L{twisted.internet.interfaces.IReactorSocket.adoptStreamPort} ) rrUnsupportedAddressFamilyrsocketAF_UNIXr'rq_fromListeningDescriptorrrr)r5fileDescriptor addressFamilyrrws r;adoptStreamPort PosixReactorBase.adoptStreamPort:ss  > > >00? ? ;=FNN: 224QA11mA r>c X R;a[R"U5e[(a4U[R :Xa [ RRXU5$[RRXX05$)zO @see: L{twisted.internet.interfaces.IReactorSocket.adoptStreamConnection} ) rrrrrrr'Server_fromConnectedSocketr)r5rrrs r;adoptStreamConnection&PosixReactorBase.adoptStreamConnectionOsd  > > >00? ? ;=FNN:;;33NTR R::22w r>cU[R[R4;a[R"U5e[ R RXX#US9nUR5 U$)N)rv) rAF_INETAF_INET6rrr rqrrr)r5rrrtrvrws r;adoptDatagramPort"PosixReactorBase.adoptDatagramPort^s]  A A00? ? HH - - - .  r>cV[R"XX4U5nUR5 U$rK)rrqrr)r5rsrrrurws r; listenTCPPosixReactorBase.listenTCPls% HHTG = r>cV[R"XX4XP5nUR5 U$rK)rrr)r5hostrsrrrrs r; connectTCPPosixReactorBase.connectTCPqs$ MM$g J r>c [b*[RUSU5nURXXuU5$[b*[R XX4XVU5nUR 5 U$S5e)NTSSL support is not present)r#TLSMemoryBIOFactoryrr$rr) r5rrsrcontextFactoryrr tlsFactoryrs r; connectSSLPosixReactorBase.connectSSLsg ?00wOJ??4zKP P _ GW4A IIKH 66 65r>c[b2[RUSU5nURXXE5nSUlU$[b)[R XX4XP5nUR 5 U$S5e)NFTLSr)r#rr_typer$rqrr)r5rsrrrrurrws r; listenSSLPosixReactorBase.listenSSLsj ?00PJ>>$GGDDJK _QA   H 66 65r>c[U5UR- nUHnURU5 M [U5nUHnURU5 M [ X5-5$)a/ Remove all readers and writers, and list of removed L{IReadDescriptor}s and L{IWriteDescriptor}s. Meant for calling from subclasses, to implement removeAll, like:: def removeAll(self): return self._removeAll(self._reads, self._writes) where C{self._reads} and C{self._writes} are iterables. )setrQr,r2list)r5readerswritersremovedReadersreaderremovedWriterswriters r; _removeAllPosixReactorBase._removeAllscW(=(==$F   f %%W$F   f %%N344r>)rP)returnr )rr) )rrF)r)2r)rr)rrN)r)rr)g>@N) rstrrsintrz'ClientFactory'rfloatrztuple[str, int] | Nonerr )rN)!r@rArBrCrD _childWakerrMrTrXrnrxr}rrrrrrrrrr__annotations__rrrrrrrrrF __classcell__)r.s@r;rHrHvs'K '<    6tPU "  NR " NN OO NNE !#A  NN OO% ! *  FJ .2   !    ,   LP 7 755r>rHc\rSrSrSrSrSrg)_PollLikeMixinia Mixin for poll-like reactors. Subclasses must define the following attributes:: - _POLL_DISCONNECTED - Bitmask for events indicating a connection was lost. - _POLL_IN - Bitmask for events indicating there is input to read. - _POLL_OUT - Bitmask for events indicating output can be written. Must be mixed in to a subclass of PosixReactorBase (for _disconnectSelectable). cSnSnX0R-(a2X0R-(dX R;a Sn[nOt[nOmUR 5S:Xa[ nOQX0R-(aUR5nSnU(d%X0R-(aUR5nSnU(aURXU5 gg![a0 [R"5Sn[R"5 NTf=f)zO fd is available for read or write, do the work and raise errors if necessary. NFTr)_POLL_DISCONNECTED_POLL_IN_readsrrfileno _NO_FILEDESCdoRead _POLL_OUTdoWrite BaseExceptionsysexc_inforerrr<)r5r6fdeventr7inReads r;_doReadOrWrite_PollLikeMixin._doReadOrWrites  ** *EMM4I[[ %& $$&",'C}},(//1!%5>>#9)002!&   & &z ?  ! llnQ'  s C&AC7D  D r?N)r@rArBrCrDrrFr?r>r;rrs  7@r>rcl\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrg)_ContinuousPollingiao Schedule reads and writes based on the passage of time, rather than notification. This is useful for supporting polling filesystem files, which C{epoll(7)} does not support. The implementation uses L{_PollLikeMixin}, which is a bit hacky, but re-implementing and testing the relevant code yet again is unappealing. @ivar _reactor: The L{EPollReactor} that is using this instance. @ivar _loop: A C{LoopingCall} that drives the polling, or L{None}. @ivar _readers: A C{set} of C{FileDescriptor} objects that should be read from. @ivar _writers: A C{set} of C{FileDescriptor} objects that should be written to. rcZXlSUl[5Ul[5UlgrK)_reactor_loopr_readers_writers)r5reactors r;__init___ContinuousPolling.__init__s     r>ctUR(dUR(acURcUSSKJnJn U"UR 5UlURURlURRUSS9 ggUR(a"URR5 SUlgg)zP Start or stop a C{LoopingCall} based on whether there are readers and writers. Nr)_EPSILON LoopingCallF)now) rrrtwisted.internet.taskrriteraterclockstartstop)r5rrs r; _checkLoop_ContinuousPolling._checkLoops ==DMMzz!G(6 #'==     u 5"ZZ JJOO DJr>c[UR5HnURXUR5 M! [UR5HnURX"UR 5 M! g)zH Call C{doRead} and C{doWrite} on all readers and writers respectively. N)rrrrrr)r5rrs r;r_ContinuousPolling.iterate/sR4==)F    >*4==)F    ?*r>cZURRU5 UR5 g)zE Add a C{FileDescriptor} for notification of data available to read. N)rrRrr5rs r;rS_ContinuousPolling.addReader8  &! r>cZURRU5 UR5 g)zF Add a C{FileDescriptor} for notification of data available to write. N)rrRrr5rs r; addWriter_ContinuousPolling.addWriter?r r>c|URRU5 UR5 g![a gf=f)zI Remove a C{FileDescriptor} from notification of data available to read. N)rremoveKeyErrorrrs r;r,_ContinuousPolling.removeReaderFs9  MM  (     . ;;c|URRU5 UR5 g![a gf=f)zJ Remove a C{FileDescriptor} from notification of data available to write. N)rrrrr s r;r2_ContinuousPolling.removeWriterPs9   MM  (    rc[URUR-5nURR5 URR5 U$)z! Remove all readers and writers. )rrrclear)r5results r; removeAll_ContinuousPolling.removeAll[sBdmmdmm34   r>c,[UR5$)z Return a list of the readers. )rrrLs r; getReaders_ContinuousPolling.getReadersfDMM""r>c,[UR5$)z Return a list of the writers. )rrrLs r; getWriters_ContinuousPolling.getWriterslrr>cXR;$)a* Checks if the file descriptor is currently being observed for read readiness. @param fd: The file descriptor being checked. @type fd: L{twisted.internet.abstract.FileDescriptor} @return: C{True} if the file descriptor is being observed for read readiness, C{False} otherwise. @rtype: C{bool} )rr5rs r; isReading_ContinuousPolling.isReadingr]]""r>cXR;$)a, Checks if the file descriptor is currently being observed for write readiness. @param fd: The file descriptor being checked. @type fd: L{twisted.internet.abstract.FileDescriptor} @return: C{True} if the file descriptor is being observed for write readiness, C{False} otherwise. @rtype: C{bool} )rr#s r; isWriting_ContinuousPolling.isWritingr&r>)rrrrN)r@rArBrCrDrrrrrrrSr r,r2rrr r$r(rFr?r>r;rrsV,HI $@  # # # #r>rfromfd)ArD __future__rrrtypingrzope.interfacerrtwisted.internetrrr twisted.internet.baser twisted.internet.interfacesr r r rrrrrrrrtwisted.internet.mainrrtwisted.internet.protocolrtwisted.pythonrrtwisted.python.runtimerr_signalsrrr r!r"ConnectionFdescWentAwayrtwisted.protocolsr#_tls ImportErrorr$_sslrprocessEnabledr&r' isWindowsrbr)rHrrgetattr__all__r?r>r;r?s # 7,,-    C3'9,,-CD - C, Cg% .N  #<#