ó
‹EYc@@sµdZd
dl
mZ
d
dlZd
dlZd
dlZddlmZmZ
ej	e
ƒ
Zej	e
ƒ
Zd„Z
d„Zd„Zd	„Zd
„Zdef
d„ƒYZdS(
sJ
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`.

i(
tabsolute_importNi(texctutilc
C@s}ts|tkrdStj
|ƒ
}
xP|
jƒD]B}|tkr3t|}|j
|ƒ

|sutj
|ƒ

quq3q3WdS(
N(t_collection_to_keytpoptvaluest_key_to_collection(treftlistener_to_keytkeytdispatch_reg((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pyt_collection_gced3s








cC@s`|j}t
|}|
j}tj|jƒ
}||kr>tS|||<t|}|||<tS(
N(t_keyRRtweakreft
_listen_fntFalseRtTrue(t	event_keytownerR	R
t	owner_reft
listen_refR((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pyt_stored_in_collectionAs
	
	





cC@sx|j}t
|}tj|jƒ
}|
j}|j|dƒ
|sNt
|=n|tkrtt|}|j|ƒ

ndS(
N(RRR
RRRtNoneR(RRR	R
RRR((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pyt_removed_from_collectionTs
	
	






c	C@s¡|s
dS|
j}
|j}t
|
}t
|}xj|D]b}tj|ƒ
}||}t|}||kr…|||kst‚
n
|||<|||<q7WdS(
N(RRR
RtAssertionError(	tnewownertoldownertelementstold_listener_to_keytnew_listener_to_keyt	listen_fnRR	R
((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pyt_stored_in_collection_multies

	
	











cC@su|
s
dS|j}t
|}xQ|
D]I}tj|ƒ
}||}t|}|j|dƒ
|s$t|=q$q$WdS(
N(RRR
RRR(RRRRRR	R
((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pyt_clear{s

	










t	_EventKeycB@s˜eZ
dZdZdd„
Zed„ƒ
Zd	„Zd
„Z	d„Z
d„Zd
„Ze
e
e
d„Zed„ƒ
Zd„Zd„Zd„ZRS(s)Represent :func:`.listen` arguments.
    ttargett
identifiertfntfn_keytfn_wraptdispatch_targetcC@sv|
|_||_
||_t|tjƒrQt|jƒ
t|jƒ
f|_	nt|ƒ
|_	||_
||_dS(
N(R"R#R$t
isinstancettypest
MethodTypetidt__func__t__self__R%R&R'(tselfR"R#R$R't_fn_wrap((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pyt__init__“s	
	
	

$
	
c

C@st|j
ƒ
|j|jfS(
N(R+R"R#R%(
R.((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pyRŸscC@s<|
|jkr|St
|j|j|j|jd
|
ƒ
SdS(NR/(RR!R"R#R$R'(R.R&((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pytwith_wrapper£s





	
cC@s<|
|jkr|St
|j|j|j|
d
|jƒ
SdS(NR/(R'R!R"R#R$R&(R.R'((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pytwith_dispatch_target¯s






c

O@s¿|jd
t
ƒ}|jdt
ƒ}|j|j|j}}}t|j|ƒ}|j||ƒ}	|j|	ƒ
}|r¢|jt	j
|jƒ
ƒ
j|
|Ž
n|jjj||
|Ž

dS(Ntoncetnamed(
RRR'R#Rtgetattrtdispatcht_adjust_fn_specR1Rt	only_oncetlistent_listen(
R.targstkwR3R4R"R#R$tdispatch_collectiontadjusted_fn((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pyR9»s



"c
C@s°|j}
|
t
kr=tjd
|j|j|jfƒ
‚
nt
j|
ƒ
}x]|jƒD]O\}}|ƒ}|ƒ}|dk	rY|dk	rY|j
|j|ƒ
ƒ

qYqYWdS(Ns*No listeners found for event %s / %r / %s (RRR
tInvalidRequestErrorR"R#R$RtitemsRtremoveR1(R.R	R
tcollection_reftlistener_reft
collectiontlistener_fn((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pyRAÎs
	



	
	

c

C@s
|jt
kS(
s?Return True if this event key is registered to listen.
        (RR(
R.((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pytcontainsÞscC@st|j|j
|j}}}t|j|ƒ}|rT|j|jƒ
j||
ƒ
n|j|jƒ
j||
ƒ
dS(
N(R'R#RR5R6t
for_modifytinserttappend(R.t	propagateRHR4R"R#R$R=((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pytbase_listenãs


c

C@s|jp|j
S(
N(R&R$(
R.((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pyRòscC@s+t||
ƒr#|j
|jƒ

tStSdS(
N(RRIRRR(R.Rtlist_((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pytappend_to_listös


cC@s!t||
ƒ
|j
|jƒ

dS(
N(RRAR(R.RRL((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pytremove_from_listýs


cC@s+t||
ƒr#|j
|jƒ

tStSdS(
N(Rt
appendleftRRR(R.RRL((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pytprepend_to_list

s


(stargets
identifiersfnsfn_keysfn_wrapsdispatch_targetN(t__name__t
__module__t__doc__t	__slots__RR0tpropertyRR1R2R9RARFRRKRRMRNRP(((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pyR!‹s					
		(RSt
__future__RR
tcollectionsR)tR
RtdefaultdicttdictRRRRRRR tobjectR!(((sN/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/event/registry.pyt<module>s