这里只关注Nova virt的spawn函数，glance、nova后端为ceph
nova/virt/libvirt/driver.py
def spawn(self, context, instance, image_meta, injected_files,
admin_password, network_info=None, block_device_info=None):
image_meta = objects.ImageMeta.from_dict(image_meta)
disk_info = blockinfo.get_disk_info(CONF.libvirt.virt_type,
instance,
image_meta,
block_device_info)
self._create_image(context, instance, # 虚拟机拉取glance image
disk_info[‘mapping‘],
network_info=network_info,
block_device_info=block_device_info,
files=injected_files,
admin_pass=admin_password)
xml = self._get_guest_xml(context, instance, network_info,
disk_info, image_meta,
block_device_info=block_device_info,
write_to_disk=True)
self._create_domain_and_network(context, xml, instance, network_info,
disk_info,
block_device_info=block_device_info)
LOG.debug("Instance is running", instance=instance)
def _wait_for_boot():
"""Called at an interval until the VM is running."""
state = self.get_info(instance).state
if state == power_state.RUNNING:
LOG.info(_LI("Instance spawned successfully."),
instance=instance)
raise loopingcall.LoopingCallDone()
timer = loopingcall.FixedIntervalLoopingCall(_wait_for_boot) # loopingcall等待虚拟机running的状态
timer.start(interval=0.5).wait()
nova/virt/libvirt/driver.py
def _create_image(self, context, instance,
disk_mapping, suffix=‘‘,
disk_images=None, network_info=None,
block_device_info=None, files=None,
admin_pass=None, inject_files=True,
fallback_from_host=None):
booted_from_volume = self._is_booted_from_volume( # 判断是不是boot_from_volume，boot_from_volume没有base image
instance)
if not booted_from_volume:
root_fname = imagecache.get_cache_fname(disk_images, ‘image_id‘)
size = instance.root_gb * units.Gi
if size == 0 or suffix == ‘.rescue‘:
size = None
backend = image(‘disk‘)
if backend.SUPPORTS_CLONE: # 只有backend为rbd的才支持clone操作
def clone_fallback_to_fetch(*args, **kwargs):
try:
backend.clone(context, disk_images[‘image_id‘]) # clone操作在nova/virt/libvirt/imagebackend.py中class Rbd下
except exception.ImageUnacceptable: # 除image格式为raw和iso外的格式都抛异常
libvirt_utils.fetch_image(*args, **kwargs)
fetch_func = clone_fallback_to_fetch
else:
fetch_func = libvirt_utils.fetch_image
self._try_fetch_image_cache(backend, fetch_func, context, # 进入_try_fetch_image_cache函数
root_fname, disk_images[‘image_id‘],
instance, size, fallback_from_host)
nova/virt/libvirt/imagebackend.py
def clone(self, context, image_id_or_uri):
image_meta = IMAGE_API.get(context, image_id_or_uri,
include_locations=True)
locations = image_meta[‘locations‘]
LOG.debug(‘Image locations are: %(locs)s‘ % {‘locs‘: locations})
if image_meta.get(‘disk_format‘) not in [‘raw‘, ‘iso‘]: # image格式判断, 所以ceph image格式最好是raw，这样走的ceph的clone
reason = _(‘Image is not raw format‘)
raise exception.ImageUnacceptable(image_id=image_id_or_uri,
reason=reason)
for location in locations:
if self.driver.is_cloneable(location, image_meta):
return self.driver.clone(location, self.rbd_name) # 调用nova/virt/libvirt/storage/rbd_utils.py
reason = _(‘No image locations are accessible‘)
raise exception.ImageUnacceptable(image_id=image_id_or_uri,
reason=reason)
nova/virt/libvirt/driver.py
def _try_fetch_image_cache(self, image, fetch_func, context, filename,
image_id, instance, size,
fallback_from_host=None):
try:
image.cache(fetch_func=fetch_func, # 进入cache函数
context=context,
filename=filename,
image_id=image_id,
user_id=instance.user_id,
project_id=instance.project_id,
size=size)
except exception.ImageNotFound:
if not fallback_from_host:
raise
LOG.debug("Image %(image_id)s doesn‘t exist anymore "
"on image service, attempting to copy "
"image from %(host)s",
{‘image_id‘: image_id, ‘host‘: fallback_from_host},
instance=instance)
def copy_from_host(target, max_size):
libvirt_utils.copy_image(src=target,
dest=target,
host=fallback_from_host,
receive=True)
image.cache(fetch_func=copy_from_host,
filename=filename)
nova/virt/libvirt/imagebackend.py
def cache(self, fetch_func, filename, size=None, *args, **kwargs):
"""Creates image from template.
Ensures that template and image not already exists.
Ensures that base directory exists.
Synchronizes on template fetching.
:fetch_func: Function that creates the base image
Should accept `target` argument.
:filename: Name of the file in the image directory
:size: Size of created image in bytes (optional)
"""
@utils.synchronized(filename, external=True, lock_path=self.lock_path)
def fetch_func_sync(target, *args, **kwargs):
# The image may have been fetched while a subsequent
# call was waiting to obtain the lock.
if not os.path.exists(target): # 如果不存在base image的话
fetch_func(target=target, *args, **kwargs) # fetch_func是clone_fallback_to_fetch
base_dir = os.path.join(CONF.instances_path,
CONF.image_cache_subdirectory_name)
if not os.path.exists(base_dir):
fileutils.ensure_tree(base_dir)
base = os.path.join(base_dir, filename)
if not self.check_image_exists() or not os.path.exists(base):
self.create_image(fetch_func_sync, base, size, base image如果不存在的话，进入create_image
*args, **kwargs)
if (size and self.preallocate and self._can_fallocate() and
os.access(self.path, os.W_OK)):
utils.execute(‘fallocate‘, ‘-n‘, ‘-l‘, size, self.path)
nova/virt/libvirt/imagebackend.py
def create_image(self, prepare_template, base, size, *args, **kwargs):
if not self.check_image_exists():
prepare_template(target=base, max_size=size, *args, **kwargs) # prepare_template这里是fetch_func_sync
# prepare_template() may have cloned the image into a new rbd
# image already instead of downloading it locally
if not self.check_image_exists(): # 如果走的是rbd clone操作，这里就不会用rbd import了
self.driver.import_image(base, self.rbd_name)
self.verify_base_size(base, size)
if size and size > self.get_disk_size(self.rbd_name):
self.driver.resize(self.rbd_name, size)
总结： nova、glance后端为ceph，raw格式的image没有base image， qcow2格式还是有base image的。
时间： 2024-10-25 06:08:56