o >h(T@sXdZddlmZddlZddlZddlmZddlmZm 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 -dZ.zddl/m0Z1Wn e2ydZ0Ynwe1Z0zddl m3Z4Wn e2ydZ3Ynwe4Z3e&dkZ5dZ6e5rddl m7Z7m8Z8dZ6e%9rzddl:Z:dZ6Wn e2ydZ:YnwGdddZ;e eeeGddde;eZe0duse3duree Mixin providing the C{_disconnectSelectable} method. cCsx||||j}|r-|r!|jtjkr!t|r!||dS||| |dS||| t |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 selectablewhyisReadfaildictfr7z/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/twisted/internet/posixbase.py_disconnectSelectableUs     z0_DisconnectSelectableMixin._disconnectSelectableN) __name__ __module__ __qualname____doc__rr+rr0ConnectionLostr9r7r7r7r8r'Ps  r'cseZdZUdZdZd@ddZddZdAfd d Zd idddd dfddZdBddZ dCddZ dDddZ dEddZ dFddZ dGd d!ZerTejejejfZd"ed#<nejejfZd$d%Zd&d'Z dHd(d)ZdId*d+Z , dJdKd8d9Z dLd:d;ZdIdd?ZZS)MPosixReactorBasez 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. NreturnrcCstSN)r!r1r7r7r8 _wakerFactoryszPosixReactorBase._wakerFactorycCs2|js||_|j|j||jdSdS)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)wakerrC_internalReadersadd addReaderrBr7r7r8 installWakers  zPosixReactorBase.installWakerrcs,t}tdkrt|t|j|jfS|S)zj Customize reactor signal handling to support child processes on POSIX platforms. r$)super_signalsFactoryrr r_addInternalReader_removeInternalReader)r1 baseHandlingr*r7r8rJs  z PosixReactorBase._signalsFactoryr7rc Cstdkr(|r| durtdt||||||||| St||||||||| Stdkr]|dur4td|dur@hoststrreintru'ClientFactory'rvfloatrtuple[str, int] | Noner cCs t||||||}||SrA)rrrrs)r1rrerurvrrxr7r7r8 connectTCPqszPosixReactorBase.connectTCPc CsZtdurt|d|}||||||Stdur)t|||||||}||SJd)NTFSSL support is not present)r"TLSMemoryBIOFactoryrr#rrrs) r1rrerucontextFactoryrvr tlsFactoryrxr7r7r8 connectSSLszPosixReactorBase.connectSSLcCs`tdurt|d|}|||||}d|_|Stdur,t||||||}||SJd)NFTLSr)r"rr_typer#rcrd)r1rerurr|rgrrir7r7r8 listenSSLszPosixReactorBase.listenSSLcCsJt||j}|D]}||q t|}|D]}||qt||BS)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. )setrEr(r.list)r1readerswritersremovedReadersreaderremovedWriterswriterr7r7r8 _removeAlls    zPosixReactorBase._removeAll)r@r)r@r)r`ra)r`raF)rnr)rzr{r)rar{)rar{N)ra)rzr`)rN) rrrerrurrvrrrr@r )rnN)r:r;r<r= _childWakerrCrHrJr_rjrmryrrrrqrrrrr__annotations__rrrrrrrr __classcell__r7r7rNr8r?vsT    :         r?c@seZdZdZddZdS)_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). cCsd}d}||j@r||j@s||jvrd}t}n:t}n7z#|dkr%t}n||j@r0|}d}|s=||j@r=| }d}Wnt yQt d}t Ynw|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_inforerrr9)r1r2fdeventr3inReadr7r7r8_doReadOrWrites0      z_PollLikeMixin._doReadOrWriteN)r:r;r<r=rr7r7r7r8rs rc@s|eZdZdZdZdZdZddZddZd d Z d d Z d dZ ddZ ddZ ddZddZddZddZddZdS)_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. rcCs ||_d|_t|_t|_dSrA)_reactor_loopr_readers_writers)r1reactorr7r7r8__init__s z_ContinuousPolling.__init__cCsr|js|jr*|jdur(ddlm}m}||j|_|j|j_|jj |dddSdS|jr7|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)r1rrr7r7r8 _checkLoops      z_ContinuousPolling._checkLoopcCsDt|jD] }||||jqt|jD] }||||jqdS)zX Call C{doRead} and C{doWrite} on all readers and writers respectively. N)rrrrrr)r1rrr7r7r8r/s z_ContinuousPolling.iteratecC|j||dS)zU Add a C{FileDescriptor} for notification of data available to read. N)rrFrr1rr7r7r8rG8  z_ContinuousPolling.addReadercCr)zV Add a C{FileDescriptor} for notification of data available to write. N)rrFrr1rr7r7r8 addWriter?rz_ContinuousPolling.addWritercC2z|j|Wn tyYdSw|dS)zY Remove a C{FileDescriptor} from notification of data available to read. N)rremoveKeyErrorrrr7r7r8r(Fs   z_ContinuousPolling.removeReadercCr)zb Remove a C{FileDescriptor} from notification of data available to write. N)rrrrrr7r7r8r.Ps   z_ContinuousPolling.removeWritercCs(t|j|jB}|j|j|S)z1 Remove all readers and writers. )rrrclear)r1resultr7r7r8 removeAll[s  z_ContinuousPolling.removeAllcC t|jS)z/ Return a list of the readers. )rrrBr7r7r8 getReadersf z_ContinuousPolling.getReaderscCr)z/ Return a list of the writers. )rrrBr7r7r8 getWriterslrz_ContinuousPolling.getWriterscC ||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} )rr1rr7r7r8 isReadingr z_ContinuousPolling.isReadingcCr)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} )rrr7r7r8 isWritingrz_ContinuousPolling.isWritingN)r:r;r<r=rrrrrrrGrr(r.rrrrrr7r7r7r8rs"     rfromfd)Ar= __future__rrrtypingrzope.interfacerrtwisted.internetrrrtwisted.internet.baser twisted.internet.interfacesr r r r rrrrrrrtwisted.internet.mainrrtwisted.internet.protocolrtwisted.pythonrrtwisted.python.runtimerr_signalsrrrr r!ConnectionFdescWentAwayrtwisted.protocolsr"_tls ImportErrorr#_sslrqprocessEnabledr%r& isWindowsrSr'r?rrgetattr__all__r7r7r7r8sr   4      &=I