o hZ@szddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z ddl m Z ddlmZddlmZddlmZmZddlmZmZmZmZmZdd lmZerdd lmZdd lmZdd lmZdd lm Z ddlm!Z!ddlm"Z"ddlm#Z#ddlm$Z$ddlm%Z%ddl&m'Z'ddl(m)Z)m*Z*ddlm+Z+m,Z,m-Z-m.Z.m/Z/m0Z0e'de1e.e2dZ3zddl4m5Z5ddl6m7Z8e8Z7e5ddZ9Wne:yej;Z9dZ7Ynwdad d!Z?d"d#Z@d$d%ZAd&d'ZBd(d)ZCd*d+ZDd,d-ZEd.d/ZFd0d1ZGGd2d3d3ZHGd4d5d5ZIGd6d7d7eIZJGd8d9d9eIZKd:ZLGd;d<d<ZMGd=d>d>ZNdS)?N)deque)datetimetimezone)VERSION)Envelope)LRUCache)DEFAULT_SAMPLING_FREQUENCY extract_stack)capture_internal_exception is_geventloggernowset_in_app_in_frames) TYPE_CHECKING)Any)Callable)Deque)Dict)List)Optional)Set)Type)Union) TypedDict)ContinuousProfilerModeSDKInfo)ExtractedSampleFrameIdStackIdThreadIdProcessedFrameProcessedStackProcessedSample timestamp thread_idstack_id) get_original) ThreadPooltimesleepcCstdu}|rtdttrtj}ntj}|ddur$|d}n |di}|dp0|}t }|tjkr@t||||an|tjkrMt||||ant d |tdj tjd|set tdS) Nz0[Profiling] Continuous Profiler is already setup profiler_mode _experimentscontinuous_profiling_modez$Unknown continuous profiler mode: {}z9[Profiling] Setting up continuous profiler in {mode} mode)modeT) _schedulerr debugteardown_continuous_profilerr GeventContinuousSchedulerr.ThreadContinuousSchedulergetr ValueErrorformatatexitregister)optionssdk_info capture_funcalready_initializeddefault_profiler_moder+ experiments frequencyr@i/var/www/html/pro-man-master/venv/lib/python3.10/site-packages/sentry_sdk/profiler/continuous_profiler.pysetup_continuous_profilerJs<       rBcCstdurdStjSNF)r/sampledr@r@r@rAis_profile_session_sampledrEcCs$tdurdSts dStdSN)r/is_auto_start_enabled manual_startr@r@r@rA!try_autostart_continuous_profilers  rJcCstdurdStSrG)r/ auto_startr@r@r@rA!try_profile_lifecycle_trace_startsrLcCtdurdStdSrG)r/rIr@r@r@rAstart_profiler rNcCtjdtddtdS)NzWThe `start_profile_session` function is deprecated. Please use `start_profile` instead. stacklevel)warningswarnDeprecationWarningrNr@r@r@rAstart_profile_session  rWcCrMrG)r/ manual_stopr@r@r@rA stop_profilerrOrZcCrP)NzUThe `stop_profile_session` function is deprecated. Please use `stop_profile` instead.rQrR)rTrUrVrZr@r@r@rAstop_profile_sessionrXr[cCstdadSrG)rZr/r@r@r@rAr1sr1cCstdurdStjSrG)r/ profiler_idr@r@r@rAget_profiler_idrFr]cCs|sdStt|kSrC)randomfloat) sample_rater@r@rA+determine_profile_session_sampling_decisionsrac@s"eZdZUdZeed<ddZdS)ContinuousProfileTactivecCs d|_dSrC)rcselfr@r@rAstops zContinuousProfile.stopN)__name__ __module__ __qualname__rcbool__annotations__rfr@r@r@rArbs  rbc@steZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ e ddZddZddZdS)ContinuousSchedulerunknowncCszd||_||_||_||_|jd|_|jd}t||_||_ d|_ d|_ d|_ d|_ tdd|_t|_dS)Ng?profile_lifecycleprofile_session_sample_rateF)maxlen)intervalr9r:r;r4 lifecyclerarD make_samplersamplerbufferpidrunning soft_shutdownr new_profilessetactive_profiles)rer?r9r:r;ror@r@rA__init__s     zContinuousScheduler.__init__cCs0|jtkr dS|jd}|sdS|dS)NFr,continuous_profiling_auto_start)rwosgetpidr9r4)rer>r@r@rArHs   z)ContinuousScheduler.is_auto_start_enabledcCs@|jsdS|jdkr dStdt}|j|||S)Ntracez"[Profiling] Auto starting profiler)rDrsr r0rbrzappendensure_running)reprofiler@r@rArKs   zContinuousScheduler.auto_startcCs$|jsdS|jdkr dS|dSNmanual)rDrsrrdr@r@rArI s   z ContinuousScheduler.manual_startcCs|jdkrdS|dSr)rsteardownrdr@r@rArY*s  zContinuousScheduler.manual_stopcCtrGNotImplementedErrorrdr@r@rAr1z"ContinuousScheduler.ensure_runningcCrrGrrdr@r@rAr5rzContinuousScheduler.teardowncCrrGrrdr@r@rApause9rzContinuousScheduler.pausecCst|j|jt|j|_dSrG) ProfileBufferr9r:PROFILE_BUFFER_SECONDSr;rvrdr@r@rA reset_buffer=s z ContinuousScheduler.reset_buffercCs|jdurdS|jjSrG)rvr\rdr@r@rAr\Cs zContinuousScheduler.profiler_idcsDttddjdkrfdd}|Sfdd}|S)N)max_sizercsjsjsdStj}t}zfddtD}Wnty0tt YdSwt |D] }j j q5g}jD] }|j sP||qF|D]}j|qSjdurhj||dS) Take a sample of the stack on all the threads in the process. This should be called at a regular interval to collect samples. Tc$g|]\}}t|t|fqSr@strr .0tidframecachecwdr@rA jKContinuousScheduler.make_sampler.._sample_stack..FN)rzr|lenr sys_current_framesitemsAttributeErrorr exc_inforangeaddpopleftrcrremovervwrite)argskwargsrztssample_inactive_profilesrrrrer@rA _sample_stackRs0          z7ContinuousScheduler.make_sampler.._sample_stackcsdt}zfddtD}Wnty#ttYdSwjdur0j||dS)rcrr@rrrr@rArrrFN) r rrrrr rrvr)rrrrrr@rArs     )rgetcwdrrs)rerr@rrArtJs  [z ContinuousScheduler.make_samplercCszt}|jr,||_t|}||jkrt|j||jr%d|_nt}|js|jdur;|jd|_dSdSrC) r) perf_counterrxruryrr thread_sleeprvflush)relastelapsedr@r@rAruns      zContinuousScheduler.runN)rgrhrir.r}rHrKrIrYrrrrpropertyr\rtrr@r@r@rArls   erlcs8eZdZdZdZdZfddZddZdd ZZ S) r3zr This scheduler is based on running a daemon thread that will call the sampler at a regular interval. threadz)sentry.profiler.ThreadContinuousSchedulercs&t||||d|_t|_dSrG)superr}r threadingLocklockrer?r9r:r; __class__r@rAr}sz"ThreadContinuousScheduler.__init__c Csd|_t}|jr|j|krdS|jN|jr&|j|kr& WddS||_d|_|tj|j |j dd|_ z|j Wnt yQd|_d|_ Yn wWddSWddS1sewYdS)NFT)nametargetdaemon)ryrrrxrwrrrThreadrrrstart RuntimeErrorrerwr@r@rArs,  "z(ThreadContinuousScheduler.ensure_runningcC0|jrd|_|jdur|jd|_d|_dSrCrxrjoinrvrdr@r@rAr    z"ThreadContinuousScheduler.teardown) rgrhri__doc__r.rr}rr __classcell__r@r@rrAr3s &r3cs4eZdZdZdZfddZddZddZZS) r2as 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. geventcs>tdur td|jt||||d|_t|_ dS)Nz"Profiler mode: {} is not available) r(r5r6r.rr}rrrrrrr@rAr}!s z"GeventContinuousScheduler.__init__c Csd|_t}|jr|j|krdS|jJ|jr&|j|kr& WddS||_d|_|td|_z |j |j Wnt yMd|_d|_Yn wWddSWddS1sawYdS)NFT) ryrrrxrwrrr(rspawnrrrr@r@rAr,s,   "z(GeventContinuousScheduler.ensure_runningcCrrCrrdr@r@rArNrz"GeventContinuousScheduler.teardown) rgrhrirr.r}rrrr@r@rrAr2s   "r2<c@s,eZdZddZddZddZddZd S) rcCsP||_||_||_||_tj|_t|_ t |_ t t j|j |_dSrG)r9r: buffer_sizer;uuiduuid4hexr\ ProfileChunkchunkr start_monotonic_timerrutcr$start_timestamp)rer9r:rr;r@r@rAr}^s zProfileBuffer.__init__cCs:||r|t|_t|_|j|j||dSrG) should_flushrrrr rrr)remonotonic_timerr@r@rArus zProfileBuffer.writecCs||j|jkSrG)rr)rerr@r@rAr~szProfileBuffer.should_flushcCs4|j|j|j|j}t}||||dSrG)rto_jsonr\r9r:radd_profile_chunkr;)rerenveloper@r@rArs zProfileBuffer.flushN)rgrhrir}rrrr@r@r@rAr]s  rc@s$eZdZddZddZddZdS)rcCs.tj|_i|_i|_g|_g|_g|_dSrG) rrrchunk_idindexed_framesindexed_stacksframesstackssamplesrdr@r@rAr}s  zProfileChunk.__init__c s|D]]\}\}}}zG|jvrBt|D]\}}|jvr,tjj|<j||qtjj|<jfdd|Dj||j|dWqty_t t YqwdS)Ncsg|]}j|qSr@)r)rframe_idrdr@rArsz&ProfileChunk.write..r#) r enumeraterrrrrrrr rr) rerrrr& frame_idsrirr@rdrArs,   zProfileChunk.writecCs|j|j|jddtDd}t|d|d|d|d|j|dtd d ||d d }d D]}||durCt|| ||<q1|S)NcSs"i|] }t|jdt|jiqS)r)ridentr)rrr@r@rA s  z(ProfileChunk.to_json..)rrrthread_metadatarin_app_excludein_app_include project_rootr)rversionpython2)r client_sdkplatformrr\r)release environmentdist) rrrrrrrrrstrip)rer\r9r:rpayloadkeyr@r@rArs6  zProfileChunk.to_jsonN)rgrhrir}rrr@r@r@rArs r)Or7rr^rrr)rrT collectionsrrrsentry_sdk.constsrsentry_sdk.envelopersentry_sdk._lru_cachersentry_sdk.profiler.utilsrr sentry_sdk.utilsr r r r rtypingrrrrrrrrrrtyping_extensionsrsentry_sdk._typesrrrrrrr r!r_intr" gevent.monkeyr'gevent.threadpoolr( _ThreadPoolr ImportErrorr*r/rBrErJrLrNrWrZr[r1r]rarbrlr3r2rrrr@r@r@rAs                    6   lBI0