o 0 iZ@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 _experimentsZcontinuous_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_funcZalready_initializedZdefault_profiler_moder+ experiments frequencyr=s/home/app/PaddleOCR-VL-test/.venv_paddleocr/lib/python3.10/site-packages/sentry_sdk/profiler/continuous_profiler.pysetup_continuous_profilerJs<       r?cCstdurdStjSNF)r.sampledr=r=r=r>is_profile_session_sampledrBcCs$tdurdSts dStdSN)r.is_auto_start_enabled manual_startr=r=r=r>!try_autostart_continuous_profilers  rGcCstdurdStSrD)r. auto_startr=r=r=r>!try_profile_lifecycle_trace_startsrIcCtdurdStdSrD)r.rFr=r=r=r>start_profiler rKcCtjdtddtdS)NzWThe `start_profile_session` function is deprecated. Please use `start_profile` instead. stacklevel)warningswarnDeprecationWarningrKr=r=r=r>start_profile_session  rTcCrJrD)r. manual_stopr=r=r=r> stop_profilerrLrWcCrM)NzUThe `stop_profile_session` function is deprecated. Please use `stop_profile` instead.rNrO)rQrRrSrWr=r=r=r>stop_profile_sessionrUrXcCstdadSrD)rWr.r=r=r=r>r0sr0cCstdurdStjSrD)r. profiler_idr=r=r=r>get_profiler_idrCrZcCs|sdStt|kSr@)randomfloat)Z sample_rater=r=r>+determine_profile_session_sampling_decisionsr]c@s"eZdZUdZeed<ddZdS)ContinuousProfileTactivecCs d|_dSr@)r_selfr=r=r>stops zContinuousProfile.stopN)__name__ __module__ __qualname__r_bool__annotations__rbr=r=r=r>r^s  r^c@steZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ e ddZddZddZdS)ContinuousSchedulerunknowncCszd||_||_||_||_|jd|_|jd}t||_||_ d|_ d|_ d|_ d|_ tdd|_t|_dS)Ng?Zprofile_lifecycleprofile_session_sample_rateF)maxlen)intervalr8r9r:r3 lifecycler]rA make_samplersamplerbufferpidrunning soft_shutdownr new_profilessetactive_profiles)rar<r8r9r:rjr=r=r>__init__s     zContinuousScheduler.__init__cCs0|jtkr dS|jd}|sdS|dS)NFr,Zcontinuous_profiling_auto_start)rrosgetpidr8r3)rar;r=r=r>rEs   z)ContinuousScheduler.is_auto_start_enabledcCs@|jsdS|jdkr dStdt}|j|||S)Ntracez"[Profiling] Auto starting profiler)rArnr r/r^ruappendensure_running)raprofiler=r=r>rHs   zContinuousScheduler.auto_startcCs$|jsdS|jdkr dS|dSNZmanual)rArnr}r`r=r=r>rF s   z ContinuousScheduler.manual_startcCs|jdkrdS|dSr)rnteardownr`r=r=r>rV*s  zContinuousScheduler.manual_stopcCtrDNotImplementedErrorr`r=r=r>r}1z"ContinuousScheduler.ensure_runningcCrrDrr`r=r=r>r5rzContinuousScheduler.teardowncCrrDrr`r=r=r>pause9rzContinuousScheduler.pausecCst|j|jt|j|_dSrD) ProfileBufferr8r9PROFILE_BUFFER_SECONDSr:rqr`r=r=r> reset_buffer=s z ContinuousScheduler.reset_buffercCs|jdurdS|jjSrD)rqrYr`r=r=r>rYCs zContinuousScheduler.profiler_idcsDttddjdkrfdd}|Sfdd}|S)N)max_sizer{csjsjsdStj}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=r> jKContinuousScheduler.make_sampler.._sample_stack..FN)rurwlenr sys_current_framesitemsAttributeErrorr exc_inforangeaddpopleftr_r|removerqwrite)argskwargsrutssample_Zinactive_profilesr~rrrar=r> _sample_stackRs0          z7ContinuousScheduler.make_sampler.._sample_stackcsdt}zfddtD}Wnty#ttYdSwjdur0j||dS)rcrr=rrrr=r>rrrFN) r rrrrr rrqr)rrrrrr=r>rs     )rygetcwdrrn)rarr=rr>roJs  [z ContinuousScheduler.make_samplercCszt}|jr,||_t|}||jkrt|j||jr%d|_nt}|js|jdur;|jd|_dSdSr@) r) perf_counterrsrprtrm thread_sleeprqflush)ralastelapsedr=r=r>runs      zContinuousScheduler.runN)rcrdrer-rxrErHrFrVr}rrrpropertyrYrorr=r=r=r>rhs   erhcs8eZdZdZdZdZfddZddZdd ZZ S) r2zr 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|_dSrD)superrxr threadingLocklockrar<r8r9r: __class__r=r>rxsz"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)rtryrzrsrrrrrThreadrrrstart RuntimeErrorrarrr=r=r>r}s,  "z(ThreadContinuousScheduler.ensure_runningcC0|jrd|_|jdur|jd|_d|_dSr@rsrjoinrqr`r=r=r>r    z"ThreadContinuousScheduler.teardown) rcrdre__doc__r-rrxr}r __classcell__r=r=rr>r2s &r2cs4eZdZdZdZfddZddZddZZS) r1as 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. Zgeventcs>tdur td|jt||||d|_t|_ dS)Nz"Profiler mode: {} is not available) r(r4r5r-rrxrrrrrrr=r>rx!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) rtryrzrsrrrrr(rZspawnrrrr=r=r>r},s,   "z(GeventContinuousScheduler.ensure_runningcCrr@rr`r=r=r>rNrz"GeventContinuousScheduler.teardown) rcrdrerr-rxr}rrr=r=rr>r1s   "r1<c@s,eZdZddZddZddZddZd S) rcCsP||_||_||_||_tj|_t|_ t |_ t t j|j |_dSrD)r8r9 buffer_sizer:uuiduuid4hexrY ProfileChunkchunkr start_monotonic_timerrutcr$start_timestamp)rar8r9rr:r=r=r>rx^s zProfileBuffer.__init__cCs:||r|t|_t|_|j|j||dSrD) should_flushrrrr rrr)ramonotonic_timerr=r=r>rus zProfileBuffer.writecCs||j|jkSrD)rr)rarr=r=r>r~szProfileBuffer.should_flushcCs4|j|j|j|j}t}||||dSrD)rto_jsonrYr8r9rZadd_profile_chunkr:)rarenveloper=r=r>rs zProfileBuffer.flushN)rcrdrerxrrrr=r=r=r>r]s  rc@s$eZdZddZddZddZdS)rcCs.tj|_i|_i|_g|_g|_g|_dSrD) rrrchunk_idindexed_framesindexed_stacksframesstackssamplesr`r=r=r>rxs  zProfileChunk.__init__c s|D]]\}\}}}zG|jvrBt|D]\}}|jvr,tjj|<j||qtjj|<jfdd|Dj||j|dWqty_t t YqwdS)Ncsg|]}j|qSr=)r)rframe_idr`r=r>rsz&ProfileChunk.write..r#) r enumeraterrrr|rrrr rr) rarrrr&Z frame_idsrirr=r`r>rs,   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=r> s  z(ProfileChunk.to_json..)rrrZthread_metadatarZin_app_excludeZin_app_includeZ project_rootr)rversionpython2)rZ client_sdkplatformr~rYr)release environmentdist) rrrrrrrrrstrip)rarYr8r9r~payloadkeyr=r=r>rs6  zProfileChunk.to_jsonN)rcrdrerxrrr=r=r=r>rs r)Or6ryr[rrr)rrQ collectionsrrrZsentry_sdk.constsrZsentry_sdk.enveloperZsentry_sdk._lru_cacherZsentry_sdk.profiler.utilsrr Zsentry_sdk.utilsr r r r rtypingrrrrrrrrrrZtyping_extensionsrZsentry_sdk._typesrrrrrrr r!r\intr"Z gevent.monkeyr'Zgevent.threadpoolr(Z _ThreadPoolr ImportErrorr*r.r?rBrGrIrKrTrWrXr0rZr]r^rhr2r1rrrr=r=r=r>s                    6   lBI0