ó
w=4\c@sg
dd
lZdd
l
Z
dd
lZdd
lZddlmZ
ddlmZmZ
yddlm	Z

Wn!ek
r


ddlm	Z

n
Xyddl
mZ
Wn!ek
rÅ


ddlmZ
n
XddlmZ
ddlmZ
ejdd	d
ddƒ
ejd
d	d
ddƒ
gZe
jeƒ
ZejZejedƒ
d„Zdef
d„ƒYZd
S(iÿÿÿÿN(
tThread(tQueuetEmpty(
tlog(
tcfg(
tutils(
t
qemuimagestoverride_blocktdefaulttcinderthelpsWby default block disk_type is mapped to cinder It can be override to lvm by this optiontcontego_staging_dirsVby default uses CONF.instances_path It can be override depending on user configurationtbackendscCsF|jd
ƒ
}x&|r7|jd
ƒ
}|
j
|ƒ

qW|jƒ
dS(Ni(treadtputtclose(touttqueuetline((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pytenqueue_output+s


	


tBackendcBsƒeZ
d„Zd
„Zd
d„
Zd
d„
Zd„Zd„Zd„Z	d„Z
d„Zd	„Zd
„Z
d„Zd„ZRS(c

CsEid
d6d
d6dd6dd6dd6d	d
6d	d6dd
6|_dS(NsAcontego.nova.extension.driver.backends.qcow2_backend.QCOW2Backendtfiletqcow2sCcontego.nova.extension.driver.backends.cinder_backend.CinderBackendR	s=contego.nova.extension.driver.backends.rdb_backend.RBDBackendtrbdtcephsEcontego.nova.extension.driver.backends.rbdboot_backend.RBDBootBackendtrbdboottcephboots@contego.nova.extension.driver.backends.cinder_backend.LVMBackendtlvm(
tBACKEND(
tself((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pyt__init__4s

cKs¢|
dkrtj
j}
n|jj|
ƒ
}|
sFtd|
ƒ
‚
n|jdƒ
}dj|d ƒ
}t|ƒ
}x!|dD]}t	||ƒ}qW||S(	NtblocktiscsiR	sUnknown backend type=%st
.iÿÿÿÿi
(sblockR scinder(
tCONFRRRtgettRuntimeErrortsplittjoint
__import__tgetattr(Rtbackendtkwargstbackend_class_nametpartstmodulet
backend_classtcomp((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pyR#Ls






c
CsdS(
N((Rt
instance_uuidtadditional_files((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pytconfigure_security_profile]s
c
CsdS(
N((RR0R1((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pytreset_security_profile`s
cKstd
ƒ
‚
dS(Ns,create_snapshot() method must be implemented(
tNotImplementedError(RtdevicesR*((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pytcreate_snapshotcs

cKstd
ƒ
‚
dS(Ns,delete_snapshot() method must be implemented(
R4(Rt	disk_infoR*((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pytdelete_snapshotgs

cKstd
ƒ
‚
dS(Ns0check_prev_snapshot() method must be implemented(
R4(RR7R*((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pytcheck_prev_snapshotks

cKstd
ƒ
‚
dS(Ns1update_snapshot_info() method must be implemented(
R4(RR7R*((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pytupdate_snapshot_infoos

cKstd
ƒ
‚
dS(Ns,update_snapshot() method must be implemented(
R4(RR7R*((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pytupload_snapshotss

c
	Cs½i}
td
dƒ}xw|D]o}|j
ƒjdƒ
r@qn|jdƒ
}t|ƒ
dkrt|dj
dƒ
j
dƒ
ƒ
|
|d	<qqWWdQX|
d
|
jd|
d
ƒ|
dfS(
Ns/etc/os-releaset
rt
#t
=ii
s

t
"itIDtID_LIKEt
VERSION_ID(topentstript
startswithR%tlentstrR#(Rtkargst
fRtvalue((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pytget_distro_versionws








7c
Cs
|jƒ\}
}}t
jjtjƒ
\}}t
jj|d
ƒ}x»|
jƒ|jƒD]£}t
jj|||d
ƒ}t
jj|ƒ
r“|St
jj|||jdƒ
dd
ƒ}t
jj|ƒ
rÑ|St
jj||d
ƒ}t
jj|ƒ
r\|Sq\WdS(Nsqemu-imgR!i(RKtostpathR%tsyst
executableR&texists(Rtspecifictlikestversiontvirtenv_pathtbinarytdistrot	qemu_path((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pytget_qemu_img_pathƒs 







	
cCs}d
}d}t
jj|
ƒ
}	t
jj|	dƒ}
x¦
|dksO|jƒrÛ
|jƒ}yg
y|jddƒ
}Wnytk
rÐ


t
jj	|
ƒ
r½y|j
ƒ
Wn


n
X|jƒ}ntj|
ƒ

w6nät
k
rï
}
tj|ƒ

nÅXt
jj	|
ƒ
r)
y|j
ƒ
Wn


n
X|jƒ}ntjd|ƒdkrG
w6ntjd|ƒjdƒ
}tjdi|d6|d	6t|ƒ
d
6ƒ

t|ƒ
}tj|
dt|ƒ
ƒ
tj|
ƒ

Wq6t
k
r×

}
q6Xq6W|jjƒ
|j}
|
ritjd|
ƒ

|
d
krd}n(di|
d6|jjƒd6|d6}tj|
d|ƒ
t
|ƒ
‚
ntj|
dƒ
dS(s! Utility method that updates a tracking file with information dury an image
            copy.

        Args:
            tracking_file (str): Path to the tracking file to update.
            process (process): Process handle of the sub process.
            update_queue (queue): Queue of file copy percentages from process.
            volume_path (str): Volume path used for logging.
            backup_image_file_path (str): Backup image path used for logging.
            cmd (str): Comand the process is executing. Used for logging.
        gt	cancelledttimeoutis\d+\.\d+isLcopying from %(backup_path)s to %(volume_path)s %(percentage)s %% completed
tbackup_pathtvolume_patht
percentages%s %% percentage complete
s
Result was %di÷ÿÿÿsUser initiated cancel requests7Execution error %(exit_code)d (%(stderr)s). cmd %(cmd)st	exit_codetstderrtcmds
Error: %s
s
Completed
N(tNoneRLRMtdirnameR&temptytpollR#RRPtkillt
contego_utilst
touch_filet	ExceptiontLOGt	exceptiontretsearchtgrouptdebugRGtfloattupdate_progresststdinRt
returncodeterrorR_R
(Rt
tracking_filetprocesstupdate_queueR\tbackup_image_file_pathR`R]tprocess_statusttracking_dirtcancel_filetoutputtext_returncodetmsg((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pytupdate_tracking_filesj


























	


	



	



	





cCs

|r?tj
j|ƒ
r?tj|ƒ
}|jdks?t‚
n|jƒ}dj|
ƒ
}t	j
d|ƒ

tj|
dtj
dtj
dtj
dd	d
tdtƒ
}tƒ}	tdtd
|j|	fƒ}
t|
_|
jƒ
|j|||	|||ƒ
dS(Nii@t
 s,_execute_qemu_img_and_track_progress cmd %s RqtstdoutR_tbufsizeiÿÿÿÿt	close_fdstshellttargettargsi
(RLRMRPRt
qemu_img_infotcluster_sizetAssertionErrorRXR&RiRnt
subprocesstPopentPIPEtTruetFalseR
RRRtdaemontstartR(Rtcmdspectcurr_snap_patht	qcow2filetprogress_tracker_patht
qcow2_infotqemu_img_binR`RuRtread_thread((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pyt$_execute_qemu_img_and_track_progressôs(



	
	
	


		

	


N(t__name__t
__module__RR#RaR2R3R6R8R9R:R;RKRXRR˜(((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pyR3s
										W( RLRkRNRŠt	threadingRR
Rtoslo_logRtloggingtImportErrortnova.openstack.commontoslo_configRtoslo.configtcontegoRRftcontego.nova.extension.driverRtStrOptRatbackend_optst	getLoggerR™RiR"t
register_optsRtobjectR(((sc/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/backends/backend.pyt<module>s4