o ¯b¢1ã@s–dZddlZddlmZddlmZmZmZddlm Z ddl m Z gfdd„Z Gd d „d ej ƒZee ƒGd d „d ejejƒƒZGd d„dejƒZdS)aC This module provides base support for Twisted to interact with the glib/gtk mainloops. The classes in this module should not be used directly, but rather you should import gireactor or gtk3reactor for GObject Introspection based applications, or glib2reactor or gtk2reactor for applications using legacy static bindings. éN)Ú implementer)ÚbaseÚ posixbaseÚ selectreactor)Ú IReactorFDSet)ÚlogcCs:|D]}tj |¡durt|ƒ‚q|D]}dtj|<qdS)a[ Check whether the given modules were imported, and if requested, ensure they will not be importable in the future. @param moduleNames: A list of module names we make sure aren't imported. @type moduleNames: C{list} of C{str} @param preventImports: A list of module name whose future imports should be prevented. @type preventImports: C{list} of C{str} @param errorMessage: Message to use when raising an C{ImportError}. @type errorMessage: C{str} @raise ImportError: with given error message if a given module name has already been imported. N)ÚsysÚmodulesÚgetÚ ImportError)Ú moduleNamesÚ errorMessageÚpreventImportsÚname©rú._mainquitcóˆj ˆjj¡Sr©Ú_glibÚidle_addÚloopÚquitrrrrÚ|óz*GlibReactorBase.__init__..)Ú_simtagÚsetÚ_readsÚ_writesÚ_sourcesr)r"rÚPosixReactorBaseÚ__init__Ú source_removeÚ_source_removeÚ timeout_addÚ _timeout_addÚevents_pendingÚ_pendingÚmain_iteration_doÚ _iterationÚ_crashÚmainÚ_runÚmain_context_defaultÚcontextÚpendingÚ iterationÚMainLoopr+Úrun©rÚ glib_moduleÚ gtk_moduleÚuseGtkr%rrrr5bs*          zGlibReactorBase.__init__cCs"tj |¡| dtjj|¡dS)Nr)rÚ_SignalReactorMixinÚ_handleSignalsÚ callLaterrr4rrrrrLs zGlibReactorBase._handleSignalscsBtˆdƒr‡‡fdd„}ˆ ¡}nˆ}ˆ}|jj||||jjdS)NÚfilenocs ˆˆ|ƒSrr)ÚignoredÚ condition©ÚcallbackÚsourcerrÚwrapper”s z*GlibReactorBase.input_add..wrapper©Úpriority)ÚhasattrrNr)Ú io_add_watchÚPRIORITY_DEFAULT_IDLE)rrSrPrRrTrNrrQrÚ input_add‘s   ÿzGlibReactorBase.input_addcCst ||j|||¡dS)z@ Called by event loop when an I/O event occurs. T)rÚcallWithLoggerÚ_doReadOrWrite)rrSrPrrrÚ_ioEventCallbackŸsz GlibReactorBase._ioEventCallbackcCsT||vrdS|}||vr| |j|¡||O}| |||j¡|j|<| |¡dS)a Add the given L{FileDescriptor} for monitoring either for reading or writing. If the file is already monitored for the other operation, we delete the previous registration and re-register it for both reading and writing. N)r7r3rZr]Úadd)rrSÚprimaryÚotherÚ primaryFlagÚ otherFlagÚflagsrrrÚ_add¦szGlibReactorBase._addcCó| ||j|j|j|j¡dS)zS Add a L{FileDescriptor} for monitoring of data available to read. N)rdr1r2ÚINFLAGSÚOUTFLAGS©rÚreaderrrrÚ addReader¶ózGlibReactorBase.addReadercCre)zO Add a L{FileDescriptor} for monitoring ability to write data. N)rdr2r1rgrf©rÚwriterrrrÚ addWriter¼rkzGlibReactorBase.addWritercCó t|jƒS)zW Retrieve the list of current L{FileDescriptor} monitored for reading. )Úlistr1rrrrÚ getReadersÂó zGlibReactorBase.getReaderscCro)zW Retrieve the list of current L{FileDescriptor} monitored for writing. )rpr2rrrrÚ getWritersÈrrzGlibReactorBase.getWriterscCs| |j|j¡S)zJ Remove monitoring for all registered L{FileDescriptor}s. )Ú _removeAllr1r2rrrrÚ removeAllÎszGlibReactorBase.removeAllcCsX||vrdS| |j|¡| |¡||vr$| |||j¡|j|<dS|j |¡dS)zÝ Remove monitoring the given L{FileDescriptor} for either reading or writing. If it's still monitored for the other operation, we re-register the L{FileDescriptor} for only that operation. N)r7r3ÚremoverZr]Úpop)rrSr_r`rcrrrÚ_removeÔs zGlibReactorBase._removecCó| ||j|j|j¡dS)zJ Stop monitoring the given L{FileDescriptor} for reading. N)rxr1r2rgrhrrrÚ removeReaderãózGlibReactorBase.removeReadercCry)zJ Stop monitoring the given L{FileDescriptor} for writing. N)rxr2r1rfrlrrrÚ removeWriterér{zGlibReactorBase.removeWriterrcCs*| ¡| ¡r| d¡| ¡sdSdS)zv One iteration of the event loop, for trial's use. This is not used for actual reactor runs. rN)ÚrunUntilCurrentr;r=)rÚdelayrrrÚiterateïs ÿzGlibReactorBase.iteratecCótj |¡| ¡dS)z$ Crash the reactor. N)rr4Úcrashr>rrrrrùs  zGlibReactorBase.crashcCr€)z# Stop the reactor. N)rr4ÚstopÚwakeUprrrrr‚s  zGlibReactorBase.stopTcCs.| |j¡|j|d|jr| ¡dSdS)z" Run the reactor. ©ÚinstallSignalHandlersN)ÚcallWhenRunningÚ _rescheduleÚ startRunningÚ_startedr@©rr…rrrrFs   ÿzGlibReactorBase.runcOs&tjj|g|¢Ri|¤Ž}| ¡|S)z, Schedule a C{DelayedCall}. )rr4rMr‡)rÚargsÚkwargsÚresultrrrrMszGlibReactorBase.callLatercCsT|jdur| |j¡d|_| ¡}|dur(|jt|dƒ|j|jjd|_dSdS)z; Schedule a glib timeout for C{_simulate}. NéèrU)r/r7Útimeoutr9Úintrr)rY©rrrrrr‡!s    ýÿzGlibReactorBase._reschedulecCs| ¡| ¡dS)zX Run timers, and then reschedule glib timeout for next scheduled event. N)r}r‡rrrrr0s zGlibReactorBase._simulateN©F)r©T)rrrrrÚ _wakerFactoryr5rLrZr]rdrjrnrqrsrurxrzr|rrr‚rFrMr‡rrrrrr=s.!      rc@s4eZdZdZd dd„Zdd„Zddd „Zd d „Zd S)ÚPortableGlibReactorBasezŠ Base class for GObject event loop reactors that works on Windows. Sockets aren't supported by GObject's input_add on Win32. Fcs~dˆ_|ˆ_|ˆ_tj ˆ¡ˆjjˆ_ˆjjˆ_ ‡fdd„}|r+|ˆ_ ˆjj ˆ_ dSˆj  ¡ˆ_‡fdd„ˆ_ ˆjjˆ_ dS)Ncr rr!rrrrr%Hr&z3PortableGlibReactorBase.__init__.._mainquitcr'rr(rrrrr-Qr.z2PortableGlibReactorBase.__init__..)r/r)r"rÚ SelectReactorr5r6r7r8r9r>r?r@rEr+rFrGrrrr5?s     z PortableGlibReactorBase.__init__cCstj |¡| ¡dSr)rr–rr>rrrrrTs  zPortableGlibReactorBase.crashTcCs0|j|d| d|j¡|jr| ¡dSdS)Nr„r)rˆr9Úsimulater‰r@rŠrrrrFXs  ÿzPortableGlibReactorBase.runcCs\|jdur | |j¡| ¡t| ¡dƒ}|durd}|jt|dƒ|j|jj d|_dS)z@ Run simulation loops and reschedule callbacks. Ng{®Gáz„?rŽrU) r/r7rÚminrr9rr—r)rYr‘rrrr—^s    ýz PortableGlibReactorBase.simulateNr’r“)rrrrr5rrFr—rrrrr•8s    r•)rrÚzope.interfacerÚtwisted.internetrrrÚtwisted.internet.interfacesrÚtwisted.pythonrrrrr4Ú_PollLikeMixinrr–r•rrrrÚs     {