| Server IP : 66.29.153.156 / Your IP : 216.73.216.226 Web Server : LiteSpeed System : Linux premium322.web-hosting.com 4.18.0-553.50.1.lve.el8.x86_64 #1 SMP Thu Apr 17 19:10:24 UTC 2025 x86_64 User : lastyfjz ( 1521) PHP Version : 8.1.34 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/imunify360/venv/lib64/python3.11/site-packages/sentry_sdk/__pycache__/ |
Upload File : |
�
� �iy � � � 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