/
opt
/
alt
/
python27
/
lib64
/
python2.7
/
site-packages
/
sqlalchemy
/
event
/
up file
home
� 1��fc @� se d Z d d l m Z d d l m Z d d l Z d d l m Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d e j f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d S( s� 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. i ( t absolute_import( t with_statementN( t chaini ( t legacy( t registryi ( t exc( t util( t threading( t AsyncAdaptedLockt RefCollectionc B� s e Z d Z d � Z RS( t refc C� s t j | t j � S( N( t weakrefR R t _collection_gced( t self( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt _memoized_attr_ref2 s ( R ( t __name__t __module__t __slots__R ( ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR / s t _empty_collectionc B� s5 e Z d � Z d � Z d � Z d � Z d � Z RS( c C� s d S( N( ( R t element( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt append7 s c C� s d S( N( ( R t other( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt extend: s c C� s d S( N( ( R R ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt remove= s c C� s t g � S( N( t iter( R ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt __iter__@ s c C� s d S( N( ( R ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt clearC s ( R R R R R R R ( ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR 6 s t _ClsLevelDispatchc B� sn e Z d Z d Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s2 Class-level events on :class:`._Dispatch` classes.t clsnamet namet arg_namest has_kwt legacy_signaturest _clslevelt __weakref__c C� s� | j | _ | j | _ t j | � } | j d | _ t | j � | _ t t t t | d g � d d � �� � | _ t j | | | � | _ t j � | _ d S( Ni t _legacy_signaturest keyc S� s | d S( Ni ( ( t s( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt <lambda>] t ( R R R R t inspect_getfullargspect argsR t boolt varkwR t listt reversedt sortedt getattrR R t _augment_fn_docst __doc__R t WeakKeyDictionaryR! ( R t parent_dispatch_clst fnt argspec( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt __init__T s 'c C� sj | r | j | � } n | j rf y t j | d t �} Wn t k rM qf Xt j | | | � } n | S( Nt no_self( t _wrap_fn_for_kwR R t get_callable_argspect Truet TypeErrorR t _wrap_fn_for_legacy( R R4 t namedR5 ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt _adjust_fn_spece s c � s � � f d � } | S( Nc � s/ t t � j | � � } | j | � � | � S( N( t dictt zipR t update( R) t kwt argdict( R4 R ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt wrap_kwr s ( ( R R4 RD ( ( R4 R sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR8 q s c C� s� | j } t | t � s$ t d � � t | d t � sO t j d | f � � n x� t j | � D]� } | | k r� | | j k r� | j | � q_ | | j k r� | j | � n | r� | j | j | j � q_ | j | j | j � q_ Wt j | | � d S( Ns* Class-level Event targets must be classes.t _sa_propagate_class_eventss. Can't assign an event directly to the %s class( t dispatch_targett isinstancet typet AssertionErrorR/ R: R t InvalidRequestErrorR t walk_subclassesR! t update_subclassR t _listen_fnt appendleftR t _stored_in_collection( R t event_keyt is_appendt targett cls( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt _do_insert_or_appendy s c C� s | j | d t �d S( NRQ ( RT t False( R RP t propagate( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt insert� s c C� s | j | d t �d S( NRQ ( RT R: ( R RP RV ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR � s c C� s� | | j k rJ t | d t � r7 t j � | j | <qJ t � | j | <n | j | } xZ | j d D]K } | | j k re | j g | j | D] } | | k r� | ^ q� � qe qe Wd S( NRE i ( R! R/ R: t collectionst dequeR t __mro__R ( R RR t clslevelRS R4 ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRL � s c C� s` | j } x@ t j | � D]/ } | | j k r | j | j | j � q q Wt j | | � d S( N( RF R RK R! R RM R t _removed_from_collection( R RP RR RS ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR � s c C� sN t � } x. | j j � D] } | j | � | j � q Wt j | | � d S( s Clear all class level listenersN( t setR! t valuesRA R R t _clear( R t to_cleart dispatcher( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR � s c C� s | S( s� Return an event collection which can be modified. For _ClsLevelDispatch at the class level of a dispatcher, this returns self. ( ( R t obj( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt for_modify� s ( R R R R R R! R" ( R R R1 R R6 R> R8 RT RW R RL R R Rc ( ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR G s$ t _InstanceLevelDispatchc B� s e Z d Z d � Z RS( c C� s | j j | | � S( N( t parentR> ( R R4 R= ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR> � s ( ( R R R R> ( ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRd � s t _EmptyListenerc B� s� e Z d Z e � Z d Z d Z d � Z d � Z d � Z e Z Z Z Z Z Z d � Z d � Z d � Z d � Z e Z RS( s� 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. Re t parent_listenersR c C� sH | | j k r | j | � n | | _ | j | | _ | j | _ d S( N( R! RL Re Rg R ( R Re t target_cls( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR6 � s c C� sh t | j | j � } t | | j � | k rC t | | j | � n! t t | | j � t � sd t � | S( s� 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. ( t _ListenerCollectionRe t _instance_clsR/ R t setattrRG t _JoinedListenerRI ( R Rb t result( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRc � s !c O� s t d � � d S( Ns need to call for_modify()( t NotImplementedError( R R) RB ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt _needs_modify� s c O� s% x | j D] } | | | � q Wd S( s Execute this event.N( Rg ( R R) RB R4 ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt __call__� s c C� s t | j � S( N( t lenRg ( R ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt __len__� s c C� s t | j � S( N( R Rg ( R ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR � s c C� s t | j � S( N( R* Rg ( R ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt __bool__� s ( ( Re Rg R ( R R R1 t frozensetRV t listenersR R6 Rc Ro t exec_oncet exec_once_unless_exceptionRW R R R Rp Rr R Rs t __nonzero__( ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRf � s t _CompoundListenerc B� sw e Z d Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z e Z RS( t _exec_once_mutext _exec_oncet _exec_w_sync_oncet _is_asyncioc O� s& t t | � j | | � t | _ d S( N( t superRy R6 RU R} ( R t argRB ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR6 s c C� s t | _ d S( N( R: R} ( R ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt _set_asyncio s c C� s | j r t � St j � Sd S( N( R} R R t Lock( R ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt _memoized_attr__exec_once_mutex s c O� sl | j �] | j sb z. y | | | � t } Wn t } � n XWd | sR | r^ t | _ n Xn Wd QXd S( N( Rz R{ RU R: ( R t retry_on_exceptionR) RB t exception( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt _exec_once_impl s c O� s# | j s | j t | | � n d S( s] Execute this event, but only if it has not been executed already for this collection.N( R{ R� RU ( R R) RB ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRv ' s c O� s# | j s | j t | | � n d S( st 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 N( R{ R� R: ( R R) RB ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRw . s c O� sT | j sC | j �, y | | | � Wn � n Xt | _ Wd QXn | | | � d S( sn 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 N( R| Rz R: ( R R) RB ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt _exec_w_sync_on_first_run= s c O� sF x | j D] } | | | � q Wx | j D] } | | | � q+ Wd S( s Execute this event.N( Rg Ru ( R R) RB R4 ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRp T s c C� s t | j � t | j � S( N( Rq Rg Ru ( R ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRr \ s c C� s t | j | j � S( N( R Rg Ru ( R ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR _ s c C� s t | j p | j � S( N( R* Ru Rg ( R ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRs b s ( Rz R{ R| R} ( R R R R6 R� R� R� Rv Rw R� Rp Rr R Rs Rx ( ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRy s Ri c B� sV e Z d Z d Z d � Z d � Z e d � Z d � Z d � Z d � Z d � Z RS( s� 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. Rg Re R Ru RV R" c C� s� t t | � j � | | j k r2 | j | � n t | _ t | _ | j | | _ | | _ | j | _ t j � | _ t � | _ d S( N( R~ Ri R6 R! RL RU R{ R| Rg Re R RX RY Ru R] RV ( R Re Rh ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR6 { s c C� s | S( s� Return an event collection which can be modified. For _ListenerCollection at the instance level of a dispatcher, this returns self. ( ( R Rb ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRc � s c C� s� | j } t | � } | j j | j � g | j D]. } | | k rK | sZ | | j k r2 | ^ q2 } | j | � | j r� | j � n | j j | � } t j | | | � d S( sI Populate from the listeners in another :class:`_Dispatch` object.N( Ru R] RV RA R R} R� t unionR t _stored_in_collection_multi( R R t only_propagatet existing_listenerst existing_listener_sett lt other_listenerst to_associate( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt _update� s c C� s8 | j | | j � r4 | r4 | j j | j � q4 n d S( N( t prepend_to_listRu RV t addRM ( R RP RV ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRW � s c C� s8 | j | | j � r4 | r4 | j j | j � q4 n d S( N( t append_to_listRu RV R� RM ( R RP RV ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR � s c C� s: | j j | j � | j j | j � t j | | � d S( N( Ru R RM RV t discardR R\ ( R RP ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR � s c C� s1 t j | | j � | j j � | j j � d S( N( R R_ Ru RV R ( R ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR � s ( Rg Re R Ru RV R" ( R R R1 R R6 Rc R: R� RW R R R ( ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRi h s Rl c B� s\ e Z d Z d � Z e d � � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( Re R t localRg c C� s4 t | _ | | _ | | _ | | _ | j | _ d S( N( RU R{ Re R R� Rg ( R Re R R� ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR6 � s c C� s t | j | j � S( N( R/ Re R ( R ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRu � s c C� s | j j | | � S( N( R� R> ( R R4 R= ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR> � s c C� s | j j | � | _ | _ | S( N( R� Rc Rg ( R Rb ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRc � s c C� s | j j | | � d S( N( R� RW ( R RP RV ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRW � s c C� s | j j | | � d S( N( R� R ( R RP RV ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR � s c C� s | j j | � d S( N( R� R ( R RP ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR � s c C� s t � � d S( N( Rn ( R ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyR � s ( Re R R� Rg ( R R R R6 t propertyRu R> Rc RW R R R ( ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyRl � s ( R1 t __future__R R RX t itertoolsR R R' R R R R R t util.concurrencyR t MemoizedSlotsR t objectR R Rd Rf Ry Ri Rl ( ( ( sH /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/event/attr.pyt <module> s& x?cT