/usr/local/lib/python3.9/site-packages/asgiref/__pycache__
a Ұ�h0 � @ sT d dl Z d dlZd dlZd dlZd dlmZmZmZ G dd� d�ZG dd� d�Z dS )� N)�Any�Dict�Unionc sP e Zd ZdZdd�dd�Zdd� Zeedd�� fd d � Zedd �d d �Z � Z S )�_CVarzStorage utility for Local.N)�returnc C s t �d�| _d S )Nz asgiref.local)� contextvarsZ ContextVar�_data)�self� r �7/usr/local/lib/python3.9/site-packages/asgiref/local.py�__init__ s �z_CVar.__init__c C s@ | j �i �}z || W S ty: t| �d|����Y n0 d S �Nz object has no attribute )r �get�KeyError�AttributeError�r �key�storage_objectr r r � __getattr__ s z_CVar.__getattr__)r �valuer c s> |dkrt � �||�S | j�i ��� }|||< | j�|� d S )Nr )�super� __setattr__r r �copy�set)r r r r �� __class__r r r s z_CVar.__setattr__)r r c C sB | j �i ��� }||v r,||= | j �|� nt| �d|����d S r )r r r r r r r r r � __delattr__ s z_CVar.__delattr__) �__name__� __module__� __qualname__�__doc__r r �strr r r � __classcell__r r r r r s r c sP e Zd ZdZdedd�dd�Zejdd� �Zd d � Z � fd d �Z d d� Z � Z S )�Locala Local 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. FN)�thread_criticalr c C s0 || _ t�� | _| |r$t�� | _nt� | _d S �N)�_thread_critical� threading�RLock� _thread_lock�local�_storager )r r$ r r r r D s zLocal.__init__c c s� | j r^d}z t�� W n ty, d}Y n0 |s<| jV q�t| jd�sRt� | j_| jjV n.| j� | jV W d � n1 s�0 Y d S )NTF�cvar) r& �asyncioZget_running_loop� RuntimeErrorr+ �hasattrr r, r) )r �is_asyncr r r � _lock_storageQ s zLocal._lock_storagec C s6 | � � �}t||�W d � S 1 s(0 Y d S r% )r1 �getattr�r r �storager r r r w s zLocal.__getattr__c sN |dv rt � �||�S | �� � }t|||� W d � n1 s@0 Y d S )N)�_localr+ r& r) )r r r1 �setattr)r r r r4 r r r r { s zLocal.__setattr__c C s6 | � � �}t||� W d � n1 s(0 Y d S r% )r1 �delattrr3 r r r r � s zLocal.__delattr__)F) r r r r �boolr � contextlib�contextmanagerr1 r r r r" r r r r r# ( s % r# ) r- r9 r r' �typingr r r r r# r r r r �<module> s
.
Edit
..
Edit
__init__.cpython-39.pyc
Edit
compatibility.cpython-39.pyc
Edit
current_thread_executor.cpython-39.pyc
Edit
local.cpython-39.pyc
Edit
server.cpython-39.pyc
Edit
sync.cpython-39.pyc
Edit
testing.cpython-39.pyc
Edit
timeout.cpython-39.pyc
Edit
typing.cpython-39.pyc
Edit
wsgi.cpython-39.pyc
Edit