DsljxddlZddlZddlZddlZddlmZmZGddZd dZGddZ Gdd Z y) N)AnyUnionc2eZdZdZdZdedeeefddfdZ y)_StorageanThread-tagged storage for a non-thread-critical ``Local``. The data is tagged with the identity of the thread that owns it. This lets ``_CVar`` ignore data that leaked into an unrelated thread. Python 3.14 added ``sys.flags.thread_inherit_context``, which is enabled by default on free-threaded builds. When set, a new thread starts with a copy of the spawning thread's context instead of an empty one, so the contextvar backing a ``Local`` would otherwise be visible in any thread spawned from one that had set it -- breaking the documented "thread-local in sync threads" behaviour. asgiref re-homes the storage to the current thread at the points where it *intentionally* moves work between threads (see ``asgiref.sync._restore_context``); data merely inherited by an unrelated thread is never re-homed and so stays isolated.  thread_iddatarr returnNc ||_||_yNr)selfrr s F/var/www/eggtrainer/venv/lib/python3.12/site-packages/asgiref/local.py__init__z_Storage.__init__s" ) __name__ __module__ __qualname____doc__ __slots__intdictstrrrrrrrs0 &I#T#s(^rrcRttj|jS)z7Return a copy of *storage* owned by the current thread.)r threading get_identr )storages r_rehomer s I'')7<< 88rcVeZdZdZd dZd dZdZdededdffd Z deddfd Z xZ S) _CVarzStorage utility for Local.r Nc8tjd|_y)Nz asgiref.local) contextvars ContextVar_data)r s rrz_CVar.__init__(s9D9O9O :  rc|jjd}|!|jtjk7rt tjiS|Sr )r$getrrrr)r rs r_storagez_CVar._storage-sL**..& ?g//93F3F3HHI//126 6rcx |jj|S#t$rt|d|wxYwNz object has no attribute )r'r KeyErrorAttributeError)r keys r __getattr__z_CVar.__getattr__6sG N==?'', , N D8+DSG!LM M Ns9r,valuec|dk(rt|||S|jjj }|||<|j j ttj|y)Nr$) super __setattr__r'r copyr$setrrr)r r,r.r __class__s rr1z_CVar.__setattr__<s_ '>7&sE2 2}}##((*S  x 3 3 5t<=rc|jjj}||vr;||=|jj t t j|yt|d|r)) r'r r2r$r3rrrr+)r r,r s r __delattr__z_CVar.__delattr__Dsa}}##((* $;S JJNN8I$7$7$94@ A D8+DSG!LM Mr)r N)r r) rrrrrr'r-rrr1r6 __classcell__r4s@rr r %sF$ N >s>3>4>NsNtNrr cdeZdZdZd deddfdZejdZdZ fdZ d Z xZ S) LocalaLocal storage for async tasks. This is a namespace object (similar to `threading.local`) where data is also local to the current async task (if there is one). In async threads, local means in the same sense as the `contextvars` module - i.e. a value set in an async frame will be visible: - to other async code `await`-ed from this frame. - to tasks spawned using `asyncio` utilities (`create_task`, `wait_for`, `gather` and probably others). - to code scheduled in a sync thread using `sync_to_async` In "sync" threads (a thread with no async event loop running), the data is thread-local, but additionally shared with async code executed via the `async_to_sync` utility, which schedules async code in a new thread and copies context across to that thread. If `thread_critical` is True, then the local will only be visible per-thread, behaving exactly like `threading.local` if the thread is sync, and as `contextvars` if the thread is async. This allows genuinely thread-sensitive code (such as DB handles) to be kept strictly to their initial thread and disable the sharing across `sync_to_async` and `async_to_sync` wrapped calls. Unlike plain `contextvars` objects, this utility is threadsafe. thread_criticalr Nc||_tj|_||rtj|_yt |_yr )_thread_criticalrRLock _thread_locklocalr'r )r r;s rrzLocal.__init__is8 /%OO- %OO-DM"GDMrc#K|jrpd} tj|s|jyt |jdst |j_|jjy|j5|jdddy#t$rd}YwxYw#1swYyxYww)NTFcvar) r=asyncioget_running_loop RuntimeErrorr'hasattrr rBr?)r is_asyncs r _lock_storagezLocal._lock_storagevs  H !((* mm#t}}f5).DMM& mm((("" $mm# $ $3  !  !2 $ $s@CB#A%C B4 C# B1.C0B11C4B=9Ccf|j5}t||cdddS#1swYyxYwr )rHgetattrr r,rs rr-zLocal.__getattr__s/    ! )W7C( ) ) )s '0c|dvrt|||S|j5}t|||dddy#1swYyxYw)N)_localr'r=r?)r0r1rHsetattr)r r,r.rr4s rr1zLocal.__setattr__sM L L7&sE2 2    ! )W GS% ( ) ) )s =Acf|j5}t||dddy#1swYyxYwr )rHdelattrrKs rr6zLocal.__delattr__s/    ! "W GS ! " " "s '0)F) rrrrboolr contextlibcontextmanagerrHr-r1r6r7r8s@rr:r:MsE6 $ $ $#$#$J)) "rr:)rrr r) rCrRr"rtypingrrrrr r:rrrrUs<09 %N%NP["["r