+ :i?/Rt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIH t ^RI H t H t ^RIHt^RIHtHt!RR]P&4t]!.RO4tRt!R R 4t]!]4tR tR tR t!RR]P<4t!RR]4t !RR]4t!] R4t"] R4t#] R4t$RRlt%RRlt&] RRl4t'RRlt(Rt)]PT'd ])!4R#R#) ag The ``numba.core.event`` module provides a simple event system for applications to register callbacks to listen to specific compiler events. The following events are built in: - ``"numba:compile"`` is broadcast when a dispatcher is compiling. Events of this kind have ``data`` defined to be a ``dict`` with the following key-values: - ``"dispatcher"``: the dispatcher object that is compiling. - ``"args"``: the argument types. - ``"return_type"``: the return type. - ``"numba:compiler_lock"`` is broadcast when the internal compiler-lock is acquired. This is mostly used internally to measure time spent with the lock acquired. - ``"numba:llvm_lock"`` is broadcast when the internal LLVM-lock is acquired. This is used internally to measure time spent with the lock acquired. - ``"numba:run_pass"`` is broadcast when a compiler pass is running. - ``"name"``: pass name. - ``"qualname"``: qualified name of the function being compiled. - ``"module"``: module name of the function being compiled. - ``"flags"``: compilation flags. - ``"args"``: argument types. - ``"return_type"`` return type. Applications can register callbacks that are listening for specific events using ``register(kind: str, listener: Listener)``, where ``listener`` is an instance of ``Listener`` that defines custom actions on occurrence of the specific event. N) default_timer)contextmanager ExitStack) defaultdict)configutilsc^]tRt^2tRt]P !4t]P !4tRt R#) EventStatuszStatus of an event. N) __name__ __module__ __qualname____firstlineno____doc__enumautoSTARTEND__static_attributes__r N/var/www/html/photoedit/myenv/lib/python3.14/site-packages/numba/core/event.pyr r 2s IIKE ))+Crr cjVPR4'dV\9dV R2p\V4hV#)aGuard to ensure that an event kind is valid. All event kinds with a "numba:" prefix must be defined in the pre-defined ``numba.core.event._builtin_kinds``. Custom event kinds are allowed by not using the above prefix. Parameters ---------- kind : str Return ------ res : str znumba:zG is not a valid event kind, it starts with the reserved prefix 'numba:') startswith_builtin_kinds ValueError)kindmsgs& r _guard_kindrBs: x  T%?==o Krca]tRt^XtoRtR Rlt]R4t]R4t]R4t ]R4t ]R4t ]R 4t R t ] tR tVtR#) EventzAn event. Parameters ---------- kind : str status : EventStatus data : any; optional Additional data for the event. exc_details : 3-tuple; optional Same 3-tuple for ``__exit__``. Nc|\V4VnW nW0nVe V^,f RVnR#TVnR#N)r_kind_status_data _exc_details)selfrstatusdata exc_detailss&&&&&r__init__Event.__init__ds< &   + 3{1~7M""- rc VP#)z&Event kind Returns ------- res : str )r"r&s&rr Event.kindlzzrc VP#)z0Event status Returns ------- res : EventStatus )r#r-s&rr' Event.statusvs||rc VP#)z)Event data Returns ------- res : object )r$r-s&rr( Event.datar/rc <VP\P8H#)z3Is it a *START* event? Returns ------- res : bool )r#r rr-s&ris_startEvent.is_starts||{0000rc <VP\P8H#)z2Is it an *END* event? Returns ------- res : bool )r#r rr-s&ris_end Event.is_ends||{..rc VPRJ#)zIs the event carrying an exception? This is used for *END* event. This method will never return ``True`` in a *START* event. Returns ------- res : bool N)r%r-s&r is_failedEvent.is_faileds  D((rcVPe!\VP4P MRpRVP RVP RV R2#)NNonezEvent(z, z, data: ))r(typer r"r#)r&r(s& r__str__ Event.__str__sM99( ?//0.4  |2dll^8D6CCr)r$r%r"r#NN)r r r rrr*propertyrr'r(r5r8r;rA__repr__r__classdictcell__ __classdict__s@rrrXs /11// ) )D Hrrc\V\4'gQh\V4p\V,P V4R#)zbRegister a listener for a given event kind. Parameters ---------- kind : str listener : Listener N) isinstanceListenerr _registeredappendrlisteners&&rregisterrPs4 h ) )) ) t DX&rc\V\4'gQh\V4p\V,pVP V4R#)zdUnregister a listener for a given event kind. Parameters ---------- kind : str listener : Listener N)rJrKrrLremove)rrOlsts&& r unregisterrTs7 h ) )) ) t D d CJJxrcd\VP,FpVPV4K R#)zUBroadcast an event to all registered listeners. Parameters ---------- event : Event N)rLrnotify)eventrOs& r broadcastrXs&  ++,rcra]tRt^toRt]P R4t]P R4tRt Rt Vt R#)rKz(Base class for all event listeners. c R#)zKCalled when there is a *START* event. Parameters ---------- event : Event Nr r&rWs&&ron_startListener.on_start rc R#)zICalled when there is a *END* event. Parameters ---------- event : Event Nr r[s&&ron_endListener.on_endr^rc VP'dVPV4R#VP'dVPV4R#\ R4h)zPNotify this Listener with the given Event. Parameters ---------- event : Event unreachableN)r5r\r8r`AssertionErrorr[s&&rrVListener.notifys9 >>> MM% \\\ KK  / /rr N) r r r rrabcabstractmethodr\r`rVrrFrGs@rrKrKsF      0 0rrKcVa]tRtRtoRtRtRtRt]R4t ]R4t Rt Vt R #) TimingListenerizxA listener that measures the total time spent between *START* and *END* events during the time this listener is active. c^VnR#N)_depthr-s&rr*TimingListener.__init__s  rcxVP^8Xd\4VnV;P^, unR#rk)rmtimer_tsr[s&&rr\TimingListener.on_start s% ;;! wDH q rcV;P^,unVP^8Xd7\VR^4p\4VP, V,VnR#R#) _durationN)rmgetattrrprqru)r&rWlasts&& rr`TimingListener.on_endsF q ;;! 4a0D#g0D8DN rc \VR4#)zReturns a ``bool`` indicating whether a measurement has been made. When this returns ``False``, the matching event has never fired. If and only if this returns ``True``, ``.duration`` can be read without error. ru)hasattrr-s&rdoneTimingListener.donest[))rc VP#)zReturns the measured duration. This may raise ``AttributeError``. Users can use ``.done`` to check that a measurement has been made. )rur-s&rdurationTimingListener.durations~~r)rmrurqN) r r r rrr*r\r`rDr{r~rrFrGs@rririsA 9 **rric6a]tRtRtoRtRtRtRtRtVt R#)RecordingListeneri(zA listener that records all events and stores them in the ``.buffer`` attribute as a list of 2-tuple ``(float, Event)``, where the first element is the time the event occurred as returned by ``time.time()`` and the second element is the event. c.VnR#r!bufferr-s&rr*RecordingListener.__init__.s  rcfVPP\P!4V34R#r!rrMtimer[s&&rr\RecordingListener.on_start1 DIIK/0rcfVPP\P!4V34R#r!rr[s&&rr`RecordingListener.on_end4rrrN) r r r rrr*r\r`rrFrGs@rrr(s 111rrc#d"\W4Vx\W4R# \Y4i;i5i)aUInstall a listener for event "kind" temporarily within the duration of the context. Returns ------- res : Listener The *listener* provided. Examples -------- >>> with install_listener("numba:compile", listener): >>> some_code() # listener will be active here. >>> other_code() # listener will be unregistered by this point. N)rPrTrNs&&rinstall_listenerr8s)$ T#4" 4"s 0 0 -0c#"\4p\W4;_uu_4VxRRR4VP'dV!VP4R#R# +'giL8;i5i)aInstall a TimingListener temporarily to measure the duration of an event. If the context completes successfully, the *callback* function is executed. The *callback* function is expected to take a float argument for the duration in seconds. Returns ------- res : TimingListener Examples -------- This is equivalent to: >>> with install_listener(kind, TimingListener()) as res: >>> ... N)rirr{r~)rcallbacktls&& r install_timerrQsH*  B $ # # $ www $ #s A(AA(A( A% A(c#"\4p\W4;_uu_4VxRRR4R# +'giR#;i5i)aBInstall a RecordingListener temporarily to record all events. Once the context is closed, users can use ``RecordingListener.buffer`` to access the recorded events. Returns ------- res : RecordingListener Examples -------- This is equivalent to: >>> with install_listener(kind, RecordingListener()) as res: >>> ... N)rr)rrls& rinstall_recorderrns-&  B $ # # $ # # #sA/ A A AcT\V\PVR7p\V4R#)zTrigger the start of an event of *kind* with *data*. Parameters ---------- kind : str Event kind. data : any; optional Extra event data. )rr'r(N)rr rrX)rr(evts&& r start_eventrs T+"3"3$ ?C cNrcT\V\PWR7p\V4R#)zTrigger the end of an event of *kind*, *exc_details*. Parameters ---------- kind : str Event kind. data : any; optional Extra event data. exc_details : 3-tuple; optional Same 3-tuple for ``__exit__``. Or, ``None`` if no error. )rr'r(r)N)rr rrX)rr(r)rs&&& r end_eventrs"  +// CcNrc#aa"\4;_uu_4pVPVV3Rl4p\SSR7RxRRR4R# +'giR#;i5i)aA context manager to trigger the start and end events of *kind* with *data*. The start event is triggered when entering the context. The end event is triggered when exiting the context. Parameters ---------- kind : str Event kind. data : any; optional Extra event data. c$<\SSVR7R#))r(r)N)r)r)r(rs*ron_exittrigger_event..on_exits d; ?r)r(N)rpushr)rr(scopersff r trigger_eventrsC   @  @ Dt$ sA(A  A A  Ac$V^8dQhR\/#)rO)r)formats"r __annotate__rs):rc ^\P!4p\P!4p.pVPFpwrEVP p\ VP4pVR,pVP'dRMRp VR,p Tp \WqW(WV R7p VPV 4Kr V#)zGPrepare events in `listener` for serializing as chrome trace data. i@BBEname)catpidtidtsphrargs) osgetpid threading get_native_idrr(strrr5dictrM) rOrrevsrrecr(r ts_scaledrrrevs & r_prepare_chrome_trace_datars ))+C  ! ! #C C??xx#((mN LLLScF| #  2# Jrcaa\4o\RS4\Po\PVV3Rl4pR#)zTSetup a RecordingListener and an exit handler to write the captured events to file. numba:run_passc<\S4p\SR4;_uu_4p\P!W\P R7RRR4R# +'giR#;i)w)clsN)ropenjsondumpr_LazyJSONEncoder)routfilenamerOs r_write_chrome_trace=_setup_chrome_trace_exit_handler.._write_chrome_tracesA)2 (C C IIcE$:$: ;! s 'A A# N)rrPr CHROME_TRACEatexit)rrrOs @@r _setup_chrome_trace_exit_handlerrs9!"H x(""H __<rs#!F )0#$$)),XXv$  ' #0sww#0L#X#L 1 1 ##08. $*0 <  $&r