ó
….ëac@sÜdd
lZdd
l
Z
ddlmZ
dd
lZddlmZ
ddlmZ
ddl	m
Z

ddlmZ
ddlmZ
ej
jZd„Zejd	„ƒ
Zd
„Zd
d
d
d„Zd„Zd
„Zd
S(iÿÿÿÿN(
texcutils(
tbase(
t	exception(
tfields(
trpc(
t
safe_utilscCs*t||
|||ƒ
t
|
||ƒ
dS(
N(t#_emit_legacy_exception_notificationt&_emit_versioned_exception_notification(tnotifiertcontexttext
function_nametargstsource((s;/usr/lib/python2.7/site-packages/dmapi/exception_wrapper.pyt_emit_exception_notifications

c	Cs†tj
j|
ƒ
}tjd
tjd|ƒ}tjdddtj	j
ƒ}tjd|d|dtjj
d	|ƒ}|j|ƒ

dS(
NthostR
tobjecttcomputetactiont	publishert
event_typetprioritytpayload(RtExceptionPayloadtfrom_exceptionR
tNotificationPublishertCONFRt	EventTypeRtNotificationActiont	EXCEPTIONtExceptionNotificationtNotificationPrioritytERRORtemit(R	R
R
tversioned_exception_payloadRRtnotification((s;/usr/lib/python2.7/site-packages/dmapi/exception_wrapper.pyRs

	


	



	
cCs,td
|d|ƒ}|j
|
||ƒ
dS(NRR(tdictterror(RR	R
RRR((s;/usr/lib/python2.7/site-packages/dmapi/exception_wrapper.pyR*s
cs‡‡
‡fd
†}|S(sšThis decorator wraps a method to catch any exceptions that may
    get thrown. It also optionally sends the exception to the notification
    system.
    c
s+‡
‡‡‡fd
†}
tj
ˆƒ
|
ƒ
S(Nc
s–yˆ
||
||ŽSWnxtk
r‘
}
t
jƒW
ˆsBˆrˆtˆ
||
||Ž}ˆ
j}tˆprˆƒ|
|||ˆƒ
nWdQXn
XdS(
N(t	ExceptionRtsave_and_reraise_exceptiont_get_call_dictt__name__R(tselfR	Rtkwt
et	call_dictR(tbinaryt
ftget_notifierR(s;/usr/lib/python2.7/site-packages/dmapi/exception_wrapper.pytwrapped6s







	


(t	functoolstwraps(R/R1(R.R0R(
R/s;/usr/lib/python2.7/site-packages/dmapi/exception_wrapper.pytinner5s
((RR0R.R4((R.R0Rs;/usr/lib/python2.7/site-packages/dmapi/exception_wrapper.pytwrap_exception0scOsTtj
|ƒ
}tj||
|||Ž}|jd
dƒ
|jddƒ
t|ƒ
S(NR*R	(Rtget_wrapped_functiontinspecttgetcallargstpoptNonet
_cleanse_dict(tfunctionR*R	RR+twrapped_funcR-((s;/usr/lib/python2.7/site-packages/dmapi/exception_wrapper.pyR(Is


c

Csd
„t|j
ƒƒ
Dƒ
S(sAStrip all admin_password, new_pass, rescue_pass keys from a dict.c
Ss+i|]!\}
}d|
kr||
“qS(
t_pass((t.0t
kt
v((s;/usr/lib/python2.7/site-packages/dmapi/exception_wrapper.pys
<dictcomp>Ys	(tlisttitems(
toriginal((s;/usr/lib/python2.7/site-packages/dmapi/exception_wrapper.pyR;Ws(R2R7t
oslo_utilsRt
dmapi.conftdmapitdmapi.notifications.objectsR
Rt
dmapi.objectsRRRtconfRRtif_notifications_enabledRRR:R5R(R;(((s;/usr/lib/python2.7/site-packages/dmapi/exception_wrapper.pyt<module>s