o h0@sTddlZddlZddlZddlZddlmZmZmZGdddZGdddZ dS)N)AnyDictUnioncsReZdZdZdddZddZded eddffd d Zdeddfd d Z Z S)_CVarzStorage utility for Local.returnNcCstd|_dS)Nz asgiref.local) contextvars ContextVar_data)selfr M/var/www/html/premium_crap/venv/lib/python3.10/site-packages/asgiref/local.py__init__ s z_CVar.__init__cCs8|ji}z||WStyt|d|wNz object has no attribute )r getKeyErrorAttributeErrorr keystorage_objectr r r __getattr__s   z_CVar.__getattr__rvaluecs>|dkr t||S|ji}|||<|j|dS)Nr )super __setattr__r rcopyset)r rrr __class__r r rs z_CVar.__setattr__cCs@|ji}||vr||=|j|dSt|d|r)r rrrrrr r r __delattr__s z_CVar.__delattr__)rN) __name__ __module__ __qualname____doc__r rstrrrr __classcell__r r rr rs  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 stricly 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|_dSN)_thread_critical threadingRLock _thread_locklocal_storager)r r%r r r r Ds   zLocal.__init__ccs|jr2d}ztWn tyd}Ynw|s |jVdSt|jds+t|j_|jjVdS|j |jVWddS1sEwYdS)NTFcvar) r'asyncioget_running_loop RuntimeErrorr,hasattrrr-r*)r is_asyncr r r _lock_storageQs       "zLocal._lock_storagecCs6| }t||WdS1swYdSr&)r3getattrr rstorager r r rws $zLocal.__getattr__csP|dvr t||S|}t|||WddS1s!wYdS)N)_localr,r'r*)rrr3setattr)r rrr6rr r r{s  "zLocal.__setattr__cCs8|}t||WddS1swYdSr&)r3delattrr5r r r rs  "zLocal.__delattr__)F) rrr r!boolr contextlibcontextmanagerr3rrrr#r r rr r$(s % r$) r.r;rr(typingrrrrr$r r r r s