[EDIT] FILE: worker.cpython-311.pyc
� ��]jy � � � d dl Z d dlZd dlmZmZ d dlmZ d dlmZmZ d dl m Z d dl m Z e rd dl mZ d dl mZ d d l mZ e� � Z G d � d e� � ZdS ) � N)�sleep�time)�check_thread_support)�Queue�Full)�logger)�MYPY)�Any)�Optional)�Callablec �^ � e Zd Zd d�Zed� � � Zd� Zd� Zd� Zd� Z dd �Z d � Z d � Z d � Z dS )�BackgroundWorker� c � � t � � t |� � | _ t j � � | _ d | _ d | _ d S �N)r r �_queue� threading�Lock�_lock�_thread�_thread_for_pid)�self� queue_sizes �H/opt/imunify360/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 skt j | j d�� � | _ | j � d� � | 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 � setDaemonr# r r r r! s r r# zBackgroundWorker.start= s� � � �Z� 3� 3��=� 3� (� /� �<�.M� � � �� � � �&�&�t�,�,�,�� �"�"�$�$�$�')�y�{�{��$� 3� 3� 3� 3� 3� 3� 3� 3� 3� 3� 3� 3���� 3� 3� 3� 3� 3� 3s �A3B�B �B 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.killH 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.flushY 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 � � t d|� � }| � |� � sV| j � � � }t j d|� � |� |||� � | � ||z � � d S d S )Ng�������?z %d event(s) pending on flush)�minr/ r �qsizer r7 )r r& r= �initial_timeout�pendings r r< z BackgroundWorker._wait_flusha s� � � �c�7�+�+���%�%�o�6�6� >��k�'�'�)�)�G� �L�7�� A� A� A��#����'�*�*�*� � "� "�7�_�#<� =� =� =� =� =� >� >r c � � | � � � | j � |� � d S # t $ r t j d� � Y d S w xY w)Nz,background worker queue full, dropping event)r$ r r8 r r r7 �r r= s r �submitzBackgroundWorker.submitk so � � ��� � � � I� �K� "� "�8� ,� ,� ,� ,� ,��� I� I� I� �L�G� H� H� H� H� H� H� I���s �2 � A�Ac �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 �errorr rE s r r4 zBackgroundWorker._targets 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 r )�__name__� __module__� __qualname__r �propertyr r$ r/ r# r: r> r< rF r4 � r r r r s� � � � � � �$� $� $� $� �'� '� �X�'�� � � +� +� +�$ 3� 3� 3�,� ,� ,�"2� 2� 2� 2�>� >� >�I� I� I� � � � � r r )r r r r �sentry_sdk._compatr �sentry_sdk._queuer r �sentry_sdk.utilsr �sentry_sdk._typesr �typingr r r �objectr9 r rQ r r �<module>rX s �� � � � � � � � � � � � � � � � � 3� 3� 3� 3� 3� 3� )� )� )� )� )� )� )� )� #� #� #� #� #� #� "� "� "� "� "� "�� ������� � � � � � � � � � � � � �f�h�h� �l� l� l� l� l�v� l� l� l� l� lr
SAVE
CANCEL