U
|
¸ý°dWR ã @ s d Z ddlmZ ddlZddlmZ ddlZddlmZ ddl Z ddl m
|
Z
|
ddl m Z ddl m Z dd l m Z dd
|
l mZ dd l mZ dd l mZ dd l mZ ddl mZ ddl mZ ddl mZ ddl mZ ddl mZ ddl mZ ddl mZ ddl mZ ddl mZ ddlZddl m Z ddl m Z ddl m Z ddl m Z dd l m!Z! d d l m"Z" d d l m#Z# d d l$m%Z% d d!l&m'Z' ed"e
|
d#Z(e j)r¸dd$l*m+Z+ dd%l*m,Z, dd&l*m-Z- G d'd( d(e#j.ee Z/G d)d* d*e e( Z0ee e( e0e( f Z1G d+d, d,e/e Z2G d-d. d.e/e e e! Z3G d/d0 d0e3e Z4G d1d2 d2e'Z5G d3d4 d4e3e Z6G d5d6 d6e6e Z7G d7d8 d8e6e Z8dS )9a Attribute implementation for _Dispatch classes.
|
|
The various listener targets for a particular event class are represented
|
as attributes, which refer to collections of listeners to be fired off.
|
These collections can exist at the class level as well as at the instance
|
level. An event is fired off using code like this::
|
|
some_object.dispatch.first_connect(arg1, arg2)
|
|
Above, ``some_object.dispatch`` would be an instance of ``_Dispatch`` and
|
``first_connect`` is typically an instance of ``_ListenerCollection``
|
if event listeners are present, or ``_EmptyListener`` if none are present.
|
|
The attribute mechanics here spend effort trying to ensure listener functions
|
are available with a minimum of function call overhead, that unnecessary
|
objects aren't created (i.e. many empty per-instance listener collections),
|
as well as that everything is garbage collectable when owning references are
|
lost. Other features such as "propagation" of listener functions across
|
many ``_Dispatch`` instances, "joining" of multiple ``_Dispatch`` instances,
|
as well as support for subclass propagation (e.g. events assigned to
|
``Pool`` vs. ``QueuePool``) are all implemented here.
|
|
é )Ú annotationsN)Úchain)Ú TracebackType)ÚAny)Úcast)Ú
|
Collection)ÚDeque)Ú FrozenSet)ÚGeneric)ÚIterator)ÚMutableMapping)ÚMutableSequence)ÚNoReturn)ÚOptional)ÚSequence)ÚSet)ÚTuple)ÚType)ÚTypeVar)ÚUnioné )Úlegacy)Úregistry)Ú_ET)Ú _EventKey)Ú_ListenerFnTypeé )Úexc)Úutil)ÚAsyncAdaptedLock)ÚProtocolÚ_T)Úbound)Ú _Dispatch)Ú_DispatchCommon)Ú_HasEventsDispatchc @ s( e Zd ZU dZded< ddddZdS )Ú RefCollection)Úrefz weakref.ref[RefCollection[_ET]]r' ©Úreturnc C s t | tj¡S ©N)Úweakrefr' r Z_collection_gced©Úself© r. úLd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/event/attr.pyÚ_memoized_attr_refP s z RefCollection._memoized_attr_refN)Ú__name__Ú
|
__module__Ú __qualname__Ú __slots__Ú__annotations__r0 r. r. r. r/ r& K s
|
r& c @ s e Zd ZdddddZdddddZddd d
|
d Zdddd d ZdddddZddddZddddZ ddddZ
|
dS ) Ú_empty_collectionr! ÚNone)Úelementr) c C s d S r* r. ©r- r8 r. r. r/ ÚappendU s z_empty_collection.appendc C s d S r* r. r9 r. r. r/ Ú
|
appendleftX s z _empty_collection.appendleftz Sequence[_T])Úotherr) c C s d S r* r. )r- r< r. r. r/ Úextend[ s z_empty_collection.extendc C s d S r* r. r9 r. r. r/ Úremove^ s z_empty_collection.remover Úboolc C s dS ©NFr. r9 r. r. r/ Ú __contains__a s z _empty_collection.__contains__z Iterator[_T]r( c C s t g S r* )Úiterr, r. r. r/ Ú__iter__d s z_empty_collection.__iter__c C s d S r* r. r, r. r. r/ Úclearg s z_empty_collection.clearÚintc C s dS ©Nr r. r, r. r. r/ Ú__len__j s z_empty_collection.__len__N) r1 r2 r3 r: r; r= r> rA rC rD rG r. r. r. r/ r6 T s r6 c @ sì e Zd ZU dZdZded< ded< ded< ded < d
|
ed < d ed < dddddZddddddZdddddZddddd d Z dddd d d Z
|
dddd d!d"Z d#dd$d%d&Z ddd'd(d)Z dd*d+d,Zd-d.d/d0d1Zd2S )3Ú_ClsLevelDispatchz2Class-level events on :class:`._Dispatch` classes.)ÚclsnameÚnameÚ arg_namesÚhas_kwÚlegacy_signaturesÚ _clslevelÚ __weakref__ÚstrrI rJ z Sequence[str]rK r? rL z,MutableSequence[legacy._LegacySignatureType]rM zCMutableMapping[Type[_ET], _ListenerFnSequenceType[_ListenerFnType]]rN z Type[_HasEventsDispatch[_ET]]r )Úparent_dispatch_clsÚfnc C sv |j | _|j | _t |¡}|jdd
| _t|j| _ t
|
t t t |dg dd d| _t | ||¡|_t ¡ | _d S )Nr Z_legacy_signaturesc S s | d S rF r. )Úsr. r. r/ Ú<lambda> ó z,_ClsLevelDispatch.__init__.<locals>.<lambda>)Úkey)r1 rJ rI r Zinspect_getfullargspecÚargsrK r? ÚvarkwrL ÚlistÚreversedÚsortedÚgetattrrM r Z_augment_fn_docsÚ__doc__r+ ÚWeakKeyDictionaryrN )r- rQ rR Úargspecr. r. r/ Ú__init__ s
|
|
ÿÿÿz_ClsLevelDispatch.__init__©rR Únamedr) c C sN |r| |¡}| jrJztj|dd}W n tk
|
r: Y nX t | ||¡}|S )NT)Zno_self)Ú_wrap_fn_for_kwrM r Zget_callable_argspecÚ TypeErrorr Z_wrap_fn_for_legacy)r- rR rb r_ r. r. r/ Ú_adjust_fn_spec s
|
z!_ClsLevelDispatch._adjust_fn_spec)rR r) c s dddd fdd }|S )Nr ©rW Úkwr) c s$ t tj| }| |¡ f |S r* )ÚdictÚziprK Úupdate)rW rg Zargdict©rR r- r. r/ Úwrap_kw« s
|
z2_ClsLevelDispatch._wrap_fn_for_kw.<locals>.wrap_kwr. )r- rR rl r. rk r/ rc ª s z!_ClsLevelDispatch._wrap_fn_for_kwú_EventKey[_ET]r7 )Ú event_keyÚ is_appendr) c C s² |j }t|tstdt|dds6t d| d¡t |¡D ]`}||k rb|| j krb|
|
|¡ q@|| j krv|
|
|¡ |r| j | |j ¡ q@| j | |j ¡ q@t || ¡ d S )Nz*Class-level Event targets must be classes.Ú_sa_propagate_class_eventsTz&Can't assign an event directly to the z class)Údispatch_targetÚ
|
isinstanceÚtypeÚAssertionErrorr\ r ZInvalidRequestErrorr Úwalk_subclassesrN Úupdate_subclassr: Ú
|
_listen_fnr; r Z_stored_in_collection)r- rn ro ÚtargetÚclsr. r. r/ Ú_do_insert_or_append² s( ÿþ
|
ÿ
|
|
z&_ClsLevelDispatch._do_insert_or_append©rn Ú propagater) c C s | j |dd d S )NF©ro ©rz ©r- rn r| r. r. r/ ÚinsertÌ s z_ClsLevelDispatch.insertc C s | j |dd d S )NTr} r~ r r. r. r/ r: Ï s z_ClsLevelDispatch.appendú Type[_ET])rx r) c s| || j kr2t|ddr&t ¡ | j |< n t | j |< | j | |jdd
D ],}|| j krJ fdd| j | D ¡ qJd S )Nrp Tr c s g | ]}| kr|qS r. r. )Ú.0rR ©Zclslevelr. r/ Ú
|
<listcomp>Þ s z5_ClsLevelDispatch.update_subclass.<locals>.<listcomp>)rN r\ Ú collectionsÚdequer6 Ú__mro__r= )r- rx ry r. r r/ rv Ò s
|
|
|
ÿz!_ClsLevelDispatch.update_subclass©rn r) c C sB |j }t |¡D ] }|| jkr| j| |j¡ qt || ¡ d S r* )rq r ru rN r> rw r Ú_removed_from_collection)r- rn rx ry r. r. r/ r> á s
|
|
z_ClsLevelDispatch.remover( c C s8 t }| j ¡ D ]}| |¡ | ¡ qt | |¡ dS )z Clear all class level listenersN)ÚsetrN Úvaluesrj rD r Ú_clear)r- Zto_clearÚ
|
dispatcherr. r. r/ rD é s
|
|
|
z_ClsLevelDispatch.clearú_Dispatch[_ET]ú_ClsLevelDispatch[_ET]©Úobjr) c C s | S ©zReturn an event collection which can be modified.
|
|
For _ClsLevelDispatch at the class level of
|
a dispatcher, this returns self.
|
|
r. ©r- r r. r. r/ Ú
|
for_modifyò s z _ClsLevelDispatch.for_modifyN)r1 r2 r3 r] r4 r5 r` re rc rz r r: rv r> rD r r. r. r. r/ rH q s$
|
|
rH c @ sò e Zd ZU dZded< ddddddZd dd
|
d d Zd dddZddddZddddZ d d ddddZ
|
d d ddddZ d d ddd d Z d d ddd d Z d ddd!d"d#Zd ddd!d$d%Zd dd&d'd(Zd)d*d+d,d-Zd.S )/Ú_InstanceLevelDispatchr. r Úparentr r? ra c C s | j ||¡S r* )r re ©r- rR rb r. r. r/ re s z&_InstanceLevelDispatch._adjust_fn_specr ©Úitemr) c C s
|
t d S r* ©ÚNotImplementedError©r- r r. r. r/ rA s z#_InstanceLevelDispatch.__contains__rE r( c C s
|
t d S r* r r, r. r. r/ rG s z _InstanceLevelDispatch.__len__úIterator[_ListenerFnType]c C s
|
t d S r* r r, r. r. r/ rC s z _InstanceLevelDispatch.__iter__c C s
|
t d S r* r r, r. r. r/ Ú__bool__ s z _InstanceLevelDispatch.__bool__r7 rf c O s
|
t d S r* r ©r- rW rg r. r. r/ Ú exec_once s z _InstanceLevelDispatch.exec_oncec O s
|
t d S r* r r r. r. r/ Úexec_once_unless_exception s z1_InstanceLevelDispatch.exec_once_unless_exceptionc O s
|
t d S r* r r r. r. r/ Ú_exec_w_sync_on_first_run s z0_InstanceLevelDispatch._exec_w_sync_on_first_runc O s
|
t d S r* r r r. r. r/ Ú__call__ s z _InstanceLevelDispatch.__call__rm r{ c C s
|
t d S r* r r r. r. r/ r s z _InstanceLevelDispatch.insertc C s
|
t d S r* r r r. r. r/ r: ! s z _InstanceLevelDispatch.appendr c C s
|
t d S r* r ©r- rn r. r. r/ r> $ s z _InstanceLevelDispatch.removeú_DispatchCommon[_ET]ú_InstanceLevelDispatch[_ET]r c C s | S r r. r r. r. r/ r ' s z!_InstanceLevelDispatch.for_modifyN)r1 r2 r3 r4 r5 re rA rG rC r r r¡ r¢ r£ r r: r> r r. r. r. r/ r ü s
|
r c @ s2 e Zd ZU dZdZe Zded< dZded< ded < d
|
ed < d ed < dddddZ dddddZ
|
ddddddZ ddddd d Z ddddd d Z ddddd d!Zddddd"d#Zddddd$d%Zddddd&d'Zddd(dd)d*Zdd+d,d-d.Zd/d0d1d2Zd3d0d4d5Zd+d0d6d7Zd8S )9Ú_EmptyListenerzÙServes as a proxy interface to the events
|
served by a _ClsLevelDispatch, when there are no
|
instance-level events present.
|
|
Is replaced by _ListenerCollection when instance-level
|
events are added.
|
|
)r Úparent_listenersrJ zFrozenSet[_ListenerFnType]r| r. z Tuple[()]Ú listenersr r z(_ListenerFnSequenceType[_ListenerFnType]r¨ rP rJ r ©r Ú
|
target_clsc C s2 ||j kr| |¡ || _|j | | _|j| _d S r* )rN rv r r¨ rJ ©r- r r« r. r. r/ r` E s
|
|
|
z_EmptyListener.__init__r¥ ú_ListenerCollection[_ET]r c C s` t d|}|jdk stt| j|j}t|| j| krFt|| j| ntt|| jt s\t|S )zìReturn an event collection which can be modified.
|
|
For _EmptyListener at the instance level of
|
a dispatcher, this generates a new
|
_ListenerCollection, applies it to the instance,
|
and returns it.
|
|
r N)
|
r Z _instance_clsrt Ú_ListenerCollectionr r\ rJ Úsetattrrr Ú_JoinedListener)r- r Úresultr. r. r/ r L s
|
z_EmptyListener.for_modifyr r rf c O s t dd S )Nzneed to call for_modify()r r r. r. r/ Ú _needs_modifya s z _EmptyListener._needs_modifyc O s | j || d S r* ©r² r r. r. r/ r d s z_EmptyListener.exec_oncec O s | j || d S r* r³ r r. r. r/ r¡ g s z)_EmptyListener.exec_once_unless_exceptionc O s | j || d S r* r³ r r. r. r/ r j s z_EmptyListener.insertc O s | j || d S r* r³ r r. r. r/ r: m s z_EmptyListener.appendc O s | j || d S r* r³ r r. r. r/ r> p s z_EmptyListener.removec O s | j || d S r* r³ r r. r. r/ rD s s z_EmptyListener.clearr7 c O s | j D ]}||| qdS ©zExecute this event.N©r¨ ©r- rW rg rR r. r. r/ r£ v s
|
z_EmptyListener.__call__r? r c C s
|
|| j kS r* rµ r r. r. r/ rA | s z_EmptyListener.__contains__rE r( c C s
|
t | jS r* )Úlenr¨ r, r. r. r/ rG s z_EmptyListener.__len__r c C s
|
t | jS r* )rB r¨ r, r. r. r/ rC s z_EmptyListener.__iter__c C s
|
t | jS r* )r? r¨ r, r. r. r/ r
s z_EmptyListener.__bool__N)r1 r2 r3 r] r4 Ú frozensetr| r5 r© r` r r² r r¡ r r: r> rD r£ rA rG rC r r. r. r. r/ r§ 3 s*
|
r§ c @ s. e Zd ZddddZddddd d
|
d Zd S ) Ú_MutexProtocolr? r( c C s d S r* r. r, r. r. r/ Ú __enter__ s z_MutexProtocol.__enter__z Optional[Type[BaseException]]zOptional[BaseException]zOptional[TracebackType]zOptional[bool])Úexc_typeÚexc_valÚexc_tbr) c C s d S r* r. )r- r» r¼ r½ r. r. r/ Ú__exit__ s z_MutexProtocol.__exit__N)r1 r2 r3 rº r¾ r. r. r. r/ r¹ s r¹ c @ sì e Zd ZU dZded< ded< ded< ded< ded < d
|
d d d Zdd ddZdddd
|
dddZddd
|
dddZddd
|
dddZ ddd
|
dddZ
|
ddd
|
ddd Z ddd d d Z d d d!d"Z d#d d$d%Zdd d&d'Zd(S ))Ú_CompoundListener)Ú_exec_once_mutexÚ
|
_exec_onceÚ_exec_w_sync_oncer¹ rÀ úCollection[_ListenerFnType]r¨ r© r? rÁ r r7 r( c C s t | _d S r* )r rÀ r, r. r. r/ Ú _set_asyncio s z _CompoundListener._set_asyncioc C s t ¡ S r* )Ú threadingÚLockr, r. r. r/ Ú _memoized_attr__exec_once_mutex¢ s z1_CompoundListener._memoized_attr__exec_once_mutexr )Úretry_on_exceptionrW rg r) c O sX | j H | jsJz*z| || d}W n d} Y nX W 5 |rB|sHd| _X W 5 Q R X d S )NTF)rÀ rÁ )r- rÈ rW rg Ú exceptionr. r. r/ Ú_exec_once_impl¥ s
|
z!_CompoundListener._exec_once_implrf c O s | j s| jd|| dS )z]Execute this event, but only if it has not been
|
executed already for this collection.FN)F©rÁ rÊ r r. r. r/ r ´ s z_CompoundListener.exec_oncec O s | j s| jd|| dS )at Execute this event, but only if it has not been
|
executed already for this collection, or was called
|
by a previous exec_once_unless_exception call and
|
raised an exception.
|
|
If exec_once was already called, then this method will never run
|
the callable regardless of whether it raised or not.
|
|
.. versionadded:: 1.3.8
|
|
TN)TrË r r. r. r/ r¡ » s z,_CompoundListener.exec_once_unless_exceptionc O sL | j s>| j* z| || W n Y nX d| _ W 5 Q R X n
|
| || dS )an Execute this event, and use a mutex if it has not been
|
executed already for this collection, or was called
|
by a previous _exec_w_sync_on_first_run call and
|
raised an exception.
|
|
If _exec_w_sync_on_first_run was already called and didn't raise an
|
exception, then a mutex is not used.
|
|
.. versionadded:: 1.4.11
|
|
TN)r rÀ r r. r. r/ r¢ Ê s z+_CompoundListener._exec_w_sync_on_first_runc O s0 | j D ]}||| q| jD ]}||| q dS r´ ©r¨ r© r¶ r. r. r/ r£ á s
|
|
z_CompoundListener.__call__r c C s || j kp|| jkS r* rÌ r r. r. r/ rA é s z _CompoundListener.__contains__rE c C s t | jt | j S r* )r· r¨ r© r, r. r. r/ rG ì s z_CompoundListener.__len__r c C s t | j| jS r* )r r¨ r© r, r. r. r/ rC ï s z_CompoundListener.__iter__c C s t | jp | jS r* )r? r© r¨ r, r. r. r/ r ò s z_CompoundListener.__bool__N)r1 r2 r3 r4 r5 rÄ rÇ rÊ r r¡ r¢ r£ rA rG rC r r. r. r. r/ r¿ s"
|
r¿ c @ s´ e Zd ZU dZdZded< ded< ded< d ed
|
< d ed < dd dddZdddddZd)ddddddZd ddd d d Z d ddd d d!Z
|
d dd"d#d$Z dd%d&d'Z d(S )*r® zÛInstance-level attributes on instances of :class:`._Dispatch`.
|
|
Represents a collection of listeners.
|
|
As of 0.7.9, _ListenerCollection is only first
|
created via the _EmptyListener.for_modify() method.
|
|
)r¨ r rJ r© r| rO rà r¨ r r rP rJ zDeque[_ListenerFnType]r© zSet[_ListenerFnType]r| r rª c C sP ||j kr| |¡ d| _d| _|j | | _|| _|j| _t ¡ | _ t
|
| _ d S r@ ) rN rv rÁ r r¨ r rJ r
r r© r r| r¬ r. r. r/ r` s
|
|
|
z _ListenerCollection.__init__r¥ r r c C s | S )zReturn an event collection which can be modified.
|
|
For _ListenerCollection at the instance level of
|
a dispatcher, this returns self.
|
|
r. r r. r. r/ r s z _ListenerCollection.for_modifyTr? r7 )r< Úonly_propagater) c s\ j }t| j |j¡ fdd|j D }| |¡ |j |¡}t ||¡ dS )zIPopulate from the listeners in another :class:`_Dispatch`
|
object.c s& g | ] }| krr |j kr|qS r. )r| )r Úl©Zexisting_listener_setrÍ r- r. r/ r - s
|
|
üz/_ListenerCollection._update.<locals>.<listcomp>N)r© r r| rj r= Úunionr Z_stored_in_collection_multi)r- r< rÍ Zexisting_listenersZother_listenersZ to_associater. rÏ r/ Ú_update% s þ
|
z_ListenerCollection._updaterm r{ c C s$ | | | j¡r |r | j |j¡ d S r* )Zprepend_to_listr© r| Úaddrw r r. r. r/ r : s z_ListenerCollection.insertc C s$ | | | j¡r |r | j |j¡ d S r* )Zappend_to_listr© r| rÒ rw r r. r. r/ r: ? s z_ListenerCollection.appendr c C s, | j |j¡ | j |j¡ t || ¡ d S r* )r© r> rw r| Údiscardr r r¤ r. r. r/ r> D s z_ListenerCollection.remover( c C s& t | | j¡ | j ¡ | j ¡ d S r* )r r r© r| rD r, r. r. r/ rD I s
|
z_ListenerCollection.clearN)T) r1 r2 r3 r] r4 r5 r` r rÑ r r: r> rD r. r. r. r/ r® ö s
|
ÿr® c @ sÀ e Zd ZU dZded< ded< ded< ded < ddd
|
d d d ZejsXeddddZ ddddddZ
|
dddddZ dddd d d Z dddd d d Z ddd!d"d#Zddd$d%Zd&S )'r° )Úparent_dispatchrJ Úlocalr¨ r¥ rÔ rP rJ r¦ rÕ rà r¨ z_EmptyListener[_ET])rÔ rJ rÕ c C s$ d| _ || _|| _|| _| j| _d S r@ )rÁ rÔ rJ rÕ r¨ )r- rÔ rJ rÕ r. r. r/ r` W s
|
z_JoinedListener.__init__r( c C s t | j| jS r* )r\ rÔ rJ r, r. r. r/ r© j s z_JoinedListener.listenersr r? ra c C s | j ||¡S r* )rÕ re r r. r. r/ re n s z _JoinedListener._adjust_fn_specz_JoinedListener[_ET]r c C s | j |¡ | _ | _| S r* )rÕ r r¨ r r. r. r/ r s s z_JoinedListener.for_modifyrm r7 r{ c C s | j ||¡ d S r* )rÕ r r r. r. r/ r w s z_JoinedListener.insertc C s | j ||¡ d S r* )rÕ r: r r. r. r/ r: z s z_JoinedListener.appendr c C s | j |¡ d S r* )rÕ r> r¤ r. r. r/ r> } s z_JoinedListener.removec C s
|
t d S r* r r, r. r. r/ rD s z_JoinedListener.clearN)r1 r2 r3 r4 r5 r` ÚtypingÚ TYPE_CHECKINGÚpropertyr© re r r r: r> rD r. r. r. r/ r° O s
|
r° )9r] Ú
|
__future__r r
Ú itertoolsr rÅ Útypesr rÖ r r r r r r
|
r r r r r r r r r r r r+ Ú r r r r r r r Zutil.concurrencyr Z util.typingr r! r× Úbaser# r$ r% Z MemoizedSlotsr& r6 Z_ListenerFnSequenceTyperH r r§ r¹ r¿ r® r° r. r. r. r/ Ú<module> sb 7V `Y
|
