o i(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 Z providedByZreadConnectionLost removeWriterZconnectionLostrFailure)self selectablewhyZisReadZfaildictfr2`C:\Users\psant\Downloads\PAF backend\school\venv\Lib\site-packages\twisted/internet/posixbase.py_disconnectSelectableUs     z0_DisconnectSelectableMixin._disconnectSelectableN) __name__ __module__ __qualname____doc__rr+rr-ZConnectionLostr4r2r2r2r3r'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!r.r2r2r3 _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)Zwakerr=_internalReadersadd addReaderr<r2r2r3 installWakers  zPosixReactorBase.installWakerrcs,t}tdkrt|t|j|jfS|S)zj Customize reactor signal handling to support child processes on POSIX platforms. r$N)super_signalsFactoryrr rZ_addInternalReaderZ_removeInternalReader)r.Z baseHandlingr*r2r3rCs  z PosixReactorBase._signalsFactoryr2rc Cstdkr(|r| durtdt||||||||| St||||||||| Stdkr]|dur4td|dur@hoststrrVintrd'ClientFactory'refloatrntuple[str, int] | Noner cCs t||||||}||Sr;)rrarb)r.rrVrdrernrfr2r2r3 connectTCPqszPosixReactorBase.connectTCPc CsZtdurt|d|}||||||Stdur)t|||||||}||SJd)NTFSSL support is not present)r"TLSMemoryBIOFactoryrr#rarb) r.rrVrdcontextFactoryrern tlsFactoryrfr2r2r3 connectSSLszPosixReactorBase.connectSSLcCs`tdurt|d|}|||||}d|_|Stdur,t||||||}||SJd)NFZTLSr)r"rr}_typer#rTrU)r.rVrdrrjrXrrZr2r2r3 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. N)setr>r(r,list)r.readersZwritersZremovedReadersreaderZremovedWriterswriterr2r2r3 _removeAlls    zPosixReactorBase._removeAll)r:r)r:r)rQrR)rQrRF)r]r)rhrir)rRri)rRriN)rR)rhrQ)r~N) rrrVrrdrrerrnrr:r )r]N)r5r6r7r8Z _childWakerr=rArCrPr[r\rgrlrmror`rrrzr{rsrp__annotations__rwryr|r}rrrr __classcell__r2r2rDr3r9vsT    :         r9c@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_INZ_readsrrfileno _NO_FILEDESCZdoRead _POLL_OUTZdoWrite BaseExceptionsysexc_inforerrr4)r.r/fdeventr0ZinReadr2r2r3_doReadOrWrites0      z_PollLikeMixin._doReadOrWriteN)r5r6r7r8rr2r2r2r3rs 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|_dSr;)_reactor_loopr_readers_writers)r.Zreactorr2r2r3__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) rrrZtwisted.internet.taskrriteraterZclockstartstop)r.rrr2r2r3 _checkLoops      z_ContinuousPolling._checkLoopcCsDt|jD] }||||jqt|jD] }||||jqdS)zX Call C{doRead} and C{doWrite} on all readers and writers respectively. N)rrrrrr)r.rrr2r2r3r/s z_ContinuousPolling.iteratecC|j||dS)zU Add a C{FileDescriptor} for notification of data available to read. N)rr?rr.rr2r2r3r@8  z_ContinuousPolling.addReadercCr)zV Add a C{FileDescriptor} for notification of data available to write. N)rr?rr.rr2r2r3 addWriter?rz_ContinuousPolling.addWritercC2z|j|Wn tyYdSw|dS)zY Remove a C{FileDescriptor} from notification of data available to read. N)rremoveKeyErrorrrr2r2r3r(Fs   z_ContinuousPolling.removeReadercCr)zb Remove a C{FileDescriptor} from notification of data available to write. N)rrrrrr2r2r3r,Ps   z_ContinuousPolling.removeWritercCs(t|j|jB}|j|j|S)z1 Remove all readers and writers. N)rrrclear)r.resultr2r2r3 removeAll[s  z_ContinuousPolling.removeAllcC t|jS)z/ Return a list of the readers. N)rrr<r2r2r3 getReadersf z_ContinuousPolling.getReaderscCr)z/ Return a list of the writers. N)rrr<r2r2r3 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} N)rr.rr2r2r3 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} N)rrr2r2r3 isWritingrz_ContinuousPolling.isWritingN)r5r6r7r8rrrrrrr@rr(r,rrrrrr2r2r2r3rs"     rfromfd)Ar8 __future__rrrrtypingrZzope.interfacerrZtwisted.internetrrrZtwisted.internet.baser Ztwisted.internet.interfacesr r r r rrrrrrrZtwisted.internet.mainrrZtwisted.internet.protocolrZtwisted.pythonrrZtwisted.python.runtimerrZ_signalsrrrr r!ZConnectionFdescWentAwayrZtwisted.protocolsr"Z_tls ImportErrorr#_sslr`ZprocessEnabledr%r&Z isWindowsrHr'r9rrgetattr__all__r2r2r2r3sr   4      &=I