ó
w=4\c@s

dZd
dl
Z
d
dlZd
dlZd
dlZd
dlmZ
d
dlZd
dlm	Z	
d
dl
mZ
d
dlmZ
d
dlmZ
ej
dƒ
Zd	„Zd
dd„ƒYZeƒZdZeƒZed
„
Zd„Zd„Zdef
d„ƒYZdS(s*Support for mounting images with qemu-nbd.iÿÿÿÿN(
tLock(
tevent(
t
subprocess(
tgreenthread(
tpoolss	nbd[0-9]+c
Gst|d
ƒ
S(Ni(
tstr(
targs((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyt
_s
tlogc
Bs5eZ
d„Zd
„Zd„Zd„Zd„ZRS(c
Gs
|
d
GHdS(Ni((tselftarg((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pytinfo$s
c
Gs
|
d
GHdS(Ni((R	R
((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyt	exception's
c
Gs
|
d
GHdS(Ni((R	R
((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyterror*s
c
Gs
|
d
GHdS(Ni((R	R
((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pytdebug-s
c
Gs
|
d
GHdS(Ni((R	R
((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pytcritical0s
(t__name__t
__module__RRR
RR(((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyR#s

				i
c
s‡f
d
†}
|
S(sSynchronization decorator.c
s‡‡
fd
†}
|
S(Ncs-ˆ
jƒ
zˆ||
ŽSWdˆ
j
ƒ
XdS(
N(tacquiretrelease(Rtkw(t
ftlock(sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pytnew_function=s



((RR(
R(
Rsj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pytwrap<s
((RR((
Rsj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pytsynchronized:scOs |
jd
dƒ}|
jddg
ƒ}t}t|tƒrO|}dg
}nt|tƒrj|g
}n|
jdtƒ}|
jddƒ}|
jdtƒ}|
jdtƒ}t|
ƒ
rÑtd	|
ƒ
‚
nd
g
t	|ƒ
}t
t|ƒ}x¦
|dkr›|d8}z{
y
tj
tdƒ
dj|ƒ
ƒ

tj}	tj|d
|	d|	d|	dtd|ƒ
}
d}|dk	rŒ
|
j|ƒ
}n|
jƒ}|
jjƒ
|
j}|rtj
tdƒ
|ƒ

|r||kr|\}
}td|d|
d|ddj|ƒ
ƒ‚
qn|ddfSWnZtk
r…


|sE‚q†tj
tdƒ
|ƒ

|r†tjtjddƒdƒ

q†n
XWdtjdƒ

XqöWdS(Nt
process_inputtcheck_exit_codeitdelay_on_retrytattemptsi
trun_as_roottshells-Got unknown keyword args to utils.execute: %rtsudosRunning cmd (subprocess): %st
 tstdintstdouttstderrt	close_fdss
Result was %st	exit_codetcmdts%r failed. Retrying.iiÈgY@(tpoptNonetFalset
isinstancetbooltinttTruetlentExceptontlisttmapRtLOGRRtjoinRtPIPEtPopentcommunicateR"tcloset
returncodet	ExceptionRtsleeptrandomtrandint(R'tkwargsRRtignore_exit_codeRRRRt_PIPEtobjtresultt_returncodeR#R$((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pytexecuteGsh



















 
	





	





	















(cOs~|
jd
t
ƒ}yt||
Ž\}}t
}Wntk
rJ


t}n
X|rt|rt|rttj|ƒ

d}n||fS(sš

    A wrapper around execute() to more easily handle warnings and errors.

    Returns an (out, err) tuple of strings containing the output of
    the command's stdout and stderr.  If 'err' is not empty then the
    command can be considered to have failed.

    :discard_warnings   True | False. Defaults to False. If set to True,
                        then for succeeding commands, stderr is cleared

    tdiscard_warningsR((R)R+RER;R/R4R(RR?RFtoutterrtfailed((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyttrycmd†s








	tNbdMountcBsteZ
dZd
Zddd„Zd„Zd„Zd„Ze	ƒd„ƒ
Z
d„Zd„Zd	„Z
d
„ZRS(sqemu-nbd support disk images.tnbdcCsV|
|_||_
||_d
|_t|_|_|_|_||_	|_
dS(NR((timaget	partitiont	mount_dirR
R+tlinkedtmappedtmountedt
automappedtdevicet
mapped_device(R	RMRORNRT((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyt__init__¦s	
	
		
c

Cstt
jtjd
ƒ
ƒS(sDetect nbd device files.s/sys/block/(tfiltert
NBD_DEVICE_REtmatchtostlistdir(
R	((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyt_detect_nbd_devices´scCs€xf|
D]^}tj
jtj
jd
|dƒƒ
stj
jd|ƒ
sK|Stjtdƒ
|ƒ

qqWtjtdƒ
ƒ

dS(Ns/sys/block/tpids/var/lock/qemu-nbd-%ssBNBD error - previous umount did not cleanup /var/lock/qemu-nbd-%s.sNo free nbd devices(	RZtpathtexistsR5R4R
RtwarningR*(R	tdevicesRT((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyt_find_unused¸s


$




c
CsŒtj
jd
ƒ
s8tjtdƒ
ƒ

tdƒ
|_dS|jƒ}
tj	|
ƒ

|j
|
ƒ
}|sytdƒ
|_dStj
jd|ƒS(Ns/sys/block/nbd0snbd module not loadeds"nbd unavailable: module not loadedsNo free nbd devicess/dev(RZR^R_R4R
RR*R\R=tshuffleRbR5(R	RaRT((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyt
_allocate_nbdÃs









c
Csq
|jƒ}
|
st
Stjd
i|
d6|jd6ƒ

tdd|
|jdtƒ
\}}|r“tdƒ
||_tj	tdƒ
|jƒ

t
Sd	t
jj|
ƒ
}x¯t
tƒ
D]2}t
jj|ƒ
rÛ|
|_Pntjd
ƒ

q¶Wtdƒ
|
|_tj	tdƒ
|jƒ

tdd|
dtƒ
\}}|rW
tjtd
ƒ
|ƒ

nt
Sd|_t|_tS(Ns&Get nbd device %(dev)s for %(imgfile)stdevtimgfilesqemu-nbds-cRsqemu-nbd error: %ssNBD mount error: %ss/sys/block/%s/pidi
snbd device %s did not show ups-ds6Detaching from erroneous nbd device returned error: %sR((RdR+R4RRMRJR/RR
RRZR^tbasenametrangettimeout_nbdR_RTttimeR<R`RP(R	RTt_outRHtpidfilet_i((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyt_inner_get_devÒs8

	









	







	
	
c
Cs‚tjƒ}
|j
ƒ}xc|s}tjtd
ƒ
ƒ

tjdƒ

tjƒ|
tkrntjtdƒ
ƒ

tS|j
ƒ}qWt	S(s1Some implementations need to retry their get_dev.s2Device allocation failed. Will retry in 2 seconds.is0Device allocation failed after repeated retries.(
RjRnR4RRR<RiR`R+R/(R	t
start_timeRT((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyt_get_dev_retry_helperûs

	






c


Cs
|jƒS(
sRetry requests for NBD devices.(
Rp(
R	((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pytget_dev

sc

CsS|js
dSt
jd
|jƒ

tjdd|jdtƒ

t|_d|_dS(NsRelease nbd device %ssqemu-nbds-dR(	RPR4RRTtutilsRER/R+R*(
R	((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyt	unget_dev
s
	



	
c

Cs,|jr(t
jd
d|jdtƒ

ndS(sflush NBD block device buffer.tblockdevs--flushbufsRN(RTRrRER/(
R	((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyt	flush_dev
s	

N(RRt__doc__tmodeR*RVR\RbRdRRnRpRqRsRu(((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyRK¢s

			)			((RvRZR=treRjt	threadingRRteventletR
teventlet.greenRRtcompileRXRRR4RitworkloadlockRRERJtobjectRK(((sj/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/filemanager_scripts/nbd.pyt<module>s(







		
	
	?