ó
±EYc@s%
dZd
dl
Z
d
dlZd
dlZd
dlZd
dlmZ
d
dlmZ
d
dlm	Z

d
dlZd
dl
mZ
d
dl
mZ
d
dl
mZ
d
d	lmZ
d
d
lmZ
d
d	lmZ
e
jeƒ
ZejjZd„Zd„Zd
„Zdejf
d„ƒYZdS(s€Image cache manager.

The cache manager implements the specification at
http://wiki.openstack.org/nova-image-cache-management.

iÿÿÿÿN(
t	lockutils(
tprocessutils(
tlog(
t_LE(
t_LI(
t_LW(
tutils(
t
imagecachec

Cstj
|jd
ƒ
ƒ
jƒS(sG
Return a filename based on the SHA1 hash of a given image ID.

    Image files stored in the _base directory that match this pattern
    are considered for cleanup by the image cache manager. The cache
    manager considers the file to be in use if it matches an instance's
    image_ref, kernel_id or ramdisk_id property.
    sutf-8(thashlibtsha1tencodet	hexdigest(
timage_id((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pytget_cache_fname-sc
Cs'tj
j|ƒ
}
tjji
|
d
6S(smConstruct a filename for storing additional information about a base
    image.

    Returns a filename.
    timage(tostpathtbasenametCONFtlibvirttimage_info_filename_pattern(t	base_patht	base_file((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pytget_info_filename8s
	
c
CsUtj
ƒjd
}
tjji
di
|
d6d6}tj||ƒ}|rQtSt	S(s8Test if a given path matches the pattern for info files.isY([0-9a-f]{%(digest_size)d}|[0-9a-f]{%(digest_size)d}_sm|[0-9a-f]{%(digest_size)d}_[0-9]+)tdigest_sizeR(
RR	t
digestsizeRRRtretmatchtTruetFalse(RRtregexpt
m((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pytis_valid_info_fileDs
	




tImageCacheManagercBs¤eZ
d„Zd
„Zed„
Zd„Zd„Zd„Zd„Z	e
d„ƒ
Zed„
Z
d	„Zd
„Zd„Zd„Zd
„Zd„Zd„ZRS(c

Cs<tt
|ƒjƒ
tjjtjd
ƒ|_|j	ƒ
dS(Ntlocks(
tsuperR!t__init__RRtjoinRtinstances_patht	lock_patht_reset_state(
tself((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyR$Ts


c

CsUi|_t
ƒ|_t
ƒ|_t
ƒ|_g|_g|_g|_g|_d
S(s)Reset state variables used for each pass.N(	tused_imagestsettinstance_namestback_swap_imagestused_swap_imagestactive_base_filest	originalstremovable_base_filestunexplained_images(
R)((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyR(Ys	

	
	
	
cCsWtj
j|
|ƒ}tj
j|ƒ
rS|jj|ƒ

|rS|jj|ƒ

qSnd
S(s)Store a base image for later examination.N(RRR%tisfileR2tappendR0(R)tbase_dirtenttoriginaltentpath((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt_store_imagegs




cCs|
jd
ƒ
}t
|ƒ
dkr}|ddkr}t
|dƒ
dkr}|djƒr}tjd|
ƒ
|jj|
ƒ

q}ndS(s-Store base swap images for later examination.t
_iitswapi
s"Adding %s into backend swap imagesN(tsplittlentisdigittLOGtdebugR-tadd(R)R6tnames((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt_store_swap_imageos

"
&

cCsÌtj
ƒjd
}x²tj|
ƒ
D]¡}tjj|
|ƒ}t|ƒ
rMq#t|ƒ
|krx|j	|
|dt
ƒ

q#t|ƒ
|d
kr·||dkr·|j	|
|dtƒ

q#|j|ƒ

q#WdS(sÓScan base images in base_dir and call _store_image or
        _store_swap_image on each as appropriate. These methods populate
        self.unexplained_images, self.originals, and self.back_swap_images.
        iR7R:N(
RR	RRtlistdirRR%R R=R9RRRC(R)R5RR6R((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt_scan_base_imagesws



&
c
Cs…
g}
xx
tj
tjƒ
D]d
}||jkrtjd
|ƒ
tjjtj|dƒ}tjj	|ƒ
r}
tjd|ƒ
yt
j|ƒ
}Wn?tj
k
rÏ


tjj	|ƒ
sÉtjd|ƒ
qqЂn
Xtjdi|d6|d6ƒ
|rz
tjjtjtj|ƒ}||
kr.
|
j|ƒ

n||jkrw
tjtdƒ
i|d6|d6ƒ
|jj|ƒ

qw
qz
q}
qqW|
S(	s)List the backing images currently in use.s%s is a valid instance nametdisks%s has a disk files#Failed to get disk backing file: %ss.Instance %(instance)s is backed by %(backing)stinstancetbackingsdInstance %(instance)s is using a backing file %(backing)s which does not appear in the image service(RRDRR&R,R?R@RR%texistst
libvirt_utilstget_disk_backing_fileR
tProcessExecutionErrortimage_cache_subdirectory_nameR4R2twarningRtremove(R)tinuse_imagesR6t	disk_pathtbacking_filetbacking_path((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt_list_backing_imagesžs@











	


	


	


	





 
ccsÅtj
j|
|ƒ}tj
j|ƒ
r8|ttfV
ntj
j|
|d
ƒ}tj
j|ƒ
rt|ttfV
ntjd|ƒ
}x7|jD],}|j	|ƒ
}|r‘|ttfV
q‘q‘WdS(sl
Find the base file matching this fingerprint.

        Yields the name of the base file, a boolean which is True if the image
        is "small", and a boolean which indicates if this is a resized image.
        Note that it is possible for more than one yield to result from this
        check.

        If no base file is found, then nothing is yielded.
        t_sms
.*/%s_[0-9]+$N(
RRR%RIRRRtcompileR2R(R)R5tfingerprintRt	resize_retimgR((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt_find_base_fileÉs







c
CsXtj
j|ƒ
s,tjd
|ƒ
tdfStj
j|ƒ
}
tjƒ|
}t|fS(Ns#Cannot remove %s, it does not existi(	RRRIR?R@RtgetmtimettimeR(Rtmtimetage((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt_get_age_of_fileäs



c	sõˆjˆƒ
\}}|sd
St
jjˆƒ
d}tj|dtdˆjƒ
‡‡
‡fd†ƒ
}|ˆ
krtj	t
dƒ
ˆƒ
nd|ƒ
|rñy tj|dddˆjƒ

Wqñt
k
rí
}
tjd	i|d
6|d6ƒ
qñXnd
S(s6Remove a single swap or base file if it is old enough.NiÿÿÿÿtexternalR'cs¿ˆjˆƒ
\}}
|s(|
ˆ
kr,dSt
jtd
ƒ
ˆƒ
y?tjˆƒ

tˆƒ
}tjj|ƒ
r€tj|ƒ

nWn7t	k
rº
}
t
j
tdƒ
iˆd6|d6ƒ
n
XdS(NsRemoving base or swap file: %ss3Failed to remove %(base_file)s, error was %(error)sRterror(R_R?tinfoRRRORRRItOSErrorRaR(RIR^t	signaturet
e(RtmaxageR)(sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt_inner_remove_old_enough_file÷s










s)Base or swap file too young to remove: %stlock_file_prefixsnova-s3Failed to remove %(lock_file)s, error was %(error)st	lock_fileRa(R_RRR<RtsynchronizedRR'R?RbRRtremove_external_lock_fileRcR@(	R)RRftremove_lockRIR^RiRgRe((RRfR)sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt_remove_old_enough_fileïs$


! 







	

cCs#tj
}|j|
|d
tƒ

dS(s3Remove a single swap base file if it is old enough.RlN(Rt*remove_unused_original_minimum_age_secondsRmR(R)RRf((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt_remove_swap_file,
s	cCs;tj
j}|
|jkr'tj}n|j|
|ƒ
d
S(s.Remove a single base file if it is old enough.N(RRt)remove_unused_resized_minimum_age_secondsR0RnRm(R)RRf((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt_remove_base_file2
s

cCs˜
t}t
jtd
ƒ
i|
d6|d6ƒ
||jkrL|jj|ƒ

n|
|jkr
|j|
\}}}|dks‰|dkr
t}t
jtdƒ
i|
d6|d6|d6|d6ƒ
|jj	|ƒ

|s
t
j
tdƒ
i|
d6|d6d	j|ƒ
d
6ƒ
q
q
n|r”
|sQ
t
j
di|
d6|d6ƒ
|jj	|ƒ

q”
t
j
di|
d6|d6ƒ
tjj|ƒ
r”
tj|ƒ

q”
nd
S(s*Handle the checks for a single base image.s)image %(id)s at (%(base_file)s): checkingtidRis~image %(id)s at (%(base_file)s): in use: on this node %(local)d local, %(remote)d on other nodes sharing this instance storagetlocaltremotesgimage %(id)s at (%(base_file)s): warning -- an absent base file is in use! instances: %(instance_list)st
 t
instance_lists4image %(id)s at (%(base_file)s): image is not in uses0image %(id)s at (%(base_file)s): image is in useN(RR?RbRR2ROR*RR/R4RNRR%R@R1RRRIRJtupdate_mtime(R)timg_idRtimage_in_useRsRtt	instances((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt_handle_base_image:
s@
















	


	



cCs»tj
d
ƒ

xp|jD]e}tjj||ƒ}||jkrctjj|ƒ
rctj	|ƒ

q|j
r|j|ƒ

qqW|j|j}x$|D]}tjt
dƒ
|ƒ
q—WdS(NsVerify swap imagess>%s swap image was used by instance but no back files existing!(R?R@R-RRR%R.RIRJRwtremove_unused_base_imagesRoRNR(R)tcontextR5R6Rterror_imagesterror_image((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt_age_and_verify_swap_imagesn
s



!

	




cCsÄ
tj
d
ƒ

x¡|jD]–}tj|ƒ
jƒ}tj
di|d6|d6ƒ
xZ|j||ƒD]F}|\}}}	|j||ƒ
|rc|	rc|jj	|ƒ

qcqcWqW|j
ƒ}
x0|
D](}||jkrÄ|jj	|ƒ

qÄqÄWx7|jD],}tj
tdƒ
|ƒ
|jj	|ƒ

qúW|jrX
tjtdƒ
dj|jƒ
ƒ
n|jr³
tjtdƒ
dj|jƒ
ƒ
|jr³
x!|jD]}|j|ƒ

q–
Wq³
ntj
d	ƒ

dS(
NsVerify base imagess2Image id %(id)s yields fingerprint %(fingerprint)sRrRWsUnknown base file: %ssActive base files: %sRusRemovable base files: %ssVerification complete(R?R@R*RR	RRZR{R0R4RTR/R2RNRR1RbRR%R|Rq(R)R}t
all_instancesR5RYRWtresultRtimage_smallt
image_resizedtinuse_backing_imagesRS((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt_age_and_verify_cached_images}
s8



	












	

	

	

c
CsEtj
jtjtjƒ}
tj
j|
ƒ
sAtjd
|
ƒ
dS|
S(Ns.Skipping verification, no base directory at %s(	RRR%RR&RMRIR?R@(R)R5((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt	_get_base§
s


	


cCs|jƒ}|sdS|j
ƒ
|j|ƒ

|j|
|ƒ}|d
|_|d|_|d|_|j|
||ƒ
|j|
|ƒ
dS(NR*R,R.(	R‡R(REt_list_running_instancesR*R,R.R†R€(R)R}RR5trunning((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pytupdate»
s











(t__name__t
__module__R$R(RR9RCRERTRZtstaticmethodR_RRmRoRqR{R€R†R‡RŠ(((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyR!Ss 
				'	+	=			4		*	(t__doc__RRRR\toslo_concurrencyRR
toslo_logRtloggingt	nova.conftnovat	nova.i18nRRRRt	nova.virtRtnova.virt.libvirtRJt	getLoggerR‹R?tconfRR
RR R!(((sQ/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/imagecache.pyt<module>s(