Vh(TdZddlmZddlZddlZddlmZddlmZm Z ddl m Z m Z m Z ddlmZddlmZmZmZmZmZmZmZmZmZmZmZdd lmZmZdd lm Z dd l!m"Z"m#Z#dd l$m%Z%m&Z&d dl'm(Z(m)Z)m*Z*m+Z+m,Z,e jZdZ. ddl/m0Z1e1Z0 ddl m3Z4e4Z3e&dk(Z5dZ6e5r ddl m7Z7m8Z8dZ6e%jrr ddl:Z:dZ6GddZ;e eeeGdde;eZ<GddZ=e eGdde=e;Z>e0e3 ee Mixin providing the C{_disconnectSelectable} method. c|j||j|j}|ri|rD|jtjk(r't j |r|j|y|j||j|y|j||jtj|y)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 J/home/dcms/DCMS/lib/python3.12/site-packages/twisted/internet/posixbase.py_disconnectSelectablez0_DisconnectSelectableMixin._disconnectSelectableUs *% LL ' MMU%9%99,77 C--a0!!*-))!,   j )  % %gooc&: ;N) __name__ __module__ __qualname____doc__rr.rr3ConnectionLostr;r<r:r)r)PsW  /'//2F%2F2F2H"I  /'//2F%2F2F2H"I  > >00? ? =FNN: 224QA11nmWA r<c||jvrtj|tr4|tj k(r!t jj|||Stjj||||S)zg @see: L{twisted.internet.interfaces.IReactorSocket.adoptStreamConnection} ) rrrrwrrr'Server_fromConnectedSocketr)r4rrr{s r:adoptStreamConnectionz&PosixReactorBase.adoptStreamConnectionOsj  > > >00? ? =FNN:;;33NGTR R::22 w r<c|tjtjfvrtj|t j j|||||}|j|S)N)rm) rAF_INETAF_INET6rrr rhrri)r4rrrkrmrns r:adoptDatagramPortz"PosixReactorBase.adoptDatagramPort^sa  A A00? ? HH - - .- .  r<cXtj|||||}|j|SrF)rrhri)r4rjr{rrlrns r: listenTCPzPosixReactorBase.listenTCPls) HHT7GY = r<cZtj||||||}|j|SrF)rrxry)r4hostrjr{r|rr~s r: connectTCPzPosixReactorBase.connectTCPqs* MM$gw T J r<c t,tj|d|}|j|||||St-tj |||||||}|j |SJd)NTSSL support is not present)r#TLSMemoryBIOFactoryrr$rxry) r4rrjr{contextFactoryr|r tlsFactoryr~s r: connectSSLzPosixReactorBase.connectSSLsq ?00wOJ??4z7KP P _ dG^Wk4A IIKH 66 65r<ct4tj|d|}|j||||}d|_|St,tj ||||||}|j |SJd)NFTLSr)r#rr_typer$rhri)r4rjr{rrrlrrns r: listenSSLzPosixReactorBase.listenSSLst ?00PJ>>$ GYGDDJK _wDQA   H 66 65r<ct||jz }|D]}|j|t|}|D]}|j|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. )setrKr+r1list)r4readerswritersremovedReadersreaderremovedWriterswriters r: _removeAllzPosixReactorBase._removeAllsoW(=(==$ &F   f % &W$ &F   f % &N^344r<)returnr )rr) )rrF)r)2r)rr)rrN)r)rr)g>@N) rstrrjintr{z'ClientFactory'r|floatrztuple[str, int] | Nonerr )rN)r=r>r?r@ _childWakerrHrNrQrfrorsrrrrrwrrrrr__annotations__rrrrrrrr __classcell__)r-s@r:rDrDvs"K '<    6tPU "  NR " NN OO NNE !#A  NN OO% ! *  FJ .2   !    ,   LP 7 75r<rDceZdZdZdZy)_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}nft}n_ |j dk(rt }nD||jzr|j}d}|s!||jzr|j}d}|r|j|||yy#t$r.tjd}tjYMwxYw)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_inforerrr;)r4r5fdeventr6inReads r:_doReadOrWritez_PollLikeMixin._doReadOrWrites  4** *EDMM4IT[[ %& $$&",'Ct}},(//1!%54>>#9)002!&   & &z3 ?  ! llnQ'  sAB774C.-C.N)r=r>r?r@rrBr<r:rrs  7@r<rcdeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZy)_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. rc\||_d|_t|_t|_yrF)_reactor_loopr_readers_writers)r4reactors r:__init__z_ContinuousPolling.__init__s"    r<cZ|js |jre|jXddlm}m}||j |_|j|j_|jj|dyy|jr"|jjd|_yy)zh Start or stop a C{LoopingCall} based on whether there are readers and writers. Nr)_EPSILON LoopingCallF)now) rrrtwisted.internet.taskrriteraterclockstartstop)r4rrs r: _checkLoopz_ContinuousPolling._checkLoops ==DMMzz!G(6 #'==     u 5"ZZ JJOO DJr<ct|jD]}|j|||j!t|jD]}|j|||j !y)zX Call C{doRead} and C{doWrite} on all readers and writers respectively. N)rrrrrr)r4rrs r:rz_ContinuousPolling.iterate/sb4==) ?F    > ?4==) @F    ? @r<cZ|jj||jy)zU Add a C{FileDescriptor} for notification of data available to read. N)rrLrr4rs r:rMz_ContinuousPolling.addReader8  &! r<cZ|jj||jy)zV Add a C{FileDescriptor} for notification of data available to write. N)rrLrr4rs r: addWriterz_ContinuousPolling.addWriter?rr<cz |jj||jy#t$rYywxYw)zY Remove a C{FileDescriptor} from notification of data available to read. N)rremoveKeyErrorrrs r:r+z_ContinuousPolling.removeReaderFs9  MM  (     . ::cz |jj||jy#t$rYywxYw)zb Remove a C{FileDescriptor} from notification of data available to write. N)rrrrrs r:r1z_ContinuousPolling.removeWriterPs9   MM  (    rct|j|jz}|jj|jj|S)z1 Remove all readers and writers. )rrrclear)r4results r: removeAllz_ContinuousPolling.removeAll[sBdmmdmm34   r<c,t|jS)z/ Return a list of the readers. )rrrGs r: getReadersz_ContinuousPolling.getReadersfDMM""r<c,t|jS)z/ Return a list of the writers. )rrrGs r: getWritersz_ContinuousPolling.getWriterslrr<c||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} )rr4rs r: isReadingz_ContinuousPolling.isReadingrT]]""r<c||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 r: isWritingz_ContinuousPolling.isWritingrr<N)r=r>r?r@rrrrrrrMrr+r1rrrrrrBr<r:rrsV,HI $@  # # # #r<rfromfd)Ar@ __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$_sslrwprocessEnabledr&r' isWindowsrZr)rDrrgetattr__all__rBr<r:rs # 7,,-    C3'9-u,,-CD - C, Cg% .N8 #<#EE  E EEE'&E'