ó
±EYc@sÀ
dZd
dl
Z
d
dlZd
dlZd
dlZd
dlmZ
d
dlmZ	
d
dl
mZ
d
dlmZ

d
dlmZ
d
dlmZ
d
dlmZ
d
dlmZ
d
d	lmZ
d
dlZd
d
lmZ
d
dlZd
dlmZ
d
dlmZ
d
d
lmZ
d
dlm Z 
ej!j"Z"ej#e$ƒ
Z%da'e(a)d„Z*d„Zd„Z+d„Z,d„Z-d„Z.d„Z/d„Z0d„Z1de2f
d„ƒYZ3dS(s4
Handles all requests relating to volumes + cinder.
iÿÿÿÿN(
tclient(
t
exceptions(
tloading(
tlog(
tencodeutils(
texcutils(
tstrutils(
tavailability_zones(
t	exception(
t
_(
t_LE(
t_LWc
Cs
d
a
d
S(s%Testing method to reset globals.
    N(tNonet_SESSION(((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyt
reset_globals5sc

Cs4
ts't
jttjjjjƒand}
d}|j
ƒ}tjjjd
ƒ
\}}}i|d6|d6|d6tjj
d6}tjjr°tjj|jƒ}
|
}ntj||
}
tj|
ƒ
}|dkr
tr
tdƒ
}	tj|	ƒ

tantj|dtd	|d
|dtjj|
S(Nt
:tservice_typetservice_namet	interfacetregion_namet
1s«Cinder V1 API is deprecated as of the Juno release, and Nova is still configured to use it. Enable the V2 API in Cinder and set cinder.catalog_info in nova.conf to use it.tsessiontauthtendpoint_overridetconnect_retries(R
t
ks_loadingtload_session_from_conf_optionstCONFtnovatconftcindertcinder_grouptnameRtget_auth_plugintcatalog_infotsplittos_region_nametendpoint_templatetto_dicttget_endpointt
cinder_clienttget_volume_api_from_urlt_V1_ERROR_RAISEDRtLOGtwarningtTruetClientthttp_retries(
tcontextturlRRRRRtservice_parameterstversiontmsg((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pytcinderclient<s4









	


	



	
cCs×
i}|
j|d
<|
j
|d<|
j|d<|
j|d<|
j|d<d|d<d|d<t|
d	tƒ|d	<|
jrótj	ƒ|d
<xY|
jD]N}i
i|j
dƒ
d6|j
dƒ
d6|d
6}|d
j|jƒƒ

q”Wd|d<n
d|d<t
|
dƒr)
|
j|d<|
j|d<n|
j|d<|
j|d<|
j|d<|
j|d<tj|
jƒ
|d<i|d<x+|
jjƒD]\}}||d|<q
Wt
|
dƒrÓ
tj|
jƒ
|d<n|S(s#Maps keys for volumes summary view.tidtstatustsizetavailability_zonet
created_atttattach_timet
mountpointtmultiattachtattachmentst
attachment_idtdevicet	server_idtattachedt
attach_statustdetachedtdisplay_nametdisplay_descriptiontvolume_type_idtsnapshot_idtbootabletvolume_metadatatvolume_image_metadata(R6R7R8R9R:tgetattrtFalseR?tcollectionstOrderedDicttgettupdatetitemsthasattrRFRGR tdescriptiontvolume_typeRIRtbool_from_stringRJtmetadatatcopytdeepcopyRL(R0tvolt
dt
attachmentt
atkeytvalue((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyt _untranslate_volume_summary_viewjs@













	





















cCs¸i}|
j|d
<|
j
|d<|
j|d<|
j|d<|
j|d<t|
dƒrs|
j|d<|
j|d<n|
j|d<|
j	|d<|
j
|d<|
j|d	<|
j|d
<|S(s%Maps keys for snapshots summary view.R6R7tprogressR8R:RFRGt	volume_idt
project_idtvolume_size(R6R7RbR8R:RTRFRGR RURcRd(R0tsnapshotR\((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyt"_untranslate_snapshot_summary_views



















c
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(s=Transforms a cinder exception but keeps its traceback intact.csçyˆ||
||Ž}WnÇtj
tj
fk
r_
}
tj|ƒ
}ttjd
|ƒ
ƒ

n„tjtjfk
r¢
}
tj|ƒ
}ttj	d
|ƒ
ƒ

nAtj
tj
fk
râ
}
tj|ƒ
}ttj
|ƒ
ƒ

n
X|S(Ntreason(tcinder_exceptiontConnectionErrortkeystone_exceptionRtexception_to_unicodet_reraiseRtCinderConnectionFailedt
BadRequesttInvalidInputt	Forbidden(tselftctxtargstkwargstrestexcterr_msg(
tmethod(sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pytwrapper¹s













(t	functoolstwraps(RyRz((
RysG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyttranslate_cinder_exception·sc
s‡f
d
†}
t|
ƒ
S(sLTransforms the exception for the volume but keeps its traceback intact.
    csyˆ||
|||Ž}Wn\tj
tj
fk
rQ


ttjd
|ƒ
ƒ

n*tjk
rz


ttjddƒ
ƒ

n
X|S(NRctoverstvolumes(RktNotFoundRiRmRtVolumeNotFoundt	OverLimitt	OverQuota(RrRsRcRtRuRv(
Ry(sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyRzÐs






(
R}(RyRz((
RysG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyttranslate_volume_exceptionÍsc
s‡f
d
†}
t|
ƒ
S(sUTransforms the exception for the snapshot but keeps its traceback
       intact.
    csVyˆ||
|||Ž}Wn3tj
tj
fk
rQ


ttjd
|ƒ
ƒ

n
X|S(NRI(RkR€RiRmRtSnapshotNotFound(RrRsRIRtRuRv(
Ry(sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyRzßs





(
R}(RyRz((
RysG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyttranslate_snapshot_exceptionÛsc
s‡f
d
†}
t|
ƒ
S(sDTransforms exceptions that can come from both volumes and snapshots.csyˆ||
|||Ž}Wn\tj
tj
fk
rQ


ttjd
|ƒ
ƒ

n*tjk
rz


ttjddƒ
ƒ

n
X|S(NRcR~t	snapshots(RkR€RiRmRRR‚Rƒ(RrRstres_idRtRuRv(
Ry(sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyRzês






(
R}(RyRz((
RysG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyttranslate_mixed_exceptionsèsc

Cs'tj
t|ƒ
|tjƒd
ƒ
dS(Ni(tsixtreraisettypetsystexc_info(
tdesired_exc((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyRmõs
tAPIcBs”
eZ
dZed
„ƒ
Zedd„
ƒ
Zd„Zdd„
Z	dd„
Z
dd„
Zed„ƒ
Zed„ƒ
Z
ed	„ƒ
Zed
„ƒ
Zedd„
ƒ
Zeddd
„ƒ
Zed„ƒ
Zed„ƒ
Zeed„
ƒ
Zedddddd„ƒ
Zed„ƒ
Zed„ƒ
Zed„ƒ
Zed„ƒ
Zed„ƒ
Zed„ƒ
Zed„ƒ
Zed„ƒ
Z ed„ƒ
Z!RS(s,API for interacting with the volume manager.cCs%t|
ƒ
j
j|ƒ
}t|
|ƒS(
N(R5RRQRa(RrR0Rctitem((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyRQüs
cCs^|p	i}t|
ƒ
j
jd
td|ƒ}g}x$|D]}|jt|
|ƒƒ

q:W|S(Ntdetailedtsearch_opts(R5RtlistR-tappendRa(RrR0R“RStrvalR‘((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pytget_all

s

	

cCsO|d
dkrKtdƒ
i|dd6|d
d
6}t
jd|ƒ
‚
ndS(NR7sin-usesJvolume '%(vol)s' status must be 'in-use'. Currently in '%(status)s' statusR6R[Rh(R	Rt
InvalidVolume(RrR0tvolumeR4((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pytcheck_attached
s


	


cCs›|d
dkrKtdƒ
i|dd6|d
d
6}t
jd|ƒ
‚
n|ddkr„td	ƒ
|d}t
jd|ƒ
‚
n|j|
||ƒ
dS(
NR7t	availablesFvolume '%(vol)s' status must be 'available'. Currently in '%(status)s'R6R[RhRDRCsvolume %s already attached(R	RR˜tcheck_availability_zone(RrR0R™tinstanceR4((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pytcheck_attach
s
	





cCs‰|r…tj
jr…tj|
|ƒ}||d
kr…tdƒ
i|dd6|dd6|d6|d
d6}tjd|ƒ
‚
q…nd	S(
s.Ensure that the availability zone is the same.R9s†Instance %(instance)s and volume %(vol)s are not in the same availability_zone. Instance is in %(ins_zone)s. Volume is in %(vol_zone)sR6RR[tins_zonetvol_zoneRhN(RRtcross_az_attachtaztget_instance_availability_zoneR	RR˜(RrR0R™Rtinstance_azR4((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyRœ"
s


	




cCs¦|d
dkr9tdƒ
|d}t
jd|ƒ
‚
n|ddkrjtdƒ
}t
jd|ƒ
‚
n|dk	r¢|j|d	kr¢t
jd
|dƒ
‚
ndS(NR7R›svolume %s already detachedR6RhRDREs+Volume must be attached in order to detach.R?Rc(R	RR˜RtuuidtVolumeUnattached(RrR0R™RR4((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pytcheck_detach3
s



cCst|
ƒ
j
j|ƒ

dS(
N(R5Rtreserve(RrR0Rc((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pytreserve_volumeE
scCst|
ƒ
j
j|ƒ

dS(
N(R5Rt	unreserve(RrR0Rc((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pytunreserve_volumeI
scCst|
ƒ
j
j|ƒ

dS(
N(R5Rtbegin_detaching(RrR0Rc((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyR¬M
scCst|
ƒ
j
j|ƒ

dS(
N(R5Rtroll_detaching(RrR0Rc((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyR­Q
strwcCs&t|
ƒ
j
j|||d
|ƒ

dS(Ntmode(R5Rtattach(RrR0Rct
instance_uuidR=R¯((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyR°U
s
cCsôt|
ƒ
}|j
d
kr/|jj|ƒ

dS|dkrÝ|j|
|ƒ}|drÝ|jdiƒ}|rº|j|iƒjdƒ
}|s×tjtdƒ
i|d6|d6ƒ
q×qÚtjtdƒ
i
|d6ƒ
qÝn|jj||ƒ
dS(	NRR>R?R@sÙattachment_id couldn't be retrieved for volume %(volume_id)s with instance_uuid %(instance_id)s. The volume has the 'multiattach' flag enabled, without the attachment_id Cinder most probably cannot perform the detach.Rctinstance_ids¶attachment_id couldn't be retrieved for volume %(volume_id)s. The volume has the 'multiattach' flag enabled, without the attachment_id Cinder most probably cannot perform the detach.(	R5R3RtdetachRRQR+R,R(RrR0RcR±R@RR™R?((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyR³Z
s$









	



c
Cs-
y-t|
ƒ
j
j||ƒ}||d
<|SWnùtjk
r(

}
tjƒÕ
tjt	dƒ
i|d6|j
dƒ
d6tj|ƒ
d6|j
d6ƒ
y|j|
||ƒ
Wnotk
r

}
tjt	dƒ
i|d6|j
dƒ
d6tj|ƒ
d6t|dƒr
|j
ndd6ƒ
n
XWdQXn
XdS(Nt	connectors„Initialize connection failed for volume %(vol)s on host %(host)s. Error: %(msg)s Code: %(code)s. Attempting to terminate connection.R[thostR4tcodesÛConnection between volume %(vol)s and host %(host)s might have succeeded, but attempt to terminate connection has failed. Validate the connection and determine if manual cleanup is needed. Error: %(msg)s Code: %(code)s.(R5Rtinitialize_connectionRitClientExceptionRtsave_and_reraise_exceptionR+terrorR
RQRŠt	text_typeR¶tterminate_connectiont	ExceptionRTR(RrR0RcR´tconnection_infotexRw((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyR·}
s(



















cCst|
ƒ
j
j||ƒS(
N(R5RR¼(RrR0RcR´((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyR¼
s
cCst|
ƒ
j
j|||ƒS(
N(R5Rtmigrate_volume_completion(RrR0t
old_volume_idt
new_volume_idRº((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyRÀ¢
s
c
CsÃt|
ƒ
}
|dk	r%|d
}nd}td|d|d|
jd|
jd|	d|d|ƒ}t|
tjƒr||d	<||d
<n||d<||d<|
jj	||
}
t
|
|
ƒS(
NR6RIRVtuser_idRdR9RXtimageRefRFRGR RU(R5RtdictRÃRdt
isinstancet	v1_clientR.RtcreateRa(RrR0R8R RURftimage_idRVRXR9RRIRuR‘((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyRȨ
s$



	
	


	







cCst|
ƒ
j
j|ƒ

dS(
N(R5Rtdelete(RrR0Rc((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyRÊÅ
sc
Cs
tƒ‚
dS(
N(
tNotImplementedError(RrR0Rctfields((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyRRÉ
scCs%t|
ƒ
j
j|ƒ
}t|
|ƒS(
N(R5tvolume_snapshotsRQRg(RrR0RIR‘((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pytget_snapshotÍ
s
cCsLt|
ƒ
j
jd
tƒ
}g}x$|D]}|jt|
|ƒƒ

q(W|S(NR’(R5RÍR”R-R•Rg(RrR0RStrvalsR‘((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pytget_all_snapshotsÒ
s



cCs.t|
ƒ
j
j|t||ƒ}t|
|ƒS(
N(R5RÍRÈRNRg(RrR0RcR RUR‘((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pytcreate_snapshotÜ
s



	
cCs.t|
ƒ
j
j|t||ƒ}t|
|ƒS(
N(R5RÍRÈR-Rg(RrR0RcR RUR‘((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pytcreate_snapshot_forceä
s



	cCst|
ƒ
j
j|ƒ

dS(
N(R5RÍRÊ(RrR0RI((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pytdelete_snapshotí
scCst|
ƒ
j
j|ƒ
S(
N(R5Rtget_encryption_metadata(RrR0Rc((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pytget_volume_encryption_metadatañ
scCs1t|
ƒ
j
}|j|i|d
6dd6ƒ
dS(NR7s90%Rb(R5RÍtupdate_snapshot_status(RrR0RIR7tvs((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyRÖõ
s




N("t__name__t
__module__t__doc__R„RQR}RR—RšRžRœR§R©R«R¬R­R°R³R·R¼RNRÀRÈRÊRRR†RÎRÐR‰RÑRÒRÓRÕRÖ(((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyRùsD

	



! 

	

	(4RÚRORYR{RR5RR(R
Ritcinderclient.v1RÇt
keystoneauth1RkRRtoslo_logRtloggingt
oslo_utilsRRRRŠRRR¢t	nova.confRt	nova.i18nR	R
RRRt	getLoggerRØR+RR
RNR*RRaRgR}R„R†R‰RmtobjectR(((sG/home/tvault/.virtenv/lib/python2.7/site-packages/nova/volume/cinder.pyt<module>sD

















		.	3