← Back
Editing: worker.cpython-311.pyc
� �|oi� � � � 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)�sleep�time)�check_thread_support)�Queue� FullError)�logger)�DEFAULT_QUEUE_SIZE)� TYPE_CHECKING)�Any)�Optional)�Callablec �f � e Zd Zefd�Zed� � � Zd� Zd� Zd� Z d� Z d d�Z d � Z d � Z d � Zd � ZdS )�BackgroundWorkerc � � t � � t |� � | _ t j � � | _ d | _ d | _ d S �N)r r �_queue� threading�Lock�_lock�_thread�_thread_for_pid)�self� queue_sizes �H/opt/cloudlinux/venv/lib64/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 �os�getpidr �is_alive�r s r r zBackgroundWorker.is_alive s@ � � � �2�9�;�;� .� .��5��|� ��5��|�$�$�&�&�&r c �@ � | j s| � � � d S d S r )r �startr! s r �_ensure_threadz BackgroundWorker._ensure_thread' s' � ��}� � �J�J�L�L�L�L�L� � 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_done�acquire�unfinished_tasks�release�wait)r r& �deadline�queue�delays r �_timed_queue_joinz"BackgroundWorker._timed_queue_join, s� � ��6�6�G�#��� �� � �$�$�&�&�&� +��(� 9� �4�6�6�)���A�:�:� � � � (� (� *� *� *� *� *� �$�)�)�%�)�8�8�8� �(� 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)�target�nameT) 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� ,� ,��|� ,�N��K�*�*�;�7�7�7�7�� � N� N� N��L�!L�M�M�M�M�M�N���� $�� �'+��$� ,� ,� ,� ,� ,� ,� ,� ,� ,� ,� ,� ,���� ,� ,� ,� ,� ,� ,s4 �B� A�B� A&�#B�%A&�&B�B� 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��}� 4��3� � �� � ��(�3�3�3� 4� 4� 4� 4� 4� 4� 4� 4� 4� 4� 4���� 4� 4� 4� 4� � �0�1�1�1�1�1s �$A � A�Ac �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_timeout�pendings r r< z BackgroundWorker._wait_flushf s� � � �c�7�+�+���%�%�o�6�6� L��k�'�'�)�)�A�-�G� �L�7�� A� A� A��#����'�*�*�*��)�)�'�O�*C�D�D� L� �+�+�+�-�-��1��� � A�7�K�K�K�K�K� 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��� � � ��5�5� ���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� �H�J�J�J�J�� � I� I� I��L�!8�4�H�H�H�H�H�H�I���� � �%�%�'�'�'�'��� �%�%�'�'�'�'���� �!�H�H�H� s/ � B � A � B � A0�-B �/A0�0B � 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 �<module>r\ s �� � � � � � � � � � � � � � � � � 3� 3� 3� 3� 3� 3� .� .� .� .� .� .� .� .� #� #� #� #� #� #� 0� 0� 0� 0� 0� 0� +� +� +� +� +� +�� ������� � � � � � � � � � � � � �f�h�h� �t� t� t� t� t�v� t� t� t� t� tr
Save File
Cancel