OwlCyberSecurity - MANAGER
Edit File: worker.cpython-312.pyc
� G��gp � � � d dl Z d dlZd dlmZmZ d dlmZmZ d dlmZ d dl m Z d dl m Z e rd dl m Z d dl mZ d d l mZ e� Z G d � d � Zy) � N)�sleep�time)�Queue� FullError)�logger)�DEFAULT_QUEUE_SIZE)� TYPE_CHECKING)�Any)�Optional)�Callablec �^ � e Zd Zefd�Zed� � Zd� Zd� Zd� Z d� Z d d�Z d � Z d � Z d � Zd � Zy)�BackgroundWorkerc �r � t |� | _ t j � | _ d | _ d | _ y �N)r �_queue� threading�Lock�_lock�_thread�_thread_for_pid)�self� queue_sizes �@/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/worker.py�__init__zBackgroundWorker.__init__ s+ � ��J�'�� � �^�^�%�� ��� � #�� � c � � | j t j � k7 ry| j sy| j j � S )NF)r �os�getpidr �is_alive�r s r r zBackgroundWorker.is_alive s8 � � � � �2�9�9�;� .���|�|���|�|�$�$�&�&r c �> � | j s| j � y y r )r �startr s r �_ensure_threadz BackgroundWorker._ensure_thread% s � ��}�}� �J�J�L� r c � � t � |z }| j }|j j � |j rW|t � z }|dk r |j j � y|j j |�� |j r�W |j j � y# |j 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�G�#��� � �� � � �$�$�&� +��(�(� �4�6�)���A�:� � � � � (� (� *� �$�$�)�)�%�)�8� �(�(� � � � � (� (� *��E� � � (� (� *�s � B4 �/(B4 �4 Cc �` � | j 5 | j skt j | j d�� | _ d| j _ | j j � t j � | _ d d d � y # t $ r d | _ Y �w xY w# 1 sw Y y xY w)Nzsentry-sdk.BackgroundWorker)�target�nameT) r r r �Thread�_targetr �daemonr" r r r � RuntimeErrorr s r r" zBackgroundWorker.start< s� � � �Z�Z��=�=� (� /� /� �<�<�.K� �� � '+�� � �#�(��L�L�&�&�(�+-�9�9�;�D�(� �Z�� $� (� $(�D�L� (�� �Z�s* �AB$�3B�B!� B$� B!�!B$�$B-c �, � t j d� | j 5 | j r. | j j t � d| _ d| _ ddd� y# t $ r t j d� Y �7w xY w# 1 sw Y yxY w)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.killM sw � � � � �9�:� �Z�Z��|�|�N��K�K�*�*�;�7� $�� �'+��$� �Z�� !� N��L�L�!L�M�N�� �Z�s. � B � A&�B �& B�B �B�B � BNc �� � t j d� | j 5 | j r|dkD r| j ||� d d d � t j d� y # 1 sw Y � xY w)Nz#background worker got flush requestg zbackground worker flushed)r r7 r r � _wait_flush)r r% �callbacks r �flushzBackgroundWorker.flush^ sO � �� � �:�;� �Z�Z��}�}��3� �� � ��(�3� � � � �0�1� �Z�s �$A$�$A-c �6 � | j j � S r )r �fullr s r r@ zBackgroundWorker.fullf s � ��{�{� � �!�!r c �L � t d|� }| j |� s�| j j � dz }t j d|� |� |||� | j ||z � s4| j j � dz }t j d|� y y y )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_flushj s� � � �c�7�+���%�%�o�6��k�k�'�'�)�A�-�G� �L�L�7�� A��#���'�*��)�)�'�O�*C�D� �+�+�+�+�-��1��� � � A�7�K� E� 7r c �z � | j � | j j |� y# t $ r Y yw xY w)NTF)r# r r8 r �r r= s r �submitzBackgroundWorker.submitw s: � � ��� � � �K�K� "� "�8� ,���� �� �s �. � :�:c �h � | j j � } |t u r | j j � y |� | j j � t d� �m# t $ r t j dd�� Y �Hw xY w# | j j � w xY w)NTzFailed processing job)�exc_infor )r �getr9 � task_done� Exceptionr rE r rI s r r3 zBackgroundWorker._target� s� � ���{�{���(�H� (��{�*�� � � �%�%�'� I� �J� � � �%�%�'� �!�H� �� !� I��L�L�!8�4�H�I�� � � �%�%�'�s) �B �A/ �/ B�B �B�B � B1r )�__name__� __module__� __qualname__r r �propertyr r# r. r" r: r> r@ r< rJ r3 � r r r r sL � �"4� $� �'� �'�� +�$(�",�"2�"� L�� r r )r r r r �sentry_sdk._queuer r �sentry_sdk.utilsr �sentry_sdk.constsr �typingr r r r �objectr9 r rT r r �<module>rZ s; �� � � � .� #� 0� ��� � � �h� �y� yr