jCDddlZddlZddlZddlZddlZddlZddlmZmZddlm Z ddl m Z ddl m Z ddlmZmZddlmZmZmZmZmZddlmZerUdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddl m!Z!ddl"m#Z#m$Z$ddlm%Z%m&Z&m'Z'm(Z(m)Z)m*Z*e!de+e(e,dZ- ddl.m/Z/ddl0m1Z2e2Z1e/ddZ3da6dZ7dZ8dZ9dZ:dZ;dZ<Gdd Z=Gd!d"e=Z>Gd#d$e=Z?d%Z@Gd&d'ZAGd(d)ZBy#e4$rejjZ3dZ1Y`wxYw)*N)datetimetimezone)VERSION)Envelope)LRUCache)DEFAULT_SAMPLING_FREQUENCY extract_stack)capture_internal_exception is_geventloggernowset_in_app_in_frames) TYPE_CHECKING)Any)Callable)Dict)List)Optional)Type)Union) TypedDict)ContinuousProfilerModeSDKInfo)ExtractedSampleFrameIdStackIdThreadIdProcessedFrameProcessedStackProcessedSample timestamp thread_idstack_id) get_original) ThreadPooltimesleepc@ttjdytrtj }nt j }|jdi}|jdxs|}t}|t j k(rt ||||an<|tj k(rt ||||antdj|tjdjtj tjty) Nz0[Profiling] Continuous Profiler is already setupF _experimentscontinuous_profiling_modez$Unknown continuous profiler mode: {}z9[Profiling] Setting up continuous profiler in {mode} mode)modeT) _schedulerr debugr GeventContinuousSchedulerr,ThreadContinuousSchedulergetr ValueErrorformatatexitregisterteardown_continuous_profiler)optionssdk_info capture_funcdefault_profiler_mode experiments profiler_mode frequencys d/var/www/photos/backend/venv/lib/python3.12/site-packages/sentry_sdk/profiler/continuous_profiler.pysetup_continuous_profilerr?Es GH{ !: > > 9 > >++nb1K 34M8M+I1666. w,  388 8. w, ?FF}UVV LLCJJ K   OO01 cdtytjsytjyN)r-should_autostartensure_runningr@r>!try_autostart_continuous_profilerrFts(  & & (r@c:tytjyrB)r-rDrEr@r>start_profilerrHsr@c:tytjyrB)r-teardownrEr@r> stop_profilerrKsr@ctdayrB)rKr-rEr@r>r6r6sOJr@c0tytjSrB)r- profiler_idrEr@r>get_profiler_idrOs  ! !!r@cPeZdZdZdZdZdZdZdZdZ e dZ d Z d Z y ) ContinuousSchedulerunknowncd|z |_||_||_||_|j |_d|_d|_y)Ng?F)intervalr7r8r9 make_samplersamplerbufferrunning)selfr=r7r8r9s r>__init__zContinuousScheduler.__init__sAi    (((*   r@c`|jjd}|sy|jdS)Nr*Fcontinuous_profiling_auto_start)r7r1)rYr;s r>rCz$ContinuousScheduler.should_autostarts,ll&&~6 @AAr@ctrBNotImplementedErrorrYs r>rDz"ContinuousScheduler.ensure_running!!r@ctrBr^r`s r>rJzContinuousScheduler.teardownrar@ctrBr^r`s r>pausezContinuousScheduler.pauserar@cnt|j|jt|j|_yrB) ProfileBufferr7r8PROFILE_BUFFER_SECONDSr9rWr`s r> reset_bufferz ContinuousScheduler.reset_buffers&# LL$--)?ARAR  r@cH|jy|jjSrB)rWrNr`s r>rNzContinuousScheduler.profiler_ids! ;; {{&&&r@cZtjtdfd}|S)N)max_sizec ft} tjjDcgc]\}}t |t |f}}}jjj||yycc}}w#t $r ttjYywxYw)z Take a sample of the stack on all the threads in the process. This should be called at a regular interval to collect samples. N) r sys_current_framesitemsstrr AttributeErrorr exc_inforWwrite) argskwargststidframesamplecachecwdrYs r> _sample_stackz7ContinuousScheduler.make_sampler.._sample_stacksB '*&9&9&;&A&A&C"UX}UE3?@{{& !!"f-'" +3<<>:  s"%B"BBB&B0/B0)osgetcwdr)rYr}r{r|s` @@r>rUz ContinuousScheduler.make_samplers%iik#& ..r@cptj}|jro|jtj|z }||jkrt |j|z tj}|jro|j |j jyyrB)r' perf_counterrXrVrT thread_sleeprWflush)rYlastelapseds r>runzContinuousScheduler.runs  "ll LLN '')D0G&T]]W45$$&Dll ;; " KK    #r@N)__name__ __module__ __qualname__r,rZrCrDrJrdrhpropertyrNrUrrEr@r>rQrQsD D B""" '' > r@rQc@eZdZdZdZdZfdZfdZdZdZ xZ S)r0zr This scheduler is based on running a daemon thread that will call the sampler at a regular interval. threadz)sentry.profiler.ThreadContinuousSchedulercxt|||||d|_d|_t j |_yrB)superrZrpid threadingLocklockrYr=r7r8r9 __class__s r>rZz"ThreadContinuousScheduler.__init__s2 GX|D NN$ r@cft|xr!|jtjk7SrBrrCrr~getpidrYrs r>rCz*ThreadContinuousScheduler.should_autostart%w')Edhh"))+.EEr@ctj}|jr|j|k(ry|j5|jr|j|k(r dddy||_d|_|j t j|j|jd|_ |jjdddy#t$rd|_d|_ Y"wxYw#1swYyxYw)NT)nametargetdaemonF) r~rrXrrrhrThreadrrrstart RuntimeErrorrYrs r>rDz(ThreadContinuousScheduler.ensure_runningsiik <rJz"ThreadContinuousScheduler.teardownB8 << DL ;; " KK   DK r@) rrr__doc__r,rrZrCrDrJ __classcell__rs@r>r0r0 s* D 6D%F!#F r@r0c<eZdZdZdZfdZfdZdZdZxZ S)r/as This scheduler is based on the thread scheduler but adapted to work with gevent. When using gevent, it may monkey patch the threading modules (`threading` and `_thread`). This results in the use of greenlets instead of native threads. This is an issue because the sampler CANNOT run in a greenlet because 1. Other greenlets doing sync work will prevent the sampler from running 2. The greenlet runs in the same thread as other greenlets so when taking a sample, other greenlets will have been evicted from the thread. This results in a sample containing only the sampler's code. geventct$tdj|jt|||||d|_d|_tj|_ y)Nz"Profiler mode: {} is not available) r&r2r3r,rrZrrrrrrs r>rZz"GeventContinuousScheduler.__init__^sU  AHHST T GX|D NN$ r@cft|xr!|jtjk7SrBrrs r>rCz*GeventContinuousScheduler.should_autostartjrr@ctj}|jr|j|k(ry|j5|jr|j|k(r dddy||_d|_|j t d|_ |jj|j dddy#t$rd|_d|_YdddywxYw#1swYyxYw)NTF) r~rrXrrrhr&rspawnrrrs r>rDz(GeventContinuousScheduler.ensure_runningnsiik <rJz"GeventContinuousScheduler.teardownrr@) rrrrr,rZrCrDrJrrs@r>r/r/Ns%  D %F@ r@r/ c$eZdZdZdZdZdZy)rfcD||_||_||_||_t j j |_t|_ t|_ tjtjj|jz |_yrB)r7r8 buffer_sizer9uuiduuid4hexrN ProfileChunkchunkr start_monotonic_timerrutcr"start_timestamp)rYr7r8rr9s r>rZzProfileBuffer.__init__sw   &(::<++!^ %(E! LL & 0 0 2T5N5N N r@c|j|r.|jt|_t |_|jj |j|z|yrB) should_flushrrrr rrtr)rYmonotonic_timerzs r>rtzProfileBuffer.writesK   ^ , JJL%DJ(+D % -->Gr@c:||jz |jk\SrB)rr)rYrs r>rzProfileBuffer.should_flushs  9 99T=M=MMMr@c|jj|j|j|j}t }|j ||j|yrB)rto_jsonrNr7r8radd_profile_chunkr9)rYrenvelopes r>rzProfileBuffer.flushsK ""4#3#3T\\4==Q:""5) (#r@N)rrrrZrtrrrEr@r>rfrfs .HN$r@rfceZdZdZdZdZy)rctjj|_i|_i|_g|_g|_g|_yrB) rrrchunk_idindexed_framesindexed_stacksframesstackssamplesr`s r>rZzProfileChunk.__init__s: ((      r@cp|D]\}\}}} ||jvrt|D]T\}}||jvst|j|j|<|jj ||Vt|j|j|<|j j |Dcgc]}|j|c}|jj |||j|dycc}w#t$r!ttjY1wxYw)Nr!) r enumeraterlenrappendrrrrr rnrs) rYrwrzrxr$ frame_idsriframe_ids r>rtzProfileChunk.writes%28 ; .C.(Iv ;4#6#66'0';: 8#4+>+>>: ;s)-D A=D 9D 3D D  &D54D5c |j|j|jtjDcic]-}t |j dt |ji/c}d}t|d|d|d|d|j|dtdd||d d }d D]'}|| t ||j||<)|Scc}w) Nr)rrrthread_metadatarin_app_excludein_app_include project_root)rversionpython2)r client_sdkplatformprofilerNr)release environmentdist) rrrrrrqidentrrrrstrip)rYrNr7r8rrpayloadkeys r>rzProfileChunk.to_jsonskkkk|| (113  FLL!C ,$     H  $ % $ % N #    ("!&  4 9Cs|'"73<0668  9? s2C N)rrrrZrtrrEr@r>rrs;:%r@r)Cr4r~rnrr'rrrsentry_sdk.constsrsentry_sdk.envelopersentry_sdk._lru_cachersentry_sdk.profiler.utilsrr sentry_sdk.utilsr r r r rtypingrrrrrrrrtyping_extensionsrsentry_sdk._typesrrrrrrrrfloatintr gevent.monkeyr%gevent.threadpoolr& _ThreadPoolr ImportErrorr(r-r?rFrHrKr6rOrQr0r/rgrfrrEr@r>rs*  '%(*!+A ! O*;J0L  ,^ ( "` ` FA 3AHI 3IX-$-$`MMa ::LJs'D DD