o z,h@sTddlZddlZddlZddlZddlmZmZmZGdddZGdddZ dS)N)AnyDictUnioncsReZdZdZdddZddZded eddffd d Zdeddfd d Z Z S)_CVarzStorage utility for Local.returnNcCstd|_dS)Nz asgiref.local) contextvars ContextVar_dataselfr C/var/www/html/rh/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 rset)r rrr __class__r r rs  z_CVar.__setattr__cCs<|ji}||vr||=|j|dSt|d|r)r rrrrr r r __delattr__s z_CVar.__delattr__)rN) __name__ __module__ __qualname____doc__rrstrrrr __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 rDs   zLocal.__init__ccs|jr+ztWnty|jVYdSwt|jds$t|j_|jjVdS|j |jVWddS1s>wYdS)Ncvar) r'asyncioget_running_loop RuntimeErrorr,hasattrrr-r*r r r r _lock_storageQs    "zLocal._lock_storagecCs6| }t||WdS1swYdSr&)r2getattrr rstorager r r rts $zLocal.__getattr__csP|dvr t||S|}t|||WddS1s!wYdS)N)_localr,r'r*)rrr2setattr)r rrr5rr r rxs  "zLocal.__setattr__cCs8|}t||WddS1swYdSr&)r2delattrr4r r r r~s  "zLocal.__delattr__)F) rrr r!boolr contextlibcontextmanagerr2rrrr#r r rr r$(s " r$) r.r:rr(typingrrrrr$r r r r s