c`W^'X- d dl Z d dlZd dlmZmZ d dlmZ d dlmZmZ d dl m
Z
d dl m Z d dl
mZ erd dlmZ d d lmZ d d
lmZ e Z G d d e ZdS )
N)sleeptime)check_thread_support)Queue FullError)logger)DEFAULT_QUEUE_SIZE)
TYPE_CHECKING)Any)Optional)Callablec f e Zd ZefdZed Zd Zd Zd Z d Z
d
dZ d Z d
Z
d Zd ZdS )BackgroundWorkerc t t | | _ t j | _ d | _ d | _ d S N)r r _queue threadingLock_lock_thread_thread_for_pid)self
queue_sizes c/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/sentry_sdk/worker.py__init__zBackgroundWorker.__init__ sA J'' ^%%
# c | j t j k rdS | j sdS | j S )NF)r osgetpidr is_aliver s r r zBackgroundWorker.is_alive s@ 29;; . .5| 5|$$&&&r c @ | j s| d S d S r )r startr! s r _ensure_threadz BackgroundWorker._ensure_thread' s' } JJLLLLL r c t |z }| j }|j |j rU|t z
}|dk r |j dS |j | |j U |j dS # |j w xY w)Nr F)timeoutT)r r all_tasks_doneacquireunfinished_tasksreleasewait)r r& deadlinequeuedelays r _timed_queue_joinz"BackgroundWorker._timed_queue_join, s 66G#
$$&&& +(
9 466)A::
( ( * * * * * $))%)888 (
9 ( ( * * * * *E ( ( * * * *s B+ -"B+ +Cc | j 5 | j s]t j | j d | _ d| j _ | j t j | _
d d d d S # 1 swxY w Y d S )Nz raven-sentry.BackgroundWorker)targetnameT) r r r Thread_targetr daemonr# r r r r! s r r# zBackgroundWorker.start> s
Z 3 3=
3 ( / <.M '+ # ""$$$')y{{$ 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s A%A::A>A>c " t j d | j 5 | j rS | j t n$# t $ r t j d Y nw xY wd| _ d| _ ddd dS # 1 swxY w Y dS )z
Kill worker thread. Returns immediately. Not useful for
waiting on shutdown for events, use `flush` for that.
z"background worker got kill requestz)background worker queue full, kill failedN) r debugr r r
put_nowait _TERMINATORr r r! s r killzBackgroundWorker.killI s 9:::
Z , ,|
,NK**;7777 N N NL!LMMMMMN $ '+$ , , , , , , , , , , , , , , , , , ,s4 B AB A&#B%A&&BB BNc t j d | j 5 | j r |dk r| || d d d n # 1 swxY w Y t j d d S )Nz#background worker got flush requestg zbackground worker flushed)r r7 r r _wait_flush)r r& callbacks r flushzBackgroundWorker.flushZ s :;;;
Z 4 4}
43 (333 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 011111s $A AAc 4 | j S r )r fullr! s r r@ zBackgroundWorker.fullb s { !!!r c h t d| }| | s| j dz }t j d| | ||| | ||z
s5| j dz }t j d| d S d S d S )Ng? z %d event(s) pending on flushz"flush timed out, dropped %s events)minr/ r qsizer r7 error)r r& r= initial_timeoutpendings r r< z BackgroundWorker._wait_flushf s c7++%%o66 Lk''))A-G L7 A A A#'***))'O*CDD
L +++--1 A7KKKKK L L
L
Lr c | | j | dS # t $ r Y dS w xY w)NTF)r$ r r8 r r r= s r submitzBackgroundWorker.submits sV K " "8 , , ,4 55 s 2
A A c v | j } |t u r | j d S | n&# t $ r t j dd Y nw xY w| j n # | j w xY wt d )NTzFailed processing job)exc_infor )r getr9 task_done Exceptionr rE r rI s r r4 zBackgroundWorker._target| s {((H
({** %%''''' I HJJJJ I I IL!84HHHHHHI %%'''' %%'''' !HHH s/ B
A
B
A0-B
/A00B
B(r )__name__
__module__ __qualname__r r propertyr r$ r/ r# r: r> r@ r< rJ r4 r r r r s "4 $ $ $ $ ' ' X'
+ + +$ 3 3 3, , ,"2 2 2 2" " " L L L
r r )r r r r sentry_sdk._compatr sentry_sdk._queuer r sentry_sdk.utilsr sentry_sdk.constsr sentry_sdk._typesr
typingr r r
objectr9 r rT r r r\ s 3 3 3 3 3 3 . . . . . . . . # # # # # # 0 0 0 0 0 0 + + + + + + fhh t t t t tv t t t t tr