U n5{i(Tã@shdZddlmZddlZddlZddlmZddlmZm 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  -d¡Z.zddl/m0Z1Wne2k rdZ0YnXe1Z0zddl m3Z4Wne2k rLdZ3YnXe4Z3e&dkZ5dZ6e5rxddl m7Z7m8Z8dZ6e% 9¡r®zddl:Z:dZ6Wne2k r¬dZ:YnXGdd„dƒZ;e eeeƒGdd„de;eƒƒZe0dk se3dk r ee Mixin providing the C{_disconnectSelectable} method. cCst| |¡| |j¡}|rV|r@|jtjkr@t |¡r@| |¡qp| |¡|  |¡n| |¡|  t   |¡¡dS)z¿ Utility function for disconnecting a selectable. Supports half-close notification, isRead should be boolean indicating whether error resulted from doRead(). N) Ú removeReaderÚgetÚ __class__rÚConnectionDoner Z providedByZreadConnectionLostÚ removeWriterZconnectionLostrÚFailure)ÚselfÚ selectableÚwhyZisReadZfaildictÚf©r2ú>/tmp/pip-unpacked-wheel-mnhg7r0q/twisted/internet/posixbase.pyÚ_disconnectSelectableUs  ÿ þý    z0_DisconnectSelectableMixin._disconnectSelectableN) Ú__name__Ú __module__Ú __qualname__Ú__doc__rr+rr-ZConnectionLostr4r2r2r2r3r'Ps   þûr'cseZdZUdZdZddœdd„Zdd„Zd dœ‡fd d „ Zd idddd dfdd„Zddd„Z d?dd„Z d@dd„Z dAd d!„Zer¬ejejejfZd"ed#<n ejejfZd$d%„Zd&d'„ZdBd(d)„ZdCd*d+„ZdDd-d.d/d0d1d2d3œd4d5„ZdEd6d7„ZdFd8d9„Zd:d;„Z‡ZS)GÚPosixReactorBasezÄ 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. Nr)ÚreturncCstƒS©N)r!©r.r2r2r3Ú _wakerFactoryƒszPosixReactorBase._wakerFactorycCs.|js*| ¡|_|j |j¡| |j¡dS)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=Ú_internalReadersÚaddÚ addReaderr<r2r2r3Ú installWaker†s zPosixReactorBase.installWakerrcs,tƒ ¡}tdkr(t|t|j|jƒfƒS|S)zj Customize reactor signal handling to support child processes on POSIX platforms. r$)ÚsuperÚ_signalsFactoryrr rZ_addInternalReaderZ_removeInternalReader)r.Z baseHandling©r*r2r3rC’s þüÿ z PosixReactorBase._signalsFactoryr2rc CsÊtdkrR|r6| dk rtdƒ‚t |||||||||¡ St ||||||||| ¡ Snttdkr¾|dk rjtdƒ‚|dk rztdƒ‚|r†tdƒ‚| r’tdƒ‚tr´dd lm} | ||||||ƒStd ƒ‚ntd ƒ‚dS) Nr$z1Using childFDs is not supported with usePTY=True.Úwin32z,Setting UID is unsupported on this platform.z,Setting GID is unsupported on this platform.z1The usePTY parameter is not supported on Windows.z1Customizing childFDs is not supported on Windows.r)ÚProcessz:spawnProcess not available since pywin32 is not installed.z0spawnProcess only available on Windows or POSIX.)rÚ ValueErrorr%Z PTYProcessrFÚ win32processZtwisted.internet._dumbwin32procÚNotImplementedError) r.ZprocessProtocolÚ executableÚargsÚenvÚpathÚuidÚgidZusePTYZchildFDsrFr2r2r3Ú spawnProcess¬s\ ÿÿ÷  ÿÿzPosixReactorBase.spawnProcessÚé cCst |||||¡}| ¡|S)z‡Connects a given L{DatagramProtocol} to the given numeric UDP port. @returns: object conforming to L{IListeningPort}. )rÚPortÚstartListening)r.ÚportÚprotocolÚ interfaceÚ maxPacketSizeÚpr2r2r3Ú listenUDPæszPosixReactorBase.listenUDPFcCs t ||||||¡}| ¡|S)z˜Connects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL. @returns: object conforming to IListeningPort. )rZ MulticastPortrT)r.rUrVrWrXZlistenMultiplerYr2r2r3ÚlistenMulticastñs ÿz PosixReactorBase.listenMulticastécCs*ts tdƒ‚t |||||¡}| ¡|S©NúUNIX support is not present)Ú unixEnabledÚAssertionErrorr&Ú ConnectorÚconnect)r.ÚaddressÚfactoryÚtimeoutZcheckPIDÚcr2r2r3Ú connectUNIXs zPosixReactorBase.connectUNIXé2é¶cCs,ts tdƒ‚t ||||||¡}| ¡|Sr])r_r`r&rSrT)r.rcrdÚbacklogÚmodeZwantPIDrYr2r2r3Ú listenUNIXs zPosixReactorBase.listenUNIXcCs*ts tdƒ‚t |||||¡}| ¡|S)z› Connects a given L{DatagramProtocol} to the given path. EXPERIMENTAL. @returns: object conforming to L{IListeningPort}. r^)r_r`r&Z DatagramPortrT)r.rcrVrXrkrYr2r2r3ÚlistenUNIXDatagrams z#PosixReactorBase.listenUNIXDatagramcCs,ts tdƒ‚t ||||||¡}| ¡|S)zd Connects a L{ConnectedDatagramProtocol} instance to a path. EXPERIMENTAL. r^)r_r`r&ZConnectedDatagramPortrT)r.rcrVrXrkÚ bindAddressrYr2r2r3ÚconnectUNIXDatagrams ÿz$PosixReactorBase.connectUNIXDatagramzSequence[socket.AddressFamily]Ú_supportedAddressFamiliescCsR||jkrt |¡‚tr4|tjkr4tj |||¡}nt j ||||¡}|  ¡|S)a0 Create a new L{IListeningPort} from an already-initialized socket. This just dispatches to a suitable port implementation (eg from L{IReactorTCP}, etc) based on the specified C{addressFamily}. @see: L{twisted.internet.interfaces.IReactorSocket.adoptStreamPort} ) rprÚUnsupportedAddressFamilyr_ÚsocketÚAF_UNIXr&rSÚ_fromListeningDescriptorrrT)r.ÚfileDescriptorÚ addressFamilyrdrYr2r2r3ÚadoptStreamPort:s  ÿz PosixReactorBase.adoptStreamPortcCsH||jkrt |¡‚tr2|tjkr2tj |||¡St j ||||¡SdS)zg @see: L{twisted.internet.interfaces.IReactorSocket.adoptStreamConnection} N) rprrqr_rrrsr&ÚServerZ_fromConnectedSocketr)r.rurvrdr2r2r3ÚadoptStreamConnectionOs  ÿz&PosixReactorBase.adoptStreamConnectioncCs<|tjtjfkrt |¡‚tjj|||||d}| ¡|S)N)rX) rrÚAF_INETÚAF_INET6rrqrrSrtrT)r.rurvrVrXrYr2r2r3ÚadoptDatagramPort^s ÿz"PosixReactorBase.adoptDatagramPortcCst |||||¡}| ¡|Sr;)rrSrT)r.rUrdrjrWrYr2r2r3Ú listenTCPlszPosixReactorBase.listenTCPç>@ÚstrÚintz'ClientFactory'Úfloatztuple[str, int] | Noner )ÚhostrUrdrernr:cCs t ||||||¡}| ¡|Sr;)rrarb)r.r‚rUrdrernrfr2r2r3Ú connectTCPqszPosixReactorBase.connectTCPc Csbtdk r(t |d|¡}| |||||¡Stdk rRt |||||||¡}| ¡|Sds^tdƒ‚dS)NTFúSSL support is not present)r"ÚTLSMemoryBIOFactoryrƒr#rarbr`) r.r‚rUrdÚcontextFactoryrernÚ tlsFactoryrfr2r2r3Ú connectSSLs ÿzPosixReactorBase.connectSSLcCshtdk r0t |d|¡}| ||||¡}d|_|Stdk rXt ||||||¡}| ¡|Sdsdtdƒ‚dS)NFZTLSr„)r"r…r}Ú_typer#rSrTr`)r.rUrdr†rjrWr‡rYr2r2r3Ú listenSSLŽszPosixReactorBase.listenSSLcCsJt|ƒ|j}|D]}| |¡qt|ƒ}|D]}| |¡q.t||BƒS)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. )Úsetr>r(r,Úlist)r.ZreadersZwritersZremovedReadersÚreaderZremovedWritersÚwriterr2r2r3Ú _removeAll›s   zPosixReactorBase._removeAll)rQrR)rQrRF)r\r)rhrir)rRri)rRriN)rR)rhrQ)r~N)r\N)rhrQ)r5r6r7r8Z _childWakerr=rArCrPrZr[rgrlrmror_rrrzr{rsrpÚ__annotations__rwryr|r}rƒrˆrŠrÚ __classcell__r2r2rDr3r9vs\  ö : ÿ    ÿ ýþÿ  úÿ  r9c@seZdZdZdd„ZdS)Ú_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). cCs¼d}d}||j@r6||j@s6||jkr0d}t}q¦t}npzF| ¡dkrJt}n0||j@r`| ¡}d}|sz||j@rz|  ¡}d}Wn(t k r¤t   ¡d}t  ¡YnX|r¸| |||¡dS)zg fd is available for read or write, do the work and raise errors if necessary. NFTéÿÿÿÿr)Ú_POLL_DISCONNECTEDÚ_POLL_INZ_readsrrÚfilenoÚ _NO_FILEDESCZdoReadÚ _POLL_OUTZdoWriteÚ BaseExceptionÚsysÚexc_inforÚerrr4)r.r/ÚfdÚeventr0ZinReadr2r2r3Ú_doReadOrWriteÁs*    z_PollLikeMixin._doReadOrWriteN)r5r6r7r8rŸr2r2r2r3r’²sr’c@s|eZdZdZdZdZdZdd„Zdd„Zd d „Z d d „Z d d„Z dd„Z dd„Z dd„Zdd„Zdd„Zdd„Zdd„ZdS)Ú_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. réécCs ||_d|_tƒ|_tƒ|_dSr;)Ú_reactorÚ_loopr‹Ú_readersÚ_writers)r.Zreactorr2r2r3Ú__init__sz_ContinuousPolling.__init__cCsh|js |jrN|jdkrdddlm}m}||jƒ|_|j|j_|jj |ddn|jrd|j  ¡d|_dS)zh Start or stop a C{LoopingCall} based on whether there are readers and writers. Nr)Ú_EPSILONÚ LoopingCallF)Únow) r¥r¦r¤Ztwisted.internet.taskr¨r©Úiterater£ZclockÚstartÚstop)r.r¨r©r2r2r3Ú _checkLoops     z_ContinuousPolling._checkLoopcCsDt|jƒD]}| |||j¡q t|jƒD]}| |||j¡q*dS)zX Call C{doRead} and C{doWrite} on all readers and writers respectively. N)rŒr¥rŸr•r¦r˜)r.rrŽr2r2r3r«/sz_ContinuousPolling.iteratecCs|j |¡| ¡dS)zU Add a C{FileDescriptor} for notification of data available to read. N)r¥r?r®©r.rr2r2r3r@8s z_ContinuousPolling.addReadercCs|j |¡| ¡dS)zV Add a C{FileDescriptor} for notification of data available to write. N)r¦r?r®©r.rŽr2r2r3Ú addWriter?s z_ContinuousPolling.addWritercCs4z|j |¡Wntk r&YdSX| ¡dS)zY Remove a C{FileDescriptor} from notification of data available to read. N)r¥ÚremoveÚKeyErrorr®r¯r2r2r3r(Fs z_ContinuousPolling.removeReadercCs4z|j |¡Wntk r&YdSX| ¡dS)zb Remove a C{FileDescriptor} from notification of data available to write. N)r¦r²r³r®r°r2r2r3r,Ps z_ContinuousPolling.removeWritercCs(t|j|jBƒ}|j ¡|j ¡|S)z1 Remove all readers and writers. )rŒr¥r¦Úclear)r.Úresultr2r2r3Ú removeAll[s  z_ContinuousPolling.removeAllcCs t|jƒS)z/ Return a list of the readers. )rŒr¥r<r2r2r3Ú getReadersfsz_ContinuousPolling.getReaderscCs t|jƒS)z/ Return a list of the writers. )rŒr¦r<r2r2r3Ú getWriterslsz_ContinuousPolling.getWriterscCs ||jkS)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} )r¥©r.rr2r2r3Ú isReadingrs z_ContinuousPolling.isReadingcCs ||jkS)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} )r¦r¹r2r2r3Ú isWritings z_ContinuousPolling.isWritingN)r5r6r7r8r”r•r˜r§r®r«r@r±r(r,r¶r·r¸rºr»r2r2r2r3r ûs      r Úfromfd)Ar8Ú __future__rrrršÚtypingrZzope.interfacerrZtwisted.internetrrrZtwisted.internet.baser Ztwisted.internet.interfacesr r r r rrrrrrrZtwisted.internet.mainrrZtwisted.internet.protocolrZtwisted.pythonrrZtwisted.python.runtimerrZ_signalsrrrr r!ZConnectionFdescWentAwayr—Ztwisted.protocolsr"Z_tlsÚ ImportErrorr#Ú_sslr_ZprocessEnabledr%r&Z isWindowsrHr'r9r’r ÚgetattrÚ__all__r2r2r2r3Úsj   4       & =I