File: //usr/local/CyberPanel/lib64/python3.10/site-packages/asgiref/__pycache__/local.cpython-310.pyc
o
��h0 � @ sT d dl Z d dlZd dlZd dlZd dlmZmZmZ G dd� d�ZG dd� d�Z dS )� N)�Any�Dict�Unionc sR e Zd ZdZddd�Zdd� Zded eddf� fd
d � Zdeddfd d
�Z � Z
S )�_CVarzStorage utility for Local.�returnNc C s t �d�| _d S )Nz
asgiref.local)� contextvars�
ContextVar�_data)�self� r �C/usr/local/CyberPanel/lib/python3.10/site-packages/asgiref/local.py�__init__ s
�z_CVar.__init__c C s8 | j �i �}z|| W S ty t| �d|����w �Nz object has no attribute )r �get�KeyError�AttributeError�r
�key�storage_objectr r r � __getattr__ s
�z_CVar.__getattr__r �valuec s> |dkr t � �||�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__c C s@ | j �i ��� }||v r||= | j �|� d S t| �d|����r )r r r r r r r r r � __delattr__ s
z_CVar.__delattr__)r N) �__name__�
__module__� __qualname__�__doc__r
r �strr r r �
__classcell__r r r r r s
r c sR e Zd ZdZddeddfdd�Zejdd � �Zd
d � Z � fd d
�Z
dd� 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.
F�thread_criticalr Nc C s2 || _ t�� | _| |rt�� | _d S t� | _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 r2d}zt�� W n ty d}Y nw |s | jV d S t| jd�s+t� | j_| jjV d S | j�
| jV W d � d S 1 sEw Y d S )NTF�cvar) r' �asyncio�get_running_loop� RuntimeErrorr, �hasattrr r- r* )r
�is_asyncr r r �
_lock_storageQ s � �
"�zLocal._lock_storagec C s6 | � � �
}t||�W d � S 1 sw Y d S r& )r3 �getattr�r
r �storager r r r w s
$�zLocal.__getattr__c sP |dv r t � �||�S | �� �}t|||� W d � d S 1 s!w Y d S )N)�_localr, r' r* )r r r3 �setattr)r
r r r6 r r r r { s
"�zLocal.__setattr__c C s8 | � � �}t||� W d � d S 1 sw Y d S r& )r3 �delattrr5 r r r r � s
"�zLocal.__delattr__)F)
r r r r! �boolr
�
contextlib�contextmanagerr3 r r r r# r r r r r$ ( s
% r$ )
r. r; r r( �typingr r r r r$ r r r r �<module> s