[XMc@s dZddlZddlZddlZddlZddlmZmZddlm Z ddl m Z m Z ddl m Z mZmZmZddl mZmZddl mZdd lmZdd lmZmZdd lmZmZmZdd lmZdd lmZm Z ddl!m"Z"m#Z#yddlm$Z$e%Z&Wne'k rke(Z&nXyddlm)Z)e%Z*Wne'k re(Z*nXe(Z+edkrddlm,Z,m-Z-m.Z.e%Z+ne j/ryddl0Z0e%Z+Wne'k re1Z0nXndej2ej3fdYZ4de5ej2ej3fdYZ6de6fdYZ7edkre7Z8ne4Z8de6fdYZ9de#e"fdYZ:e&ree:ene*ree:e e ne+ree:endgZ;dS(s Posix reactor base class iN(t implementstclassImplements(tset(t IReactorUNIXtIReactorUNIXDatagram(t IReactorTCPt IReactorUDPt IReactorSSLt_IReactorArbitrary(tIReactorProcesstIReactorMulticast(tIHalfCloseableDescriptor(terror(ttcptudp(tlogtfailuretutil(tstyles(t platformTypetplatform(t ReactorBaset_SignalReactorMixin(tssl(tunixtposix(tfdesctprocesst_signalst _SocketWakercBs8eZdZdZdZdZdZdZRS(s The I{self-pipe trick}, implemented using a pair of sockets rather than pipes (due to the lack of support in select() on Windows for pipes), used to wake up the main loop from another thread. icCs||_tjtjtj}tjtjtj}|jtjtjd|jd|jd|j |j |j \}}|j d|j d||_ ||_|j j|_dS(sInitialize. is 127.0.0.1iN(s 127.0.0.1i(treactortsockettAF_INETt SOCK_STREAMt setsockoptt IPPROTO_TCPt TCP_NODELAYtbindtlistentconnectt getsocknametacceptt setblockingtrtwtfileno(tselfRtservertclienttreadert clientaddr((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt__init__@s       cCsRytj|jjdWn1tjk rM\}}|tjkrNqNnXdS(s&Send a byte to my connection. txN(RtuntilConcludesR,tsendRR terrnotWSAEWOULDBLOCK(R.terrtmsg((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pytwakeUpRs cCs/y|jjdWntjk r*nXdS(s+Read some data from my connection. i N(R+trecvRR (R.((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pytdoRead[scCs|jj|jjdS(N(R+tcloseR,(R.treason((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pytconnectionLostcs (t__name__t __module__t__doc__t disconnectedR3R;R=R@(((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyR7s   t_FDWakercBs;eZdZdZdZdZdZdZdZ RS(s The I{self-pipe trick}, used to wake up the main loop from another thread or a signal handler. L{_FDWaker} is a base class for waker implementations based on writing to a pipe being monitored by the reactor. @ivar o: The file descriptor for the end of the pipe which can be written to to wake up a reactor monitoring this waker. @ivar i: The file descriptor which should be monitored in order to be awoken by this waker. icsw|_tj\__tjjtjjtjjtjjfd_dS(sInitialize. csjS(N(ti((R.(s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pytsN( RtostpipeRFtoRtsetNonBlockingt_setCloseOnExecR-(R.R((R.s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyR3|s cCstj|jddS(sA Read some bytes from the pipe and discard them. cSsdS(N(tNone(tdata((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyRGsN(Rt readFromFDR-(R.((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyR=scCset|dsdSx?|j|jfD]+}ytj|Wq&tk rPq&Xq&W|`|`dS(s$Close both ends of my pipe. RJN(thasattrRFRJRHR>tIOError(R.R?tfd((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyR@s N( RARBRCRDRMRFRJR3R=R@(((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyREis  t _UnixWakercBseZdZdZRS(s This class provides a simple interface to wake up the event loop. This is used by threads or signals to wake up the event loop. cCsa|jdk r]ytjtj|jdWq]tk rY}|jtjkrZqZq]XndS(s2Write one byte to the pipe, and flush it. R4N( RJRMRR5RHtwritetOSErrorR7tEAGAIN(R.te((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyR;s (RARBRCR;(((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyRSst _SIGCHLDWakercBs2eZdZdZdZdZdZRS(s} L{_SIGCHLDWaker} can wake up a reactor whenever C{SIGCHLD} is received. @see: L{twisted.internet._signals} cCstj||dS(N(RER3(R.R((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyR3scCstj|jdS(sJ Install the handler necessary to make this waker active. N(RtinstallHandlerRJ(R.((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pytinstallscCstjddS(sC Remove the handler which makes this waker active. iN(RRY(R.((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt uninstallscCstj|tjdS(s Having woken up the reactor in response to receipt of C{SIGCHLD}, reap the process which exited. This is called whenever the reactor notices the waker pipe is writeable, which happens soon after any call to the C{wakeUp} method. N(RER=RtreapAllProcesses(R.((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyR=s (RARBRCR3RZR[R=(((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyRXs    tPosixReactorBasecBsXeZdZeeeeeiej e j e j 6ej e j e j 6dZ dZdZdZdZdiddddddZddd Zdded Zd dd Zd dddZdddZddddZd ddZd ddZd ddZd ddZdZdZ dZ!RS(s A basis for reactors that use file descriptors. @ivar _childWaker: C{None} or a reference to the L{_SIGCHLDWaker} which is used to properly notice child process termination. cCs|j||j|j}|ry|r\|jtjkr\tj|r\|j|q|j||j |n#|j||j t j |dS(s Utility function for disconnecting a selectable. Supports half-close notification, isRead should be boolean indicating whether error resulted from doRead(). N( t removeReadertgett __class__R tConnectionDoneR t providedBytreadConnectionLostt removeWriterR@RtFailure(R.t selectabletwhytisReadtfaildicttf((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt_disconnectSelectables   cCsB|js>t||_|jj|j|j|jndS(s 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(twakert_Wakert_internalReaderstaddt addReader(R.((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt installWakers cCsutj|tdkrq|jsWt||_|jj|j|j|jn|jjt j ndS(s Extend the basic signal handling logic to also support handling SIGCHLD to know when to try to reap child processes. RN( Rt_handleSignalsRt _childWakerRXRnRoRpRZRR\(R.((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyRrs    cCs|jr|jjndS(s If a child waker was created and installed, uninstall it now. Since this disables reactor functionality and is only called when the reactor is stopping, it doesn't provide any directly useful functionality, but the cleanup of reactor-related process-global state that it does helps in unit tests involving multiple reactors and is generally just a nice thing. N(RsR[(R.((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt_uninstallHandler#s ic Cs7|j||\}}tdkr|rj| dk rEtdntj||||||||| Stj||||||||| Sntdkr*|dk s|dk rtdn|rtdn| rtdntrddlm} | ||||||St d n t d dS( NRs1Using childFDs is not supported with usePTY=True.twin32s8The uid and gid parameters are not supported on Windows.s1The usePTY parameter is not supported on Windows.s1Customizing childFDs is not supported on Windows.i(tProcesss:spawnProcess not available since pywin32 is not installed.s0spawnProcess only available on Windows or POSIX.( t_checkProcessArgsRRMt ValueErrorRt PTYProcessRvt win32processttwisted.internet._dumbwin32proctNotImplementedError( R.tprocessProtocolt executabletargstenvtpathtuidtgidtusePTYtchildFDsRv((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt spawnProcess6s*    ti cCs)tj|||||}|j|S(sConnects a given L{DatagramProtocol} to the given numeric UDP port. @returns: object conforming to L{IListeningPort}. (RtPorttstartListening(R.tporttprotocolt interfacet maxPacketSizetp((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt listenUDPUs cCs,tj||||||}|j|S(sConnects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL. @returns: object conforming to IListeningPort. (Rt MulticastPortR(R.RRRRtlistenMultipleR((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pytlistenMulticast`s icCs8tstdtj|||||}|j|S(sC@see: twisted.internet.interfaces.IReactorUNIX.connectUNIX sUNIX support is not present(t unixEnabledtAssertionErrorRt ConnectorR'(R.taddresstfactoryttimeouttcheckPIDtc((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt connectUNIXns i2icCs;tstdtj||||||}|j|S(sK @see: twisted.internet.interfaces.IReactorUNIX.listenUNIX sUNIX support is not present(RRRRR(R.RRtbacklogtmodetwantPIDR((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt listenUNIXvs cCs8tstdtj|||||}|j|S(s Connects a given L{DatagramProtocol} to the given path. EXPERIMENTAL. @returns: object conforming to L{IListeningPort}. sUNIX support is not present(RRRt DatagramPortR(R.RRRRR((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pytlistenUNIXDatagrams  cCs;tstdtj||||||}|j|S(sd Connects a L{ConnectedDatagramProtocol} instance to a path. EXPERIMENTAL. sUNIX support is not present(RRRtConnectedDatagramPortR(R.RRRRt bindAddressR((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pytconnectUNIXDatagrams cCs)tj|||||}|j|S(s@@see: twisted.internet.interfaces.IReactorTCP.listenTCP (R RR(R.RRRRR((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt listenTCPs cCs,tj||||||}|j|S(sA@see: twisted.internet.interfaces.IReactorTCP.connectTCP (R RR'(R.thostRRRRR((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt connectTCPs cCs>tstdtj|||||||}|j|S(sA@see: twisted.internet.interfaces.IReactorSSL.connectSSL sSSL support is not present(t sslEnabledRRRR'(R.RRRtcontextFactoryRRR((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt connectSSLs! cCs;tstdtj||||||}|j|S(s@@see: twisted.internet.interfaces.IReactorSSL.listenSSL sSSL support is not present(RRRRR(R.RRRRRR((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt listenSSLs cOs@tjddtdd||d<|||}|j|S(Ns@listenWith is deprecated since Twisted 10.1. See IReactorFDSet.tcategoryt stackleveliR(twarningstwarntDeprecationWarningR(R.tportTypeRtkwR((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt listenWiths  cOs@tjddtdd||d<|||}|j|S(NsAconnectWith is deprecated since Twisted 10.1. See IReactorFDSet.RRiR(RRRR'(R.t connectorTypeRRR((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt connectWiths  cCsit||j}x|D]}|j|qWt|}x|D]}|j|qDWt||BS(sg 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. (RRnR^Rdtlist(R.treaderstwriterstremovedReadersR1tremovedWriterstwriter((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyt _removeAlls    N(("RARBRCRRRRR RReR RatConnectionLostRkRqRMRsRrRtRRtFalseRRRRRRRRRRRR(((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pyR]s6"        (<RCRRR7RHtzope.interfaceRRttwisted.python.compatRttwisted.internet.interfacesRRRRRRR R R ttwisted.internetR R Rttwisted.pythonRRRttwisted.persistedRttwisted.python.runtimeRRttwisted.internet.baseRRRtTrueRt ImportErrorRRRtprocessEnabledRRRt isWindowsRzRMtLoggert EphemeralRtobjectRERSRmRXR]t__all__(((s>/usr/lib/python2.7/dist-packages/twisted/internet/posixbase.pytsh    "             2"4  '