ó
±EYc@s¶dd
lm
Z

ddlmZ
ddlZddlZddlm	Z	m
Z

ddlmZ
ddlmZ

ddlmZ
ejeƒ
ZejjZdejf
d„ƒYZdS(	iÿÿÿÿ(
tprocessutils(
tlogN(t_LEt_LW(
tutils(
tfstLibvirtNFSVolumeDrivercBsJeZ
dZd
„Zd„Zd„Zd„Zd„Zde	d„Z
RS(s7Class implements libvirt part of volume driver for NFS.c


Cs
tj
jS(
N(tCONFtlibvirttnfs_mount_point_base(
tself((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/nfs.pyt_get_mount_point_base s
cCs[tt
|ƒj|
|ƒ}d
|_|
dd|_|
djddƒ|_d|_|S(sReturns xml for libvirt.tfiletdatatdevice_pathtformattrawtnative(tsuperRt
get_configtsource_typetsource_pathtgett
driver_formatt	driver_io(R
tconnection_infot	disk_infotconf((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/nfs.pyR#s
	


	
cCs(|j|
ƒ

|j
|
ƒ
|
d
d<dS(sConnect the volume.R
RN(t_ensure_mountedt_get_device_path(R
RR((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/nfs.pytconnect_volume.s
cCsÏ|j|
ƒ
}yt
jd
|dtƒ

WnŸtjk
rÊ
}
|
dd}dtj|ƒ
ksvdtj|ƒ
kr‰tj	d|ƒ
qËdtj|ƒ
kr±tj	d	|ƒ
qËtj
td
ƒ
|ƒ
n
XdS(sDisconnect the volume.tumounttrun_as_rootR
texportsdevice is busystarget is busys!The NFS share %s is still in use.snot mounteds,The NFS share %s has already been unmounted.s!Couldn't unmount the NFS share %sN(t_get_mount_pathRtexecutetTrueRtProcessExecutionErrortsixt	text_typetLOGtdebugt	exceptionR(R
Rtdisk_devt
mount_pathtexcR!((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/nfs.pytdisconnect_volume5s







	

cCsb|
d
d}|j|
ƒ
}t
j||ƒs^|
d
jdƒ
}|j|||dtƒ

n|S(s$@type connection_info: dict
        R
R!toptionstensure(R"t
libvirt_utilst
is_mountedRt
_mount_nfsR$(R
Rt
nfs_exportR,R/((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/nfs.pyRGs




cCsítj
d
d|
ƒ
dddg}tjjdk	rP|jdtjjgƒ

n|ro|j|jdƒ
ƒ

n|j||
gƒ

ytj
dt|Œ

WnMt	j
k
rè
}
|râd	tj|ƒ
krât
jtd
ƒ
|ƒ
qé‚n
XdS(sMount nfs export to mount path.tmkdirs-ptmounts-ttnfss-ot
 R salready mounteds%s is already mountedN(RR#RRtnfs_mount_optionstNonetextendtsplitR$RR%R&R'R(twarningR(R
R,t	nfs_shareR/R0tnfs_cmdR-((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/nfs.pyR3Qs








N(t__name__t
__module__t__doc__RRRR.RR:tFalseR3(((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/nfs.pyRs
					
(toslo_concurrencyRtoslo_logR
tloggingR&t	nova.conftnovat	nova.i18nRRRtnova.virt.libvirtR1tnova.virt.libvirt.volumeRt	getLoggerR@R(RRt!LibvirtBaseFileSystemVolumeDriverR(((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/nfs.pyt<module>s