1. nova-api接收到request
在/etc/nova/api-paste.ini中，是这样配置nova v2的
[app:osapi_compute_app_v2]
paste.app_factory = nova.api.openstack.compute:APIRouter.factory在/usr/lib/python2.7/dist-packages/nova/api/openstack/compute/__init__.py中
class APIRouter(nova.api.openstack.APIRouter):中的
from nova.api.openstack.compute import servers
def _setup_routes(self, mapper, ext_mgr, init_only): …… self.resources['servers'] = servers.create_resource(ext_mgr) mapper.resource("server", "servers", controller=self.resources['servers'], collection={'detail': 'GET'}, member={'action': 'POST'})……
对于发送给/servers的POST的请求，是发给controller的。
在/usr/lib/python2.7/dist-packages/nova/api/openstack/compute/servers.py中有下面的函数
def create_resource(ext_mgr):
return wsgi.Resource(Controller(ext_mgr))class Controller(wsgi.Controller):
@wsgi.response(202) @wsgi.serializers(xml=FullServerTemplate) @wsgi.deserializers(xml=CreateDeserializer) def create(self, req, body): ……接收到的request的格式如下：
{"server": {"name": "world", "imageRef": "6a1489cb-5905-4f97-ae8b-012770818213", "availability_zone": "nova", "key_name": "153key", "flavorRef": "2", "OS-DCF:diskConfig": "AUTO", "max_count": 1, "min_count": 1, "networks": [{"uuid": "a29561e9-2f32-4765-a0f8-306b870f780b"}], "security_groups": [{"name": "default"}]}}
然后开始解析这个request，得到
- password: 如果request中有的解析出，没有则随机generate一个
- name
- image_uuid
- personality： 从中得到config_drive或者injected_files
- security_groups
- requested_networks
- flavor_id
- key_name
- user_data
- availability_zone
- block_device_mapping
- min_count
- max_count
- auto_disk_config：是否自动配置硬盘到flavor指定的大小，OS-DCF，auto_disk_config
- scheduler_hints：为scheduler提供参数
最终调用
(instances, resv_id) = self.compute_api.create(context,
inst_type, image_uuid, display_name=name, display_description=name, key_name=key_name, metadata=server_dict.get('metadata', {}), access_ip_v4=access_ip_v4, access_ip_v6=access_ip_v6, injected_files=injected_files, admin_password=password, min_count=min_count, max_count=max_count, requested_networks=requested_networks, security_group=sg_names, user_data=user_data, availability_zone=availability_zone, config_drive=config_drive, block_device_mapping=block_device_mapping, auto_disk_config=auto_disk_config, scheduler_hints=scheduler_hints, legacy_bdm=legacy_bdm)这一调用调用到/usr/lib/python2.7/dist-packages/nova/compute/api.py中
class API(base.Base):
@hooks.add_hook("create_instance")
def create(self, context, instance_type, image_href, kernel_id=None, ramdisk_id=None, min_count=None, max_count=None, display_name=None, display_description=None, key_name=None, key_data=None, security_group=None, availability_zone=None, user_data=None, metadata=None, injected_files=None, admin_password=None, block_device_mapping=None, access_ip_v4=None, access_ip_v6=None, requested_networks=None, config_drive=None, auto_disk_config=None, scheduler_hints=None, legacy_bdm=True): …… return self._create_instance( context, instance_type, image_href, kernel_id, ramdisk_id, min_count, max_count, display_name, display_description, key_name, key_data, security_group, availability_zone, user_data, metadata, injected_files, admin_password, access_ip_v4, access_ip_v6, requested_networks, config_drive, block_device_mapping, auto_disk_config, scheduler_hints=scheduler_hints, legacy_bdm=legacy_bdm)API的_create_instance的函数
def _create_instance(self, context, instance_type,
image_href, kernel_id, ramdisk_id, min_count, max_count, display_name, display_description, key_name, key_data, security_groups, availability_zone, user_data, metadata, injected_files, admin_password, access_ip_v4, access_ip_v6, requested_networks, config_drive, block_device_mapping, auto_disk_config, reservation_id=None, scheduler_hints=None, legacy_bdm=True):- _check_and_transform_bdm
- _provision_instances：在数据库中创建instance对象create_db_entry_for_new_instance，将状态设为vm_states.BUILDING
- _build_filter_properties：从scheduler_hints中得到filter_properties['instance_type']，filter_properties['force_hosts']，filter_properties['force_nodes']
- _update_instance_group：从scheduler_hints得到'group'，将instance加入group
- _record_action_start:instance_actions.CREATE
- self.compute_task_api.build_instances：调用conductor.ComputeTaskAPI()
/usr/lib/python2.7/dist-packages/nova/conductor/api.py中
class ComputeTaskAPI(object):
def build_instances(self, context, instances, image, filter_properties, admin_password, injected_files, requested_networks, security_groups, block_device_mapping, legacy_bdm=True): self.conductor_compute_rpcapi.build_instances(context, instances=instances, image=image, filter_properties=filter_properties, admin_password=admin_password, injected_files=injected_files, requested_networks=requested_networks, security_groups=security_groups, block_device_mapping=block_device_mapping, legacy_bdm=legacy_bdm)conductor_compute_rpcapi指向nova.conductor.rpcapi.ComputeTaskAPI()
def build_instances(self, context, instances, image, filter_properties,
admin_password, injected_files, requested_networks, security_groups, block_device_mapping, legacy_bdm=True): image_p = jsonutils.to_primitive(image) cctxt = self.client.prepare(version='1.5') cctxt.cast(context, 'build_instances', instances=instances, image=image_p, filter_properties=filter_properties, admin_password=admin_password, injected_files=injected_files, requested_networks=requested_networks, security_groups=security_groups, block_device_mapping=block_device_mapping, legacy_bdm=legacy_bdm)这是一个RPC调用，最终能够调用到/usr/lib/python2.7/dist-packages/nova/conductor/manager.py的class ConductorManager(manager.Manager)
2. nova-conductor
def build_instances(self, context, instances, image, filter_properties,
admin_password, injected_files, requested_networks, security_groups, block_device_mapping, legacy_bdm=True): request_spec = scheduler_utils.build_request_spec(context, image, instances) # NOTE(alaski): For compatibility until a new scheduler method is used. request_spec.update({'block_device_mapping': block_device_mapping, 'security_group': security_groups}) self.scheduler_rpcapi.run_instance(context, request_spec=request_spec, admin_password=admin_password, injected_files=injected_files, requested_networks=requested_networks, is_first_time=True, filter_properties=filter_properties, legacy_bdm_in_spec=legacy_bdm)它调用/usr/lib/python2.7/dist-packages/nova/scheduler/rpcapi.py中class SchedulerAPI(object):
def run_instance(self, ctxt, request_spec, admin_password,
injected_files, requested_networks, is_first_time, filter_properties, legacy_bdm_in_spec=True): msg_kwargs = {'request_spec': request_spec, 'admin_password': admin_password, 'injected_files': injected_files, 'requested_networks': requested_networks, 'is_first_time': is_first_time, 'filter_properties': filter_properties, 'legacy_bdm_in_spec': legacy_bdm_in_spec} cctxt = self.client.prepare() cctxt.cast(ctxt, 'run_instance', **msg_kwargs)这是一个RPC调用，最终调用到/usr/lib/python2.7/dist-packages/nova/scheduler/manager.py的class SchedulerManager(manager.Manager):
3. nova-scheduler
def run_instance(self, context, request_spec, admin_password,
injected_files, requested_networks, is_first_time, filter_properties, legacy_bdm_in_spec=True): return self.driver.schedule_run_instance(context, request_spec, admin_password, injected_files, requested_networks, is_first_time, filter_properties, legacy_bdm_in_spec)scheduler的driver我们在nova.conf中配置如下：
#scheduler
compute_scheduler_driver=nova.scheduler.filter_scheduler.FilterScheduler/usr/lib/python2.7/dist-packages/nova/scheduler/filter_scheduler.py的class FilterScheduler(driver.Scheduler):
def schedule_run_instance(self, context, request_spec,
admin_password, injected_files, requested_networks, is_first_time, filter_properties, legacy_bdm_in_spec):- instance_uuids = request_spec.get('instance_uuids')所有instance的id
- weighed_hosts = self._schedule(context, request_spec, filter_properties, instance_uuids)
- for num, instance_uuid in enumerate(instance_uuids):
- weighed_host = weighed_hosts.pop(0)
- self._provision_resource(context, weighed_host, request_spec, filter_properties, requested_networks, injected_files, admin_password,is_first_time,instance_uuid=instance_uuid,legacy_bdm_in_spec=legacy_bdm_in_spec)
_provision_resource调用
self.compute_rpcapi.run_instance(context,
instance=updated_instance, host=weighed_host.obj.host, request_spec=request_spec, filter_properties=filter_properties, requested_networks=requested_networks, injected_files=injected_files, admin_password=admin_password, is_first_time=is_first_time, node=weighed_host.obj.nodename, legacy_bdm_in_spec=legacy_bdm_in_spec)调用/usr/lib/python2.7/dist-packages/nova/compute/rpcapi.py的class ComputeAPI(object):
def run_instance(self, ctxt, instance, host, request_spec,
filter_properties, requested_networks, injected_files, admin_password, is_first_time, node=None, legacy_bdm_in_spec=True): # NOTE(russellb) Havana compat version = self._get_compat_version('3.0', '2.37') instance_p = jsonutils.to_primitive(instance) msg_kwargs = {'instance': instance_p, 'request_spec': request_spec, 'filter_properties': filter_properties, 'requested_networks': requested_networks, 'injected_files': injected_files, 'admin_password': admin_password, 'is_first_time': is_first_time, 'node': node, 'legacy_bdm_in_spec': legacy_bdm_in_spec}cctxt = self.client.prepare(server=host, version=version)
cctxt.cast(ctxt, 'run_instance', **msg_kwargs)这是一个RPC调用，最终调用/usr/lib/python2.7/dist-packages/nova/compute/manager.py的class ComputeManager(manager.Manager)
4. nova-compute
def run_instance(self, context, instance, request_spec,
filter_properties, requested_networks, injected_files, admin_password, is_first_time, node, legacy_bdm_in_spec): self._run_instance(context, request_spec, filter_properties, requested_networks, injected_files, admin_password, is_first_time, node, instance, legacy_bdm_in_spec)def _run_instance(self, context, request_spec,
filter_properties, requested_networks, injected_files, admin_password, is_first_time, node, instance, legacy_bdm_in_spec): instance, network_info = self._build_instance(context, request_spec, filter_properties, requested_networks, injected_files, admin_password, is_first_time, node, instance, image_meta, legacy_bdm_in_spec)- security_groups = request_spec.get('security_group')
- node = self.driver.get_available_nodes(refresh=True)[0]
- bdms = block_device_obj.BlockDeviceMappingList.get_by_instance_uuid(context, instance['uuid'])
- injected_files = self._decode_files(injected_files)
- rt = self._get_resource_tracker(node)
- with rt.instance_claim(context, instance, limits):
- macs = self.driver.macs_for_instance(instance)
- dhcp_options = self.driver.dhcp_options_for_instance(instance)
- network_info = self._allocate_network(context, instance, requested_networks, macs, security_groups, dhcp_options)
- self._instance_update( context, instance['uuid'], vm_state=vm_states.BUILDING, task_state=task_states.BLOCK_DEVICE_MAPPING)
- self._default_block_device_names(context, instance, image_meta, bdms)
- block_device_info = self._prep_block_device(context, instance, bdms)
- instance = self._spawn(context, instance, image_meta, network_info, block_device_info, injected_files, admin_password, set_access_ip=set_access_ip)
4.1. 配置network
_allocate_network中，状态变成Networking
instance = self._instance_update(context, instance['uuid'],
vm_state=vm_states.BUILDING, task_state=task_states.NETWORKING, expected_task_state=[None])return nova.network.model.NetworkInfoAsyncWrapper(
self._allocate_network_async, context, instance, requested_networks, macs, security_groups, is_vpn, dhcp_options)def _allocate_network_async(self, context, instance, requested_networks,
macs, security_groups, is_vpn, dhcp_options): nwinfo = self.network_api.allocate_for_instance( context, instance, vpn=is_vpn, requested_networks=requested_networks, macs=macs, security_groups=security_groups, dhcp_options=dhcp_options)调用network_api，调用neutron来创建network，nova.network.neutronv2.api.API
调用/usr/lib/python2.7/dist-packages/nova/network/neutronv2/api.py的allocate_for_instance函数
- neutron = neutronv2.get_client(context)
- nets = self._get_available_networks(context, instance['project_id'], net_ids)
- (Pdb) p nets [{u'status': u'ACTIVE', u'subnets': [u'bd652c3e-005e-4985-b65e-576c3045e890'], u'name': u'openstack-net', u'admin_state_up': True, u'tenant_id': u'8efa4856fe4b4aa0b6dcf05dc66d4efa', u'router:external': False, u'shared': False, u'id': u'a29561e9-2f32-4765-a0f8-306b870f780b'}]
- user_security_groups = neutron.list_security_groups(**search_opts).get('security_groups')
- (Pdb) p security_groups [u'default']
- self._populate_neutron_extension_values(context, instance, port_req_body)
- (Pdb) p port_req_body {'port': {'device_owner': u'compute:nova', 'device_id': u'3a5cd5d4-2676-447b-bab4-6acf21feacd6'}}
- RESP:{'status': '200', 'content-length': '3703', 'content-location': ', 'date': 'Mon, 02 Jun 2014 20:52:37 GMT', 'content-type': 'application/json; charset=UTF-8', 'x-openstack-request-id': 'req-518cd143-e3a5-4f5d-a71b-32b19d69bf2a'} {"extensions": [{"updated": "2012-10-05T10:00:00-00:00", "name": "security-group", "links": [], "namespace": ", "alias": "security-group", "description": "The security groups extension."}, {"updated": "2013-02-07T10:00:00-00:00", "name": "L3 Agent Scheduler", "links": [], "namespace": ", "alias": "l3_agent_scheduler", "description": "Schedule routers among l3 agents"}, {"updated": "2013-03-28T10:00:00-00:00", "name": "Neutron L3 Configurable external gateway mode", "links": [], "namespace": ", "alias": "ext-gw-mode", "description": "Extension of the router abstraction for specifying whether SNAT should occur on the external gateway"}, {"updated": "2014-02-03T10:00:00-00:00", "name": "Port Binding", "links": [], "namespace": ", "alias": "binding", "description": "Expose port bindings of a virtual port to external application"}, {"updated": "2012-09-07T10:00:00-00:00", "name": "Provider Network", "links": [], "namespace": ", "alias": "provider", "description": "Expose mapping of virtual networks to physical networks"}, {"updated": "2013-02-03T10:00:00-00:00", "name": "agent", "links": [], "namespace": ", "alias": "agent", "description": "The agent management extension."}, {"updated": "2012-07-29T10:00:00-00:00", "name": "Quota management support", "links": [], "namespace": ", "alias": "quotas", "description": "Expose functions for quotas management per tenant"}, {"updated": "2013-02-07T10:00:00-00:00", "name": "DHCP Agent Scheduler", "links": [], "namespace": ", "alias": "dhcp_agent_scheduler", "description": "Schedule networks among dhcp agents"}, {"updated": "2013-06-27T10:00:00-00:00", "name": "Multi Provider Network", "links": [], "namespace": ", "alias": "multi-provider", "description": "Expose mapping of virtual networks to multiple physical networks"}, {"updated": "2013-01-14T10:00:00-00:00", "name": "Neutron external network", "links": [], "namespace": ", "alias": "external-net", "description": "Adds external network attribute to network resource."}, {"updated": "2012-07-20T10:00:00-00:00", "name": "Neutron L3 Router", "links": [], "namespace": ", "alias": "router", "description": "Router abstraction for basic L3 forwarding between L2 Neutron networks and access to external networks via a NAT gateway."}, {"updated": "2013-07-23T10:00:00-00:00", "name": "Allowed Address Pairs", "links": [], "namespace": ", "alias": "allowed-address-pairs", "description": "Provides allowed address pairs"}, {"updated": "2013-03-17T12:00:00-00:00", "name": "Neutron Extra DHCP opts", "links": [], "namespace": ", "alias": "extra_dhcp_opt", "description": "Extra options configuration for DHCP. For example PXE boot options to DHCP clients can be specified (e.g. tftp-server, server-ip-address, bootfile-name)"}, {"updated": "2013-02-01T10:00:00-00:00", "name": "Neutron Extra Route", "links": [], "namespace": ", "alias": "extraroute", "description": "Extra routes configuration for L3 router"}]}
- created_port = self._create_port(port_client, instance, network_id, port_req_body, fixed_ips.get(network_id),security_group_ids, available_macs, dhcp_opts)
- (Pdb) p port_req_body {'port': {'binding:host_id': u'OpenstackIcehouse2', 'admin_state_up': True, 'network_id': u'a29561e9-2f32-4765-a0f8-306b870f780b', 'tenant_id': u'8efa4856fe4b4aa0b6dcf05dc66d4efa', 'device_owner': u'compute:nova', 'security_groups': [u'b4a79ec8-8552-4074-a410-faa52b30424d'], 'device_id': u'3a5cd5d4-2676-447b-bab4-6acf21feacd6'}}
- RESP:{'date': 'Mon, 02 Jun 2014 20:56:01 GMT', 'status': '201', 'content-length': '717', 'content-type': 'application/json; charset=UTF-8', 'x-openstack-request-id': 'req-a9ef458b-adfe-41f9-b66a-640cb8d56833'} {"port": {"status": "DOWN", "binding:host_id": "OpenstackIcehouse2", "name": "", "allowed_address_pairs": [], "admin_state_up": true, "network_id": "a29561e9-2f32-4765-a0f8-306b870f780b", "tenant_id": "8efa4856fe4b4aa0b6dcf05dc66d4efa", "binding:vif_details": {"port_filter": true, "ovs_hybrid_plug": true}, "binding:vnic_type": "normal", "binding:vif_type": "ovs", "device_owner": "compute:nova", "mac_address": "fa:16:3e:64:b6:8a", "binding:profile": {}, "fixed_ips": [{"subnet_id": "bd652c3e-005e-4985-b65e-576c3045e890", "ip_address": "192.168.2.19"}], "id": "9d6cd91a-dac8-4523-a692-01dc61c04b21", "security_groups": ["b4a79ec8-8552-4074-a410-faa52b30424d"], "device_id": "3a5cd5d4-2676-447b-bab4-6acf21feacd6"}}
- nw_info = self.get_instance_nw_info(context, instance, networks=nets, port_ids=ports_in_requested_order)
- (Pdb) p nw_info [VIF({'ovs_interfaceid': u'9d6cd91a-dac8-4523-a692-01dc61c04b21', 'network': Network({'bridge': 'br-int', 'subnets': [Subnet({'ips': [FixedIP({'meta': {}, 'version': 4, 'type': 'fixed', 'floating_ips': [], 'address': u'192.168.2.19'})], 'version': 4, 'meta': {'dhcp_server': u'192.168.2.2'}, 'dns': [IP({'meta': {}, 'version': 4, 'type': 'dns', 'address': u'8.8.8.8'})], 'routes': [], 'cidr': u'192.168.2.0/24', 'gateway': IP({'meta': {}, 'version': 4, 'type': 'gateway', 'address': u'192.168.2.1'})})], 'meta': {'injected': False, 'tenant_id': u'8efa4856fe4b4aa0b6dcf05dc66d4efa'}, 'id': u'a29561e9-2f32-4765-a0f8-306b870f780b', 'label': u'openstack-net'}), 'devname': u'tap9d6cd91a-da', 'qbh_params': None, 'meta': {}, 'details': {u'port_filter': True, u'ovs_hybrid_plug': True}, 'address': u'fa:16:3e:64:b6:8a', 'active': False, 'type': u'ovs', 'id': u'9d6cd91a-dac8-4523-a692-01dc61c04b21', 'qbg_params': None})]
4.2. _spawn instances
/usr/lib/python2.7/dist-packages/nova/compute/manager.py的
def _spawn(self, context, instance, image_meta, network_info,
block_device_info, injected_files, admin_password, set_access_ip=False): self.driver.spawn(context, instance, image_meta, injected_files, admin_password, network_info, block_device_info)在nova.conf中compute_driver=libvirt.LibvirtDriver
所以会最终调用/usr/lib/python2.7/dist-packages/nova/virt/libvirt/driver.py
5. libvirt
/usr/lib/python2.7/dist-packages/nova/virt/libvirt/driver.py的class LibvirtDriver(driver.ComputeDriver):
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)
- (Pdb) p disk_info {'disk_bus': 'virtio', 'cdrom_bus': 'ide', 'mapping': {'disk': {'bus': 'virtio', 'boot_index': '1', 'type': 'disk', 'dev': 'vda'}, 'root': {'bus': 'virtio', 'boot_index': '1', 'type': 'disk', 'dev': 'vda'}}}
- 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)
- xml = self.to_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, block_device_info)
5.1. 获取Image
/usr/lib/python2.7/dist-packages/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):在这个函数中参数
(Pdb) p disk_images
{'kernel_id': u'', 'image_id': u'6a1489cb-5905-4f97-ae8b-012770818213', 'ramdisk_id': u''}得到flavor
inst_type = flavors.extract_flavor(instance)
(Pdb) p inst_type
{'root_gb': 20, 'name': 'm1.small', 'ephemeral_gb': 0, 'memory_mb': 2048, 'vcpus': 1, 'swap': 0, 'rxtx_factor': 1.0, 'flavorid': '2', 'vcpu_weight': None, 'id': 5}下载和缓存image
image('disk').cache(fetch_func=libvirt_utils.fetch_image,
context=context, filename=root_fname, size=size, image_id=disk_images['image_id'], user_id=instance['user_id'], project_id=instance['project_id'])- 首先会调用/usr/lib/python2.7/dist-packages/nova/virt/libvirt/utils.py的fetch_image
- images.fetch_to_raw(context, image_id, target, user_id, project_id, max_size=max_size)
- 会调用/usr/lib/python2.7/dist-packages/nova/virt/images.py的fetch_to_raw，最终调用image_service.download(context, image_id, dst_path=path)，会从glance下载下来image
- 其次，会调用/usr/lib/python2.7/dist-packages/nova/virt/libvirt/imagebackend.py的cache函数
- (Pdb) p base '/var/lib/nova/instances/_base/4b1ad1f3fa1222ea960f8e373baa4eef880c5ff1'
- (Pdb) p size 21474836480
- 会调用class Qcow2(Image)的create_image(self, prepare_template, base, size, *args, **kwargs)并最后调用到copy_qcow2_image
- copy_qcow2_image是调用了两个命令：
- ('qemu-img', 'create', '-f', 'qcow2', '-o', 'backing_file=/var/lib/nova/instances/_base/4b1ad1f3fa1222ea960f8e373baa4eef880c5ff1', '/var/lib/nova/instances/4d169b6a-b921-4e24-83b0-2c36ea4da7d0/disk')
- ('qemu-img', 'resize', '/var/lib/nova/instances/4d169b6a-b921-4e24-83b0-2c36ea4da7d0/disk', 21474836480)
配置configuration drive
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) cdb.make_drive(configdrive_path)配置injection file
self._inject_data(instance, network_info, admin_pass, files, suffix)
5.2. 生成XML
to_xml xml=<domain type="kvm">
<uuid>33985948-f19d-4d01-be63-989f302c218e</uuid> <name>instance-0000001a</name> <memory>2097152</memory> <vcpu>1</vcpu> <sysinfo type="smbios"> <system> <entry name="manufacturer">OpenStack Foundation</entry> <entry name="product">OpenStack Nova</entry> <entry name="version">2014.1</entry> <entry name="serial">21172311-7f0c-44b5-b57c-48e5cc032d12</entry> <entry name="uuid">33985948-f19d-4d01-be63-989f302c218e</entry> </system> </sysinfo> <os> <type>hvm</type> <boot dev="hd"/> <smbios mode="sysinfo"/> </os> <features> <acpi/> <apic/> </features> <clock offset="utc"> <timer name="pit" tickpolicy="delay"/> <timer name="rtc" tickpolicy="catchup"/> <timer name="hpet" present="no"/> </clock> <cpu mode="host-model" match="exact"/> <devices> <disk type="file" device="disk"> <driver name="qemu" type="qcow2" cache="none"/> <source file="/var/lib/nova/instances/33985948-f19d-4d01-be63-989f302c218e/disk"/> <target bus="virtio" dev="vda"/> </disk> <interface type="bridge"> <mac address="fa:16:3e:f0:c0:b4"/> <model type="virtio"/> <source bridge="qbr4700fff8-b4"/> <target dev="tap4700fff8-b4"/> </interface> <serial type="file"> <source path="/var/lib/nova/instances/33985948-f19d-4d01-be63-989f302c218e/console.log"/> </serial> <serial type="pty"/> <input type="tablet" bus="usb"/> <graphics type="vnc" autoport="yes" keymap="en-us" listen="0.0.0.0"/> <video> <model type="cirrus"/> </video> </devices> </domain>5.3.创建Instance，并连接到network
/usr/lib/python2.7/dist-packages/nova/virt/libvirt/driver.py的
def _create_domain_and_network(self, context, xml, instance, network_info,
block_device_info=None, power_on=True, reboot=False, vifs_already_plugged=False):- self.plug_vifs(instance, network_info)
- self.firewall_driver.setup_basic_filtering(instance, network_info)
- self.firewall_driver.prepare_instance_filter(instance, network_info)
- domain = self._create_domain(xml, instance=instance, launch_flags=launch_flags, power_on=power_on)
首先是调用/usr/lib/python2.7/dist-packages/nova/virt/libvirt/vif.py的def plug_ovs_hybrid(self, instance, vif):
- iface_id = self.get_ovs_interfaceid(vif)
- (Pdb) p iface_id u'4700fff8-b437-45fb-8b81-dbd69dec2b5a'
- br_name = self.get_br_name(vif['id'])
- (Pdb) p br_name u'qbr4700fff8-b4'
- v1_name, v2_name = self.get_veth_pair_names(vif['id'])
- (Pdb) p v1_name u'qvb4700fff8-b4'
- (Pdb) p v2_name u'qvo4700fff8-b4'
- utils.execute('brctl', 'addbr', br_name, run_as_root=True)
- utils.execute('brctl', 'setfd', br_name, 0, run_as_root=True)
- utils.execute('brctl', 'stp', br_name, 'off', run_as_root=True)
- utils.execute('tee', ('/sys/class/net/%s/bridge/multicast_snooping' % br_name), process_input='0', run_as_root=True, check_exit_code=[0, 1])
- linux_net._create_veth_pair(v1_name, v2_name)
- utils.execute('ip', 'link', 'set', br_name, 'up', run_as_root=True)
- utils.execute('brctl', 'addif', br_name, v1_name, run_as_root=True)
- linux_net.create_ovs_vif_port(self.get_bridge_name(vif), v2_name, iface_id, vif['address'], instance['uuid'])
- (Pdb) p vif VIF({'ovs_interfaceid': u'4700fff8-b437-45fb-8b81-dbd69dec2b5a', 'network': Network({'bridge': 'br-int', 'subnets': [Subnet({'ips': [FixedIP({'meta': {}, 'version': 4, 'type': 'fixed', 'floating_ips': [], 'address': u'192.168.2.18'})], 'version': 4, 'meta': {'dhcp_server': u'192.168.2.2'}, 'dns': [IP({'meta': {}, 'version': 4, 'type': 'dns', 'address': u'8.8.8.8'})], 'routes': [], 'cidr': u'192.168.2.0/24', 'gateway': IP({'meta': {}, 'version': 4, 'type': 'gateway', 'address': u'192.168.2.1'})})], 'meta': {'injected': False, 'tenant_id': u'8efa4856fe4b4aa0b6dcf05dc66d4efa'}, 'id': u'a29561e9-2f32-4765-a0f8-306b870f780b', 'label': u'openstack-net'}), 'devname': u'tap4700fff8-b4', 'qbh_params': None, 'meta': {}, 'details': {u'port_filter': True, u'ovs_hybrid_plug': True}, 'address': u'fa:16:3e:f0:c0:b4', 'active': False, 'type': u'ovs', 'id': u'4700fff8-b437-45fb-8b81-dbd69dec2b5a', 'qbg_params': None})
- _ovs_vsctl(['--', '--if-exists', 'del-port', dev, '--', 'add-port', bridge, dev, '--', 'set', 'Interface', dev, 'external-ids:iface-id=%s' % iface_id, 'external-ids:iface-status=active', 'external-ids:attached-mac=%s' % mac, 'external-ids:vm-uuid=%s' % instance_id])
- _set_device_mtu(dev)
其次调用/usr/lib/python2.7/dist-packages/nova/virt/libvirt/driver.py的
def _create_domain(self, xml=None, domain=None,
instance=None, launch_flags=0, power_on=True):- domain = self._conn.defineXML(xml)
- domain.createWithFlags(launch_flags)
机器运行起来了。