ёRMc @s ddkZddklZddklZddklZddklZddk l Z dZ dZ d e fd YZd e fd YZd efdYZde fdYZdefdYZdefdYZdefdYZdS(iN(tStack(tOperationError(tLONG_BIT(tunrolling_iterable(tjitidcCs,|i||i||i||dS(N(t call_functiontwrap(tspacet w_callabletframeteventtw_arg((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytapp_profile_call s  tExecutionContextcBs,eZdZdZdZdZedZdZdZ de fdYZ dd Z dd Zd Zd Zd ZdZedZee_dZee_dZdZdZdZdZdZedZdZ ddZ!dZ"dZ#RS(sYAn ExecutionContext holds the state of an execution thread in the Python interpreter.cCsL||_ti|_d|_d|_|i|_d|_ d|_ dS(Ni( RRt vref_Nonet topframereftNonet w_tracefunct is_tracingtcreatecompilertcompilert profilefunctw_profilefuncarg(tselfR((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyt__init__s     cCs |iS(N(R(R((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyt gettopframe'scCs8|i}x%|o|io|i}qW|S(N(Rthidet f_backref(RR ((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytgettopframe_nohidden*s  cCs8|i}x%|o|io|i}qW|S(N(RR(R ((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytgetnextframe_nohidden0s  cCs"|i|_ti||_dS(N(RRRt virtual_ref(RR ((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytenter7s cCs~z+|io|i|d|iinWd|i|_ti|X|idj o"|i o|ii i ndS(Nt leaveframe( Rt_traceRtw_NoneRRRtvirtual_ref_finishRRRtframe_trace_actiontfire(RR ((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytleave;s ! t SubcontextcBsGeZdZdZdZdZdZdZdZRS(cCs1d|_d|_d|_d|_d|_dS(Ni(RttopframeRRRR(R((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRLs     cCsYti|i|_|i|_|i|_|i|_|i|_|ii i dS(N( Rtnon_virtual_refR(RRRRRRR$R%(Rtec((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRSs     cCsC|i|_|i|_|i|_|i|_|i|_dS(N(RR(RRRR(RR*((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyR&[s    cCs d|_dS(N(RR((R((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytclear_framestackbscCs=g}|iD]}||i|q~}|i|S(N(t getframestackRtnewtuple(RRt_[1]tftitems((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytgetstatefs0cCs\ddkl}|i|}t|djo|i||d|_n d|_dS(Ni(tPyFramei(tpypy.interpreter.pyframeR2tunpackiterabletlentinterp_wR(R(RRtw_stateR2tframes_w((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytsetstatels cCsKg}|i}x+|dj o|i||i}qW|i|S(N(R(RtappendRtreverse(RtlstR/((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyR,ts    ( t__name__t __module__RRR&R+R1R9R,(((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyR'Is      cCs|i|||ddS(s&Profile the call of a builtin functiontc_callN(t_c_call_return_trace(RR tw_functargs((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyt c_call_trace~scCs|i|||ddS(s*Profile the return from a builtin functiontc_returnN(R@(RR RARB((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytc_return_tracescCs|idjo t|_nddkl}t||ob|dj oU|i}|dj o8ddkl}||i |||i i |}qn|i |||dS(Ni(tFunctionWithFixedCode(tdescr_function_get( RRtFalsetis_being_profiledtpypy.interpreter.functionRFt isinstancetfirstargRGRttypeR!(RR RARBR RFt w_firstargRG((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyR@s   cCs4|idjo t|_n|i|d|dS(s,Profile function called upon OperationError.t c_exceptionN(RRRHRIR!(RR tw_exc((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytc_exception_traces cCsX|idj p|idj o4|i|d|ii|io t|_qTndS(sTrace the call of a functiontcallN(RRRR!RR"tTrueRI(RR ((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyt call_traces  cCs+|idj o|i|d|ndS(s Trace the return from a functiontreturnN(RRR!(RR tw_retval((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyt return_tracescCs:|ii}|i|djo|i||ndS(s+Trace function called before each bytecode.iN(Rt actionflagtdecrement_tickertaction_dispatcher(RR tdecr_byRX((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytbytecode_traces cCs7|ii}|idjo|i||ndS(s9Like bytecode_trace(), but without increasing the ticker.iN(RRXt get_tickerRZ(RR RX((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytbytecode_trace_after_exceptions cCs8|i|idj o|i|dd|ndS(s*Trace function called upon OperationError.t exceptionN(trecord_interpreter_tracebackRRR!(RR t operationerr((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytexception_traces cCsI|i}x6|o.|idj o |iSn|i|}qWdS(sMImplements sys.exc_info(). Return an OperationError instance or None.N(Rtlast_exceptionRR(RR ((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyt sys_exc_infos  cCsP|ii||iio d|_n$|i||_|iiidS(sSet the global trace function.N(Rtis_wR"RRtforce_all_framesR$R%(RRA((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytsettraces    cCsF|ii||iiod|_d|_n|it|dS(sSet the global trace function.N(RReR"RRRt setllprofileR (RRA((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyt setprofiles  cCs|iS(N(R(R((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyt getprofilescCsT|dj o1|djotdn|idtn||_||_dS(Ns'Cannot call setllprofile with real NoneRI(Rt ValueErrorRfRSRR(RtfuncR ((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRhs    cCsB|i}x/|o'|o t|_n|i|}qWdS(N(RRSRIR(RRIR ((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRfs  cCsJ|i}d|_z'|iii|ii||SWd||_XdS(Ni(RRR$R%RR(RRAtw_argsR((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyt call_tracings   c CsI|ip |iodSn|i}|djo |i}n |i}|dj o|djo|dj o:|i|}|i|i||i |i g}n|i |id7_zyZ|i ||i ||i ||}|i ||io d|_n ||_Wn#|i|id|_nXWd|id8_|i|iiXn|idj o|d jodSn|i} |djo d}n|idjpt|id7_zCy |i||i|||Wnd|_d|_nXWd| |_|id8_XndS( NRRR iR?RDRORUi(s leaveframescallsc_callsc_returns c_exception(RRRRt w_f_traceRt get_w_valueR-tw_typeRtapplication_tracebackt fast2localsRReR"Rgt locals2fastR$R%RRctAssertionErrorR( RR R R toperrRt w_callbacktw_valuetw_resultRc((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyR!sZ      *             cCs1|iidj o|iii|dndS(sSimilar to PyErr_CheckSignals(). If called in the main thread, and if signals are pending for the process, deliver them now (i.e. call the signal handlers).N(Rtcheck_signal_actionRtperform(R((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyt checksignals<scCstddS(NsExecutionContext instances should not be seen during translation. Now is a good time to inspect the traceback and see where this one comes from :-)(t Exception(R((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyt_freeze_CsN($R=R>t__doc__RRRt staticmethodRRR&tobjectR'RRCRER@RQRTRWtTICK_COUNTER_STEPR\RSt_always_inline_R^RbRdRgRiRjRhRHRfRnR!R|R~(((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyR s:    5                = tAbstractActionFlagcBsDeZdZdZdZdZdZdZdZRS(s This holds in an integer the 'ticker'. If threads are enabled, it is decremented at each bytecode; when it reaches zero, we release the GIL. And whether we have threads or not, it is forced to zero whenever we fire any of the asynchronous actions. cCs?g|_g|_t|_d|_dt|_|idS(Nid( t_periodic_actionst_nonperiodic_actionsRHthas_bytecode_counterRt fired_actionsRtcheckinterval_scaledt_rebuild_action_dispatcher(R((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyROs      cCsU|ipGt|_|idjo g|_n|ii||idndS(s8Request for the action to be run before the next opcode.iN(t_firedRSRRR:t reset_ticker(Rtaction((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyR%Ws    cCsIt|tpt|ii||o t|_n|idS(sNOT_RPYTHON: Register the PeriodicAsyncAction action to be called whenever the tick counter becomes smaller than 0. If 'use_bytecode_counter' is True, make sure that we decrease the tick counter at every bytecode. This is needed for threads. Note that 'use_bytecode_counter' can be False for signal handling, because whenever the process receives a signal, the tick counter is set to -1 by C code in signals.h. N(RKtPeriodicAsyncActionRuRR:RSRR(RRtuse_bytecode_counter((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytregister_periodic_actionbs  cCs |itS(N(RR(R((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytgetcheckintervalqscCsLtit}|djo d}n||jo |}n|t|_dS(Ni(tsystmaxintRR(RtintervaltMAX((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytsetcheckintervalts      cs@titifd}t|_|_dS(NcsiixD]}|i||qWi}|dj o7d_x+|D]}t|_|i||qWWndS(N(RRR{RRRHR(R*R Rtlist(tperiodic_actionsR(s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRZs    (RRRtdont_look_insideRSt _dont_inline_RZ(RRZ((RRs5/64/home/arigo/u/pypy/interpreter/executioncontext.pyR|s ( R=R>RRR%RRRR(((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRIs    t ActionFlagcBs/eZdZdZdZdZdZRS(sWThe normal class for space.actionflag. The signal module provides a different one.icCs|iS(N(t_ticker(R((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyR]scCs ||_dS(N(R(Rtvalue((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRscCs.|i}|io||8}||_n|S(N(RR(RtbyR((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRYs     (R=R>RRR]RRY(((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRs   t AsyncActioncBs8eZdZeZdZdZdZdZRS(sAbstract base class for actions that must be performed asynchronously with regular bytecode execution, but that still need to occur between two opcodes, not at a completely random time. cCs ||_dS(N(R(RR((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRscCs|iii|dS(sRequest for the action to be run before the next opcode. The action must have been registered at space initalization time.N(RRXR%(R((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyR%scCsddkl}||_dS(s+Bit of a hack: fire() the action but only the next time the GIL is released and re-acquired (i.e. after a potential thread switch). Don't call this if threads are not enabled. Currently limited to one action (i.e. reserved for CheckSignalAction from module/signal). i(t spacestateN(tpypy.module.thread.gilRtaction_after_thread_switch(RR((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytfire_after_thread_switchscCsdS(sTo be overridden.N((RtexecutioncontextR ((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyR{s( R=R>RRHRRR%RR{(((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRs    RcBseZdZRS(sdAbstract base class for actions that occur automatically every sys.checkinterval bytecodes. (R=R>R(((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRst UserDelActioncBs2eZdZdZdZdZdZRS(sUAn action that invokes all pending app-level __del__() method. This is done as an action instead of immediately when the interp-level __del__() is invoked, because the latter can occur more or less anywhere in the middle of code that might not be happy with random app-level code mutating data structures under its feet. cCs/ti||g|_g|_d|_dS(Ni(RRtdying_objects_wt weakrefs_wtfinalizers_lock_count(RR((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRs  cCs|ii||idS(N(RR:R%(Rtw_obj((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytregister_dying_objectscCs|ii||idS(N(RR:R%(Rtw_ref((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pytregister_weakref_callbacksc Cs|idjodSn|i}g|_|i}xtt|D]m}||}d||RRRRR{(((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRs    tFrameTraceActioncBseZdZdZRS(s;An action that calls the local trace functions (w_f_trace).c Cs!|idjp |iodSn|i}|i|ijo |ijno4|i|ijo|i|d|i i qn|t |i d}d}|i }d}|i }x|djowt||} || |ijoPn|| 7}| o ||_n|t||d7}|d7}|d8}qW|djopx`toX|d8}|djoPn|t||7}t||doPn|d7}qOW||_n ti|_|i|ijo&||_|i|d|i i n|i|_|i iidS(Ntlineiii(RoRRtpycodetinstr_lbt last_instrtinstr_ubt instr_prevR!RR"R5t co_lnotabtco_firstlinenotordRSRRtf_linenoR$R%( RRR tcodetsizetaddrRtptlinenotc((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyR{sN '!             (R=R>RR{(((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyRs(Rtpypy.interpreter.miscutilsRtpypy.interpreter.errorRtpypy.rlib.rarithmeticRtpypy.rlib.unrollRt pypy.rlibRRR RR RRRRRR(((s5/64/home/arigo/u/pypy/interpreter/executioncontext.pyss  ;I1