PATH:
opt
/
imunify360
/
venv
/
lib
/
python3.11
/
site-packages
/
defence360agent
/
model
/
__pycache__
/
Editing: tls_check.cpython-311.opt-1.pyc
� ���i� � �� � d dl Z d dlZd dlZd dlZd dlmZ d dlmZ G d� de� � Z e j e � � Z ej � � ZdZ G d� d� � Z G d � d e� � Zd d �Zd � ZdS )� N)�SqliteExtDatabase)�gc � � e Zd ZdZdS )�OverridingResetz� Overriding reset could be a signal of logic error thus need to be explicitly handled in all places where this exception is expected to occur. N)�__name__� __module__� __qualname__�__doc__� � �T/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/model/tls_check.pyr r s � � � � � �� � �Dr r g @c �& � e Zd Zdefd�Zd� Zd� ZdS )� _TimedAtomic�innerc �0 � || _ d| _ d| _ d S )Ng � )�_inner�_start�_caller)�selfr s r �__init__z_TimedAtomic.__init__ s � ��� � �� � �� � � r c �� � t j � � | _ d� t j d�� � d d� � � | _ | j � � � S )Nr � )�limit���) �time� monotonicr �join� traceback� format_stackr r � __enter__)r s r r! z_TimedAtomic.__enter__! sO � ��n�&�&�� ��w�w�y� 5�A� >� >� >�s��s� C�D�D�� ��{�$�$�&�&�&r c � � | j j |� }t j � � | j z }|t k r!t � d|| j � � |S )Nz"Slow transaction held for %.2fs %s) r �__exit__r r r �_SLOW_TXN_THRESHOLD_S�logger�warningr )r �args�result�elapseds r r# z_TimedAtomic.__exit__& s[ � �%���%�t�,���.�"�"�T�[�0�� �*� *� *� �N�N�5��� � � � � � r N)r r r �objectr r! r# r r r r r sM � � � � � � �f� � � � � '� '� '� � � � � r r c �0 � � e Zd Z� fd�Zddef� fd� Z� xZS )�SqliteDatabaseWrapperc �N �� t |i |�� t � � j |i |��S �N)� _validate�super� execute_sql)r r' �kwargs� __class__s �r r1 z!SqliteDatabaseWrapper.execute_sql3 s2 �� ��4�"�6�"�"�"�"�u�w�w�"�D�3�F�3�3�3r � IMMEDIATE� lock_typec � �� t � � � |� � }t j d� � rt |� � S |S )N�DEBUG)r0 �atomicr �getr )r r5 r r3 s �r r8 z SqliteDatabaseWrapper.atomic7 s; �� ������y�)�)�� �5��>�>� '� ��&�&� &�� r )r4 )r r r r1 �strr8 � __classcell__)r3 s @r r, r, 2 sb �� � � � � �4� 4� 4� 4� 4�� �� � � � � � � � � � r r, c � � t t d� � rt � � �| pt j � � t _ d S )N�thread_ident_memo)�hasattr�_thread_local_storager � threading� get_identr= )� new_values r �resetrC > sC � ��$�&9�:�:� � � � � � �*�Y�(�*�*� �+�+�+r c � � t t dd � � }|� t � d� � d S |t j � � k r1t � d|t j � � | |� � d S d S )Nr= z7wrong thread or _validate() was not preceded by reset()zFthread_ident_memo check failed [%r != %r] context: args: %s kwargs: %s)�getattrr? r% �errorr@ rA )r' r2 r= s r r/ r/ G s� � � � � 2�D�� �� � �� � �N�O�O�O�O�O� �i� 1� 3� 3� 3� 3�� � � -� � � � !� !� � � � � � � � 4� 3r r. )�loggingr@ r r �playhouse.sqlite_extr �&defence360agent.internals.global_scoper � Exceptionr � getLoggerr r% �localr? r$ r r, rC r/ r r r �<module>rM s' �� ���� � � � � � � � � � � � � 2� 2� 2� 2� 2� 2� 4� 4� 4� 4� 4� 4� � � � � �i� � � � �� �8� $� $��'� ��)�)� �� �� � � � � � � �. � � � � � -� � � �� � � � � � � � r
SAVE
CANCEL