OwlCyberSecurity - MANAGER
Edit File: local.cpython-39.pyc
a gH�f� � @ 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)� contextvars� ContextVar�_data��self� r �O/home/gouroczh/virtualenv/test/3.9/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 �set)r r r r �� __class__r r r s z_CVar.__setattr__)r r c C s> | j �i �}||v r(||= | j �|� nt| �d|����d S 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 rPz t�� W n ty, | jV Y q~0 t| jd�sDt� | j_| jjV n.| j� | jV W d � n1 st0 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 s(0 Y d S r& )r2 �getattr�r r �storager r r r t s zLocal.__getattr__c sN |dv rt � �||�S | �� � }t|||� W d � n1 s@0 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 s6 | � � �}t||� W d � n1 s(0 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