관리-도구
편집 파일: registry.cpython-37.pyc
B ��4]� � @ s� d Z ddlmZ ddlZddlZddlZddlmZ ddlmZ e� e �Z e� e �Z dd� Z d d � Zd d � Zd d� Zdd� ZG dd� de�ZdS )aJ Provides managed registration services on behalf of :func:`.listen` arguments. By "managed registration", we mean that event listening functions and other objects can be added to various collections in such a way that their membership in all those collections can be revoked at once, based on an equivalent :class:`._EventKey`. � )�absolute_importN� )�exc)�utilc C sX t r | t krd S t �| �}x8|�� D ],}|tkr$t| }|�| � |s$t�|� q$W d S )N)�_collection_to_key�pop�values�_key_to_collection)�ref�listener_to_key�key� dispatch_reg� r �L/opt/alt/python37/lib64/python3.7/site-packages/sqlalchemy/event/registry.py�_collection_gced5 s r c C sH | j }t| }|j}t�| j�}||kr,dS |||< t| }|||< dS )NFT)�_keyr r �weakref� _listen_fnr )� event_key�ownerr r � owner_ref� listen_refr r r r �_stored_in_collectionC s r c C sT | j }t| }t�| j�}|j}|�|d � |s6t|= |tkrPt| }|�|� d S )N)r r r r r r r )r r r r r r r r r r �_removed_from_collectionV s r c C sz |sd S |j }| j } t| }t| }xP|D ]H}t� |�}|| }t| }| |krb|| |ksjt�n||| < |||< q*W d S )N)r r r r �AssertionError) ZnewownerZoldowner�elementsZold_listener_to_keyZnew_listener_to_key� listen_fnr r r r r r �_stored_in_collection_multig s r c C sX |sd S | j } t| }x<|D ]4}t� |�}|| }t| }|�| d � |s t|= q W d S )N)r r r r r )r r r r r r r r r r �_clear} s r c @ s� e Zd ZdZdZd dd�Zedd� �Zdd � Zd d � Z d d � Z dd� Z dd� Z d dd�Z edd� �Zdd� Zdd� Zdd � ZdS ) � _EventKeyz)Represent :func:`.listen` arguments. )�target� identifier�fn�fn_key�fn_wrap�dispatch_targetNc C sP || _ || _|| _t|tj�r6t|j�t|j�f| _ n t|�| _ || _ || _ d S )N) r r! r" � isinstance�types� MethodType�id�__func__�__self__r# r$ r% )�selfr r! r" r% �_fn_wrapr r r �__init__� s z_EventKey.__init__c C s t | j�| j| jfS )N)r) r r! r# )r, r r r r � s z_EventKey._keyc C s, || j kr| S t| j| j| j| j|d�S d S )N)r- )r r r r! r" r% )r, r$ r r r � with_wrapper� s z_EventKey.with_wrapperc C s, || j kr| S t| j| j| j|| jd�S d S )N)r- )r% r r r! r" r$ )r, r% r r r �with_dispatch_target� s z _EventKey.with_dispatch_targetc O s� |� dd�}|� dd�}| j| j| j }}}t|j|�}|�||�} | �| �} t| jjj| j�} t | d�rt| � � |r�| �t � | j��j ||� n| jjj| f|�|� d S )N�onceF�named�_sa_warn)r r% r! r �getattr�dispatchZ_adjust_fn_specr/ Z_events�hasattrr3 r Z only_once�listenZ_listen) r, �args�kwr1 r2 r r! r" �dispatch_collectionZ adjusted_fnZ stub_functionr r r r7 � s z_EventKey.listenc C sx | j }|tkr(t�d| j| j| jf ��t�|�}x@|�� D ]4\}}|� }|� }|d k r<|d k r<|� | � |�� q<W d S )Nz*No listeners found for event %s / %r / %s ) r r r ZInvalidRequestErrorr r! r" r �items�remover/ )r, r r Zcollection_refZ listener_refZ collectionZ listener_fnr r r r< � s z_EventKey.removec C s | j tkS )z?Return True if this event key is registered to listen. )r r )r, r r r �contains� s z_EventKey.containsFc C sL | j | j }}t|j|�}|r4|�|j��| |� n|�|j��| |� d S )N)r% r! r4 r5 Z for_modify�insert�append)r, � propagater> r2 �retvalr r! r: r r r � base_listen� s z_EventKey.base_listenc C s | j p | jS )N)r$ r" )r, r r r r s z_EventKey._listen_fnc C s" t | |�r|�| j� dS dS d S )NTF)r r? r )r, r �list_r r r �append_to_list s z_EventKey.append_to_listc C s t | |� |�| j� d S )N)r r< r )r, r rC r r r �remove_from_list s z_EventKey.remove_from_listc C s" t | |�r|�| j� dS dS d S )NTF)r � appendleftr )r, r rC r r r �prepend_to_list s z_EventKey.prepend_to_list)N)FFFN)�__name__� __module__� __qualname__�__doc__� __slots__r. �propertyr r/ r0 r7 r< r= rB r rD rE rG r r r r r � s r )rK � __future__r � collectionsr' r � r r � defaultdict�dictr r r r r r r �objectr r r r r �<module> s