Bʢ;y 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 ZdefdZd Zd ZdS ) _TimedAtomicinnerc 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&& wwy 5A > > >ss CDD {$$&&&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_Sloggerwarningr )r argsresultelapseds r
r# z_TimedAtomic.__exit__& s[ %%t,.""T[0 * * * NN5
r N)r r r objectr r! r# r r r
r r sM f
' ' '
r r c 0 e Zd Z fdZddef fd
Z xZS )SqliteDatabaseWrapperc N t |i | t j |i |S N) _validatesuper execute_sql)r r' kwargs __class__s r
r1 z!SqliteDatabaseWrapper.execute_sql3 s2 4"6""""uww"D3F333r IMMEDIATE lock_typec t | }t j d rt | S |S )NDEBUG)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 )Nthread_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 2D NOOOOO 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
rM s' 2 2 2 2 2 2 4 4 4 4 4 4 i
8 $ $' )) . -
r