ó [³XMc@s³dZddlZddlZddlmZy0eedƒ r]ddlZejdƒnWnee fk rwnXddl Z ee dƒr e j ƒnddl m Z mZmZddlmZdd lmZdd lmZmZmZmZmZe je jBe jBZe jeBZe j eBZ!d „Z"d ej#fd „ƒYZ$dej%fd„ƒYZ&e'd„Z(e'd„Z)ej*j+ƒdkr¦e)Z(ndgZ,dS(sÚ This module provides support for Twisted to interact with the glib/gtk2 mainloop. In order to use this support, simply do the following:: | from twisted.internet import gtk2reactor | gtk2reactor.install() Then use twisted.internet APIs as usual. The other methods here are not intended to be called directly. When installing the reactor, you can choose whether to use the glib event loop or the GTK+ event loop which is based on it but adds GUI integration. iÿÿÿÿN(t implementstfrozens2.0t threads_init(tlogtruntimetfailure(tset(t IReactorFDSet(tmaintbaset posixbaseterrort selectreactorcCs)ddl}|jƒr%|jƒndS(Niÿÿÿÿ(tgtkt main_levelt main_quit(R ((s@/usr/lib/python2.7/dist-packages/twisted/internet/gtk2reactor.pyt _our_mainquit:s  t Gtk2ReactorcBseZdZeeƒed„Zejdkr=d„Z nd„Z d„Z d„Z d„Z d„Zd „Zd „Zd „Zd „Zd „ZdZd„Zd„Zd„Zdd„Ziejejƒƒej6ejejƒƒej6d„Zd„Z d„Z!RS(s“ GTK+-2 event loop reactor. @ivar _sources: A dictionary mapping L{FileDescriptor} instances to gtk watch handles. @ivar _reads: A set of L{FileDescriptor} instances currently monitored for reading. @ivar _writes: A set of L{FileDescriptor} instances currently monitored for writing. @ivar _simtag: A gtk timeout handle for the next L{simulate} call. cCsód|_tƒ|_tƒ|_i|_tjj|ƒt t ddƒdkr¶| r¶t j ƒ|_ |j j |_|j j|_t jƒ|_|jj|_|jj|_n9ddl}|j|_|j|_t|_|j|_dS(Nt pygtk_versioniii[iÿÿÿÿ((iii[(tNonet_simtagRt_readst_writest_sourcesR tPosixReactorBaset__init__tgetattrtgobjecttmain_context_defaulttcontexttpendingt_Gtk2Reactor__pendingt iterationt_Gtk2Reactor__iterationtMainLooptlooptquitt_Gtk2Reactor__crashtrunt_Gtk2Reactor__runR tevents_pendingtmain_iterationRR(tselftuseGtkR ((s@/usr/lib/python2.7/dist-packages/twisted/internet/gtk2reactor.pyRWs"        tposixcsxddlm‰tjjˆƒtjtj‡‡fd†ƒttddƒdk rmtj tjt ƒnˆƒdS(Niÿÿÿÿ(treapAllProcessescs ˆjˆƒS(N(tcallFromThread(ta(R*t_reapAllProcesses(s@/usr/lib/python2.7/dist-packages/twisted/internet/gtk2reactor.pytyst siginterrupt( ttwisted.internet.processR-R t_SignalReactorMixint_handleSignalstsignaltSIGCHLDRRR2tFalse(R*((R*R0s@/usr/lib/python2.7/dist-packages/twisted/internet/gtk2reactor.pyR5os cCsNt|dƒr7||d„}tj|jƒ||ƒStj|||ƒSdS(NtfilenocSs |||ƒS(N((tsourcet conditiontreal_streal_cb((s@/usr/lib/python2.7/dist-packages/twisted/internet/gtk2reactor.pytwrapperŒs(thasattrRt io_add_watchR9(R*R:R;tcallbackR>((s@/usr/lib/python2.7/dist-packages/twisted/internet/gtk2reactor.pyt input_add‰scCss||krdS|}||krCtj|j|ƒ||O}n|j|||jƒ|j|<|j|ƒdS(s 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(Rt source_removeRRBRAtadd(R*R:tprimarytothert primaryFlagt otherFlagtflags((s@/usr/lib/python2.7/dist-packages/twisted/internet/gtk2reactor.pyt_add“s   cCs#|j||j|jttƒdS(sS Add a L{FileDescriptor} for monitoring of data available to read. N(RJRRtINFLAGStOUTFLAGS(R*treader((s@/usr/lib/python2.7/dist-packages/twisted/internet/gtk2reactor.pyt addReader¤scCs#|j||j|jttƒdS(sO Add a L{FileDescriptor} for monitoring ability to write data. N(RJRRRLRK(R*twriter((s@/usr/lib/python2.7/dist-packages/twisted/internet/gtk2reactor.pyt addWriter«scCs t|jƒS(sW Retrieve the list of current L{FileDescriptor} monitored for reading. (tlistR(R*((s@/usr/lib/python2.7/dist-packages/twisted/internet/gtk2reactor.pyt getReaders²scCs t|jƒS(sW Retrieve the list of current L{FileDescriptor} monitored for writing. (RQR(R*((s@/usr/lib/python2.7/dist-packages/twisted/internet/gtk2reactor.pyt getWriters¹scCs|j|j|jƒS(sJ Remove monitoring for all registered L{FileDescriptor}s. (t _removeAllRR(R*((s@/usr/lib/python2.7/dist-packages/twisted/internet/gtk2reactor.pyt removeAllÀscCss||krdStj|j|ƒ|j|ƒ||kr_|j|||jƒ|j|s4   (   ÿ-