\dXV"dZddlZddlZddlmZddlmZmZddlm Z m Z m Z ddl m Z mZddlmZmZmZmZmZmZmZmZmZmZddlmZmZdd lmZmZdd l m!Z!m"Z"d d l#m$Z$m%Z%e j&d Z'e j&dZ( ddl)m*Z+e+Z*n #e,$rdZ*YnwxYw ddlm-Z.e.Z-n #e,$rdZ-YnwxYwe"dkZ/dZ0e/r ddlm1Z1m2Z2dZ0e!j3r ddl4Z4dZ0n #e,$rdZ4YnwxYwGddZ5eeeeGddee5e Z6GddZ7eeGdde7e5Z8e*e- ee6ee/r ee6eee0r ee6ee9edd ee6edgZ:dS)z Posix reactor base class N)Sequence)classImplements implementer)errortcpudp) ReactorBase_SignalReactorMixin) IHalfCloseableDescriptor IReactorFDSetIReactorMulticastIReactorProcessIReactorSocket IReactorSSL IReactorTCP IReactorUDP IReactorUNIXIReactorUNIXDatagram)CONNECTION_DONECONNECTION_LOST)failurelog)platform platformType) _SIGCHLDWaker_WakerzHandler has no fileno methodzFile descriptor lost)tls)sslposixF)processunixTceZdZdZejejejejejejifdZ dS)_DisconnectSelectableMixinz> Mixin providing the C{_disconnectSelectable} method. c||||j}|rn|r@|jtjkr+t j|r||dS||| |dS||| tj |dS)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 :lib/python3.11/site-packages/twisted/internet/posixbase.py_disconnectSelectablez0_DisconnectSelectableMixin._disconnectSelectableMs *%%% LL ' ' < -MU%999,7 CC:--a00000!!*---))!,,,,,   j ) ) )  % %goc&:&: ; ; ; ; ;N) __name__ __module__ __qualname____doc__rr)rr.ConnectionLostr6r7r5r$r$Hsy  /'/2F%2F2H2H"I"I  /'/2F%2F2H2H"I"I <<<<< > >0?? ?  =FN:: 224QQAA11nmWA r7c||jvrtj|tr1|tjkr!t j|||Stj||||S)zg @see: L{twisted.internet.interfaces.IReactorSocket.adoptStreamConnection} ) rrrrvrrr"Server_fromConnectedSocketr)r/rrrzs r5adoptStreamConnectionz&PosixReactorBase.adoptStreamConnectionRst  > > >0?? ?  =FN::;33NGTRR R:22 w r7c|tjtjfvrtj|t j|||||}||S)N)rk) rAF_INETAF_INET6rrrrfrrg)r/rrrirkrls r5adoptDatagramPortz"PosixReactorBase.adoptDatagramPortasi  A A A0?? ? H - - .- .   r7c^tj|||||}||SN)rrfrg)r/rhrzrrjrls r5 listenTCPzPosixReactorBase.listenTCPos0 HT7GY = = r7c`tj||||||}||Sr)rrwrx)r/hostrhrzr{rr}s r5 connectTCPzPosixReactorBase.connectTCPts- M$gw T J J r7c t5t|d|}||||||St6t|||||||}||SJd)NTFSSL support is not present)rTLSMemoryBIOFactoryrrrwrx) r/rrhrzcontextFactoryr{r tlsFactoryr}s r5 connectSSLzPosixReactorBase.connectSSL{s ?00wOOJ??4z7KPP P _ dG^Wk4A IIKKKH 66 6 6 6r7ct=t|d|}|||||}d|_|St5t||||||}||SJd)NFTLSr)rrr_typerrfrg)r/rhrzrrrjrrls r5 listenSSLzPosixReactorBase.listenSSLs ?00PPJ>>$ GYGGDDJK _wDQQA     H 66 6 6 6r7ct||jz }|D]}||t|}|D]}||t ||zS)ag 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. )setrCr&r,list)r/readerswritersremovedReadersreaderremovedWriterswriters r5 _removeAllzPosixReactorBase._removeAllsW(==$ & &F   f % % % %W$ & &F   f % % % %N^3444r7)rcrd)rcrdF)rrr)rrr)rdr)rdrN)rd)rrc)rrN)"r8r9r:r;rrBrGrKrIrPrbrmrqr~rrrrvrrrrrr AddressFamily__annotations__rrrrrrrrr=r7r5r?r?nsM ' ' 'K'''&))).    6666tPU    "     NR    "  N O NE !8F,@#A     N O% ! *    FJ     LP 7 7 7 7 7 7 7 755555r7r?ceZdZdZdZdS)_PollLikeMixina 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). cd}d}||jzr%||jzs||jvr d}t}nt}n |dkrt }nB||jzr|}d}|s ||jzr| }d}n<#t$r/tj d}tjYnwxYw|r||||dSdS)zg 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_inforerrr6)r/r0fdeventr1inReads r5_doReadOrWritez_PollLikeMixin._doReadOrWrites>  4* *. EDM4I. T[  %& $$&&",,'CCt},&(//11!%'54>#9')0022!&    lnnQ'    @  & &z3 ? ? ? ? ? @ @sA"B6CCN)r8r9r:r;rr=r7r5rrs2  7@7@7@7@7@r7rcfeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdS)_ContinuousPollinga 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. rcn||_d|_t|_t|_dSr)_reactor_loopr_readers_writers)r/reactors r5__init__z_ContinuousPolling.__init__s*    r7c|js|jrU|jLddlm}m}||j|_|j|j_|j |ddSdS|jr"|j d|_dSdS)zh Start or stop a C{LoopingCall} based on whether there are readers and writers. Nr)_EPSILON LoopingCallF)now) rrrtwisted.internet.taskrriteraterclockstartstop)r/rrs r5 _checkLoopz_ContinuousPolling._checkLoops = DM z!GGGGGGGG([66 #'=     u 55555"!Z  JOO   DJJJ  r7ct|jD]}||||jt|jD]}||||jdS)zX Call C{doRead} and C{doWrite} on all readers and writers respectively. N)rrrrrr)r/rrs r5rz_ContinuousPolling.iterate+s~4=)) ? ?F    > > > >4=)) @ @F    ? ? ? ? @ @r7cb|j||dS)zU Add a C{FileDescriptor} for notification of data available to read. N)rrDrr/rs r5rEz_ContinuousPolling.addReader40 &!!! r7cb|j||dS)zV Add a C{FileDescriptor} for notification of data available to write. N)rrDrr/rs r5 addWriterz_ContinuousPolling.addWriter;rr7c |j|n#t$rYdSwxYw|dS)zY Remove a C{FileDescriptor} from notification of data available to read. N)rremoveKeyErrorrrs r5r&z_ContinuousPolling.removeReaderBsX  M  ( ( ( (    FF    ++c |j|n#t$rYdSwxYw|dS)zb Remove a C{FileDescriptor} from notification of data available to write. N)rrrrrs r5r,z_ContinuousPolling.removeWriterLsX   M  ( ( ( (    FF  rct|j|jz}|j|j|S)z1 Remove all readers and writers. )rrrclear)r/results r5 removeAllz_ContinuousPolling.removeAllWsIdmdm344   r7c*t|jS)z/ Return a list of the readers. )rrrFs r5 getReadersz_ContinuousPolling.getReadersbDM"""r7c*t|jS)z/ Return a list of the writers. )rrrFs r5 getWritersz_ContinuousPolling.getWritershrr7c||jvS)aj 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} )rr/rs r5 isReadingz_ContinuousPolling.isReadingnT]""r7c||jvS)al 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} )rrs r5 isWritingz_ContinuousPolling.isWriting{rr7N)r8r9r:r;rrrrrrrErr&r,rrrrrr=r7r5rrs,HI $@@@      ### ### # # # # # # # #r7rfromfd);r;rrtypingrzope.interfacerrtwisted.internetrrrtwisted.internet.baser r twisted.internet.interfacesr r r rrrrrrrtwisted.internet.mainrrtwisted.pythonrrtwisted.python.runtimerr_signalsrrConnectionFdescWentAway _NO_FILENOrtwisted.protocolsr_tls ImportErrorr_sslrvrJr!r" isWindowsrVr$r?rrgetattr__all__r=r7r5rs(   77777777,,,,,,,,,,BBBBBBBB                        CBBBBBBB''''''''99999999+++++++++U *+I J J ,u,-CDD ------ CC CCC ,,,,,, CC CCC g% ........N8  #<#<#<#<#<#<#<#