ó
±EYc@s˜dd
lZdd
l
Z
dd
lZddlmZ
ddlmZ
ddlm	Z	
dd
l
Z
ddlmZ
dd
l
ZddlmZ
ddlmZ
ddlmZ
dd	lmZ
dd
lmZ
ejjZejeƒ
Zdef
d„ƒYZd
ef
d„ƒYZd„Zd„Zdef
d„ƒYZ de f
d„ƒYZ!de f
d„ƒYZ"de f
d„ƒYZ#de#f
d„ƒYZ$de#f
d„ƒYZ%de#f
d„ƒYZ&d„Z'ej(e'e!ƒZ)ej(e'e"ƒZ*ej(e'e#ƒZ+ej(e'e$ƒZ,ej(e'e%ƒZ-ej(e'e&ƒZ.d „Z/d!„Z0d"„Z1d#„Z2d$„Z3d%„Z4e!e"e#e$e%e&fZ5d&„Z6d'„Z7d
S((iÿÿÿÿN(
tlog(
t	jsonutils(
texcutils(
tblock_device(
t	exception(
t_LE(
t_LI(
t_LW(
t
encryptorst_NotTransformablec
BseZ
RS((t__name__t
__module__(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR	%s
t_InvalidTypec
BseZ
RS((R
R(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR)s
c
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(Ncs+zˆ||
||Ž}Wd|jƒ
X|S(
N(
tsave(tobjtcontexttargstkwargstret_val(
tmethod(sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pytwrapped.s

(t	functoolstwraps(RR((
RsK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyt	update_db-s
c


Cstj
jrd
S|jS(si
Determine az to use when creating a volume

    Uses the cinder.cross_az_attach config option to determine the availability
    zone value to use when creating a volume.

    :param nova.objects.Instance instance: The instance for which the volume
        will be created and attached.
    :returns: The availability_zone value to pass to volume_api.create
    N(tCONFtcindertcross_az_attachtNonetavailability_zone(
tinstance((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyt_get_volume_create_az_value8s
tDriverBlockDevicecBsƒeZ
dZeƒZeƒZeƒZidd
6dd6dd6Zd„Z	d„Z
d„Zd„Zd„Z
d	„Zd
„ZRS(s²A dict subclass that represents block devices used by the virt layer.

    Uses block device objects internally to do the database access.

    _fields and _legacy_fields class attributes present a set of fields that
    are expected on a certain DriverBlockDevice type. We may have more legacy
    versions in the future.

    If an attribute access is attempted for a name that is found in the
    _proxy_as_attr set, it will be proxied to the underlying object. This
    allows us to access stuff that is not part of the data model that all
    drivers understand.

    The save() method allows us to update the database using the underlying
    object. _update_on_save class attribute dictionary keeps the following
    mapping:

        {'object field name': 'driver dict field name (or None if same)'}

    These fields will be updated on the internal object, from the values in the
    dict, before the actual database update is done.
    tdisk_bustdevice_nametdevice_typecCsM|
|jd
<|j
jr%tƒ‚
n|jd„|jDƒ
ƒ

|jƒ
dS(Nt_bdm_objc
Ssi|]}
d|
“qS(
N(
R(t.0tfield((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pys
<dictcomp>zs	(t__dict__R#t	no_deviceR	tupdatet_fieldst
_transform(tselftbdm((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyt__init__ts




cCs9|
|jkrt
|j|
ƒStt|ƒj|
ƒ

dS(
N(t_proxy_as_attrtgetattrR#tsuperRt__getattr__(R+tname((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR1}s

cCs?|
|jkr"t
|j|
|ƒStt|ƒj|
|ƒ
dS(
N(R.tsetattrR#R0Rt__setattr__(R+R2tvalue((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR4ƒs

c


Cs
tƒ‚
d
S(s6Transform bdm to the format that is passed to drivers.N(
tNotImplementedError(
R+((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR*‰sc

s‡f
d
†ˆjDƒ
S(s¦Basic legacy transformation.

        Basic method will just drop the fields that are not in
        _legacy_fields set. Override this in subclass if needed.
        c
s"i|]}
ˆj|
ƒ
|
“qS((
tget(R$tkey(
R+(sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pys
<dictcomp>“s	(
t_legacy_fields(
R+((
R+sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pytlegacysc

Ks
tƒ‚
d
S(s¯Make the device available to be used by VMs.

        To be overridden in subclasses with the connecting logic for
        the type of device the subclass represents.
        N(
R6(R+R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pytattach•sc
Csvxbtj
|jƒ
D]N\}
}|p(|
}||t|j|
ƒkrt|j|
||ƒ
qqW|jjƒ
dS(
N(tsixt	iteritemst_update_on_saveR/R#R3R
(R+t	attr_nametkey_nametlookup_name((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR
s





N(R
Rt__doc__tsetR)R9R.RR>R-R1R4R*R:R;R
(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyRTs	
		




							tDriverSwapBlockDevicecBsMeZ
edd
dgƒ
Zeedg
ƒ
Zidd6dd6Zd„ZRS(R!t	swap_sizeR c

CsYtj
|jƒ
st‚
n|ji|jjd
6|jjp@dd6|jjd6ƒ

dS(NR!iRER (Rtnew_format_is_swapR#RR(R!tvolume_sizeR (
R+((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR*¬s

	
	



N(R
RRCR)R9RR>R*(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyRD¥s





tDriverEphemeralBlockDevicecBsbeZ
edd
dgƒ
Zeddgƒ
eBZeeeddgƒ
BZd„Zdd	„
ZRS(
R R"tguest_formatR!tsizetnumtvirtual_namec

Csstj
|jƒ
st‚
n|ji|jjd
6|jjp@dd6|jjd6|jjd6|jj	d6ƒ

dS(NR!iRJR R"RI(
Rtnew_format_is_ephemeralR#RR(R!RGR R"RI(
R+((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR*¼s

	
	







icCs7tt
|ƒjƒ}|
|d
<dt|
ƒ
|d<|S(NRKt	ephemeralRL(R0RHR:tstr(R+RKt
legacy_bdm((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR:Çs




(R
RRCt_new_only_fieldsR)R9R*R:(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyRH¶s



	tDriverVolumeBlockDevicecBsÀeZ
edd
dgƒ
Zeddddgƒ
ZeeBZdZdZedd	gƒ
Zidd6d
d
6dd6Z
d„Zd„Ze
eed
„ƒ
Ze
d„ƒ
Zd„Zd„ZRS(tconnection_infotmount_devicetdelete_on_terminationRIR"R t
boot_indextvolumeRGt	volume_idR!c

s­ˆjj
ˆjks,ˆjjˆjkr5t‚
nˆj‡f
d
†tjˆjƒ
Dƒ
ƒ

ˆjj	ˆd<yt
jˆjjƒ
ˆd<Wnt
k
r¨


dˆd<n
XdS(Nc
s;i|]1\}
}|
ˆjt
dg
ƒ
Bkr||
“qS(
RU(t_new_fieldsRC(R$t
kt
v(
R+(sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pys
<dictcomp>äs		
RTRS(R#tsource_typet
_valid_sourcetdestination_typet_valid_destinationRR(R<R=R!R
tloadsRSt	TypeErrorR(
R+((
R+sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR*Ýs

	


	
#





cCsp|d
rld|d
krld|d
dkrl|d
dd|
dd<tj
tdƒ
|
ddƒ
qlndS(NRStdatatmultipath_idspreserve multipath_id %s(tLOGtinfoR(R+RS((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyt_preserve_multipath_idîs




cKsÁ|j|
|j
ƒ}|r4|j|
|d
|ƒ

n|d}	|
jƒ}
|j|ƒ
}
|j|
|	|
ƒ}d|krŠ|j
|d<n|j|ƒ

|r^
tj|
||	|ƒ}y8|j	|
|||dd|dd|dd|ƒ
Wq^
t
k
rZ



tjƒL
t
jtdƒ
i|	d	6|dd
6d|
d
|ƒ
|j|
|	|
ƒ
WdQXq^
Xn||d<|jdkrŒ
|jd
ƒ
|_nd}
d|kr·
|djddƒ}
n|ddkr½|jƒ
y'|j|
|	|j|dd|
ƒ

Wq½t
k
r¹


tjƒ 
|ry!|j|||dd|ƒ

Wqt
k
r‰


t
jtdƒ
i|	d	6|dd6dtd|
d
|ƒ
qXn|j|
|	|
ƒ
|j|
|	ƒ
WdQXq½XndS(NRtidtserialRTR R"t
encryptions>Driver failed to attach volume %(volume_id)s at %(mountpoint)sRXt
mountpointRRSRJtrwRbtaccess_modet
attach_statustdetachedtmodes@Driver failed to detach volume %(volume_id)s at %(mount_point)s.tmount_pointtexc_info(R7RXtcheck_attachtelevatedtget_volume_connectortinitialize_connectionRfRtget_encryption_metadatat
attach_volumet	ExceptionRtsave_and_reraise_exceptionRdRRtterminate_connectionRGRR
R;tuuidt
detach_volumetwarningRtTruetdetach(R+RRt
volume_apitvirt_drivertdo_check_attachtdo_driver_attachRRWRXt	connectorRSRiRo((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR;ösp




	

	







	






























	












cCsl|d
sdS|j|ƒ
}|j
|
|j|ƒ}d|krQ|j|d<n|j|ƒ

||d
<dS(NRSRh(RtRuRXRf(R+RRR€RR„RS((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pytrefresh_connection_infoC
s


	

	




c
Cshy=tj
|jd
ƒ
ƒ
}
|
|jjkr<|
|j_nWntk
rP


n
Xtt|ƒjƒ
dS(NRS(	R
tdumpsR7R#RSRaR0RRR
(R+tconnection_info_string((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR
S
s







c	Csšy||
|ƒ
Wn‚tj
k
r•


tjƒ`
|d
rŒy|j|
|ƒ
WqŒtk
rˆ
}
tjtdƒ
i|d6|d6ƒ
qŒXnWdQXn
XdS(NRUs5Failed to delete volume: %(volume_id)s due to %(exc)sRXtexc(	RtVolumeNotCreatedRRytdeleteRxRdR}R(R+Rt	wait_funcR€RXRˆ((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyt_call_wait_func_
s











	N(R
RRCR9RYR)R]R_R.RR>R*RfRR~tFalseR;R…R
RŒ(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyRRÎs$
	

	








		K	tDriverSnapshotBlockDevicecBs2eZ
dZed
ddgƒ
Zded„ZRS(tsnapshotRGRXtsnapshot_idc
Csª|jst
|ƒ
}|j|
|jƒ}|j|
|jd
d
|d|ƒ
}	|rq|j|
|||	dƒ
n|	d|_ntt|ƒj	|
|||d|ƒ

dS(NtRRgR‚(
RXRtget_snapshotRtcreateRGRŒR0RŽR;(
R+RRR€RR‹R‚tav_zoneRtvol((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR;s
s	

	






N(R
RR]RCR.RR~R;(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyRŽn
s
tDriverImageBlockDevicecBs2eZ
dZed
ddgƒ
Zded„ZRS(timageRGRXtimage_idc		Cs›|jsrt
|ƒ
}|j|
|jd
d
d|jd|ƒ}|rb|j|
|||dƒ
n|d|_ntt|ƒj|
|||d|ƒ

dS(NR‘R˜RRgR‚(	RXRR“RGR˜RŒR0R–R;(	R+RRR€RR‹R‚R”R•((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR;Œ
s	



	



N(R
RR]RCR.RR~R;(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR–‡
s
tDriverBlankBlockDevicecBs2eZ
dZed
ddgƒ
Zded„ZRS(tblankRGRXR˜c
CsŸ|jsv|j
d
}t|ƒ
}|j|
|j|dd|ƒ
}	|rf|j|
|||	dƒ
n|	d|_ntt|ƒj|
|||d|ƒ

dS(Ns
-blank-volR‘RRgR‚(	RXR{RR“RGRŒR0R™R;(
R+RRR€RR‹R‚tvol_nameR”R•((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR;¢
s	




	



N(R
RR]RCR.RR~R;(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyR™
s
cCsFg}x9|
D]1}y|j||ƒ
ƒ

Wq
t
k
r=


q
Xq
W|S(
N(tappendR	(R"tblock_device_mappingtdevicesR,((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyt_convert_block_devices³
s







cGsYt|ƒ
}
t
|ƒ
}t|ƒ
}t|ƒ
}gtj|
|||ƒD]}|^qIS(
N(tconvert_volumestconvert_snapshotstconvert_imagestconvert_blankst	itertoolstchain(tvolume_bdmst
source_volumetsource_snapshottsource_imagetsource_blankR•((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pytconvert_all_volumesÓ
s





c

Cs*yt|ƒ
d
SWnt
k
r%


n
XdS(Ni(R«t
IndexError(
t
volume_bdm((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pytconvert_volumeÞ
s




c
s#‡‡
fd
†}t||ƒ
|S(Nc
s0
ˆd
}
ˆd}|jdƒ
r]t
jtdƒ
i|jd6|dd6d|
d|ƒ
n¿|jd	ƒ
r¦t
jtd
ƒ
i|jd	6|dd6d|
d|ƒ
nv|jdƒ
rït
jtdƒ
i|jd6|dd6d|
d|ƒ
n-t
jtd
ƒ
i
|dd6d|
d|ƒ
|jˆˆ
Ž
dS(Nii
RXs3Booting with volume %(volume_id)s at %(mountpoint)sRTRjRRRs>Booting with volume snapshot %(snapshot_id)s at %(mountpoint)sR˜s?Booting with volume-backed-image %(image_id)s at %(mountpoint)ss+Booting with blank volume at %(mountpoint)s(R7RdReRRXRR˜R;(R,RR(tattach_argst
attach_kwargs(sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyt_log_and_attachæ
s*





















(
tmap(RR¯R°R±((R¯R°sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pytattach_block_deviceså
s


c
Os tt
jd
|
|Ž
|ƒ
|S(NR…(R²toperatortmethodcaller(Rtrefresh_argstrefresh_kwargs((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pytrefresh_conn_infoss

	

c
Csg|D]}
|
jƒ^q}t
d
„|Dƒ
ƒ
r{xCt|ƒ
D]2\}}|dd t|ƒ
|d<||d<qBWn|S(Nc
ss|]}
t|
t
ƒV
qdS(
N(t
isinstanceRH(R$R,((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pys	<genexpr>s
RLiÿÿÿÿRK(R:tallt	enumerateRO(RR,tbdmst
itdev((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pytlegacy_block_devices
s
	




c

CsAtd
„|Dƒ
ƒ
sdSy|jƒSWntk
r<


dSXdS(sšGet the swap device out of the list context.

    The block_device_info needs swap to be a single device,
    not a list - otherwise this is a no-op.
    c
ss*|] }
t|
t
ƒp!d|
kV
qd
S(REN(R¹RD(R$tdevice((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pys	<genexpr> sN(RºRtpopR¬(
ttransformed_list((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pytget_swaps	






c
Cs;x4tD],}
y|
|ƒ

t
SWqtk
r2


qXqWtS(
N(t_IMPLEMENTED_CLASSESR~R	R(R,tcls((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pytis_implemented/s









c

Cs(|jdko'|j
dko't|ƒ
S(NR—RWRRš(simagesvolumessnapshotsblank(R\R^RÆ(
R,((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pytis_block_device_mapping9s


(8RR¤R´toslo_logRtloggingtoslo_serializationR
t
oslo_utilsRR<tnovaRt	nova.confRt	nova.i18nRRRtnova.volumeRtconfRt	getLoggerR
RdRxR	RRRtdictRRDRHRRRŽR–R™RŸtpartialtconvert_swaptconvert_ephemeralsR R¡R¢R£R«R®R³R¸R¿RÃRÄRÆRÇ(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/block_device.pyt<module>sd










		Q 	
	
		
		
		
		
		
				!