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发送消息处理的,其他操作都只是上层的逻辑操作而已。