ó [³XMc@s_ddlmZddlmZddlmZmZddlmZddlZddl m Z ddl m Z ddl mZdd l mZdd lmZmZmZdd lmZdd lmZddlZdd lmZmZddlmZejdƒZejdƒZ d„Z!d„Z"dej#fd„ƒYZ$d„Z%dgZ&dS(iÿÿÿÿ(t generators(tThread(tQueuetEmpty(tsleepN(t implements(t IReactorFDSet(terror(t posixbase(tlogtfailuret threadable(tstyles(t platformType(tEINTRtEBADF(t_selectsHandler has no fileno methodsFiledescriptor went awaycCs#y ||=Wntk rnXdS(N(tKeyError(tdcttvalue((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyt dictRemoveRs  cCs |‚dS(N((te((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pytraiseExceptionXstThreadedSelectReactorcBseZdZeeƒd„Zd„Zd„Zd„Zd„Z d„Z d„Z d„Z d „Z d „Ze Zd „Zd „ZeZd „Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zdd„Zd„Z RS(sVA threaded select() based reactor - runs on all POSIX platforms and on Win32. cCsstjdƒi|_i|_tƒ|_tƒ|_d|_d|_ t j j |ƒ|j dd|jƒdS(Nitaftertshutdown(R tinittreadstwritesRt toThreadQueuet toMainThreadtNonet workerThreadt mainWakerRtPosixReactorBaset__init__taddSystemEventTriggert_mainLoopShutdown(tself((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyR#as       cCs|jjƒdS(N(twakertwakeUp(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyR(lscOs&tjj|||Ž}|jƒ|S(N(RR"t callLaterR((R&targstkwttple((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyR)ps cGs6|jj||fƒ|jdk r2|jƒndS(N(RtputR!R(R&tmsgR*((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyt _sendToMainuscGs|jj||fƒdS(N(RR-(R&tfnR*((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyt _sendToThread{scCsÑtjdƒ|jjƒ}|jjƒ}|jjƒ|jjƒx…|j|f|j|ffD]e\}}xV|D]N}y#tj|g|g|gdƒWntjd|ƒqwXd||((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyt_process_FailureÓscCsH|jdks|jjƒ rDtd|jƒ|_|jjƒndS(Nttarget(R RtisAliveRR?tstart(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pytensureWorkerThreadØscCsM|j|j|ƒ|jƒ|jjƒ\}}t|d|ƒ|ŒdS(Nt _process_(R1t_doIterationInThreadRZRR<tgetattr(R&RER.R*((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pytdoThreadIterationÝs ccs}xv|jrx|jƒ|jƒ}|jo.|}|j|j|ƒdV|jjƒ\}}t|d|ƒ|ŒqWdS(NR[( trunningtrunUntilCurrentRER1R\RRt get_nowaitR](R&tt2ttR.R*((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyt _interleaveçs   cOsL|j||Ž|jƒ}||d„}||_|jƒ|jƒdS(s„ interleave(waker) interleaves this reactor with the current application by moving the blocking parts of the reactor (select() in this case) to a separate thread. This is typically useful for integration with GUI applications which have their own event loop already running. See the module docstring for more information. cSs||jƒdS(N(tnext(R'tloop((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyR!sN(t startRunningRdR!ReRZ(R&R'R*R+RfR!((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyt interleaveôs    cCsýd|_|jdk r~|jttƒ|jƒyx|jjƒ\}}q8Wnt k rdnX|jj ƒd|_nygx`|j jƒ\}}||j kr¸t jdƒq„|tkr×|dtkr×q„||Œq„Wnt k rønXdS(Ns'Iteration is still in the thread queue!i(RR!R R1RR=R(RRaRtjoinRR\R R.(R&R.R*R0((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyR%s*      cCs™yOt||ƒƒ}t|ddƒ}|s6t}n|ƒdkrNt}nWn!tjƒd}tjƒnX|r•|j|||dkƒndS(NtfilenoiÿÿÿÿiRM( R]Rt _NO_FILENOt _NO_FILEDESCtsystexc_infoR RBt_disconnectSelectable(R&R9RTtdicttwhythandfn((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyRO"s  cCs'|j|jj|dƒ|jƒdS(sIAdd a FileDescriptor for notification of data available to read. iN(R1Rt __setitem__R((R&treader((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyt addReader0scCs'|j|jj|dƒ|jƒdS(sJAdd a FileDescriptor for notification of data available to write. iN(R1RRsR((R&twriter((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyt addWriter6scCs|jt|j|ƒdS(sHRemove a Selectable for notification of data available to read. N(R1RR(R&Rt((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyt removeReader<scCs|jt|j|ƒdS(sIRemove a Selectable for notification of data available to write. N(R1RR(R&Rv((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyt removeWriterAscCs|j|j|jƒS(N(t _removeAllRR(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyt removeAllFscCs |jjƒS(N(RR2(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyt getReadersJscCs |jjƒS(N(RR2(R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyt getWritersNscCstjj|ƒ|jƒdS(s› Extend the base stop implementation to also wake up the select thread so that C{runUntilCurrent} notices the reactor should stop. N(RR"tstopR((R&((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyR~RsicCs|jd|ƒ|jƒdS(NtinstallSignalHandlers(RgtmainLoop(R&R((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pytrun[scCsStƒ}|j|jƒx3|jrNy|jƒƒWqtk rJPqXqWdS(N(RRhR-R_R<t StopIteration(R&tq((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyR€_s   (!t__name__t __module__t__doc__RRR#R(R)R/R1R:R?RLRURVR\RZR^t doIterationRdRhR%RORuRwRxRyR{R|R}R~RR€(((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyR[s<       (               cCs'tƒ}ddlm}||ƒ|S(sIConfigure the twisted mainloop to be run using the select() reactor. iÿÿÿÿ(tinstallReactor(Rttwisted.internet.mainRˆ(treactorRˆ((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pytinstalljs  R‹('t __future__Rt threadingRRRttimeRRmtzope.interfaceRttwisted.internet.interfacesRttwisted.internetRRttwisted.pythonR R R ttwisted.persistedR ttwisted.python.runtimeR R4terrnoRRttwisted.internet.selectreactorRtConnectionFdescWentAwayRkRlRRR"RR‹t__all__(((sD/usr/lib/python2.7/dist-packages/twisted/internet/_threadedselect.pyts,5    ÿ