ó
±EYc@sw
dd
lm
Z

ddlmZ
yddlZddlZWnek
r[


dZdZn
Xddlm	Z

ddlmZ
ddl
mZ
ddlmZ
ddlmZ
dd	lmZ
dd
lmZ
ddlmZ
ddlmZ
dd
lmZ
dd
lmZ
e
jeƒ
Zdef
d„ƒYZdef
d„ƒYZ def
d„ƒYZ!def
d„ƒYZ"dS(iÿÿÿÿ(
ttpool(
turllibN(
tlog(
t	jsonutils(
tloopingcall(
texcutils(
tunits(
t	exception(
t
_(
t_LE(
t_LW(
tutilstRbdProxyc
Bs eZ
dZd
„Zd„ZRS(sáA wrapper around rbd.RBD class instance to avoid blocking of process.

    Offloads all calls to rbd.RBD class methods to native OS threads, so that
    we do not block the whole process while executing the librbd code.

    c

Cstj
tjƒƒ
|_dS(
N(RtProxytrbdtRBDt_rbd(
tself((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyt__init__3s
cCst|j
|
ƒS(
N(tgetattrR(Rtattr((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyt__getattr__6s
(t__name__t
__module__t__doc__RR(((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyR+s	tRBDVolumeProxycBs;eZ
dZdded
„Zd„Zd„Zd„ZRS(s$
Context manager for dealing with an existing rbd volume.

    This handles connecting to rados and opening an ioctx automatically, and
    otherwise acts like a librbd Image object.

    The underlying librados client and ioctx can be accessed as the attributes
    'client' and 'ioctx'.
    c	Cs
|
j|ƒ
\}}yR|r-|j
d
ƒ
nd}tjtj||j
d
ƒ
d|d|ƒƒ
|_Wn“tjk
r°


t	j
ƒ%
tjd|ƒ
|
j
||ƒ
WdQXnMtjk
rü


t	j
ƒ+
tjtdƒ
|ƒ
|
j
||ƒ
WdQXn
X|
|_||_||_dS(Ntutf8tsnapshott	read_onlysrbd image %s does not existserror opening rbd image %s(t_connect_to_radostencodetNoneRR
RtImagetvolumet
ImageNotFoundRtsave_and_reraise_exceptiontLOGtdebugt_disconnect_from_radostErrorRR	tdrivertclienttioctx(	RR(tnametpoolRRR)R*t	snap_name((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyRCs"














	
	
c


Cs|S(
N((
R((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyt	__enter__Xs
cCs2z|jj
ƒ
Wd|jj|j|jƒ
XdS(
N(R!tcloseR(R&R)R*(Rttype_tvaluet	traceback((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyt__exit__[s

cCst|j
|
ƒS(
N(RR!(Rtattrib((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyRas
N(	RRRRtFalseRR.R3R(((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyR:s

		tRADOSClientcBs;eZ
dZdd
„
Zd„Zd„Zed„ƒ
ZRS(sBContext manager to simplify error handling for connecting to ceph.cCs(|
|_|
j
|ƒ
\|_|_dS(
N(R(RtclusterR*(RR(R,((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyRgs
	
c


Cs|S(
N((
R((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyR.ks
cCs|jj
|j|jƒ
dS(
N(R(R&R7R*(RR0R1R2((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyR3ns
c
CsF|jj
d
ƒ
}
|
dks0t|
ƒ
dkr<tj}
nt|
ƒ
S(Ntrbd_default_featuresi(R7tconf_getRtintRtRBD_FEATURE_LAYERING(Rtfeatures((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyR<qs


N(	RRRRRR.R3tpropertyR<(((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyR6es


		t	RBDDrivercBsþeZ
d„Zdd
„
Zd„Zd„Zd„Zd„Zd„Z	d„Z
dd„
Zd	„Zd
„Z
dd„
Zdd„
Zddd
„Zd„Zd„Zdd„
Zd„Zd„Zded„Zeded„Zd„Zdd„
ZRS(cCss|
jd
ƒ
|_
|r'|jd
ƒ
nd|_|rE|jd
ƒ
nd|_tdkrottdƒ
ƒ
‚
ndS(NRtsrbd python libraries not found(RR,t	ceph_confRtrbd_userRtRuntimeErrorR(RR,R@RA((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyR{s




cCs…tj
d
|jd|jƒ}y?|jƒ
|
p7|j}|j|jdƒ
ƒ
}||fSWn!tjk
r€


|j	ƒ
‚n
XdS(Ntrados_idtconffilesutf-8(
tradostRadosRAR@tconnectR,t
open_ioctxRR'tshutdown(RR,R)tpool_to_openR*((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyR„s










c
Cs|jƒ
|
j
ƒ
dS(
N(R/RI(RR)R*((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyR&‘s

c
CsNg}
|jr(|
j
d
|jgƒ

n|jrJ|
j
d|jgƒ

n|
S(s°List of command line parameters to be passed to ceph commands to
           reflect RBDDriver configuration such as RBD user name and location
           of ceph.conf.
        s--ids--conf(RAtextendR@(Rtargs((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyt	ceph_args–s
	

	

c
Cs
d
dddg|jƒ}
t
j|
Œ\}}|jdƒ
}|djdƒ
r`|d}ntjdj|ƒ
ƒ
}g|d	D]}|d
^qƒ}g}g}	x\|D]T}
|
|
jdƒ
 }|j	ddƒ\}}
|j
|jd
ƒ
ƒ

|	j
|
ƒ

q¬W||	fS(Ntcephtmontdumps
--format=jsons

isdumped monmap epochi
tmonstaddrt
/t
:s[](RMRtexecutetsplitt
startswithRtloadstjointrindextrsplittappendtstrip(RRLtoutRtlinestmonmapROtaddrsthoststportsRRt	host_portthosttport((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyt
get_mon_addrs¢s







!








cCsÔd
}|
j|ƒ
s<t
dƒ
}tjd|
d|ƒ‚
nttjj|
t|ƒ
j	dƒ
ƒ}d|kr—t
dƒ
}tjd|
d|ƒ‚
nt|ƒ
dkrÐt
d	ƒ
}tjd|
d|ƒ‚
n|S(
Nsrbd://sNot stored in rbdtimage_idtreasonRSR?sBlank componentsisNot an rbd snapshot(
RWRRtImageUnacceptabletmapR
tparsetunquotetlenRV(RturltprefixRitpieces((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyt	parse_url³s




(






c
Cs&t|ƒ
}
|
j
jƒSWdQXdS(
N(R6R7tget_fsid(RR)((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyRsÁs

c
Cs
|
d
}y|j|ƒ
\}}}}Wn't
jk
rR
}
tjd|ƒ
tSX|jƒ|kr€d|}	tj|	ƒ

tS|jdƒ
dkrÁdj||jdƒ
ƒ}	tj|	ƒ

tSy|j	|d|d|ƒ
SWn7t
jk
r

}
tjd	td
|d|ƒƒ

tSXdS(NRosnot cloneable: %ss!%s is in a different ceph clustertdisk_formattrawsHrbd image clone requires image format to be 'raw' but image {0} is '{1}'R,Rs%Unable to open image %(loc)s: %(err)stlocterr(
RrRRjR$R%R5RstgettformattexistsRR'tdict(
Rtimage_locationt
image_metaRotfsidR,timageRt
eRi((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pytis_cloneableÅs*


















	

c
Cs

|j|
d
ƒ
\}}}}t
jdtd|d|d|d|d|ƒƒ
t|t|ƒ
ƒ–}t||ƒ~}	yGtƒj|j|j	dƒ
|j	dƒ
|	jt|ƒ
d	|j
ƒ

Wn-tjk
rð


t
jtd
ƒ
|ƒ
‚
n
XWdQXWdQXdS(NRos@cloning %(pool)s/%(img)s@%(snap)s to %(dest_pool)s/%(dest_name)sR,timgtsnapt	dest_poolt	dest_namesutf-8R<s&no write permission on storage pool %s(RrR$R%R{R6tstrRtcloneR*RR<RtPermissionErrorRt	ForbiddenR(
RR|R…R„t_fsidR,RRt
src_clienttdest_client((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyR‡ás"


	












cCs,t||
d
t
ƒ
}|jƒSWdQXdS(NR(RtTruetsize(RR+tvol((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyRŽõs

cCs<tj
d
|
|ƒ
t||
ƒ}|j|ƒ

WdQXdS(s_Resize RBD volume.

        :name: Name of RBD object
        :size: New size in bytes
        sresizing rbd image %s to %dN(R$R%Rtresize(RR+RŽR((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyRùs

cCsly8t|t
|
ƒ
d
|dtƒ}|jƒSWdQXWn-tjk
rg


tjtdƒ
|
ƒ
‚
n
XdS(sœReturns the pool, image and snapshot name for the parent of an
        RBD volume.

        :volume: Name of RBD object
        :pool: Name of pool
        R,RNs'no usable parent snapshot for volume %s(	RR†Rtparent_infoRR"RRjR(RR!R,R((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyR‘
s





cCsQtj
d
td|d|
ƒƒ
t|t|
ƒ
d|ƒ
}|jƒ
WdQXdS(s²"Flattens" a snapshotted image with the parents' data,
        effectively detaching it from the parent.

        :volume: Name of RBD object
        :pool: Name of pool
        sflattening %(pool)s/%(vol)sR,RN(R$R%R{RR†tflatten(RR!R,R((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyR’
s

c	CsLy0t||
d
|d|dt
ƒ	
t
SWdQXWntjk
rG


tSXdS(NR,RR(RRRR"R5(RR+R,R((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyRz
s








c	Cs±t||j
ƒ™}ytƒj|j|
ƒ
Wnutjk
rl


tjt	d
ƒ
i|
d6|j
d6ƒ
n;tj
k
r¦


tjtdƒ
i|
d6|j
d6ƒ
n
XWdQXdS(s=Remove RBD volume

        :name: Name of RBD volume
        sDimage %(volume)s in pool %(pool)s can not be found, failed to removeR!R,sAimage %(volume)s in pool %(pool)s has snapshots, failed to removeN(
R6R,RtremoveR*RR"R$twarningR
tImageHasSnapshotsterrorR	(RR+R)((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pytremove_image'
s





cCsId
|j|
|g}|dg
7}||j
ƒ7}tjdd|Œ
dS(sýImport RBD volume from image file.

        Uses the command line import instead of librbd since rbd import
        command detects zeroes to preserve sparseness in the image.

        :base: Path to image file
        :name: Name of RBD volume
        s--pools--image-format=2RtimportN(R,RMRRU(RtbaseR+RL((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pytimport_image8
s	


csŠ‡f
d
†}i
dd6}tj
||
j||ƒ}|jddƒ
jƒ}|r†y||
j||ƒ
Wq†tjk
r‚


q†XndS(s3Destroy an RBD volume, retrying as needed.
        csÏy)tƒj
||
ƒ
tjd
tƒ
‚
Wnptjk
rX


ˆj|
tj	dt
ƒ

nDtjtjfk
r›


tj
tdƒ
i|
d6ˆjd6ƒ
n
X|dcd8<|ddk
rËtjƒ‚
ndS(	Ntretvaluet
ignore_errorss-rbd remove %(volume)s in pool %(pool)s failedR!R,tretriesi
i(RR“RtLoopingCallDoneR5RR•tremove_snapt
libvirt_utilstRESIZE_SNAPSHOT_NAMERt	ImageBusyR$R”R
R,(R*R!tretryctx(
R(sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyt_cleanup_volL
s











i
Rtintervali
N(RtFixedIntervalLoopingCallR*tstarttwaitRž(RR)R!R,R¤R£ttimert	timed_out((
RsX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyt_destroy_volumeI
s







cCs^t||j
ƒF}tƒj|jƒ
}x't|
|ƒD]}|j||ƒ
q:WWdQXdS(
N(R6R,RtlistR*tfilterR«(Rt	filter_fnR)tvolumesR!((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pytcleanup_volumesh
s



c
Csbt|ƒ
P}
|
j
jƒ}i|d
tjd6|dtjd6|dtjd6SWdQXdS(Ntkbttotaltkb_availtfreetkb_usedtused(R6R7tget_cluster_statsRtKi(RR)tstats((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyt
get_pool_infon
s





cCsytj
d
i|d6|
d6ƒ
t|t|
ƒ
d|ƒ
:}|j|ƒ

|ro|j|ƒ
ro|j|ƒ

nWdQXdS(s¿Create a snapshot of an RBD volume.

        :volume: Name of RBD object
        :name: Name of snapshot
        :pool: Name of pool
        :protect: Set the snapshot to "protected"
        s1creating snapshot(%(snap)s) on rbd image(%(img)s)RƒR‚R,N(R$R%RR†tcreate_snaptis_protected_snaptprotect_snap(RR!R+R,tprotectR((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyR»u
s	





c
Cs

t|t
|
ƒ
d
|ƒ
é}|g|jƒD]}|jddƒ^q.krÓ|j|ƒ
r¥|rt|j|ƒ

q¥|s¥tjtdƒ
i|d6|
d6ƒ
dSntj	di|d6|
d6ƒ
|j
|ƒ

n-|s
tjtdƒ
i|d6|
d6ƒ
nWdQXdS(	s
Removes a snapshot from an RBD volume.

        :volume: Name of RBD object
        :name: Name of snapshot
        :ignore_errors: whether or not to log warnings on failures
        :pool: Name of pool
        :force: Remove snapshot even if it is protected
        R,R+R?s?snapshot(%(name)s) on rbd image(%(img)s) is protected, skippingR‚Ns1removing snapshot(%(name)s) on rbd image(%(img)s)s1no snapshot(%(name)s) found on rbd image(%(img)s)(RR†t
list_snapsRxR¼tunprotect_snapR$R”R
R%RŸ(RR!R+RœR,tforceRRƒ((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyRŸ„
s

1






	



c
Cst||
ƒx}|g|j
ƒD]}|jd
dƒ^q"krqtjdi|d6|
d6ƒ
|j|ƒ

ntjd|ƒ
‚
WdQXdS(sRevert an RBD volume to its contents at a snapshot.

        :volume: Name of RBD object
        :name: Name of snapshot
        R+R?s5rolling back rbd image(%(img)s) to snapshot(%(snap)s)RƒR‚tsnapshot_idN(RR¿RxR$R%trollback_to_snapRtSnapshotNotFound(RR!R+RRƒ((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyRá
s
1
	

cCs,t||ƒ}|j
||
ƒ
Wd
QXd
S(s0A one-shot version of cleanup_volumes()
        N(R6R«(RR!R,R)((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pytdestroy_volume¯
s
N(RRRRRR&RMRgRrRsRR‡RŽRR‘R’RzR—RšR«R°RºR5R»RŸRÃRÅ(((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyR>ys0		
								

				
	(#teventletRt	six.movesR
RERtImportErrorRtoslo_logRtloggingtoslo_serializationRtoslo_serviceRt
oslo_utilsRRtnovaRt	nova.i18nRR	R
Rtnova.virt.libvirtR t	getLoggerRR$tobjectRRR6R>(((sX/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/storage/rbd_utils.pyt<module>s.
















+