在openstack中创建虚拟机的底层实现是nova使用了libvirt,代码在nova/virt/libvirt/driver.py。
#image_meta:镜像的相关内容,#injected_files:要注入到VM的文件 #network_info:网络相关信息,block_device_info:磁盘相关信息 def spawn(self, context, instance, image_meta, injected_files, admin_password, network_info=None, block_device_info=None): #确定客户机的磁盘映射关系 disk_info = blockinfo.get_disk_info(CONF.libvirt.virt_type, instance, block_device_info, image_meta) #创建VM的磁盘文件 self._create_image(context, instance, disk_info['mapping'], network_info=network_info, block_device_info=block_device_info, files=injected_files, admin_pass=admin_password) #综合各方面的信息,拼装一个define VM的XML文件 xml = self.to_xml(context, instance, network_info, disk_info, image_meta, block_device_info=block_device_info, write_to_disk=True) #向neutron请求IP,然后使用xml创建domain self._create_domain_and_network(context, xml, instance, network_info, block_device_info)下面将详细分析上述4个函数,比源代码略有删减
#virt_type: cpu_mode,一般为kvm,具体可参见该选项的注释 def get_disk_info(virt_type, instance, block_device_info=None, image_meta=None, rescue=False): #根据device_type和virt_type返回总线类型,如kvm和disk,则会返回virtio #cdrom和kvm,则会返回ide disk_bus = get_disk_bus_for_device_type(virt_type, image_meta, "disk") cdrom_bus = get_disk_bus_for_device_type(virt_type, image_meta, "cdrom") #确定怎样映射默认的disks到VM中,如root挂到/dev/vda等,还有swap, local等 mapping = get_disk_mapping(virt_type, instance, disk_bus, cdrom_bus, block_device_info, image_meta, rescue)
#准备磁盘文件 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): #判断是否从volume启动VM booted_from_volume = self._is_booted_from_volume( instance, disk_mapping) #根据images_type,如qcow2, RBD等,创建各种格式的镜像对应的类 def image(fname, image_type=CONF.libvirt.images_type): return self.image_backend.image(instance, fname + suffix, image_type) #创建raw格式的镜像对应的类 def raw(fname): return image(fname, image_type='raw') LOG.info(_('Creating image'), instance=instance) if not disk_images: disk_images = {'image_id': instance['image_ref'], 'kernel_id': instance['kernel_id'], 'ramdisk_id': instance['ramdisk_id']} if disk_images['kernel_id']: fname = imagecache.get_cache_fname(disk_images, 'kernel_id') #这里用到了上面定义的def raw(),其返回一个raw类型的类,cache()使用#fetch_image()完成镜像文件的kernel下载,关于镜像的下载详细情况可以参#考:http://blog.csdn.net/epugv/article/details/27970625 raw('kernel').cache(fetch_func=libvirt_utils.fetch_image, context=context, filename=fname, image_id=disk_images['kernel_id'], user_id=instance['user_id'], project_id=instance['project_id']) if disk_images['ramdisk_id']: fname = imagecache.get_cache_fname(disk_images, 'ramdisk_id') #完成ramdisk文件下载 raw('ramdisk').cache(fetch_func=libvirt_utils.fetch_image, context=context, filename=fname, image_id=disk_images['ramdisk_id'], user_id=instance['user_id'], project_id=instance['project_id']) # 创建临时磁盘,ephemeral disk指的是除了root disk和swap disk之外的ephemeral #空间 ephemeral_gb = instance['ephemeral_gb'] if 'disk.local' in disk_mapping: disk_image = image('disk.local') fn = functools.partial(self._create_ephemeral, fs_label='ephemeral0', os_type=instance["os_type"], is_block_dev=disk_image.is_block_dev) fname = "ephemeral_%s_%s" % (ephemeral_gb, os_type_with_default) size = ephemeral_gb * units.Gi disk_image.cache(fetch_func=fn, filename=fname, size=size, ephemeral_size=ephemeral_gb) #如果还有ephemeral disk,继续创建,label为'ephemeral%d' % idx for idx, eph in enumerate(driver.block_device_info_get_ephemerals( block_device_info)): disk_image = image(blockinfo.get_eph_disk(idx)) fn = functools.partial(self._create_ephemeral, fs_label='ephemeral%d' % idx, os_type=instance["os_type"], is_block_dev=disk_image.is_block_dev) size = eph['size'] * units.Gi fname = "ephemeral_%s_%s" % (eph['size'], os_type_with_default) disk_image.cache( fetch_func=fn, filename=fname, size=size, ephemeral_size=eph['size']) #创建swap disk if swap_mb > 0: size = swap_mb * units.Mi image('disk.swap').cache(fetch_func=self._create_swap, filename="swap_%s" % swap_mb, size=size, swap_mb=swap_mb) # OpenStack还可以使用Config Drive实现元数据的注入,但是在制作image时一 #定要安装cloud-init软件,否则无法实现元数据注入 # Config drive if configdrive.required_by(instance): LOG.info(_('Using config drive'), instance=instance) extra_md = {} if admin_pass: extra_md['admin_pass'] = admin_pass #提取instance matedata inst_md = instance_metadata.InstanceMetadata(instance, content=files, extra_md=extra_md, network_info=network_info) with configdrive.ConfigDriveBuilder(instance_md=inst_md) as cdb: configdrive_path = self._get_disk_config_path(instance) LOG.info(_('Creating config drive at %(path)s'), {'path': configdrive_path}, instance=instance) #将metadata写入实例所在的文件夹下的一个disk.config文件中 try: cdb.make_drive(configdrive_path) except processutils.ProcessExecutionError as e: with excutils.save_and_reraise_exception(): LOG.error(_('Creating config drive failed ' 'with error: %s'), e, instance=instance) #根据官方文档 -2 => disable, -1 => inspect (libguestfs only), 0 => #not partitioned, >0 => partition number # File injection only if needed elif inject_files and CONF.libvirt.inject_partition != -2: if booted_from_volume: LOG.warn(_('File injection into a boot from volume ' 'instance is not supported'), instance=instance) self._inject_data( instance, network_info, admin_pass, files, suffix)
def to_xml(self, context, instance, network_info, disk_info, image_meta=None, rescue=None, block_device_info=None, write_to_disk=False): # We should get image metadata every time for generating xml if image_meta is None: image_ref = instance['image_ref'] image_meta = compute_utils.get_image_metadata( context, self._image_api, image_ref, instance) msg = ('Start to_xml ' 'network_info=%(network_info)s ' 'disk_info=%(disk_info)s ' 'image_meta=%(image_meta)s rescue=%(rescue)s ' 'block_device_info=%(block_device_info)s' % {'network_info': network_info_str, 'disk_info': disk_info, 'image_meta': image_meta, 'rescue': rescue, 'block_device_info': block_device_info}) #返回guest的详细参数 conf = self.get_guest_config(instance, network_info, image_meta, disk_info, rescue, block_device_info) xml = conf.to_xml()#将详细参数使用etree.tostring()生产一个xml dom
def _create_domain_and_network(self, context, xml, instance, network_info, block_device_info=None, power_on=True, reboot=False, vifs_already_plugged=False): for vol in block_device_mapping: connection_info = vol['connection_info'] disk_info = blockinfo.get_info_from_bdm( CONF.libvirt.virt_type, vol) #挂载volume前与volume建立连接,如iscsi中的discover conf = self.volume_driver_method('connect_volume', connection_info, disk_info) #。。。。。。 launch_flags = events and libvirt.VIR_DOMAIN_START_PAUSED or 0 try: with self.virtapi.wait_for_instance_event( instance, events, deadline=timeout, error_callback=self._neutron_failed_callback): self.plug_vifs(instance, network_info)#向network注入VIF self.firewall_driver.setup_basic_filtering(instance, network_info) self.firewall_driver.prepare_instance_filter(instance, network_info) domain = self._create_domain(#调用libvirt的#defineXML () and #createWithFlags() xml, instance=instance, launch_flags=launch_flags, power_on=power_on) #应用防火墙 self.firewall_driver.apply_instance_filter(instance, network_info) #下面是错误处理,不表
Nova创建虚拟机的底层代码分析,布布扣,bubuko.com
原文:http://blog.csdn.net/epugv/article/details/38706263