;ò ÎÑAHc@s4dkZdklZlZdklZdklZdkl Z dk Z dk Z dk Z dk Z dk l Z lZdklZlZlZlZlZdkZd„Zd„Zd efd „ƒYZd fd „ƒYZeZed jo:edgdhdd<dd<ƒZeiƒdGHndS(N(sreactorsthreads(s make_IPython(sInteractiveShell(sStruct(ssignalsSIGINT(sTermswarnserrors flag_callss ask_yes_nocCsdkl}|iƒdS(s. Install gtk2 reactor, needs to be called bef (s gtk2reactorN(stwisted.internets gtk2reactorsinstall(s gtk2reactor((s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pys install_gtk2 s csCdkl}|i‰dtf‡d†ƒY}|ƒ|_ˆSdS(s Modifies Twisted's reactor with a dummy so user code does not block IPython. This function returns the original 'twisted.internet.reactor' that has been hijacked. NOTE: Make sure you call this *AFTER* you've installed the reactor of your choice. (sinternets DummyReactorcs)tZd„Z‡d†Z‡d†ZRS(NcCsdS(N((sself((s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pysrunscstˆ|ƒSdS(N(sgetattrs orig_reactorsname(sselfsname(s orig_reactor(s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pys __getattr__!scstˆ||ƒSdS(N(ssetattrs orig_reactorsnamesvalue(sselfsnamesvalue(s orig_reactor(s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pys __setattr__#s(s__name__s __module__sruns __getattr__s __setattr__((s orig_reactor(s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pys DummyReactors  N(stwistedsinternetsreactors orig_reactorsobjects DummyReactor(s orig_reactors DummyReactorsinternet((s orig_reactors@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pyshijack_reactors    sTwistedInteractiveShellcBs\tZdZeZeededeƒeedd„Zddd„Zd„Z d „Z RS( sSimple multi-threaded shell.soptssargssc Ksti|||||||ƒt i ƒ|_ t |_ |idgƒ} x)| D]!}t|ƒ o td‚qPqPW| |_t |_t|_t|_dS(sBSimilar to the normal InteractiveShell, but with threading controlson_kills#on_kill must be a list of callablesN(sInteractiveShells__init__sselfsnamesusagesrcsuser_nssuser_global_nssbanner2sQueues code_queuesNones_killskwsgetson_killstscallables TypeErrors worker_identsFalsesreactor_startedsTrues first_run( sselfsnamesusagesrcsuser_nssuser_global_nssbanner2skwstson_kill((s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pys__init__5s     sssinglecCs†tiott_tSn|iotSny|i|||ƒ}Wn-t t t fj o|i|ƒtSnX|tjotSn|i p>|itjo|i p#|itiƒjp ti|ƒoti||ƒdSnt|_tiƒtiƒf\}}|ii|||fƒtid|iƒ|i dƒ|i!ƒ odGHdGHt|_n |i ƒtSdS(s´Compile and run some source in the interpreter. Modified version of code.py's runsource(), to handle threading issues. See the original for full docstring details.Nf0.0is-Warning: Timeout for mainloop thread exceededs=switching to nonthreaded mode (until mainloop wakes up again)("s shellglobalssKBINTsFalsesselfs_killsTruescompilessourcesfilenamessymbolscodes OverflowErrors SyntaxErrors ValueErrorsshowsyntaxerrorsNonesreactor_starteds worker_idents first_runsthreads get_identsrun_in_frontendsInteractiveShellsruncodes threadingsEvents completed_evs received_evs code_queuesputsreactors callLaterswaitsisSet(sselfssourcesfilenamessymbolscodes received_evs completed_ev((s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pys runsourceMs6      L    cCsstiƒ|_|ioWtidItiiƒx|iD] }|ƒq=WtidIJ|ii ƒt Snyt t tiƒWntj onXt}xÈnoÀy|iiƒ\}}}Wntij oPnX|i ƒzeyt t_ti||ƒWnAtj o5dGHx%|iiƒ o|iiƒ}q#WPnXWdtt_|i ƒXqªWt SdS(sQExecute a code object. Multithreaded wrapper around IPython's runcode().sClosing threads...sDone.is Keyboard interrupted in mainloopN( sthreads get_identsselfs worker_idents_killsTermscoutsflushson_killstokillssetsTruessignalsSIGINTs shellglobalsssigint_handlers SystemErrorsNones code_to_runs code_queues get_nowaits completed_evs received_evsQueuesEmptysCODE_RUNsInteractiveShellsruncodesKeyboardInterruptsemptyscodesFalse(sselfs code_to_runscodes received_evs completed_evstokill((s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pysruncode„sL           cCs3tiƒ|_tid|iƒ|iiƒdS(s6Kill the thread, returning when it has been shut down.f0.0N(s threadingsEventsselfs_killsreactors callLatersruncodeswait(sself((s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pyskillÃs( s__name__s __module__s__doc__sTrues isthreadedsNonesStructs__init__s runsourcesruncodeskill(((s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pysTwistedInteractiveShell)s  '7 ?sIPShellTwistedcBs;tZdZdZeeded„Zd„Zd„ZRS(síRun a Twisted reactor while in an IPython session. Python commands can be passed to the thread where they will be executed. This is implemented by periodically checking for passed code using a Twisted reactor callback. f0.01ic s˜dkl}tƒˆ_ˆii}d„}|ˆi_ˆii‰t ˆ_ ‡‡d†} | ˆi_t |d|d|d|d|gƒˆ_dS(N(sreactorcCsdS(N((((s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pys reactorstopÞscs%xtoˆi o ˆƒqWdS(N(sTruesselfsquittingsreactorrun_orig((sreactorrun_origsself(s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pys reactorrunãssuser_nssdebugs shell_classson_kill(stwisted.internetsreactorshijack_reactorsselfsstopsmainquits reactorstopsrunsreactorrun_origsFalsesquittings reactorruns make_IPythonsargvsuser_nssdebugs shell_classsIP( sselfsargvsuser_nssdebugs shell_classsreactors reactorstopsmainquitsreactorrun_origs reactorrun((sselfsreactorrun_origs@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pys__init__Õs        cCs'|iiƒt|_|iiƒdS(N(sselfsIPsmainloopsTruesquittingskill(sself((s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pysrunîs  csGd„‰‡‡d†}ti|ƒtˆi_ˆiiƒdGHdS(NcCsdGt|ƒGHdS(NsmainLoopThreadDeath: (sstrsr(sr((s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pysmainLoopThreadDeathôscs#tiˆiƒ}|iˆƒdS(N(sthreadss deferToThreadsselfsrunsdsaddBothsmainLoopThreadDeath(sd(sselfsmainLoopThreadDeath(s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pysspawnMainloopThreadössmainloop ending....( smainLoopThreadDeathsspawnMainloopThreadsreactorscallWhenRunningsTruesselfsIPsreactor_startedsrun(sselfsmainLoopThreadDeathsspawnMainloopThread((sselfsmainLoopThreadDeaths@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pysmainloopós     ( s__name__s __module__s__doc__sTIMEOUTsNonesTwistedInteractiveShells__init__srunsmainloop(((s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pysIPShellTwistedËs  s__main__sargvsuser_nss__name__s __example__shellosworldsGoodbye!(ssysstwisted.internetsreactorsthreadssIPython.ipmakers make_IPythons IPython.iplibsInteractiveShellsIPython.ipstructsStructsQueuesthreads threadingssignalsSIGINTsIPython.genutilssTermswarnserrors flag_callss ask_yes_nos shellglobalss install_gtk2shijack_reactorsTwistedInteractiveShellsIPShellTwistedsTruesexistss__name__sshellsmainloop(sreactorsexistss flag_callsssyssIPShellTwistedsStructssignalsSIGINTsTermsshells make_IPythonshijack_reactors shellglobalssthreadss ask_yes_nosTwistedInteractiveShellsQueuesthreadsInteractiveShellswarns threadingserrors install_gtk2((s@/u/d/b/dbachman/=/lib/python2.3/site-packages/IPython/twshell.pys?s$    $%   ¢3