o j@shddlZddlZddlZddlZddlmZmZGdddZd ddZGd d d Z Gd d d Z dS)N)AnyUnionc@s2eZdZdZdZdedeeefddfddZ dS) _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_iddatarrreturnNcCs||_||_dSNr)selfrrr K/var/www/html/django_cbt/venv/lib/python3.10/site-packages/asgiref/local.py__init__s z_Storage.__init__) __name__ __module__ __qualname____doc__ __slots__intdictstrrr r r r r rs"rstoragercCstt|jS)z7Return a copy of *storage* owned by the current thread.)r threading get_identr)rr r r _rehome srcs\eZdZdZdddZdddZd d Zd ed eddffd d Z d eddfddZ Z S)_CVarzStorage utility for Local.rNcCstd|_dS)Nz asgiref.local) contextvars ContextVar_data)r r r r r (s z_CVar.__init__rcCs4|jd}|dus|jtkrttiS|Sr )rgetrrrr)r rr r r _storage-s z_CVar._storagecCs2z|j|WStyt|d|wNz object has no attribute )rrKeyErrorAttributeError)r keyr r r __getattr__6s  z_CVar.__getattr__r#valuecsF|dkr t||S|j}|||<|jtt |dS)Nr) super __setattr__rrcopyrsetrrr)r r#r%r __class__r r r'<s z_CVar.__setattr__cCsH|j}||vr||=|jtt|dSt|d|r ) rrr(rr)rrrr")r r#rr r r __delattr__Ds z_CVar.__delattr__)rN)rr) rrrrr rr$rrr'r, __classcell__r r r*r r%s   rcsReZdZdZddeddfddZejdd Zd d Z fd d Z ddZ Z 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. Fthread_criticalrNcCs2||_t|_||rt|_dSt|_dSr )_thread_criticalrRLock _thread_locklocalrr)r r/r r r r is   zLocal.__init__ccs|jr2d}ztWn tyd}Ynw|s |jVdSt|jds+t|j_|jjVdS|j |jVWddS1sEwYdS)NTFcvar) r0asyncioget_running_loop RuntimeErrorrhasattrrr4r2)r is_asyncr r r _lock_storagevs       "zLocal._lock_storagecCs6| }t||WdS1swYdSr )r:getattrr r#rr r r r$s $zLocal.__getattr__csP|dvr t||S|}t|||WddS1s!wYdS)N)_localrr0r2)r&r'r:setattr)r r#r%rr*r r r's  "zLocal.__setattr__cCs8|}t||WddS1swYdSr )r:delattrr<r r r r,s  "zLocal.__delattr__)F) rrrrboolr contextlibcontextmanagerr:r$r'r,r-r r r*r r.Ms % r.)rrrr) r5rArrtypingrrrrrr.r r r r s (