summaryrefslogtreecommitdiff
path: root/ironic/conductor/task_manager.py
diff options
context:
space:
mode:
authorLaura Moore <laura.moore@sap.com>2015-07-27 17:14:40 -0400
committervsaienko <vsaienko@mirantis.com>2016-02-04 22:40:54 +0200
commita603e3c12c62e29e12e45283d8602f9aa5acfc0f (patch)
tree3fb5ff0a8a53f19800a9366f32225d299b7d14bb /ironic/conductor/task_manager.py
parent134ad4cbf6f1930de9c4dd7fd653fedb7decaf18 (diff)
downloadironic-a603e3c12c62e29e12e45283d8602f9aa5acfc0f.tar.gz
Add portgroups to support LAG interfaces - RPC
Ironic should be able to provide the requisite connectivity information to the Neutron ML2 plugin to allow drivers to provision the top-of-rack switch for the bare metal server. The addition of portgroups in Ironic allows the concept of link aggregation to be handled in Ironic in order to provide support for cases where multiple interfaces on the bare metal server connect to switch ports of a single LAG. This commit includes changes to: - the RPC API (to include portgroup methods) - the RPC tests Partial-bug: #1526403 DocImpact Co-Authored-By: Jenny Moorehead (jenny.moorehead@sap.com) Co-Authored-By: Will Stevenson (will.stevenson@sap.com) Change-Id: Iac6355e615e57e6ed002facd6795c9ff06188998
Diffstat (limited to 'ironic/conductor/task_manager.py')
-rw-r--r--ironic/conductor/task_manager.py4
1 files changed, 4 insertions, 0 deletions
diff --git a/ironic/conductor/task_manager.py b/ironic/conductor/task_manager.py
index b5bb119d3..aac3ca12c 100644
--- a/ironic/conductor/task_manager.py
+++ b/ironic/conductor/task_manager.py
@@ -204,7 +204,10 @@ class TaskManager(object):
else:
self._debug_timer.restart()
self.node = objects.Node.get(context, node_id)
+
self.ports = objects.Port.list_by_node_id(context, self.node.id)
+ self.portgroups = objects.Portgroup.list_by_node_id(context,
+ self.node.id)
self.driver = driver_factory.get_driver(driver_name or
self.node.driver)
@@ -313,6 +316,7 @@ class TaskManager(object):
self.node = None
self.driver = None
self.ports = None
+ self.portgroups = None
self.fsm = None
def _thread_release_resources(self, t):