ó
‹EYc@Às%
dZd
dl
mZmZ
ddlmZ
ddlmZ
ddlmZ
ddlmZ
d
d	l	m
Z

d
d
lZd
d
lZdej
f
d„ƒYZd
ef
d„ƒYZdef
d„ƒYZdef
d„ƒYZdef
d„ƒYZdef
d„ƒYZdef
d„ƒYZd
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(tabsolute_importtwith_statementi(
tutil(
t	threadingi
(
tregistry(
tlegacy(
tchainNt
RefCollectionc
BÀseZ
dZd
„ZRS(trefc

CÀstj
|tjƒS(
N(tweakrefRRt_collection_gced(
tself((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyt_memoized_attr_ref.s
(
sref(t__name__t
__module__t	__slots__R(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyR+s
t_ClsLevelDispatchcBÀseeZ
dZdZd„Zd„Zd	„Zd
„Zd„Zd„Z	d
„Z
d„Zd„ZRS(s2Class-level events on :class:`._Dispatch` classes.tnamet	arg_namesthas_kwtlegacy_signaturest	_clslevelt__weakref__cCÀs˜|j|_
tj|ƒ
}|jd
|_t|jƒ
|_t	t
tt|dgƒdd„ƒ

ƒ
ƒ
|_
tj||
|ƒ|_tjƒ|_dS(Ni
t_legacy_signaturestkeyc

SÀs|d
S(Ni((
t
s((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyt<lambda>@s(R
RRtinspect_getargspectargsRtbooltkeywordsRtlisttreversedtsortedtgetattrRRt_augment_fn_docst__doc__R	tWeakKeyDictionaryR(Rtparent_dispatch_clstfntargspec((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyt__init__8s







cCÀsj|r|j|
ƒ
}
n|j
rfytj|
d
tƒ

}Wntk
rM


qfXtj||
|ƒ}
n|
S(Ntno_self(t_wrap_fn_for_kwRRtget_callable_argspectTruet	TypeErrorRt_wrap_fn_for_legacy(RR'tnamedR(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyt_adjust_fn_specGs


	





cÀs‡‡
fd
†}|S(NcÀs/tt
ˆ
j|ƒƒ
}|j|
ƒ

ˆ|S(
N(tdicttzipRtupdate(Rtkwtargdict(R'R(sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pytwrap_kwTs



((RR'R7((R'RsJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyR+Ss
cCÀs×|
j}t
|tƒs$td
ƒ
‚
|g
}x“|rÂ|jdƒ
}|j|jƒƒ

||k	rƒ||jkrƒ|j|ƒ

q0||jkr¨t	j
ƒ|j|<n|j|j|
jƒ

q0Wt
j|
|ƒ
dS(Ns*Class-level Event targets must be classes.i(tdispatch_targett
isinstancettypetAssertionErrortpoptextendt__subclasses__Rtupdate_subclasstcollectionstdequet
appendleftt
_listen_fnRt_stored_in_collection(Rt	event_keyt	propagatettargettstacktcls((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pytinsertZs
	

	
	
	






cCÀs×|
j}t
|tƒs$td
ƒ
‚
|g
}x“|rÂ|jdƒ
}|j|jƒƒ

||k	rƒ||jkrƒ|j|ƒ

q0||jkr¨t	j
ƒ|j|<n|j|j|
jƒ

q0Wt
j|
|ƒ
dS(Ns*Class-level Event targets must be classes.i(R8R9R:R;R<R=R>RR?R@RAtappendRCRRD(RRERFRGRHRI((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRKjs
	

		
	






cCÀs“|
|jkr%t
jƒ|j|
<n|j|
}xZ|
jd
D]K}||jkr@|jg|j|D]}||kri|^qiƒ

q@q@WdS(Ni
(RR@RAt__mro__R=(RRGtclslevelRIR'((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyR?{s









cCÀs~|
j}|g
}xU|ri|j
d
ƒ
}|j|jƒƒ

||jkr|j|j|
jƒ

qqWtj|
|ƒ
dS(Ni(	R8R<R=R>RtremoveRCRt_removed_from_collection(RRERGRHRI((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRN‡s
	
	
	




c
CÀsNtƒ}
x.|j
jƒD]}|
j|ƒ

|jƒ
qWtj||
ƒ
d
S(sClear all class level listenersN(tsetRtvaluesR4tclearRt_clear(Rtto_cleart
dispatcher((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRR‘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.

        ((Rtobj((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyt
for_modifyšs(snames	arg_namesshas_kwslegacy_signaturess	_clslevels__weakref__(
R
RR$RR)R1R+RJRKR?RNRRRW(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyR2s

							
		t_InstanceLevelDispatchc
BÀseZ
d
Zd„ZRS(cCÀs|jj
|
|ƒS(
N(tparentR1(RR'R0((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyR1§s
((R
RRR1(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRX¤s
t_EmptyListenercBÀs~eZ
dZeƒZdZdZd„Zd„Zd„Z	e	Z
ZZZ
Zd„Zd„Zd	„Zd
„ZeZRS(
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.

    RYtparent_listenersRcCÀsH||
jkr|
j
|ƒ

n|
|_|
j||_|
j|_dS(
N(RR?RYR[R(RRYt
target_cls((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyR)ºs



	

cCÀsht|j
|
jƒ}t|
|jƒ|krCt|
|j|ƒ
n!tt|
|jƒtƒsdt‚
|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_ListenerCollectionRYt
_instance_clsR"RtsetattrR9t_JoinedListenerR;(RRVtresult((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRWÁs
	

!
c
OÀstd
ƒ
‚
dS(Nsneed to call for_modify()(
tNotImplementedError(RRR5((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyt
_needs_modifyÑs
c
OÀs%x|jD]}||
|Ž
q
Wd
S(sExecute this event.N(
R[(RRR5R'((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyt__call__Ös
c

CÀs
t|j
ƒ
S(
N(tlenR[(
R((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyt__len__Üs
c

CÀs
t|j
ƒ
S(
N(titerR[(
R((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyt__iter__ßs
c

CÀs
t|j
ƒ
S(
N(RR[(
R((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyt__bool__âs
((sparentsparent_listenerssname(R
RR$t	frozensetRFt	listenersRR)RWRct	exec_onceRJRKRNRRRdRfRhRit__nonzero__(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRZ«s	
							t_CompoundListenercBÀsJeZ
dZd„Zd„Zd„Zd„Zd„Zd„ZeZ	RS(	t_exec_once_mutext
_exec_oncec


CÀs
tj
ƒS(
N(RtLock(
R((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyt_memoized_attr__exec_once_mutexës
c
	OÀsJ|jsF|j
/
|js=z||
|Ž
Wd
t|_XnWd
QXnd
S(s]Execute this event, but only if it has not been
        executed already for this collection.N(RpRoR-(RRR5((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRlîs	


	

c
OÀsFx|jD]}||
|Ž
q
Wx|j
D]}||
|Ž
q+Wd
S(sExecute this event.N(R[Rk(RRR5R'((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRdús


c

CÀst|j
ƒ
t|jƒ
S(
N(ReR[Rk(
R((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRf
s
c

CÀst|j
|jƒS(
N(RR[Rk(
R((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRh
s
c

CÀst|j
p|jƒ
S(
N(RRkR[(
R((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRi
s
(s_exec_once_mutexs
_exec_once(
R
RRRrRlRdRfRhRiRm(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRnès
						R]cBÀsVeZ
dZdZd„Zd„Zed	„
Zd
„Zd„Z	d„Z
d
„ZRS(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.

    R[RYRRkRFRcCÀsl||
jkr|
j
|ƒ

nt|_|
j||_|
|_|
j|_tjƒ|_	t
ƒ|_dS(
N(RR?tFalseRpR[RYRR@RARkRPRF(RRYR\((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyR)
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.

        ((RRV((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRW&
scCÀsœ|j}t
|ƒ
}|jj|
jƒ

g|
jD].}||krK|sZ||jkr2|^q2}|j|ƒ

|
jj|ƒ
}tj||
|ƒ
d
S(sMPopulate from the listeners in another :class:`_Dispatch`
            object.N(RkRPRFR4R=tunionRt_stored_in_collection_multi(Rtothertonly_propagatetexisting_listenerstexisting_listener_sett
ltother_listenerstto_associate((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyt_update/
s	






"

cCÀs8|
j||j
ƒr4|r4|jj|
jƒ

q4ndS(
N(tprepend_to_listRkRFtaddRC(RRERF((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRJA
s


cCÀs8|
j||j
ƒr4|r4|jj|
jƒ

q4ndS(
N(tappend_to_listRkRFRRC(RRERF((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRKF
s


cCÀs:|jj
|
jƒ

|jj|
jƒ

tj|
|ƒ
dS(
N(RkRNRCRFtdiscardRRO(RRE((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRNK
s


c

CÀs1tj
||jƒ
|jjƒ
|jjƒ
dS(
N(RRSRkRFRR(
R((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRRP
s



(sparent_listenerssparentsnames	listenerss	propagates__weakref__(R
RR$RR)RWR-R}RJRKRNRR(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyR]
s
	
					R`cBÀs\eZ
dZd„Zed„ƒ
Zd„Zd„Zd„Zd	„Z	d
„Z
d„ZRS(
RYRtlocalR[cCÀs4t|_
|
|_||_||_|j|_dS(
N(RsRpRYRR‚R[(RRYRR‚((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyR)Y
s

	
	
	
	
c

CÀst|j
|jƒS(
N(R"RYR(
R((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRk`
scCÀs|jj
|
|ƒS(
N(R‚R1(RR'R0((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyR1d
s
cCÀs |jj
|
ƒ
|_|_|S(
N(R‚RWR[(RRV((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRWg
s

cCÀs|jj
|
|ƒ
dS(
N(R‚RJ(RRERF((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRJk
s
cCÀs|jj
|
|ƒ
dS(
N(R‚RK(RRERF((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRKn
s
cCÀs|jj
|
ƒ

dS(
N(R‚RN(RRE((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRNq
s
c


CÀs
tƒ‚
dS(
N(
Rb(
R((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyRRt
s
(sparentsnameslocalsparent_listeners(R
RRR)tpropertyRkR1RWRJRKRNRR(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyR`V
s
						(R$t
__future__RR
tRRRRt	itertoolsRR	R@t
MemoizedSlotsRRRXRZRnR]R`(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/attr.pyt<module>s





r=&H