[ Avaa Bypassed ]




Upload:

Command:

hmhc3928@3.15.208.206: ~ $
�

>�Dgy���ddlZddlZddlmZmZddlmZddlmZmZddl	m
Z
ddlmZerddl
mZddl
mZdd	l
mZe��ZGd
�de��ZdS)�N)�sleep�time)�check_thread_support)�Queue�Full)�logger)�MYPY)�Any)�Optional)�Callablec�^�eZdZd
d�Zed���Zd�Zd�Zd�Zd�Z	dd	�Z
d
�Zd�Zd�Z
dS)�BackgroundWorker�c��t��t|��|_tj��|_d|_d|_dS�N)rr�_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��|jtj��krdS|jsdS|j���S)NF)r�os�getpidr�is_alive�rs rr zBackgroundWorker.is_alives@����2�9�;�;�.�.��5��|�	��5��|�$�$�&�&�&rc�@�|js|���dSdSr)r �startr!s r�_ensure_threadzBackgroundWorker._ensure_thread&s'���}�	��J�J�L�L�L�L�L�	�	rc��t��|z}|j}|j���	|jrU|t��z
}|dkr	|j���dS|j�|���|j�U	|j���dS#|j���wxYw)NrF)�timeoutT)rr�all_tasks_done�acquire�unfinished_tasks�release�wait)rr&�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�*�|j5|jsktj|jd���|_|j�d��|j���tj	��|_
ddd��dS#1swxYwYdS)Nzraven-sentry.BackgroundWorker)�target�nameT)rr r�Thread�_targetr�	setDaemonr#rrrr!s rr#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�"�tjd��|j5|jrS	|j�t��n$#t$rtjd��YnwxYwd|_d|_ddd��dS#1swxYwYdS)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�debugrrr�
put_nowait�_TERMINATORrrr!s r�killzBackgroundWorker.killHs���	��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���tjd��|j5|jr|dkr|�||��ddd��n#1swxYwYtjd��dS)Nz#background worker got flush requestgzbackground worker flushed)rr7rr �_wait_flush)rr&�callbacks   r�flushzBackgroundWorker.flushYs�����:�;�;�;�
�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��td|��}|�|��sV|j���}t	jd|��|�|||��|�||z
��dSdS)Ng�������?z%d event(s) pending on flush)�minr/r�qsizerr7)rr&r=�initial_timeout�pendings     rr<zBackgroundWorker._wait_flushas����c�7�+�+���%�%�o�6�6�	>��k�'�'�)�)�G��L�7��A�A�A��#����'�*�*�*��"�"�7�_�#<�=�=�=�=�=�	>�	>rc��|���	|j�|��dS#t$rt	jd��YdSwxYw)Nz,background worker queue full, dropping event)r$rr8rrr7�rr=s  r�submitzBackgroundWorker.submitkso��������	I��K�"�"�8�,�,�,�,�,���	I�	I�	I��L�G�H�H�H�H�H�H�	I���s�2�A�Ac�v�	|j���}	|tur	|j���dS	|��n&#t$rtjdd���YnwxYw|j���n#|j���wxYwtd����)NTzFailed processing job)�exc_infor)r�getr9�	task_done�	Exceptionr�errorrrEs  rr4zBackgroundWorker._targetss���	��{���(�(�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()rr)�__name__�
__module__�__qualname__r�propertyr r$r/r#r:r>r<rFr4�rrrrs�������$�$�$�$��'�'��X�'����
+�+�+�$	3�	3�	3�,�,�,�"2�2�2�2�>�>�>�I�I�I�
�
�
�
�
rr)rrrr�sentry_sdk._compatr�sentry_sdk._queuerr�sentry_sdk.utilsr�sentry_sdk._typesr	�typingr
rr�objectr9rrQrr�<module>rXs	��	�	�	�	�������������3�3�3�3�3�3�)�)�)�)�)�)�)�)�#�#�#�#�#�#�"�"�"�"�"�"�� ��������������������f�h�h��l�l�l�l�l�v�l�l�l�l�lr

Filemanager

Name Type Size Permission Actions
__init__.cpython-311.pyc File 992 B 0644
_compat.cpython-311.pyc File 3.78 KB 0644
_functools.cpython-311.pyc File 2.44 KB 0644
_queue.cpython-311.pyc File 11.64 KB 0644
_types.cpython-311.pyc File 1.79 KB 0644
api.cpython-311.pyc File 6.54 KB 0644
attachments.cpython-311.pyc File 2.29 KB 0644
client.cpython-311.pyc File 16.67 KB 0644
consts.cpython-311.pyc File 3.09 KB 0644
debug.cpython-311.pyc File 2.44 KB 0644
envelope.cpython-311.pyc File 12.58 KB 0644
hub.cpython-311.pyc File 25.07 KB 0644
scope.cpython-311.pyc File 16.48 KB 0644
serializer.cpython-311.pyc File 16.5 KB 0644
sessions.cpython-311.pyc File 8.71 KB 0644
tracing.cpython-311.pyc File 27.45 KB 0644
transport.cpython-311.pyc File 16.72 KB 0644
utils.cpython-311.pyc File 32.93 KB 0644
worker.cpython-311.pyc File 7.23 KB 0644