1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
# Copyright 2014 Rackspace, Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License. You may obtain
# a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations
# under the License.
from oslo_log import log
from ironic.common import exception
LOG = log.getLogger(__name__)
def get_node_vif_ids(task):
"""Get all VIF ids for a node.
This function does not handle multi node operations.
:param task: a TaskManager instance.
:returns: A dict of Node's neutron ports where keys are
'ports' & 'portgroups' and the values are dict of UUIDs
and their associated VIFs, e.g.
::
{'ports': {'port.uuid': vif.id},
'portgroups': {'portgroup.uuid': vif.id}}
"""
vifs = {}
portgroup_vifs = {}
port_vifs = {}
for portgroup in task.portgroups:
vif = task.driver.network.get_current_vif(task, portgroup)
if vif:
portgroup_vifs[portgroup.uuid] = vif
vifs['portgroups'] = portgroup_vifs
for port in task.ports:
vif = task.driver.network.get_current_vif(task, port)
if vif:
port_vifs[port.uuid] = vif
vifs['ports'] = port_vifs
return vifs
def get_portgroup_by_id(task, portgroup_id):
"""Lookup a portgroup by ID on a task object.
:param task: a TaskManager instance
:param portgroup_id: ID of the portgroup.
:returns: A Portgroup object or None.
"""
for portgroup in task.portgroups:
if portgroup.id == portgroup_id:
return portgroup
def get_ports_by_portgroup_id(task, portgroup_id):
"""Lookup ports by their portgroup ID on a task object.
:param task: a TaskManager instance
:param portgroup_id: ID of the portgroup.
:returns: A list of Port objects.
"""
return [port for port in task.ports if port.portgroup_id == portgroup_id]
def get_physnets_for_node(task):
"""Return the set of physical networks for a node.
Returns the set of physical networks associated with a node's ports. The
physical network None is excluded from the set.
:param task: a TaskManager instance
:returns: A set of physical networks.
"""
return set(port.physical_network
for port in task.ports
if port.physical_network is not None)
def get_physnets_by_portgroup_id(task, portgroup_id, exclude_port=None):
"""Return the set of physical networks associated with a portgroup.
:param task: a TaskManager instance.
:param portgroup_id: ID of the portgroup.
:param exclude_port: A Port object to exclude from the determination of the
portgroup's physical network, or None.
:returns: The set of physical networks associated with the portgroup. The
set will contain zero or one physical networks.
:raises: PortgroupPhysnetInconsistent if the portgroup's ports are not
assigned the same physical network.
"""
pg_ports = get_ports_by_portgroup_id(task, portgroup_id)
if exclude_port is not None and 'id' in exclude_port:
exclude_port_id = exclude_port.id
else:
exclude_port_id = None
pg_physnets = set(port.physical_network
for port in pg_ports
if port.id != exclude_port_id)
# Sanity check: all ports should have the same physical network.
if len(pg_physnets) > 1:
portgroup = get_portgroup_by_id(task, portgroup_id)
raise exception.PortgroupPhysnetInconsistent(
portgroup=portgroup.uuid, physical_networks=", ".join(pg_physnets))
return pg_physnets
def remove_vifs_from_node(task):
"""Remove all vif attachment records from a node.
:param task: a TaskManager instance.
"""
vifs = task.driver.network.vif_list(task)
for vif_entry in vifs:
vif = vif_entry.get('id')
if not vif:
LOG.warning('Node %(node)s has an incorrect VIF entry: %(found)s. '
'This entry lacks an "id" field and is thus '
'unsupported.',
{'node': task.node.uuid,
'found': vif_entry})
continue
try:
task.driver.network.vif_detach(task, vif)
except exception.VifNotAttached:
LOG.warning('While removing records of VIF attachments from node '
'%(node)s, we received indication that VIF %(vif)s is '
'no longer attached. This should not happen under '
'normal circumstances.',
{'node': task.node.uuid,
'vif': vif})
except exception.NetworkError as e:
LOG.error('For node %(node)s, an error occurred while removing a '
'VIF record for VIF %(vif)s. Error: %(error)s',
{'node': task.node.uuid,
'vif': vif,
'error': e})
|
