Yf 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 L/var/www/html/env/lib/python3.11/site-packages/twisted/internet/posixbase.py_disconnectSelectablez0_DisconnectSelectableMixin._disconnectSelectableRs *%%% LL ' ' < -MU%999,7 CC:--a00000!!*---))!,,,,,   j ) ) )  % %goc&:&: ; ; ; ; ;N) __name__ __module__ __qualname____doc__rr+rr0ConnectionLostr8r9r7r&r&Msy  /'/2F%2F2H2H"I"I  /'/2F%2F2H2H"I"I <<<<< > >0?? ?  =FN:: 224QQAA11nmWA r9c||jvrtj|tr1|tjkr!t j|||Stj||||S)zg @see: L{twisted.internet.interfaces.IReactorSocket.adoptStreamConnection} ) rrrrxrrr$Server_fromConnectedSocketr)r1rrr|s r7adoptStreamConnectionz&PosixReactorBase.adoptStreamConnectionLst  > > >0?? ?  =FN::;33NGTRR R:22 w r9c|tjtjfvrtj|t j|||||}||S)N)rm) rAF_INETAF_INET6rrrrhrri)r1rrrkrmrns r7adoptDatagramPortz"PosixReactorBase.adoptDatagramPort[si  A A A0?? ? H - - .- .   r9c^tj|||||}||SrD)rrhri)r1rjr|rrlrns r7 listenTCPzPosixReactorBase.listenTCPis0 HT7GY = = r9c`tj||||||}||SrD)rryrz)r1hostrjr|r}rrs r7 connectTCPzPosixReactorBase.connectTCPns- M$gw T J J r9c t5t|d|}||||||St6t|||||||}||SJd)NTFSSL support is not present)r TLSMemoryBIOFactoryrr!ryrz) r1rrjr|contextFactoryr}r tlsFactoryrs r7 connectSSLzPosixReactorBase.connectSSLus ?00wOOJ??4z7KPP P _ dG^Wk4A IIKKKH 66 6 65r9ct=t|d|}|||||}d|_|St5t||||||}||SJd)NFTLSr)r rr_typer!rhri)r1rjr|rrrlrrns r7 listenSSLzPosixReactorBase.listenSSLs ?00PPJ>>$ GYGGDDJK _wDQQA     H 66 6 65r9ct||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. )setrIr(r.list)r1readerswritersremovedReadersreaderremovedWriterswriters r7 _removeAllzPosixReactorBase._removeAllsW(==$ & &F   f % % % %W$ & &F   f % % % %N^3444r9)rerf)rerfF)rtr)rrr)rfr)rfrN)rf)rre)rtN)#r:r;r<r= _childWakerrrFrLrrOrdrorsrrrrrxrrrrrr AddressFamily__annotations__rrrrrrrr __classcell__)r*s@r7rArAss&Kw ' ' '<    6666tPU    "     NR    "  N O NE !8F,@#A     N O% ! *    FJ     LP 7 7 7 7 7 7 7 75555555r9rAceZdZdZdZdS)_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_inforerrr8)r1r2fdeventr3inReads r7_doReadOrWritez_PollLikeMixin._doReadOrWrites>  4* *. EDM4I. T[  %& $$&&",,'CCt},&(//11!%'54>#9')0022!&    lnnQ'    @  & &z3 ? ? ? ? ? @ @sA"B6CCN)r:r;r<r=rr?r9r7rrs2  7@7@7@7@7@r9rcfeZdZdZdZdZdZdZdZdZ 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|_dSrD)_reactor_loopr_readers_writers)r1reactors r7__init__z_ContinuousPolling.__init__ s*    r9c|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)r1rrs r7 _checkLoopz_ContinuousPolling._checkLoops = DM z!GGGGGGGG([66 #'=     u 55555"!Z  JOO   DJJJ  r9ct|jD]}||||jt|jD]}||||jdS)zX Call C{doRead} and C{doWrite} on all readers and writers respectively. N)rrrrrr)r1rrs r7rz_ContinuousPolling.iterate%s~4=)) ? ?F    > > > >4=)) @ @F    ? ? ? ? @ @r9cb|j||dS)zU Add a C{FileDescriptor} for notification of data available to read. N)rrJrr1rs r7rKz_ContinuousPolling.addReader.0 &!!! r9cb|j||dS)zV Add a C{FileDescriptor} for notification of data available to write. N)rrJrr1rs r7 addWriterz_ContinuousPolling.addWriter5rr9c |j|n#t$rYdSwxYw|dS)zY Remove a C{FileDescriptor} from notification of data available to read. N)rremoveKeyErrorrrs r7r(z_ContinuousPolling.removeReader<sX  M  ( ( ( (    FF    ++c |j|n#t$rYdSwxYw|dS)zb Remove a C{FileDescriptor} from notification of data available to write. N)rrrrrs r7r.z_ContinuousPolling.removeWriterFsX   M  ( ( ( (    FF  rct|j|jz}|j|j|S)z1 Remove all readers and writers. )rrrclear)r1results r7 removeAllz_ContinuousPolling.removeAllQsIdmdm344   r9c*t|jS)z/ Return a list of the readers. )rrrEs r7 getReadersz_ContinuousPolling.getReaders\DM"""r9c*t|jS)z/ Return a list of the writers. )rrrEs r7 getWritersz_ContinuousPolling.getWritersbrr9c||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} )rr1rs r7 isReadingz_ContinuousPolling.isReadinghT]""r9c||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 r7 isWritingz_ContinuousPolling.isWritingurr9N)r:r;r<r=rrrrrrrKrr(r.rrrrrr?r9r7rrs,HI $@@@      ### ### # # # # # # # #r9rfromfd)rs:   77777777,,,,,,,,,,------                        CBBBBBBB''''''''99999999-u,-CDD ------ CC CCC ,,,,,, CC CCC g% ........N8  #<#<#<#<#<#<#<#