ó
±EYc@s>
dd
lZdd
l
Z
ddlmZ
ddlmZ
ddlmZ
dd
l	Z	dd
l
ZddlmZ

ddlmZ
ddlmZ
ddlmZ
dd	lmZ
dd	lmZ
dd
lmZ
ejeƒ
ZejjZdZdZd
ZdZd
d„
Z!d„Z"d„Z#dej$f
d„ƒYZ%d
S(iÿÿÿÿN(
tprocessutils(
tlog(
t	fileutils(
t	exception(
t
_(
t_LE(
t_LI(
tutils(
tfstquobytetfiletnonetnativecCs~tj
|
ƒ

d
||
g}|r8|jd|gƒ

ntjd||
ƒ
tjdddg|Œ

tjtdƒ
|ƒ
dS(	s1Wraps execute calls for mounting a Quobyte volumes
mount.quobytes-cs(Mounting volume %s at mount point %s ...tcheck_exit_codeiisMounted volume: %sN(	Rtensure_treetextendtLOGtdebugRtexecutetinfoR(tvolumetmnt_baset
configfiletcommand((sU/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/quobyte.pytmount_volume+s


	


c
Csuytj
d
|ƒ
WnZtjk
rp
}

dtj|
ƒ
krWtjtdƒ
|ƒ
qqtj	tdƒ
|ƒ
n
XdS(s2Wraps execute calls for unmouting a Quobyte volumesumount.quobytesDevice or resource busys)The Quobyte volume at %s is still in use.s)Couldn't unmount the Quobyte Volume at %sN(
RRRtProcessExecutionErrortsixt	text_typeRterrorRR(Rtexc((sU/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/quobyte.pyt
umount_volume;s






c
Cs«d
dd|g}
ytj
|
Œ
WnCtjk
rh
}
tdƒ
i|d6|d6}tj|ƒ
‚
n
Xtj|tj	tj
Bƒs§tdƒ
|}tj|ƒ
‚
ndS(	s=Wraps execute calls for checking validity of a Quobyte volumetgetfattrs-nsquobyte.infosFThe mount %(mount_path)s is not a valid Quobyte volume. Error: %(exc)st
mount_pathRsFVolume is not writable. Please broaden the file permissions. Mount: %sN(RRRRRtnova_exceptiont
NovaExceptiontostaccesstW_OKtX_OKR(RRRtmsg((sU/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/quobyte.pytvalidate_volumeHs



	

	

tLibvirtQuobyteVolumeDrivercBsYeZ
dZd
„Zd„Zejdƒ
d„ƒ
Zejdƒ
d„ƒ
Zd„Z	RS(s;Class implements libvirt part of volume driver for Quobyte.c


Cs
tj
jS(
N(tCONFtlibvirttquobyte_mount_point_base(
tself((sU/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/quobyte.pyt_get_mount_point_base\s
cCsttt
|ƒj|
|ƒ}|
d
}t|_t|_t|_t	|_
|jddƒ|_|j
|
ƒ
|_|S(Ntdatatformattraw(tsuperR)t
get_configtSOURCE_PROTOCOLtsource_protocoltSOURCE_TYPEtsource_typetDRIVER_CACHEtdriver_cachet	DRIVER_IOt	driver_iotgett
driver_formatt_get_device_pathtsource_path(R-tconnection_infot	disk_infotconfR/((sU/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/quobyte.pyR3_s




	
	
	
	
tconnect_volumecCsÞ|
d
}|j|dƒ
}|j
|
ƒ
}tj|td|ƒ}|r±ytj|ƒ

Wq±tk
r­
}
|jtj	kr®t
}tjt
dƒ
|ƒ
t|ƒ

q®q±Xn|sÐt||tjjƒ
nt|ƒ

dS(sConnect the volume.R/texportt
@s;Fixing previous mount %s which was not unmounted correctly.N(t_normalize_exportt_get_mount_patht
libvirt_utilst
is_mountedR4R#tstattOSErrorterrnotENOTCONNtFalseRRRRRR*R+tquobyte_client_cfgR((R-R@RAR/tquobyte_volumeR tmountedR((sU/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/quobyte.pyRCms&



	











cCsc|j|
d
dƒ
}|j
|
ƒ
}tj|d|ƒrIt|ƒ

ntjtdƒ
|ƒ
dS(sDisconnect the volume.R/RDsquobyte@s-Trying to disconnected unmounted volume at %sN(RFRGRHRIRRRR(R-R@tdisk_devRPR ((sU/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/quobyte.pytdisconnect_volume‡s




cCs0td
}|
j
|ƒ
r,|
t|ƒ
}
n|
S(Ns://(R4t
startswithtlen(R-RDtprotocol((sU/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/quobyte.pyRF•s




(
t__name__t
__module__t__doc__R.R3RtsynchronizedRCRSRF(((sU/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/quobyte.pyR)Ys
		(&RLR#toslo_concurrencyRtoslo_logR
tloggingt
oslo_utilsRRt	nova.conftnovaRR!t	nova.i18nRRRRtnova.virt.libvirtRHtnova.virt.libvirt.volumeRt	getLoggerRWRRBR*R4R6R8R:tNoneRRR(t!LibvirtBaseFileSystemVolumeDriverR)(((sU/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/volume/quobyte.pyt<module>s.