【openstack】Quantum关于Port的操作(LinuxBridge)

Quantum关于Port的操作(LinuxBridge)

1      创建port

1.1    流程

 (2012/12/13修正): 为port分配IP时，当没有指定fixed_ip，是从network中选一个有空闲IP的subnet分配IP ，而不是从所有subnet分配。

 

    # 校验fixed_ips的合法性

    def _test_fixed_ips_for_port(self, context, network_id, fixed_ips):

        """Test fixed IPs for port.

 

        Check that configured subnets are valid prior to allocating any

        IPs. Include the subnet_id in the result if only an IP address is

        configured.

 

        :raises: InvalidInput, IpAddressInUse

        """

        fixed_ip_set = []

        for fixed in fixed_ips:

            found = False

            # 如果没有指定subnet

            if 'subnet_id' not in fixed:

                # 如果既没有指定subnet，也没有指定ip_address，抛错

                if 'ip_address' not in fixed:

                    msg = _('IP allocation requires subnet_id or ip_address')

                    raise q_exc.InvalidInput(error_message=msg)

 

                # 如果没有指定subnet，但指定了ip_address

                filter = {'network_id': [network_id]}

                # 找到属于入参network_id的所有subnet

                subnets = self.get_subnets(context, filters=filter)

                for subnet in subnets:

                    # 检查ip_address是否在subnet中，返回subnet_id

                    if QuantumDbPluginV2._check_subnet_ip(subnet['cidr'],

                                                          fixed['ip_address']):

                        found = True

                        subnet_id = subnet['id']

                        break

                # 如果在所有subnet都没有找到，抛错

                if not found:

                    msg = _('IP address %s is not a valid IP for the defined '

                            'networks subnets') % fixed['ip_address']

                    raise q_exc.InvalidInput(error_message=msg)

            # 如果指定了subnet

            else:

                subnet = self._get_subnet(context, fixed['subnet_id'])

                # subnet所属network与入参不一致，抛错

                if subnet['network_id'] != network_id:

                    msg = _('Failed to create port on network %s, '

                            'because fixed_ips included invalid subnet '

                            '%s') % (network_id, fixed['subnet_id'])

                    raise q_exc.InvalidInput(error_message=msg)

                subnet_id = subnet['id']

 

            # 如果指定了ip_address

            if 'ip_address' in fixed:

                # Ensure that the IP's are unique

                # 在ipallocation表中查找，如果记录已存在，抛错

                if not QuantumDbPluginV2._check_unique_ip(context, network_id,

                                                          subnet_id,

                                                          fixed['ip_address']):

                    raise q_exc.IpAddressInUse(net_id=network_id,

                                               ip_address=fixed['ip_address'])

 

                # Ensure that the IP is valid on the subnet

                # 如果记录不存在，且同时指定了subnet和ip_address，则判断ip_address是否属于指定的subnet内

                if (not found and

                    not QuantumDbPluginV2._check_subnet_ip(

                        subnet['cidr'], fixed['ip_address'])):

                    msg = _('IP address %s is not a valid IP for the defined '

                            'subnet') % fixed['ip_address']

                    raise q_exc.InvalidInput(error_message=msg)

 

                fixed_ip_set.append({'subnet_id': subnet_id,

                                     'ip_address': fixed['ip_address']})

            else:

                fixed_ip_set.append({'subnet_id': subnet_id})

        return fixed_ip_set

2      删除port

2.1    流程

 

3      更新port

3.1    流程

 

4      总结

注意，这里对port的操作中，更新port是需要向下层的agent发送消息处理的，其他操作都只是上层的逻辑操作而已。