File manager - Edit - /usr/local/CyberCP/lib/python3.10/site-packages/asgiref/__pycache__/local.cpython-310.pyc
Back
o �h� � @ 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 �@/usr/local/CyberCP/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 �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 � __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 r+zt�� W n ty | jV Y d S w t| jd�s$t� | j_| jjV d S | j� | jV W d � d S 1 s>w Y d S )N�cvar) r' �asyncio�get_running_loop� RuntimeErrorr, �hasattrr r- r* r r r r � _lock_storageQ s � � "�zLocal._lock_storagec C s6 | � � � }t||�W d � S 1 sw Y d S r& )r2 �getattr�r r �storager r r r t 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 r2 �setattr)r r r r5 r r r r x s "�zLocal.__setattr__c C s8 | � � �}t||� W d � d S 1 sw Y d S r& )r2 �delattrr4 r r r r ~ s "�zLocal.__delattr__)F) r r r r! �boolr � contextlib�contextmanagerr2 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
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings